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

Adjust to sending only 1 binary block

Browse Source
This commit is contained in:
babic_a
2020-05-27 10:54:34 +02:00
parent 32f4ef6dba
commit d42eca0e7a
2 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
sf-replay/include/ReplayZmqSender.hpp
+1 -1
View File
@@ -16,7 +16,7 @@ public:
void close();
void send(const BufferBinaryBlock* metadata, const char* data);
void send(const BufferBinaryBlock* block_data);
};
sf-replay/src/ReplayZmqSender.cpp
+2 -5
View File
@@ -41,10 +41,7 @@ void ReplayZmqSender::close() {
zmq_ctx_destroy(ctx_);
}
void ReplayZmqSender::send(
const BufferBinaryBlock* metadata,
const char* data)
void ReplayZmqSender::send(const BufferBinaryBlock* block_data)
{
zmq_send(socket_, metadata, sizeof(BufferBinaryBlock), ZMQ_SNDMORE);
zmq_send(socket_, data, MODULE_N_BYTES * BUFFER_BLOCK_SIZE, 0);
zmq_send(socket_, block_data, sizeof(BufferBinaryBlock), ZMQ_SNDMORE);
}