| /oneTBB/test/tbb/ |
| H A D | test_concurrent_hash_map.cpp | 202 CHECK(!c.empty()); in Examine() 236 CHECK(c.size() == 5); in Examine() 248 CHECK(ptr); in Examine() 607 CHECK(result); in test_with_minimalistic_mutex() 613 CHECK(result); in test_with_minimalistic_mutex() 707 CHECK(result); in test_chmap_access_mode() 712 CHECK(result); in test_chmap_access_mode() 718 CHECK(result); in test_chmap_access_mode() 723 CHECK(result); in test_chmap_access_mode() 728 CHECK(result); in test_chmap_access_mode() [all …]
|
| H A D | test_concurrent_queue.cpp | 38 CHECK(T(k) < T(nthread)); in operator ()() 44 CHECK(item <= T(nthread)); in operator ()() 88 CHECK((ci != q2.unsafe_end())); in TestVectorTypes() 91 CHECK((*ci == bar)); in TestVectorTypes() 98 CHECK((b == (i < 100))); in TestVectorTypes() 100 CHECK((!b || tmp==bar)); in TestVectorTypes() 215 CHECK(res); in TrackableItem() 220 CHECK(it != object_addresses.end()); in ~TrackableItem() 222 CHECK(object_addresses.count(this) == 0); in ~TrackableItem() 236 CHECK(exception == 1); in fill_and_catch() [all …]
|
| H A D | test_parallel_scan.cpp | 92 CHECK(ScanIsRunning); in JoinStorages() 96 CHECK(ScanIsRunning); in JoinStorages() 175 CHECK(a.my_state == full); in Accumulator() 178 CHECK(ScanIsRunning); in Accumulator() 185 CHECK(my_state == full); in operator ()() 187 CHECK(my_state == partial); in operator ()() 194 CHECK(my_state == partial); in reverse_join() 203 CHECK(other.my_state == full); in assign() 204 CHECK(my_state == full); in assign() 207 CHECK(self == this); in assign() [all …]
|
| H A D | test_resumable_tasks.cpp | 60 CHECK(m_tagQueue.empty()); in ~AsyncActivity() 208 CHECK(m_tagQueue.empty()); in ~EpochAsyncActivity() 279 CHECK(local_epoch < global_epoch); in TestSuspendResume() 280 CHECK(ets_fiber.local() == i); in TestSuspendResume() 292 CHECK(ets_fiber.local() == i); in TestSuspendResume() 296 CHECK(outer_par_iters == N); in TestSuspendResume() 297 CHECK(inner_par_iters == N*N*iter_size); in TestSuspendResume() 326 CHECK(iter_spawned == 460); in TestCleanupMaster() 328 CHECK(iter_executed == 460); in TestCleanupMaster() 415 CHECK(m_local == false); in TestCaseGuard() [all …]
|
| H A D | test_function_node.cpp | 118 CHECK( n == N ); in buffered_levels() 201 CHECK( n == N ); in buffered_levels_with_copy() 211 CHECK( exe_node.try_put( InputType() ) == true ); in buffered_levels_with_copy() 223 CHECK(global_count == expected_count); in buffered_levels_with_copy() 224 CHECK(global_count == inc_count ); in buffered_levels_with_copy() 308 CHECK( n == N ); in concurrency_levels() 314 CHECK( n == num_senders*N+lc ); in concurrency_levels() 321 CHECK( exe_node.try_put( InputType() ) == true ); in concurrency_levels() 324 CHECK( int(receivers[r]->my_count) == 0 ); in concurrency_levels() 394 CHECK( ec == p*N ); in unlimited_concurrency() [all …]
|
| H A D | test_task_arena.cpp | 64 CHECK(arena.is_active()); in InitializeAndTerminate() 73 CHECK(arena.is_active()); in InitializeAndTerminate() 80 CHECK(arena.is_active()); in InitializeAndTerminate() 139 CHECK(myId); in ArenaObserver() 347 CHECK(slot >= 0); in operator ()() 348 CHECK(slot <= 1); in operator ()() 363 CHECK(my_id.str() == e); in on_exception() 385 CHECK(my_stage == 3); in test() 387 CHECK(my_stage == 5); in test() 1759 CHECK(my_ets.local()); in operator ()() [all …]
|
| H A D | test_parallel_pipeline.cpp | 122 CHECK(is_alive()); in operator ()() 138 CHECK(is_alive()); in operator ()() 161 CHECK(is_alive()); in operator ()() 177 CHECK(is_alive()); in operator ()() 192 CHECK(is_alive()); in operator ()() 207 CHECK(is_alive()); in operator ()() 223 CHECK(is_alive()); in operator ()() 239 CHECK(is_alive()); in operator ()() 260 CHECK(is_alive()); in operator ()() 271 CHECK(is_alive()); in operator ()() [all …]
|
| H A D | test_tbb_header_secondary.cpp | 36 #define CHECK(x) do { if (!(x)) { std::terminate(); } } while (false) macro 37 #define CHECK_MESSAGE(x, y) CHECK(x);
|
| H A D | test_concurrent_vector.cpp | 670 CHECK(reduce_vector(vec.range()) == final_sum); 685 CHECK(vec2.empty()); 723 CHECK(v.size() == 382); 727 CHECK(v.size() == 737); 730 CHECK(v.size() == 27); 734 CHECK(v.size() == 737); 737 CHECK(v.size() == 1); 741 CHECK(v.size() == 40); 744 CHECK(v.size() == 2222); 748 CHECK(v.size() == 4444); [all …]
|
| H A D | test_task_group.cpp | 283 CHECK(utils::ConcurrencyTracker::PeakParallelism() <= g_MaxConcurrency); \ 284 CHECK( sum == numRepeats * F ); 560 CHECK(error == 1); in TestExceptionHandling3() 611 CHECK( exception_occurred ); in TestMissingWait() 612 CHECK( !unexpected_exception ); in TestMissingWait() 918 CHECK(tasks_executed < 10000); in __anoneb262a490702() 921 CHECK(tasks_executed == 10000); 945 CHECK(tasks_executed < 10000); in __anoneb262a490802() 948 CHECK(tasks_executed == 10000); in __anoneb262a490802() 978 CHECK(tasks_executed < 10000 + second_thread_executed); in __anoneb262a490802() [all …]
|
| /oneTBB/test/conformance/ |
| H A D | conformance_blocked_range.cpp | 70 CHECK( r.empty()==(y<=x)); in SerialTest() 71 CHECK( r.grainsize()==k); in SerialTest() 74 CHECK( r.is_divisible()==(std::size_t(y-x)>k) ); in SerialTest() 75 CHECK( r.size()==std::size_t(y-x) ); in SerialTest() 78 CHECK( GetValueOf(r.begin())==x ); in SerialTest() 80 CHECK( GetValueOf(r2.end())==y ); in SerialTest() 81 CHECK( r.grainsize()==k ); in SerialTest() 82 CHECK( r2.grainsize()==k ); in SerialTest() 105 if (Array[k] != (k<i)) CHECK(false); in ParallelTest() 138 CHECK(copy.size() == original.size() / 2); [all …]
|
| H A D | conformance_resumable_tasks.cpp | 33 CHECK(!mLocal); 44 CHECK(suspend); 45 CHECK(resume); 54 CHECK(!mLocal); 71 CHECK(suspend == N); 72 CHECK(resume == N);
|
| H A D | conformance_concurrent_queue.cpp | 210 CHECK(i == j); in TestIteratorAssignment() 211 CHECK(!(i != j)); in TestIteratorAssignment() 215 CHECK(k == j); in TestIteratorAssignment() 216 CHECK(!(k != j)); in TestIteratorAssignment() 227 CHECK((&xr == xp)); in TestIteratorTraits() 1196 CHECK(result); in TestMoveSupport() 1245 CHECK(q.empty()); in AssertEmptiness() 1246 CHECK(!q.size()); in AssertEmptiness() 1702 CHECK(q1 != q4); in test_queue_helper() 1704 CHECK(q2 == q4); in test_queue_helper() [all …]
|
| H A D | conformance_task_arena.cpp | 43 CHECK(oneapi::tbb::this_task_arena::max_concurrency() == 2); in __anon3e0b77410102() 49 CHECK(oneapi::tbb::this_task_arena::current_thread_index() >= 0); in __anon3e0b77410202() 52 CHECK(attached_arena.is_active()); in __anon3e0b77410202() 54 CHECK(attached_arena2.is_active()); in __anon3e0b77410202() 144 CHECK(run == true); 165 CHECK(run == true); 194 CHECK(run == true);
|
| H A D | conformance_parallel_reduce.cpp | 145 CHECK(result == oneapi::tbb::parallel_reduce(range, identity, body, reduction).get()); in test_preduce_invoke_basic() 146 …CHECK(result == oneapi::tbb::parallel_reduce(range, identity, body, reduction, oneapi::tbb::simple… in test_preduce_invoke_basic() 147 …CHECK(result == oneapi::tbb::parallel_reduce(range, identity, body, reduction, oneapi::tbb::auto_p… in test_preduce_invoke_basic() 148 …CHECK(result == oneapi::tbb::parallel_reduce(range, identity, body, reduction, oneapi::tbb::static… in test_preduce_invoke_basic() 150 CHECK(result == oneapi::tbb::parallel_reduce(range, identity, body, reduction, aff).get()); in test_preduce_invoke_basic() 152 …CHECK(result == oneapi::tbb::parallel_deterministic_reduce(range, identity, body, reduction).get()… in test_preduce_invoke_basic() 153 …CHECK(result == oneapi::tbb::parallel_deterministic_reduce(range, identity, body, reduction, oneap… in test_preduce_invoke_basic() 154 …CHECK(result == oneapi::tbb::parallel_deterministic_reduce(range, identity, body, reduction, oneap… in test_preduce_invoke_basic()
|
| H A D | conformance_parallel_scan.cpp | 80 CHECK(oneapi::tbb::pre_scan_tag::is_final_scan()==false); 81 CHECK(oneapi::tbb::final_scan_tag::is_final_scan()==true); 82 CHECK((bool)oneapi::tbb::pre_scan_tag()==false); 83 CHECK((bool)oneapi::tbb::final_scan_tag()==true); 102 CHECK((control == output)); 136 CHECK((control==output)); 145 CHECK(desired_vector == result_vector); in test_pscan_invoke() 146 CHECK(result.get() == result_vector.back()); in test_pscan_invoke()
|
| H A D | conformance_concurrent_hash_map.cpp | 249 CHECK(count==n); in CheckTable() 267 CHECK(!(t1 != t2)); in TestCopy() 293 CHECK(i == 1); in TestRehash() 346 CHECK(&xr==xp); in TestIteratorTraits() 352 CHECK(i==j); in TestIteratorAssignment() 353 CHECK(!(i!=j)); in TestIteratorAssignment() 355 CHECK(k==j); in TestIteratorAssignment() 356 CHECK(!(k!=j)); in TestIteratorAssignment() 407 CHECK(t2.erase(key)); in TestIteratorsAndRanges() 411 CHECK(t1 != t2); in TestIteratorsAndRanges() [all …]
|
| H A D | conformance_global_control.cpp | 39 …CHECK(8*MB == oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::thread_stack_… in TestStackSizeSimpleControl() 41 …CHECK(1*MB == oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::thread_stack_… in TestStackSizeSimpleControl() 197 CHECK(default_ss > 0); 200 …CHECK(default_ss == oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::thread_… 225 CHECK(default_toe == 0); 234 …CHECK(oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::terminate_on_exceptio… 237 …CHECK(oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::terminate_on_exceptio… 239 …CHECK(oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::terminate_on_exceptio… 242 …CHECK(oneapi::tbb::global_control::active_value(oneapi::tbb::global_control::terminate_on_exceptio… 369 CHECK(!terminate_handler_called); in __anon3ebcafb90302() [all …]
|
| H A D | conformance_task_group_context.cpp | 49 CHECK(ctx.cancel_group_execution()); 50 CHECK(ctx.is_group_execution_cancelled());
|
| H A D | conformance_parallel_for.cpp | 188 …CHECK(std::find_if_not(Array, Array + i, [](const std::atomic<int>& v) { return v.load(std::memory… in Flog() 189 …CHECK(std::find_if_not(Array + i, Array + N, [](const std::atomic<int>& v) { return v.load(std::me… in Flog() 190 CHECK(FooBodyCount == 1); in Flog() 300 CHECK(change_vector); in increase() 324 CHECK(item == number_of_overloads); in test_pfor_body_invoke() 346 CHECK(item == number_of_overloads); in test_pfor_func_invoke() 356 CHECK(change_vector[0] == number_of_overloads); in test_pfor_func_invoke() 359 CHECK(change_vector[i] == expected); in test_pfor_func_invoke()
|
| H A D | conformance_async_node.cpp | 164 CHECK(buf.try_get(result)); 165 CHECK(result == 1); 166 CHECK(!buf.try_get(result));
|
| H A D | conformance_parallel_for_each.cpp | 133 CHECK(change_vector[i] == 1); in test_pfor_each_invoke_basic() 134 CHECK(change_vector[i + items_count] == 0); in test_pfor_each_invoke_basic() 144 CHECK(item == 1); in test_pfor_each_invoke_basic()
|
| H A D | conformance_sequencer_node.cpp | 181 CHECK(x.id == expected_item); in __anona3025c380602() 197 CHECK(expected_item == objects_count); 211 CHECK(expected_item == objects_count);
|
| H A D | conformance_function_node.cpp | 101 CHECK(buf.try_get(result)); in test_fn_invoke_basic() 102 CHECK(result == 1); in test_fn_invoke_basic() 103 CHECK(!buf.try_get(result)); in test_fn_invoke_basic()
|
| /oneTBB/test/common/ |
| H A D | graph_utils.h | 138 CHECK(c <= max_executors); 191 CHECK( (max_executors == 0 || c <= max_executors) ); 192 CHECK( (std::tuple_size<OutputTuple>::value == 1) ); 287 CHECK( n == num_copies*max_value ); 345 CHECK( n == num_copies ); 349 CHECK( n == num_copies*max_value ); 392 CHECK( s == &r ); 432 CHECK( s->try_put( T(i) ) ); 435 CHECK( my_received == my_limit ); 672 CHECK(end_receiver.my_count == N); [all …]
|