From 3401f2a25e85bf54636f8f252256bfd680a31f2f Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 22 Apr 2020 14:38:39 +0200 Subject: [PATCH] Test arrangement --- sf-writer/sf_h5_writer.cpp | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp index 5baf251..a7e2844 100644 --- a/sf-writer/sf_h5_writer.cpp +++ b/sf-writer/sf_h5_writer.cpp @@ -61,7 +61,7 @@ int main (int argc, char *argv[]) auto image_buffer = make_unique(512 * 1024); unordered_map received_counter; - size_t n_recv_modules = 0; + size_t n_frames_left = 32*50; while (true) { auto n_bytes_metadata = zmq_recv( @@ -85,6 +85,8 @@ int main (int argc, char *argv[]) throw runtime_error("Unexpected number of bytes in image."); } + n_frames_left--; + if (received_counter.find(metadata_buffer->pulse_id) == received_counter.end()) { received_counter.insert({metadata_buffer->pulse_id, 31}); @@ -93,17 +95,15 @@ int main (int argc, char *argv[]) if (received_counter[metadata_buffer->pulse_id] == 0) { received_counter.erase(metadata_buffer->pulse_id); - n_recv_modules++; } } - cout << "n_recv_modules " << n_recv_modules << endl; - if (n_recv_modules == 32) { + if (n_frames_left == 0) { for(auto& data:received_counter) { - cout << data.first << ": " << data.second; + cout << data.first << ": " << data.second << endl; } - zmq_send(meta_socket, "", strlen(""), 0); - n_recv_modules = 0; +// zmq_send(meta_socket, "", strlen(""), 0); + n_frames_left = 32*50; } }