From b6936aca2a893fa71d267dfc6aecd39b97010d63 Mon Sep 17 00:00:00 2001 From: Patrick Godwin Date: Sun, 6 Oct 2019 11:25:50 -0700 Subject: [PATCH] multichannel_datasource.py: increase block size for frame writing to help with NFS --- gstlal-burst/python/snax/multichannel_datasource.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/gstlal-burst/python/snax/multichannel_datasource.py b/gstlal-burst/python/snax/multichannel_datasource.py index 54a8ddc0a..2c5ff4cd1 100644 --- a/gstlal-burst/python/snax/multichannel_datasource.py +++ b/gstlal-burst/python/snax/multichannel_datasource.py @@ -669,7 +669,7 @@ def mkbasicmultisrc(pipeline, data_source_info, channels, verbose = False): 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} 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) # allow frame reading and decoding to occur in a different # thread -- GitLab