2 #include <cds/misc/RigtorpMPMCQueue.h>
3 #include <cds_test/stress_test.h>
11 class rigtorpMPMCQueueTest : public cds_test::stress_fixture {
13 static size_t s_nRigtorpMPMCQueuePassCount;
14 static size_t s_nRigtorpMPMCQueueEnqueueStride;
15 static size_t s_nRigtorpMPMCQueueCapacity;
17 static void SetUpTestCase() {
18 cds_test::config const &cfg = get_config("SequentialMisc");
19 GetConfigExpected(RigtorpMPMCQueuePassCount, 10000);
20 GetConfigExpected(RigtorpMPMCQueueEnqueueStride, 1024);
21 GetConfigExpected(RigtorpMPMCQueueCapacity, 2048);
22 if (s_nRigtorpMPMCQueueCapacity <= s_nRigtorpMPMCQueueEnqueueStride) {
23 s_nRigtorpMPMCQueueCapacity = 2 * s_nRigtorpMPMCQueueEnqueueStride;
28 rigtorp::MPMCQueue<size_t> q(s_nRigtorpMPMCQueueCapacity);
32 while (nNo < s_nRigtorpMPMCQueuePassCount) {
33 size_t curr_push_count = std::min(s_nRigtorpMPMCQueuePassCount - nNo,
34 s_nRigtorpMPMCQueueEnqueueStride);
35 for (size_t i = 0; i < curr_push_count; i++) {
40 for (size_t i = 0; i < curr_push_count; i++) {
48 s_nRigtorpMPMCQueuePassCount * (s_nRigtorpMPMCQueuePassCount - 1) / 2;
49 if (pop_sum != supposed_sum) {
50 std::cout << "Sequential rigtorpMPMC queue pop sum: " << pop_sum
51 << " != " << supposed_sum << "\n";
56 size_t rigtorpMPMCQueueTest::s_nRigtorpMPMCQueuePassCount;
57 size_t rigtorpMPMCQueueTest::s_nRigtorpMPMCQueueEnqueueStride;
58 size_t rigtorpMPMCQueueTest::s_nRigtorpMPMCQueueCapacity;
60 TEST_F(rigtorpMPMCQueueTest, PushPop) {