From 3cb743b750112044e8f9fbb5fbcb6991caf5fcbd Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Thu, 23 Apr 2020 12:14:05 +0200
Subject: [PATCH] Create context in common thread

---
 sf-writer/sf_h5_writer.cpp | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp
index 9abede1..3a75cf0 100644
--- a/sf-writer/sf_h5_writer.cpp
+++ b/sf-writer/sf_h5_writer.cpp
@@ -17,10 +17,10 @@ using namespace core_buffer;
 void receive_replay(
         const string ipc_prefix,
         const size_t n_modules,
-        RingBuffer<DetectorFrame>& ring_buffer)
+        RingBuffer<DetectorFrame>& ring_buffer,
+        void* ctx)
 {
-    auto ctx = zmq_ctx_new();
-    zmq_ctx_set (ctx, ZMQ_IO_THREADS, WRITER_ZMQ_IO_THREADS);
+
 
     void* sockets[n_modules];
     for (size_t i=0; i<n_modules; i++) {
@@ -35,7 +35,7 @@ void receive_replay(
         }
 
         stringstream ipc_addr;
-        ipc_addr << "ipc://sf-replay-" << i;
+        ipc_addr << ipc_prefix << i;
         auto ipc = ipc_addr.str();
 
         if (zmq_bind(sockets[i], ipc.c_str()) != 0) {
@@ -118,14 +118,17 @@ int main (int argc, char *argv[])
 
     RingBuffer<DetectorFrame> ring_buffer(5);
 
-    string ipc_prefix = "ipc://sf-replay-";
     size_t n_modules = 32;
+    string ipc_prefix = "ipc://sf-replay-";
+    auto ctx = zmq_ctx_new();
+    zmq_ctx_set (ctx, ZMQ_IO_THREADS, WRITER_ZMQ_IO_THREADS);
 
     thread replay_receive_thread(
             receive_replay,
             ipc_prefix,
             n_modules,
-            ref(ring_buffer));
+            ref(ring_buffer),
+            ctx);
 
     H5Writer writer(output_file);
     writer.create_file();