From 28eb2ae5ccef5f6871c1a82df7e969d333a33d02 Mon Sep 17 00:00:00 2001 From: Peizhao Ou Date: Mon, 29 Jan 2018 15:50:09 -0800 Subject: [PATCH] Changes RigtorpSPSC test case --- .../sequential-misc/rigtorp_spsc_driver.cpp | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/test/stress/sequential/sequential-misc/rigtorp_spsc_driver.cpp b/test/stress/sequential/sequential-misc/rigtorp_spsc_driver.cpp index 0fee1798..ef3380ad 100644 --- a/test/stress/sequential/sequential-misc/rigtorp_spsc_driver.cpp +++ b/test/stress/sequential/sequential-misc/rigtorp_spsc_driver.cpp @@ -14,6 +14,8 @@ protected: static size_t s_nRigtorpSPSCQueueEnqueueStride; static size_t s_nRigtorpSPSCQueueCapacity; + rigtorp::SPSCQueue* q; + static void SetUpTestCase() { cds_test::config const &cfg = get_config("SequentialMisc"); GetConfigExpected(RigtorpSPSCQueuePassCount, 10000); @@ -25,7 +27,8 @@ protected: } void test() { - rigtorp::SPSCQueue q(s_nRigtorpSPSCQueueCapacity); + std::unique_ptr> q( + new rigtorp::SPSCQueue(s_nRigtorpSPSCQueueCapacity)); size_t nNo = 0; size_t push_sum = 0; size_t pop_sum = 0; @@ -34,15 +37,15 @@ protected: size_t curr_push_count = std::min(s_nRigtorpSPSCQueuePassCount - nNo, s_nRigtorpSPSCQueueEnqueueStride); for (size_t i = 0; i < curr_push_count; i++) { - q.push(nNo); + q->push(nNo); push_sum += nNo; ++nNo; } size_t* res = nullptr; - while ((res = q.front())) { + while ((res = q->front())) { pop_sum += *res; - q.pop(); + q->pop(); } EXPECT_EQ(pop_sum, push_sum); push_sum = 0; -- 2.34.1