intermediate changes

ref:cde9a383711a11544ce7e107a78147fb96cc4029

1 files changed, 60 insertions, 0 deletions

diff --git a/library/cpp/messagebus/actor/ring_buffer_ut.cpp b/library/cpp/messagebus/actor/ring_buffer_ut.cpp
new file mode 100644
index 00000000000..bdb379b3a92
--- /dev/null
+++ b/library/cpp/messagebus/actor/ring_buffer_ut.cpp
@@ -0,0 +1,60 @@
+#include <library/cpp/testing/unittest/registar.h>
+
+#include "ring_buffer.h"
+
+#include <util/random/random.h>
+
+Y_UNIT_TEST_SUITE(RingBuffer) {
+    struct TRingBufferTester {
+        TRingBuffer<unsigned> RingBuffer;
+
+        unsigned NextPush;
+        unsigned NextPop;
+
+        TRingBufferTester()
+            : NextPush()
+            , NextPop()
+        {
+        }
+
+        void Push() {
+            //Cerr << "push " << NextPush << "\n";
+            RingBuffer.Push(NextPush);
+            NextPush += 1;
+        }
+
+        void Pop() {
+            //Cerr << "pop " << NextPop << "\n";
+            unsigned popped = RingBuffer.Pop();
+            UNIT_ASSERT_VALUES_EQUAL(NextPop, popped);
+            NextPop += 1;
+        }
+
+        bool Empty() const {
+            UNIT_ASSERT_VALUES_EQUAL(RingBuffer.Size(), NextPush - NextPop);
+            UNIT_ASSERT_VALUES_EQUAL(RingBuffer.Empty(), RingBuffer.Size() == 0);
+            return RingBuffer.Empty();
+        }
+    };
+
+    void Iter() {
+        TRingBufferTester rb;
+
+        while (rb.NextPush < 1000) {
+            rb.Push();
+            while (!rb.Empty() && RandomNumber<bool>()) {
+                rb.Pop();
+            }
+        }
+
+        while (!rb.Empty()) {
+            rb.Pop();
+        }
+    }
+
+    Y_UNIT_TEST(Random) {
+        for (unsigned i = 0; i < 100; ++i) {
+            Iter();
+        }
+    }
+}