datasource.py File Reference

Detailed Description

A file that contains the datasource module code.

Review Status

Names	Hash	Date
Florent, Sathya, Duncan Me., Jolien, Kipp, Chad	b3ef077fe87b597578000f140e4aa780f3a227aa	2014-05-01

Action items

• State vector, DQ, etc must be in place by November and should be coordinated with JRPC/DAC/DetChar/CBC/etc
• Consider a dynamic data time out that seneses when data is not going to arrive for a while

Definition in file datasource.py.

Go to the source code of this file.

Classes
class	python.datasource.ContentHandler
	ContentHandler A stub to wrap ligolw.LIGOLWContentHandler for now More...
class	python.datasource.GWDataSourceInfo
	Hold the data associated with data source command lines. More...

Packages
namespace	python.datasource
	datasource module

Functions
def	python.datasource.channel_dict_from_channel_list
	Given a list of channels, produce a dictionary keyed by ifo of channel names:
def	python.datasource.pipeline_channel_list_from_channel_dict
	Creates a string of channel names options from a dictionary keyed by ifos.
def	python.datasource.state_vector_on_off_dict_from_bit_lists
	Produce a dictionary (keyed by detector) of on / off bit tuples from a list provided on the command line.
def	python.datasource.state_vector_on_off_list_from_bits_dict
	Produce a tuple of useful command lines from a dictionary of on / off state vector bits keyed by detector.
def	python.datasource.framexmit_dict_from_framexmit_list
	Given a list of framexmit addresses with ports, produce a dictionary keyed by ifo:
def	python.datasource.framexmit_list_from_framexmit_dict
	Creates a string of framexmit address options from a dictionary keyed by ifos.
def	python.datasource.seek_event_for_gps
	Create a new seek event, i.e., gst.event_new_seek() for a given gps_start_time and gps_end_time, with optional flags.
def	python.datasource.append_options
	Append generic data source options to an OptionParser object in order to have consistent an unified command lines and parsing throughout the project for applications that read GW data.
def	python.datasource.mksegmentsrcgate
	Gstreamer graph describing this function:
def	python.datasource.mkbasicsrc
	Gstreamer graph describing this function:
def	python.datasource.mkhtgate
	Gstreamer graph describing the pipeline

Variables
dictionary	python.datasource.state_vector_on_off_dict
	Default dictionary of state vector on/off bits by ifo Used as the default argument to state_vector_on_off_dict_from_bit_lists()
dictionary	python.datasource.framexmit_ports
	framexmit ports in use on the LDG Look-up table to map instrument name to framexmit multicast address and port