From 81369c57664a6dacc55ac5bbceb0dc20680788ca Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 17 Jan 2018 15:30:33 +0100 Subject: [PATCH] Exit when all frames are written --- src/h5_zmq_writer.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/h5_zmq_writer.cpp b/src/h5_zmq_writer.cpp index 7939f32..8dd5e22 100644 --- a/src/h5_zmq_writer.cpp +++ b/src/h5_zmq_writer.cpp @@ -49,6 +49,8 @@ void write_h5(WriterManager *manager, RingBuffer *ring_buffer, string output_fil #ifdef DEBUG_OUTPUT cout << "[h5_zmq_writer::write] Writer thread stopped." << endl; #endif + + exit(0); } void receive_zmq(WriterManager *manager, RingBuffer *ring_buffer, string connect_address, int n_io_threads=1, int receive_timeout=-1) @@ -87,7 +89,7 @@ void receive_zmq(WriterManager *manager, RingBuffer *ring_buffer, string connect } frame_metadata.type = header_parser["type"].GetString(); - + // Get the message data. receiver.recv(&message_data); frame_metadata.frame_bytes_size = message_data.size();