sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-09 07:32:04 +02:00
Code Issues Packages Projects Releases Wiki Activity

Temp disable compression

Browse Source
This commit is contained in:
babic_a
2020-04-09 13:35:52 +02:00
parent 7cb0dc1f29
commit d0961ea3d0
1 changed files with 19 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/module/ZmqRecvModule.cpp
+19 -15
View File
@@ -183,24 +183,28 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
}
char* buffer = ring_buffer_.reserve(frame_metadata);
auto compressed_size = compression::compress_bitshuffle(
memcpy(
buffer,
static_cast<const char*>(frame_data),
frame_metadata->frame_bytes_size,
1,
buffer);
frame_metadata->frame_bytes_size);
#ifdef DEBUG_OUTPUT
using namespace date;
using namespace chrono;
cout << "[" << system_clock::now() << "]";
cout << "[ZmqRecvModule::receive_thread]";
cout << " Compressed image from ";
cout << frame_metadata->frame_bytes_size << " bytes to ";
cout << compressed_size << " bytes." << endl;
#endif
// auto compressed_size = compression::compress_bitshuffle(
// static_cast<const char*>(frame_data),
// frame_metadata->frame_bytes_size,
// 1,
// buffer);
//
// #ifdef DEBUG_OUTPUT
// using namespace date;
// using namespace chrono;
// cout << "[" << system_clock::now() << "]";
// cout << "[ZmqRecvModule::receive_thread]";
// cout << " Compressed image from ";
// cout << frame_metadata->frame_bytes_size << " bytes to ";
// cout << compressed_size << " bytes." << endl;
// #endif
frame_metadata->frame_bytes_size = compressed_size;
// frame_metadata->frame_bytes_size = compressed_size;
ring_buffer_.commit(frame_metadata);
}