Uses different pass count for different parallel queue test cases
[libcds.git] / test / stress / sequential / sequential_queue.cpp
index 4fe932a58ae37089bdc8b79f44af0d79ecab35b9..6e8760d542dd1c286106ed54704f6c3f155217b3 100644 (file)
@@ -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;                    \
-    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)                         \
@@ -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;                    \
-    queue_type queue;                                                          \
-    test(queue);                                                               \
+    std::unique_ptr<queue_type> queue(new queue_type());                       \
+    test(*queue);                                                              \
   }
 
 #define CDSSTRESS_Sequential_MSQueue(test_fixture)                             \
@@ -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;                    \
-    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)