From 325ae5d9cfef39b1a394e98f77899eca57d8dd9e Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Thu, 23 Apr 2020 12:24:25 +0200 Subject: [PATCH] Add RB initialization --- sf-writer/sf_h5_writer.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp index 0cf4f32..933c5be 100644 --- a/sf-writer/sf_h5_writer.cpp +++ b/sf-writer/sf_h5_writer.cpp @@ -102,6 +102,7 @@ void receive_replay( using namespace chrono; cout << "[" << system_clock::now() << "]"; + cout << "[sf_h5_writer::receive_replay]"; cout << " Stopped because of exception: " << endl; cout << e.what() << endl; @@ -128,9 +129,11 @@ int main (int argc, char *argv[]) uint64_t start_pulse_id = (uint64_t) atoll(argv[2]); uint64_t stop_pulse_id = (uint64_t) atoll(argv[3]); - RingBuffer ring_buffer(5); - size_t n_modules = 32; + + RingBuffer ring_buffer(5); + ring_buffer.initialize(MODULE_N_BYTES*n_modules); + string ipc_prefix = "ipc://sf-replay-"; auto ctx = zmq_ctx_new(); zmq_ctx_set (ctx, ZMQ_IO_THREADS, WRITER_ZMQ_IO_THREADS);