From 07cd5373ed80e3678824db15ec18ce871b4fdbe2 Mon Sep 17 00:00:00 2001
From: "P.-A. Loizeau" <p.-a.loizeau@gsi.de>
Date: Mon, 13 Jun 2022 17:24:11 +0200
Subject: [PATCH] [MQ] In ReqRep sampler, fix missing HWM propag. and too
verbose missed TS detection
---
MQ/source/CbmMQTsSamplerRepReq.cxx | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git a/MQ/source/CbmMQTsSamplerRepReq.cxx b/MQ/source/CbmMQTsSamplerRepReq.cxx
index 5872da9caa..1524507c43 100644
--- a/MQ/source/CbmMQTsSamplerRepReq.cxx
+++ b/MQ/source/CbmMQTsSamplerRepReq.cxx
@@ -203,7 +203,7 @@ try {
//std::string connector = "tcp://" + fsHost + ":" + std::to_string(fusPort);
std::string connector = fsHost + ":" + std::to_string(fusPort);
LOG(info) << "Open TSPublisher at " << connector;
- fSource = new fles::TimesliceMultiSubscriber(connector);
+ fSource = new fles::TimesliceMultiSubscriber(connector, fulHighWaterMark);
}
else if (0 == fsFileName.size() && 0 != fsHost.size()) {
std::string connector = fsHost;
@@ -491,8 +491,8 @@ std::unique_ptr<fles::Timeslice> CbmMQTsSamplerRepReq::GetNewTs()
/// Missed TS detection (only if output channel name defined by user)
if ((uTsIndex != (fulPrevTsIndex + 1)) && !(0 == fulPrevTsIndex && 0 == uTsIndex && 0 == fulTsCounter)) {
- LOG(info) << "Missed Timeslices. Old TS Index was " << fulPrevTsIndex << " New TS Index is " << uTsIndex
- << " diff is " << uTsIndex - fulPrevTsIndex << " Missing are " << uTsIndex - fulPrevTsIndex - 1;
+ LOG(debug) << "Missed Timeslices. Old TS Index was " << fulPrevTsIndex << " New TS Index is " << uTsIndex
+ << " diff is " << uTsIndex - fulPrevTsIndex << " Missing are " << uTsIndex - fulPrevTsIndex - 1;
if ("" != fsChannelNameMissedTs) {
/// Add missing TS indices to a vector and send it in appropriate channel
--
GitLab