lloidhandler module

class lloidhandler.EyeCandy(instruments, kafka_server, analysis_tag, job_tag, stream, segmentstracker, latencytracker, f_final, node_id=None)

Bases: object

update(events, last_coincs)

web_get_H1_snr_history()

web_get_L1_snr_history()

web_get_V1_snr_history()

web_get_far_history()

web_get_latency_histogram()

web_get_latency_history()

web_get_likelihood_history()

web_get_ram_history()

web_get_snr_history()

class lloidhandler.LLOIDTracker(stream, coincs_document, rankingstat, horizon_distance_func, gracedbwrapper, zerolag_rankingstatpdf_url=None, rankingstatpdf_url=None, ranking_stat_output_url=None, ranking_stat_input_url=None, likelihood_snapshot_interval=None, sngls_snr_threshold=None, analysis_tag='test', job_tag='', kafka_server='10.14.0.112:9092', cluster=False, cap_singles=False, FAR_trialsfactor=1.0, activation_counts=None, track_latency=False, template_id_time_map=None, background_collector_type='normal', node_id=None, f_final=1024.0, verbose=False)

Bases: object

! Implements additional message handling for dealing with spectrum messages and checkpoints for the online analysis including periodic dumps of segment information, trigger files and background distribution statistics.

checkpoint(timestamp)

! Checkpoint, e.g., flush segments and triggers to disk.

@param timestamp the LIGOTimeGPS timestamp of the current buffer in order to close off open segment intervals before writing to disk

horizgatehandler(elem, timestamp, instrument_tpl)

! A handler that intercepts h(t) gate state transitions to 0 horizon distances.

@param elem A reference to the lal_gate element or None (only used for verbosity) @param timestamp A gstreamer time stamp that marks the state transition (in nanoseconds) @param instrument the instrument this state transtion is to be attributed to, e.g., “H1”, etc.. @param new_state the state transition, must be either True or False

load_rankingstat_pdf()

on_buffer(buf)

on_checkpoint(message)

on_eos(message)

on_spectrum_update(message)

record_horizon_distance(instrument, timestamp, horizon_distance)

timestamp can be a float or a slice with float boundaries.

snapshot_output_url(description, extension, verbose=False)

web_get_psd_xml()

web_get_rankingstat()

web_get_remove_counts()

web_get_sngls_snr_threshold()

web_get_zerolag_rankingstatpdf()

web_set_remove_counts()

web_set_sngls_snr_threshold()

write_output_url(url=None, description='', verbose=False)

class lloidhandler.LatencyTracker(stream, instruments, verbose=False)

Bases: object

latencyhandler(elem, timestamp, stage_latency_input)

class lloidhandler.SegmentsTracker(stream, instruments, segment_history_duration=LIGOTimeGPS(2592000, 0), verbose=False)

Bases: object

T050017_filename(description, extension)

flush_segments_to_disk(tag, timestamp)

! Flush segments to disk, e.g., when checkpointing or shutting down an online pipeline.

@param timestamp the LIGOTimeGPS timestamp of the current buffer in order to close off open segment intervals before writing to disk

gatehandler(elem, timestamp, seg_state_input)

gen_recent_segment_history_xmldoc()

! Construct and return a LIGOLW XML tree containing the recent segment histories.

Must be called with the lock held.

gen_segments_xmldoc()

! A method to output the segment list in a valid ligolw xml format.

Must be called with the lock held.

terminate(timestamp)

update_recent_segment_history()

! A method to update the recent segment histories

Must be called with the lock held.

web_get_recent_segment_history_xml()

! provide a bottle route to get recent segment history information via a url

web_get_segments_xml()

! provide a bottle route to get segment information via a url

lloidhandler.subdir_from_T050017_filename(fname)