From ff11e0291fbe27c6b6d935c5f78fc8102dea9b56 Mon Sep 17 00:00:00 2001
From: Patrick Godwin <patrick.godwin@ligo.org>
Date: Wed, 12 Sep 2018 16:14:17 -0500
Subject: [PATCH] datasource.py: add options in lvshm live source to set the
assumed duration and block size of the shared memory partition
---
gstlal/python/datasource.py | 14 +++++++++++++-
1 file changed, 13 insertions(+), 1 deletion(-)
diff --git a/gstlal/python/datasource.py b/gstlal/python/datasource.py
index a3c11badee..407d307848 100644
--- a/gstlal/python/datasource.py
+++ b/gstlal/python/datasource.py
@@ -448,6 +448,10 @@ class GWDataSourceInfo(object):
if options.shared_memory_partition is not None:
self.shm_part_dict.update( channel_dict_from_channel_list(options.shared_memory_partition) )
+ ## options for shared memory
+ self.shm_assumed_duration = options.shared_memory_assumed_duration
+ self.shm_block_size = options.shared_memory_block_size # NOTE: should this be incorporated into options.block_size? currently only used for offline data sources
+
## A dictionary of framexmit addresses
self.framexmit_addr = framexmit_ports["CIT"]
if options.framexmit_addr is not None:
@@ -592,6 +596,12 @@ def append_options(parser):
Set the name of the shared memory partition for a given instrument.
Can be given multiple times as --shared-memory-partition=IFO=PARTITION-NAME
+- --shared-memory-assumed-duration [int]
+ Set the assumed span of files in seconds. Default = 4 seconds.
+
+- --shared-memory-block-size [int]
+ Set the byte size to read per buffer. Default = 4096 bytes.
+
- --frame-segments-file [filename]
Set the name of the LIGO light-weight XML file from which to load frame segments.
Optional iff --data-source is frames
@@ -655,6 +665,8 @@ def append_options(parser):
group.add_option("--state-channel-name", metavar = "name", action = "append", help = "Set the name of the state vector channel. This channel will be used to control the flow of data via the on/off bits. Can be given multiple times as --channel-name=IFO=CHANNEL-NAME")
group.add_option("--dq-channel-name", metavar = "name", action = "append", help = "Set the name of the data quality channel. This channel will be used to control the flow of data via the on/off bits. Can be given multiple times as --channel-name=IFO=CHANNEL-NAME")
group.add_option("--shared-memory-partition", metavar = "name", action = "append", help = "Set the name of the shared memory partition for a given instrument. Can be given multiple times as --shared-memory-partition=IFO=PARTITION-NAME")
+ group.add_option("--shared-memory-assumed-duration", type = "int", default = 4, help = "Set the assumed span of files in seconds. Default = 4.")
+ group.add_option("--shared-memory-block-size", type = "int", default = 4096, help = "Set the byte size to read per buffer. Default = 4096.")
group.add_option("--frame-segments-file", metavar = "filename", help = "Set the name of the LIGO light-weight XML file from which to load frame segments. Optional iff --data-source=frames")
group.add_option("--frame-segments-name", metavar = "name", help = "Set the name of the segments to extract from the segment tables. Required iff --frame-segments-file is given")
group.add_option("--state-vector-on-bits", metavar = "bits", default = [], action = "append", help = "Set the state vector on bits to process (optional). The default is 0x7 for all detectors. Override with IFO=bits can be given multiple times. Only currently has meaning for online (lvshm) data.")
@@ -808,7 +820,7 @@ def mkbasicsrc(pipeline, gw_data_source_info, instrument, verbose = False):
if gw_data_source_info.data_source == "lvshm":
# FIXME make wait_time adjustable through web
# interface or command line or both
- src = pipeparts.mklvshmsrc(pipeline, shm_name = gw_data_source_info.shm_part_dict[instrument], wait_time = 120)
+ src = pipeparts.mklvshmsrc(pipeline, shm_name = gw_data_source_info.shm_part_dict[instrument], assumed_duration = gw_data_source_info.shm_assumed_duration, blocksize = gw_data_source_info.shm_block_size, wait_time = 120)
elif gw_data_source_info.data_source == "framexmit":
src = pipeparts.mkframexmitsrc(pipeline, multicast_iface = gw_data_source_info.framexmit_iface, multicast_group = gw_data_source_info.framexmit_addr[instrument][0], port = gw_data_source_info.framexmit_addr[instrument][1], wait_time = 120)
else:
--
GitLab