mirror of
https://github.com/paulscherrerinstitute/sf_daq_buffer.git
synced 2026-05-01 08:32:23 +02:00
Subscribe socket to all messages
This commit is contained in:
@@ -49,6 +49,10 @@ int main (int argc, char *argv[]) {
|
||||
auto socket = zmq_socket(ctx, ZMQ_PUSH);
|
||||
auto meta_socket = zmq_socket(ctx, ZMQ_SUB);
|
||||
|
||||
if (zmq_setsockopt(meta_socket, ZMQ_SUBSCRIBE, nullptr, 0) != 0) {
|
||||
throw runtime_error(strerror (errno));
|
||||
}
|
||||
|
||||
int status = 0;
|
||||
|
||||
int sndhwm = 1;
|
||||
|
||||
Reference in New Issue
Block a user