diff --git a/core-buffer/src/WriterZmqReceiver.cpp b/core-buffer/src/WriterZmqReceiver.cpp index 082485b..9dbacb6 100644 --- a/core-buffer/src/WriterZmqReceiver.cpp +++ b/core-buffer/src/WriterZmqReceiver.cpp @@ -1,5 +1,5 @@ #include "WriterZmqReceiver.hpp" -#include "bitshuffle/bitshuffle.h" +//#include "bitshuffle/bitshuffle.h" #include "zmq.h" #include "date.h" #include @@ -60,13 +60,14 @@ void WriterZmqReceiver::get_next_image( image_metadata->is_good_frame = 1; bool image_metadata_init = false; - // Set compression header. - bshuf_write_uint64_BE(image_buffer, - MODULE_N_BYTES * n_modules_); - bshuf_write_uint32_BE(image_buffer + 8, - MODULE_N_PIXELS * PIXEL_N_BYTES); - - size_t image_buffer_offset = BSHUF_LZ4_HEADER_BYTES; +// // Set compression header. +// bshuf_write_uint64_BE(image_buffer, +// MODULE_N_BYTES * n_modules_); +// bshuf_write_uint32_BE(image_buffer + 8, +// MODULE_N_PIXELS * PIXEL_N_BYTES); +// +// size_t image_buffer_offset = BSHUF_LZ4_HEADER_BYTES; + size_t image_buffer_offset = 0; for (size_t i_module = 0; i_module < n_modules_; i_module++) { @@ -130,7 +131,8 @@ void WriterZmqReceiver::get_next_image( auto n_bytes_image = zmq_recv( sockets_[i_module], - (image_buffer + image_buffer_offset), +// (image_buffer + image_buffer_offset), + image_buffer, frame_metadata.data_n_bytes, 0);