sf-daq/sf_daq_buffer
0
0
Fork 0
mirror of https://github.com/paulscherrerinstitute/sf_daq_buffer.git synced 2026-05-03 19:14:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

Add compression buffer size validation

Browse Source
This commit is contained in:
babic_a
2020-04-03 16:53:50 +02:00
parent 233c483fc7
commit 06f15b8cb9
1 changed files with 19 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core-writer/src/ZmqRecvModule.cpp
+19 -3
View File
@@ -132,14 +132,30 @@ void ZmqRecvModule::receive_thread(const string& connect_address)
char* buffer = ring_buffer_.reserve(frame_metadata);
// TODO: Add flag to disable compression.
// TODO: Cache results no to calculate this every time.
{
// TODO: Cache results no to calculate this every time.
size_t n_elements =
frame_metadata->frame_shape[0] *
frame_metadata->frame_shape[1];
size_t max_buffer_size =
compression::get_bitshuffle_max_buffer_size(
frame_metadata->frame_bytes_size, 1);
n_elements,
frame_metadata->frame_bytes_size/n_elements);
if (max_buffer_size > ring_buffer_.get_slot_size()) {
//TODO: Throw error if not large enough.
stringstream err_msg;
using namespace date;
using namespace chrono;
err_msg << "[" << system_clock::now() << "]";
err_msg << "[ZmqRecvModule::receive_thread]";
err_msg << " RingBuffer slot size ";
err_msg << ring_buffer_.get_slot_size();
err_msg << " smaller than max_buffer_size ";
err_msg << max_buffer_size << endl;
throw runtime_error(err_msg.str());
}
}