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

Send BufferBinaryBlock from sf_replay

Browse Source
This commit is contained in:
babic_a
2020-05-27 10:22:44 +02:00
parent 01776e12ad
commit 0f6d63aded
3 changed files with 7 additions and 5 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 ReplayBuffer* metadata, const char* data);
void send(const BufferBinaryBlock* metadata, const char* data);
};
sf-replay/src/ReplayZmqSender.cpp
+4 -2
View File
@@ -41,8 +41,10 @@ void ReplayZmqSender::close() {
zmq_ctx_destroy(ctx_);
}
void ReplayZmqSender::send(const ReplayBuffer* metadata, const char* data)
void ReplayZmqSender::send(
const BufferBinaryBlock* metadata,
const char* data)
{
zmq_send(socket_, metadata, sizeof(ReplayBuffer), ZMQ_SNDMORE);
zmq_send(socket_, metadata, sizeof(BufferBinaryBlock), ZMQ_SNDMORE);
zmq_send(socket_, data, MODULE_N_BYTES * BUFFER_BLOCK_SIZE, 0);
}
sf-replay/src/main.cpp
+2 -2
View File
@@ -14,7 +14,7 @@ using namespace chrono;
void sf_replay (
const string device,
const string channel_name,
FastQueue<ReplayBuffer>& queue,
FastQueue<BufferBinaryBlock>& queue,
const uint64_t start_pulse_id,
const uint64_t stop_pulse_id
)
@@ -75,7 +75,7 @@ int main (int argc, char *argv[]) {
const auto start_pulse_id = (uint64_t) atoll(argv[5]);
const auto stop_pulse_id = (uint64_t) atoll(argv[6]);
FastQueue<ReplayBuffer> queue(
FastQueue<BufferBinaryBlock> queue(
MODULE_N_BYTES * BUFFER_BLOCK_SIZE,
REPLAY_FASTQUEUE_N_SLOTS);