From 9d1158a68b174b6e8ea49da5e659dc73c8d012d1 Mon Sep 17 00:00:00 2001 From: Andrej Babic Date: Fri, 3 Apr 2020 14:13:16 +0200 Subject: [PATCH] Properly release ring buffer when reading the slots --- core-writer/test/test_ZmqRecvModule.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/core-writer/test/test_ZmqRecvModule.cpp b/core-writer/test/test_ZmqRecvModule.cpp index afb9b1d..95e8a12 100644 --- a/core-writer/test/test_ZmqRecvModule.cpp +++ b/core-writer/test/test_ZmqRecvModule.cpp @@ -42,7 +42,7 @@ TEST(ZmqRecvModule, basic_interaction) TEST(ZmqRecvModule, simple_recv) { - size_t n_msg = 1; + size_t n_msg = 10; thread sender(generate_stream, n_msg); RingBuffer ring_buffer(n_msg); @@ -61,6 +61,8 @@ TEST(ZmqRecvModule, simple_recv) // nullptr means there is no data in the buffer. ASSERT_TRUE(data.first != nullptr); ASSERT_TRUE(data.second != nullptr); + + ring_buffer.release(data.first->buffer_slot_index); } // no more messages in the buffer.