From fd33f72a091473f1d05137daf06dede22c16a1dd Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Fri, 8 May 2020 11:39:36 +0200 Subject: [PATCH] Invert bind and connect among replay and writer --- sf-buffer/src/sf_replay.cpp | 2 +- sf-buffer/src/sf_writer.cpp | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/sf-buffer/src/sf_replay.cpp b/sf-buffer/src/sf_replay.cpp index 50ed4ea..dcdf3f7 100644 --- a/sf-buffer/src/sf_replay.cpp +++ b/sf-buffer/src/sf_replay.cpp @@ -231,7 +231,7 @@ int main (int argc, char *argv[]) { if (zmq_setsockopt(socket, ZMQ_LINGER, &linger_ms, sizeof(linger_ms)) != 0) throw runtime_error(strerror (errno)); - if (zmq_connect(socket, ipc_address.c_str()) != 0) + if (zmq_bind(socket, ipc_address.c_str()) != 0) throw runtime_error(strerror (errno)); sf_replay(socket, device, channel_name, start_pulse_id, stop_pulse_id); diff --git a/sf-buffer/src/sf_writer.cpp b/sf-buffer/src/sf_writer.cpp index 608ddef..cf22240 100644 --- a/sf-buffer/src/sf_writer.cpp +++ b/sf-buffer/src/sf_writer.cpp @@ -41,7 +41,7 @@ void receive_replay( ipc_addr << ipc_prefix << i; const auto ipc = ipc_addr.str(); - if (zmq_bind(sockets[i], ipc.c_str()) != 0) { + if (zmq_connect(sockets[i], ipc.c_str()) != 0) { throw runtime_error(strerror(errno)); } }