From e3a7301b75baeaf44b3c0f2f48271c542a8fc620 Mon Sep 17 00:00:00 2001
From: "P.-A. Loizeau" <p.-a.loizeau@gsi.de>
Date: Wed, 8 May 2024 02:52:20 +0200
Subject: [PATCH] Fix blocking send in online Histo sender
---
algo/base/HistogramSender.h | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/algo/base/HistogramSender.h b/algo/base/HistogramSender.h
index f3dd22ae91..343a8e4a93 100644
--- a/algo/base/HistogramSender.h
+++ b/algo/base/HistogramSender.h
@@ -52,7 +52,8 @@ namespace cbm::algo
zmq::message_t msg(serial_str.size());
std::copy_n(static_cast<const char*>(serial_str.data()), msg.size(), static_cast<char*>(msg.data()));
- fZmqSocket.send(msg, flags);
+ /// FIXME: read return value to catch EAGAIN indicating a failed emission, use it outside to skip histo reset
+ fZmqSocket.send(msg, flags | zmq::send_flags::dontwait);
}
private:
--
GitLab