Skip to content
Snippets Groups Projects
Commit 55e89d34 authored by Soichiro Kuwahara's avatar Soichiro Kuwahara
Browse files

cherenkov/rankingstat.py: connect plumbing

- between trigger generator, coincidence code, and ranking statistic recorder
parent 0c928579
No related branches found
No related tags found
No related merge requests found
......@@ -201,8 +201,7 @@ class PipelineHandler(simplehandler.Handler):
else:
# update trigger rate and livetime
buf_seg = segments.segment(buf_timestamp, max(buf_timestamp + lal.LIGOTimeGPS(0, buf.duration), max(event.peak for event in events) if events else 0.0))
# FIXME: not implemented
#self.rankingstat.denominator.triggerrates[instrument].add_ratebin(buf_seg, len(events))
self.rankingstat.denominator.triggerrates[instrument].add_ratebin(tuple(map(float, buf_seg)), len(events))
# push the single detector trigger into the
# StreamBurca instance. the push method returns
......@@ -210,8 +209,7 @@ class PipelineHandler(simplehandler.Handler):
# In that case, call the pull() method to run the
# coincidence engine.
if self.streamburca.push(instrument, events, buf_timestamp):
# FIXME: fix snr segments
self.streamburca.pull(self.rankingstat, segments.segmentlistdict(), noninjections = self.is_noninjections)
self.streamburca.pull(self.rankingstat, self.rankingstat.segmentlists, noninjections = self.is_noninjections)
def flush(self):
self.streamburca.pull(self.rankingstat, self.rankingstat.segmentlists, noninjections = self.is_noninjections, flush = True)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment