Lines Matching refs:q
46 void push(CQ& q, ValueType v, CounterType i) { in push() argument
48 case 0: q.push( v); break; in push()
49 case 1: q.push( std::move(v)); break; in push()
50 case 2: q.emplace( v); break; in push()
262 … ConcQWithSizeWrapper( const ConcQWithSizeWrapper& q ) : oneapi::tbb::concurrent_queue<T, A>(q) {} in ConcQWithSizeWrapper() argument
263 …oncQWithSizeWrapper( const ConcQWithSizeWrapper& q, const A& a ) : oneapi::tbb::concurrent_queue<T… in ConcQWithSizeWrapper() argument
266 …ConcQWithSizeWrapper( ConcQWithSizeWrapper&& q ) : oneapi::tbb::concurrent_queue<T>(std::move(q)) … in ConcQWithSizeWrapper() argument
267 ConcQWithSizeWrapper( ConcQWithSizeWrapper&& q, const A& a ) in ConcQWithSizeWrapper() argument
268 : oneapi::tbb::concurrent_queue<T, A>(std::move(q), a) { } in ConcQWithSizeWrapper()
594 …TestNegativeQueueBody( oneapi::tbb::concurrent_bounded_queue<T>& q, std::size_t n ) : queue(q), nt… in TestNegativeQueueBody()
937 oneapi::tbb::concurrent_bounded_queue<int>* q; member in SimplePushBody
940 …SimplePushBody(oneapi::tbb::concurrent_bounded_queue<int>* _q, std::size_t hi_thr) : q(_q), max(hi… in SimplePushBody()
944 while ( q->size() < std::ptrdiff_t(max) ) { in operator ()()
947 q->abort(); in operator ()()
951 q->push(42); in operator ()()
960 oneapi::tbb::concurrent_bounded_queue<int>* q; member in SimplePopBody
965 : q(_q), max(hi_thr), prefill(nitems) {} in SimplePopBody()
970 while (q->size()> prefill - max) { in operator ()()
974 q->abort(); in operator ()()
978 q->pop(e); in operator ()()
1179 CQ q; in TestMoveSupport() local
1183 CHECK(pusher<push_op>::push( q, MoveOperationTracker() )); in TestMoveSupport()
1188 CHECK(pusher<push_op>::push( q, std::move(ob) )); in TestMoveSupport()
1195 bool result = popper<pop_op>::pop( q, ob ); in TestMoveSupport()
1238 void AssertEquality(Queue &q, const std::vector<typename Queue::value_type> &vec) { in AssertEquality() argument
1239 CHECK(q.size() == typename Queue::size_type(vec.size())); in AssertEquality()
1240 CHECK(std::equal(q.unsafe_begin(), q.unsafe_end(), vec.begin())); in AssertEquality()
1244 void AssertEmptiness(Queue &q) { in AssertEmptiness() argument
1245 CHECK(q.empty()); in AssertEmptiness()
1246 CHECK(!q.size()); in AssertEmptiness()
1248 CHECK(!q.try_pop(elem)); in AssertEmptiness()
1252 void FillTest(Queue &q, const std::vector<typename Queue::value_type> &vec) { in FillTest() argument
1254 CHECK(pusher<push_op>::push(q, *it)); in FillTest()
1255 AssertEquality(q, vec); in FillTest()
1259 void EmptyTest(Queue &q, const std::vector<typename Queue::value_type> &vec) { in EmptyTest() argument
1264 while (popper<pop_op>::pop(q, elem)) { in EmptyTest()
1269 AssertEmptiness(q); in EmptyTest()
1276 void bounded_queue_specific_test(oneapi::tbb::concurrent_bounded_queue<T, A> &q, const std::vector<… in bounded_queue_specific_test() argument
1279 FillTest<try_push_op>(q, vec); in bounded_queue_specific_test()
1280 oneapi::tbb::concurrent_bounded_queue<T, A> q2 = q; in bounded_queue_specific_test()
1281 EmptyTest<pop_op>(q, vec); in bounded_queue_specific_test()
1288 q.abort(); in bounded_queue_specific_test()
1465 void TestQueueIteratorComparisonsBasic( QueueType& q ) { in TestQueueIteratorComparisonsBasic() argument
1466 REQUIRE_MESSAGE(!q.empty(), "Incorrect test setup"); in TestQueueIteratorComparisonsBasic()
1470 it1 = q.unsafe_begin(); in TestQueueIteratorComparisonsBasic()
1472 it2 = q.unsafe_begin(); in TestQueueIteratorComparisonsBasic()
1474 it2 = q.unsafe_end(); in TestQueueIteratorComparisonsBasic()
1480 QueueType q; in TestQueueIteratorComparisons() local
1481 q.emplace(1); in TestQueueIteratorComparisons()
1482 q.emplace(2); in TestQueueIteratorComparisons()
1483 q.emplace(3); in TestQueueIteratorComparisons()
1484 TestQueueIteratorComparisonsBasic<typename QueueType::iterator>(q); in TestQueueIteratorComparisons()
1485 const QueueType& cq = q; in TestQueueIteratorComparisons()