sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-04-24 16:30:43 +02:00
Code Issues Packages Projects Releases Wiki Activity

Remove compression from WriterZmqReceiver

Browse Source
This commit is contained in:
babic_a
2020-05-19 13:34:39 +02:00
parent b54327a001
commit e49a9ef60b
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-buffer/src/WriterZmqReceiver.cpp
+11 -9
View File
@@ -1,5 +1,5 @@
#include "WriterZmqReceiver.hpp"
#include "bitshuffle/bitshuffle.h"
//#include "bitshuffle/bitshuffle.h"
#include "zmq.h"
#include "date.h"
#include <chrono>
@@ -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);