diff --git a/algo/base/HistogramSender.h b/algo/base/HistogramSender.h index f3dd22ae9155c627b7d95bf3f51be50f685dd070..343a8e4a93b875664deeae3018388f3005f9c05b 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: