Uses different pass count for different parallel queue test cases

[libcds.git] / test / stress / sequential / sequential_queue.cpp

diff --git a/test/stress/sequential/sequential_queue.cpp b/test/stress/sequential/sequential_queue.cpp
index 1a537dd63b6804a5a0bd703e3eb4ff7e04bc7a38..6e8760d542dd1c286106ed54704f6c3f155217b3 100644 (file)
--- a/test/stress/sequential/sequential_queue.cpp
+++ b/test/stress/sequential/sequential_queue.cpp
@@ -106,8 +106,8 @@ using simple_sequential_queue = sequential_queue<>;
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \

-    queue_type queue(s_nQueueSize);                                            \
-    test(queue, s_nVyukovQueuePushCount);                                      \
+    std::unique_ptr<queue_type> queue(new queue_type(s_nQueueSize));           \
+    test(*queue, s_nVyukovQueuePushCount);                                     \

   }
 
 #define CDSSTRESS_Sequential_VyukovQueue(test_fixture)                         \
   }
 
 #define CDSSTRESS_Sequential_VyukovQueue(test_fixture)                         \


@@ -120,8 +120,8 @@ CDSSTRESS_Sequential_VyukovQueue(simple_sequential_queue);
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \

-    queue_type queue;                                                          \
-    test(queue);                                                               \
+    std::unique_ptr<queue_type> queue(new queue_type());                       \
+    test(*queue);                                                              \

   }
 
 #define CDSSTRESS_Sequential_MSQueue(test_fixture)                             \
   }
 
 #define CDSSTRESS_Sequential_MSQueue(test_fixture)                             \


@@ -151,7 +151,7 @@ CDSSTRESS_Sequential_MoirQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_BasketQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_OptimsticQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_RWQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_BasketQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_OptimsticQueue(simple_sequential_queue);
 CDSSTRESS_Sequential_RWQueue(simple_sequential_queue);

-CDSSTRESS_Sequential_WeakRingBuffer(simple_sequential_queue);
+//CDSSTRESS_Sequential_WeakRingBuffer(simple_sequential_queue);

 
 // ********************************************************************
 // SegmentedQueue test
 
 // ********************************************************************
 // SegmentedQueue test


@@ -290,8 +290,8 @@ public:
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \
 #define CDSSTRESS_Sequential_Queue_F(test_fixture, type_name)                  \
   TEST_F(test_fixture, type_name) {                                            \
     typedef queue::Types<value_type>::type_name queue_type;                    \

-    queue_type queue(s_nBufferSize);                                           \
-    test(queue);                                                               \
+    std::unique_ptr<queue_type> queue(new queue_type(s_nBufferSize));          \
+    test(*queue);                                                              \

   }
 
 CDSSTRESS_WeakRingBuffer_void(sequential_weak_ring_buffer)
   }
 
 CDSSTRESS_WeakRingBuffer_void(sequential_weak_ring_buffer)