diff --git a/sf-writer/include/WriterZmqReceiver.hpp b/sf-writer/include/WriterZmqReceiver.hpp index f9fddfd..ee3cf84 100644 --- a/sf-writer/include/WriterZmqReceiver.hpp +++ b/sf-writer/include/WriterZmqReceiver.hpp @@ -23,7 +23,7 @@ public: virtual ~WriterZmqReceiver(); void get_next_buffer( - const uint64_t pulse_id, + const uint64_t start_pulse_id, ImageMetadataBuffer* image_metadata, char* image_buffer); }; diff --git a/sf-writer/src/WriterZmqReceiver.cpp b/sf-writer/src/WriterZmqReceiver.cpp index c1fdf2d..e562310 100644 --- a/sf-writer/src/WriterZmqReceiver.cpp +++ b/sf-writer/src/WriterZmqReceiver.cpp @@ -47,7 +47,7 @@ WriterZmqReceiver::~WriterZmqReceiver() } void WriterZmqReceiver::get_next_buffer( - const uint64_t pulse_id, + const uint64_t start_pulse_id, ImageMetadataBuffer* image_metadata, char* image_buffer) { @@ -61,6 +61,8 @@ void WriterZmqReceiver::get_next_buffer( size_t image_buffer_offset = 0; + for (size_t pulse_id=start_pulse_id) + for (size_t i_module = 0; i_module < n_modules_; i_module++) { auto n_bytes_metadata = zmq_recv( @@ -137,6 +139,4 @@ void WriterZmqReceiver::get_next_buffer( image_buffer_offset += n_bytes_image; } - - image_metadata->data_n_bytes = image_buffer_offset; }