From a4d03a3d8c05015faf6a87a99d025adc24b7be2e Mon Sep 17 00:00:00 2001
From: Patrick Godwin <patrick.godwin@ligo.org>
Date: Wed, 12 Sep 2018 16:57:34 -0700
Subject: [PATCH] gstlal_feature_synchronizer: add latency information to logs
upon pushing features downstream
---
gstlal-burst/bin/gstlal_feature_synchronizer | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/gstlal-burst/bin/gstlal_feature_synchronizer b/gstlal-burst/bin/gstlal_feature_synchronizer
index 4bc81a1209..2363129a7e 100755
--- a/gstlal-burst/bin/gstlal_feature_synchronizer
+++ b/gstlal-burst/bin/gstlal_feature_synchronizer
@@ -186,7 +186,7 @@ class StreamSynchronizer(object):
# push full feature vector to producer if buffer isn't empty
if self.feature_buffer:
timestamp, features = self.feature_buffer.pop()
- logger.info('pushing features with timestamp %f downstream' % timestamp)
+ logger.info('pushing features with timestamp %f downstream, latency is %.3f' % (timestamp, utils.gps2latency(timestamp)))
feature_packet = {'timestamp': timestamp, 'features': features}
self.producer.produce(timestamp = timestamp, topic = self.producer_name, value = json.dumps(feature_packet))
self.producer.poll(0)
--
GitLab