| /oneTBB/test/common/ |
| H A D | initializer_list_support.h | 29 void test_ctor( std::initializer_list<ElementType> init, const ContainerType& expected ) { in test_ctor() argument 31 REQUIRE_MESSAGE(cont == expected, "Initialization via initializer_list failed"); in test_ctor() 41 REQUIRE_MESSAGE(cont == expected, "Assignment from the initializer_list failed"); in test_assignment_operator() 51 static void test( std::initializer_list<ElementType> init, const ContainerType& expected) { in test() 54 … REQUIRE_MESSAGE(cont == expected, "assign method with the initializer list argument failed"); in test() 60 static void test( std::initializer_list<ElementType> init, const ContainerType& expected) { in test() 71 ContainerType expected(test_seq.begin(), test_seq.end()); in test_initializer_list_support() 73 test_ctor(init, expected); in test_initializer_list_support() 74 test_assignment_operator(init, expected); in test_initializer_list_support() 75 TestAssign::test(init, expected); in test_initializer_list_support() [all …]
|
| H A D | exception_handling.h | 149 intptr_t expected = 0; in ThrowTestException() local 150 if ( g_ExceptionsThrown.compare_exchange_strong(expected, 1) ) { in ThrowTestException() 157 intptr_t expected = 0; in ThrowTestException() local 158 if ( g_ExceptionsThrown.compare_exchange_strong(expected, 1) ) { in ThrowTestException() 176 intptr_t expected = 0;\ 177 g_ExecutedAtFirstCatch.compare_exchange_strong(expected , g_CurExecuted); \ 179 expected = g_ExecutedAtLastCatch.load();\ 180 …while (expected < curExecuted) g_ExecutedAtLastCatch.compare_exchange_strong(expected, curExecuted…
|
| H A D | test_join_node_multiple_predecessors.h | 81 buffer_node<continue_msg>& bn3, queue_node_t& qn, bool expected) in run_and_check() argument 91 (qn.try_get(msg) == expected), in run_and_check()
|
| /oneTBB/include/oneapi/tbb/ |
| H A D | collaborative_call_once.h | 145 std::uintptr_t expected = runner_bits; in set_completion_state() local 147 expected = runner_bits; in set_completion_state() 151 spin_wait_until_eq(m_state, expected); in set_completion_state() 152 } while (!m_state.compare_exchange_strong(expected, desired)); in set_completion_state() 157 std::uintptr_t expected = m_state.load(std::memory_order_acquire); in do_collaborative_call_once() local 161 …if (expected == state::uninitialized && m_state.compare_exchange_strong(expected, runner.to_bits()… in do_collaborative_call_once() 179 auto max_value = expected | collaborative_once_references_mask; in do_collaborative_call_once() 180 expected = spin_wait_while_eq(m_state, max_value); in do_collaborative_call_once() 182 … } while (expected > state::done && !m_state.compare_exchange_strong(expected, expected + 1)); in do_collaborative_call_once() 184 …if (auto shared_runner = collaborative_once_runner::from_bits(expected & ~collaborative_once_refer… in do_collaborative_call_once() [all …]
|
| H A D | queuing_mutex.h | 106 scoped_lock* expected = nullptr; in try_acquire() local 110 if (!m.q_tail.compare_exchange_strong(expected, this, std::memory_order_acq_rel)) in try_acquire() 127 scoped_lock* expected = this; in release() local 128 if (m_mutex->q_tail.compare_exchange_strong(expected, nullptr)) { in release()
|
| /oneTBB/src/tbb/ |
| H A D | queuing_rw_mutex.cpp | 51 word expd = reinterpret_cast<word>(expected); in compare_exchange_strong() 110 auto expected = RELEASED; in try_acquire_internal_lock() local 111 return s.my_internal_lock.compare_exchange_strong(expected, ACQUIRED); in try_acquire_internal_lock() 272 d1::queuing_rw_mutex::scoped_lock* expected = nullptr; in try_acquire() local 273 if (!m.q_tail.compare_exchange_strong(expected, &s, std::memory_order_acq_rel)) in try_acquire() 294 d1::queuing_rw_mutex::scoped_lock* expected = &s; in release() local 296 if( s.my_mutex->q_tail.compare_exchange_strong(expected, nullptr, in release() 367 d1::queuing_rw_mutex::scoped_lock* expected = &s; in release() local 388 d1::queuing_rw_mutex::scoped_lock* expected = &s; in release() local 473 d1::queuing_rw_mutex::scoped_lock* expected = &s; in upgrade_to_writer() local [all …]
|
| H A D | arena_slot.h | 299 d1::task** expected = task_pool_ptr; in acquire_task_pool() local 301 task_pool.compare_exchange_strong(expected, LockedTaskPool ) ) { in acquire_task_pool() 337 d1::task** expected = victim_task_pool; in lock_task_pool() local 338 …if (victim_task_pool != LockedTaskPool && task_pool.compare_exchange_strong(expected, LockedTaskPo… in lock_task_pool()
|
| H A D | private_server.cpp | 361 auto expected = my_slack.load(std::memory_order_relaxed); in try_insert_in_asleep_list() local 362 while (expected < 0) { in try_insert_in_asleep_list() 363 if (my_slack.compare_exchange_strong(expected, expected + 1)) { in try_insert_in_asleep_list()
|
| H A D | mailbox.h | 138 atomic_proxy_ptr* expected = &curr->next_in_mailbox; in internal_pop() local 139 if ( my_last.compare_exchange_strong( expected, prev_ptr ) ) { in internal_pop()
|
| H A D | itt_notify.cpp | 40 #error This file is expected to be used for either TBB or TBB allocator build.
|
| /oneTBB/test/conformance/ |
| H A D | conformance_version.cpp | 28 const char* expected = "1.0"; variable 29 REQUIRE_MESSAGE(std::strcmp(expected, ONETBB_SPEC_VERSION) == 0,
|
| H A D | conformance_limiter_node.cpp | 122 int expected[] = {0, 2, 3, 4, 5, 6}; variable 125 CHECK_MESSAGE(actual == expected[m++], "" ); 126 …CHECK_MESSAGE(( sizeof(expected) / sizeof(expected[0]) == m), "Not all messages have been processe…
|
| H A D | conformance_flowgraph.h | 31 constexpr int expected = 5; variable 486 produce_messages<Node, InputType>(testing_node, expected); in test_forwarding() 489 CHECK_MESSAGE(expected == messages_received, "For correct execution of test"); in test_forwarding() 496 CHECK_MESSAGE((values[0] == expected), "Value passed is the actual one received."); in test_forwarding()
|
| /oneTBB/test/tbb/ |
| H A D | test_openmp.cpp | 147 data_type expected[M+N], actual[M+N]; variable 154 CHECK(memcmp(actual, expected, (m + n - 1) * sizeof(data_type)) == 0); in RunTest() 169 SerialConvolve( expected, A, m, B, n );
|
| H A D | test_limiter_node.cpp | 392 int expected[] = {0, 2, 3, 4, 5, 6}; in test_decrementer() local 395 CHECK_MESSAGE( actual == expected[m++], "" ); in test_decrementer() 396 …CHECK_MESSAGE( ( sizeof(expected) / sizeof(expected[0]) == m), "Not all messages have been process… in test_decrementer()
|
| H A D | test_parallel_reduce.cpp | 67 REQUIRE_MESSAGE( result1 == expected, "Wrong parallel summation result" ); in CheckParallelReduce() 77 REQUIRE_MESSAGE( result2 == expected, "Wrong parallel summation result" ); in CheckParallelReduce() 82 static const ValueType count, expected; member in ParallelSumTester 86 const ValueType ParallelSumTester::expected = count * (count + 1) / 2; member in ParallelSumTester
|
| H A D | test_parallel_scan.cpp | 49 int expected = init + TriangularSum(finish_index); in VerifySum() local 50 …CHECK_MESSAGE(expected == sum, "line " << line << ": sum[0.." << finish_index << "] should be = " … in VerifySum()
|
| H A D | test_task.cpp | 428 int expected = 1; in execute() local 429 if (my_resume_flag.compare_exchange_strong(expected, 2)) { in execute() 440 expected = 1; in execute() 441 if (my_resume_flag.compare_exchange_strong(expected, 2)) { in execute()
|
| H A D | test_eh_algorithms.cpp | 561 int expected = 1; // identity for multiplication in Validate() local 563 expected *= reduce_range; in Validate() 564 return expected; in Validate() 613 int expected = w.Validate(0); in TestCancelation3() local 614 REQUIRE_MESSAGE ( result == expected, "Wrong calculation result"); in TestCancelation3()
|
| /oneTBB/examples/test_all/fibonacci/ |
| H A D | README.md | 4 …uilding Blocks. Most of the computations are deliberately silly and not expected to show any speed…
|
| /oneTBB/doc/main/tbb_userguide/Migration_Guide/ |
| H A D | Task_Scheduler_Init.rst | 99 …// No more than two threads is expected; however, tbb::this_task_arena::max_concurrency() can retu… 106 … // No more than two threads is expected; however, tbb::this_task_arena::max_concurrency() is four
|
| /oneTBB/cmake/scripts/ |
| H A D | cmake_gen_github_configs.cmake | 17 # TBBConfig in TBB provided packages are expected to be placed into: <tbb-root>/lib/cmake/tbb*
|
| /oneTBB/cmake/toolchains/ |
| H A D | mips.cmake | 32 # Define return code for this try_run as 0 since threads are expected to be available on target mac…
|
| /oneTBB/doc/main/tbb_userguide/ |
| H A D | avoiding_data_races.rst | 54 is a bit smaller than the expected solution due to the data race. The
|
| /oneTBB/ |
| H A D | Bazel.md | 77 The expected output of this program is the current version of oneTBB.
|