From 10ba289df9b62369952cd39a24f534a3ca919d18 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Thu, 14 May 2020 12:28:11 +0200 Subject: [PATCH] Add writer recvhwm parameter --- core-buffer/include/buffer_config.hpp | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/core-buffer/include/buffer_config.hpp b/core-buffer/include/buffer_config.hpp index e1e26dc..3f7a2bd 100644 --- a/core-buffer/include/buffer_config.hpp +++ b/core-buffer/include/buffer_config.hpp @@ -31,12 +31,6 @@ namespace core_buffer { const std::string REPLAY_STREAM_IPC_URL = "ipc:///tmp/sf-replay-"; - // Size of sf_buffer RB in elements. - const size_t BUFFER_INTERNAL_QUEUE_SIZE = 1000; - -// // Time to sleep before retrying to read the queue. -// const size_t BUFFER_QUEUE_RETRY_MS = 5; - const size_t BUFFER_UDP_N_RECV_MSG = 64; // Size of UDP recv buffer @@ -66,6 +60,9 @@ namespace core_buffer { // How long should the RECV queue be. const size_t STREAM_RCVHWM = 100; + // Writer RECV queue on ZMQ. + const int WRITER_RCVHWM = 100; + // ZMQ threads for receiving data from sf_replay. const int WRITER_ZMQ_IO_THREADS = 2; @@ -80,8 +77,6 @@ namespace core_buffer { // If the RB is empty, how much time to wait before trying to read it again. const size_t RB_READ_RETRY_INTERVAL_MS = 5; - - const size_t LIVE_READ_BLOCK_SIZE = 10; } #endif //BUFFERCONFIG_HPP