| /oneTBB/test/tbb/ |
| H A D | test_queue_node.cpp | 256 tbb::flow::queue_node<T> q3(g); in test_parallel() local
305 tbb::flow::make_edge( q2, q3 ); in test_parallel()
310 utils::NativeParallelFor( num_threads, parallel_gets<T>(q3, t3) ); in test_parallel()
320 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_parallel()
425 tbb::flow::queue_node<T> q3(g); in test_serial() local
427 tbb::flow::make_edge( q2, q3 ); in test_serial()
436 spin_try_get( q3, j ); in test_serial()
445 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_serial()
454 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_serial()
491 queue_node q3(q0); in test_deduction_guides() local
[all …]
|
| H A D | test_priority_queue_node.cpp | 171 tbb::flow::priority_queue_node<T> q3(g); in test_parallel() local
200 tbb::flow::make_edge( q2, q3 ); in test_parallel()
203 NativeParallelFor( num_threads, parallel_gets<T>(q3) ); in test_parallel()
210 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_parallel()
304 tbb::flow::priority_queue_node<T> q3(g); in test_serial() local
306 tbb::flow::make_edge( q2, q3 ); in test_serial()
313 spin_try_get( q3, j ); in test_serial()
322 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_serial()
331 CHECK_MESSAGE( q3.try_get( j ) == false, "" ); in test_serial()
|
| H A D | test_indexer_node.cpp | 366 tbb::flow::queue_node< q3_input_type > q3(g); in test_one_serial() local
369 tbb::flow::make_edge(my_indexer, q3); in test_one_serial()
379 CHECK_MESSAGE( (q3.try_get( v )), "Error in try_get()"); in test_one_serial()
384 CHECK_MESSAGE( (!q3.try_get( v )), "extra values in output queue"); in test_one_serial()
393 CHECK_MESSAGE( (q3.try_get( v )), "Error in try_get()"); in test_one_serial()
398 CHECK_MESSAGE( (!q3.try_get( v )), "extra values in output queue"); in test_one_serial()
|
| H A D | test_split_node.cpp | 275 tbb::flow::queue_node< q3_input_type > q3(g); in test_one_serial() local
277 tbb::flow::make_edge( q3, my_split ); in test_one_serial()
|
| H A D | test_join_node.h | 1318 tbb::flow::queue_node< q3_input_type > q3(g);
1320 tbb::flow::make_edge(my_join, q3);
1333 CHECK_MESSAGE( (q3.try_get(v)), "Error in try_get()");
1352 tbb::flow::remove_edge(my_join, q3);
1355 tbb::flow::make_edge(limiter, q3);
1364 CHECK_MESSAGE( (q3.try_get(v)), "Error in try_get()");
|
| /oneTBB/test/common/ |
| H A D | concurrent_priority_queue_common.h | 118 queue_type q3; in type_tester() local
119 q3 = {vec[0], vec[1], vec[2]}; in type_tester()
121 q3.push(*it); in type_tester()
122 examine(q3, vec_sorted); in type_tester()
227 queue_type q3(std::move(q1)); in type_tester_unique_ptr()
228 examine</*HasCopyCtor=*/false>(q3, q3_copy, vec_sorted); in type_tester_unique_ptr()
|
| /oneTBB/test/conformance/ |
| H A D | conformance_concurrent_priority_queue.cpp | 365 oneapi::tbb::concurrent_priority_queue<ForwardInEmplaceTester> q3; in test_move_support_in_push_pop() local
367 q3.emplace(ForwardInEmplaceTester{5}, 2); in test_move_support_in_push_pop()
370 q3.try_pop(obj); in test_move_support_in_push_pop()
374 REQUIRE_MESSAGE(!q3.try_pop(obj), "The queue should be empty"); in test_move_support_in_push_pop()
|
| H A D | conformance_concurrent_queue.cpp | 1447 TQueue q3(q1); in TestDeductionGuides() local
1448 static_assert(std::is_same<decltype(q3), decltype(q1)>::value); in TestDeductionGuides()
1694 CQ q1, q2, q3; in test_queue_helper() local
1695 q3 = {vec_4, vec_2, vec_3}; in test_queue_helper()
1698 q1 = q3; in test_queue_helper()
1699 q2 = std::move(q3); in test_queue_helper()
1700 CHECK(q3.empty()); in test_queue_helper()
1706 swap(q2, q3); in test_queue_helper()
1708 CHECK(q3 == q4); in test_queue_helper()
|