X-Git-Url: http://plrg.eecs.uci.edu/git/?p=libcds.git;a=blobdiff_plain;f=test%2Fstress%2Fsequential%2Fsequential-misc%2Frigtorp_mpmc_driver.cpp;h=0066f901641e178c53ed95d10c102fbd1358d2a1;hp=2d46103c1047871c9b38386444ce3ad0dc794587;hb=6ec1165b0c929f8b4c7d4f7a0ff79a4126b4947e;hpb=d88faec0c6284c315cc288452212c0dc8b853a77 diff --git a/test/stress/sequential/sequential-misc/rigtorp_mpmc_driver.cpp b/test/stress/sequential/sequential-misc/rigtorp_mpmc_driver.cpp index 2d46103c..0066f901 100644 --- a/test/stress/sequential/sequential-misc/rigtorp_mpmc_driver.cpp +++ b/test/stress/sequential/sequential-misc/rigtorp_mpmc_driver.cpp @@ -25,7 +25,8 @@ protected: } void test() { - rigtorp::MPMCQueue q(s_nRigtorpMPMCQueueCapacity); + std::unique_ptr> q( + new rigtorp::MPMCQueue(s_nRigtorpMPMCQueueCapacity)); size_t nNo = 0; size_t pop_sum = 0; @@ -33,13 +34,13 @@ protected: size_t curr_push_count = std::min(s_nRigtorpMPMCQueuePassCount - nNo, s_nRigtorpMPMCQueueEnqueueStride); for (size_t i = 0; i < curr_push_count; i++) { - q.push(nNo); + q->push(nNo); ++nNo; } for (size_t i = 0; i < curr_push_count; i++) { size_t res; - q.pop(res); + q->pop(res); pop_sum += res; } }