[lloidhandler.py] Implement pipeline latency monitoring for stages using all ifos

gstlal-inspiral/python/lloidhandler.py

@@ -664,9 +664,12 @@ class LatencyTracker(object):
 		self.verbose = verbose
 
 		# recent pipeline stage latencies
-		pipeline_stages = ["datasource", "whitening", "snrSlice"]
-		self.pipeline_history = {stage: {instrument: deque(maxlen = 20) for instrument in instruments} for stage in pipeline_stages}
-
+		ifo_pipe_stages = ["datasource", "whitening", "snrSlice"]
+		all_ifo_stages = ["itacac"]
+		self.pipeline_history = {stage: {instrument: deque(maxlen = 20) for instrument in instruments} for stage in ifo_pipe_stages}
+		for stage in all_ifo_stages:
+			self.pipeline_history[stage] = {"all": deque(maxlen = 20)}
+		
 		# iterate over pipeline stages, look for the
 		# stage element that should provide the latencies, and
 		# connect handlers to collect the latencies

gstlal-inspiral/python/lloidparts.py

@@ -729,6 +729,7 @@ def mkLLOIDmulti(pipeline, detectors, banks, psd, psd_fft_length = 32, ht_gate_t
 	#
 
 	assert any(itacac_dict.values())
+	itacac_dict[list(itacac_dict.keys())[0]] = pipeparts.mklatency(pipeline, itacac_dict[list(itacac_dict.keys())[0]], name = "all_itacac_latency", silent = True)
 	if verbose:
 		for bank_id, head in itacac_dict.items():
 			# FIXME Not sure why we need a queue here, but without