From 39fe7a9f8f808a457e127d61de5e565903eb3b9d Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Mon, 12 Feb 2018 11:13:42 +0100 Subject: [PATCH] Connect before receive of messages --- src/ProcessManager.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/ProcessManager.cpp b/src/ProcessManager.cpp index cefaa4f..dc5d7cb 100644 --- a/src/ProcessManager.cpp +++ b/src/ProcessManager.cpp @@ -51,6 +51,8 @@ void ProcessManager::run_writer(WriterManager& manager, const H5Format& format, void ProcessManager::receive_zmq(WriterManager& manager, RingBuffer& ring_buffer, ZmqReceiver& receiver, const H5Format& format) { + receiver.connect(); + while (manager.is_running()) { auto frame = receiver.receive();