Skip to content
Snippets Groups Projects

Add support for High-Water Mark in HistogramSender and histserv_nofairmq + reduce logs

Merged Pierre-Alain Loizeau requested to merge p.-a.loizeau/cbmroot:online_hist_hwm into master
All threads resolved!
Files
7
@@ -20,11 +20,13 @@ namespace cbm::algo
class HistogramSender {
public:
HistogramSender(std::string_view address)
HistogramSender(std::string_view address, int32_t hwm = 1)
: fHistComChan(address)
, fHistHighWaterMark(hwm)
, fZmqContext(1)
, fZmqSocket(fZmqContext, zmq::socket_type::push)
{
fZmqSocket.set(zmq::sockopt::sndhwm, fHistHighWaterMark); // High-Water Mark, max nb updates kept in out buffer
fZmqSocket.connect(fHistComChan); // This side "connects" to socket => Other side should have "bind"!!!!
}
@@ -54,7 +56,8 @@ namespace cbm::algo
}
private:
std::string fHistComChan = "tcp://127.0.0.1:56800";
std::string fHistComChan = "tcp://127.0.0.1:56800";
int32_t fHistHighWaterMark = 1;
zmq::context_t fZmqContext; ///< ZMQ context FIXME: should be only one context per binary!
zmq::socket_t fZmqSocket; ///< ZMQ socket to histogram server
};
Loading