From d42eca0e7a8ab29433274b6368657fd3aa4f860c Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Wed, 27 May 2020 10:54:34 +0200 Subject: [PATCH] Adjust to sending only 1 binary block --- sf-replay/include/ReplayZmqSender.hpp | 2 +- sf-replay/src/ReplayZmqSender.cpp | 7 ++----- 2 files changed, 3 insertions(+), 6 deletions(-) diff --git a/sf-replay/include/ReplayZmqSender.hpp b/sf-replay/include/ReplayZmqSender.hpp index 7396b1e..5851ad4 100644 --- a/sf-replay/include/ReplayZmqSender.hpp +++ b/sf-replay/include/ReplayZmqSender.hpp @@ -16,7 +16,7 @@ public: void close(); - void send(const BufferBinaryBlock* metadata, const char* data); + void send(const BufferBinaryBlock* block_data); }; diff --git a/sf-replay/src/ReplayZmqSender.cpp b/sf-replay/src/ReplayZmqSender.cpp index 27be144..f16e028 100644 --- a/sf-replay/src/ReplayZmqSender.cpp +++ b/sf-replay/src/ReplayZmqSender.cpp @@ -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); } \ No newline at end of file