Skip to content
Snippets Groups Projects
Commit e3a7301b authored by Pierre-Alain Loizeau's avatar Pierre-Alain Loizeau
Browse files

Fix blocking send in online Histo sender

parent 94f36cfa
No related branches found
No related tags found
1 merge request!1813Fix blocking send in online Histo sender
Pipeline #29319 passed
...@@ -52,7 +52,8 @@ namespace cbm::algo ...@@ -52,7 +52,8 @@ namespace cbm::algo
zmq::message_t msg(serial_str.size()); zmq::message_t msg(serial_str.size());
std::copy_n(static_cast<const char*>(serial_str.data()), msg.size(), static_cast<char*>(msg.data())); 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: private:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment