Skip to content

GitLab

Commit b6936aca authored by Patrick Godwin's avatar Patrick Godwin
Browse files
Options

multichannel_datasource.py: increase block size for frame writing to help with NFS

parent 44289a87
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
gstlal-burst/python/snax/multichannel_datasource.py
View file @ b6936aca
...@@ -669,7 +669,7 @@ def mkbasicmultisrc(pipeline, data_source_info, channels, verbose = False): ...@@ -669,7 +669,7 @@ def mkbasicmultisrc(pipeline, data_source_info, channels, verbose = False):
elif data_source_info.data_source == "white_live": elif data_source_info.data_source == "white_live":
head = {channel : pipeparts.mkfakesrc(pipeline, instrument = data_source_info.instrument, channel_name = channel, volume = 1.0, is_live = True, rate = data_source_info.channel_dict[channel]['fsamp'], timestamp_offset = int(data_source_info.seg[0]) * Gst.SECOND) for channel in channels} head = {channel : pipeparts.mkfakesrc(pipeline, instrument = data_source_info.instrument, channel_name = channel, volume = 1.0, is_live = True, rate = data_source_info.channel_dict[channel]['fsamp'], timestamp_offset = int(data_source_info.seg[0]) * Gst.SECOND) for channel in channels}
elif data_source_info.data_source == "frames": elif data_source_info.data_source == "frames":
src = pipeparts.mklalcachesrc(pipeline, location = data_source_info.frame_cache, cache_src_regex = data_source_info.instrument[0], cache_dsc_regex = data_source_info.instrument) src = pipeparts.mklalcachesrc(pipeline, location = data_source_info.frame_cache, cache_src_regex = data_source_info.instrument[0], cache_dsc_regex = data_source_info.instrument, blocksize = 1048576)
demux = pipeparts.mkframecppchanneldemux(pipeline, src, do_file_checksum = False, skip_bad_files = True, channel_list = channels) demux = pipeparts.mkframecppchanneldemux(pipeline, src, do_file_checksum = False, skip_bad_files = True, channel_list = channels)
# allow frame reading and decoding to occur in a different # allow frame reading and decoding to occur in a different
# thread # thread
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment