Home
last modified time | relevance | path

Searched refs:status (Results 1 – 25 of 25) sorted by relevance

/oneTBB/include/oneapi/tbb/detail/
H A D_aggregator.h38 std::atomic<uintptr_t> status;
41 aggregated_operation() : status{}, next(nullptr) {} in aggregated_operation()
69 const uintptr_t status = op->status.load(std::memory_order_relaxed); variable
76 call_itt_notify(releasing, &(op->status));
90 __TBB_ASSERT(op->status.load(std::memory_order_relaxed), nullptr);
93 else if (!status) { // operation is blocking here.
95 call_itt_notify(prepare, &(op->status));
96 spin_wait_while_eq(op->status, uintptr_t(0));
H A D_flow_graph_node_impl.h198 tmp->status.store(SUCCEEDED, std::memory_order_release); in handle_operations()
238 op->status.store(SUCCEEDED, std::memory_order_release); in internal_try_put_task()
241 op->status.store(SUCCEEDED, std::memory_order_release); in internal_try_put_task()
244 op->status.store(FAILED, std::memory_order_release); in internal_try_put_task()
254 op->status.store(SUCCEEDED, std::memory_order_release); in internal_forward()
257 op->status.store(FAILED, std::memory_order_release); in internal_forward()
264 if( op_data.status == SUCCEEDED ) { in internal_try_put_bypass()
276 if( check_op.status == SUCCEEDED ) { in try_put_task_impl()
315 op_data.status = WAIT; in forward_task()
317 if(op_data.status == SUCCEEDED) { in forward_task()
[all …]
H A D_flow_graph_join_impl.h319 return op_data.status == SUCCEEDED;
326 return op_data.status == SUCCEEDED;
333 return op_data.status == SUCCEEDED;
481 return op_data.status == SUCCEEDED;
600 if(op_data.status == SUCCEEDED) {
640 return op_data.status == SUCCEEDED;
1002 return op_data.status == SUCCEEDED;
1010 return op_data.status == SUCCEEDED;
1163 return op_data.status == SUCCEEDED;
1169 return op_data.status == SUCCEEDED;
[all …]
H A D_flow_graph_indexer_impl.h148 current->status.store( SUCCEEDED, std::memory_order_release);
153 current->status.store( SUCCEEDED, std::memory_order_release);
157 …current->status.store( SUCCEEDED, std::memory_order_release); // return of try_put_task actual re…
180 return op_data.status == SUCCEEDED;
186 return op_data.status == SUCCEEDED;
/oneTBB/test/common/
H A Dmemory_usage.h93 bool status = GetProcessMemoryInfo(GetCurrentProcess(), &mem, sizeof(mem)) != 0; variable
94 ASSERT(status, nullptr);
118 kern_return_t status; variable
121 …status = task_info(mach_task_self(), TASK_BASIC_INFO, reinterpret_cast<task_info_t>(&info), &msg_t…
122 ASSERT(status == KERN_SUCCESS, nullptr);
H A Dcpu_usertime.h43 …bool status = GetProcessTimes(GetCurrentProcess(), my_times, my_times+1, my_times+2, my_times+3)!=… in GetCPUUserTime()
44 CHECK_FAST(status); in GetCPUUserTime()
60 bool status = getrusage(RUSAGE_SELF, &resources)==0; in GetCPUUserTime()
61 CHECK( status ); in GetCPUUserTime()
H A Dutils_env.h45 int status = _putenv(buf); in SetEnv() local
47 return status; in SetEnv()
/oneTBB/src/tbb/
H A Dgovernor.cpp64 int status = theTLS.create(auto_terminate); in acquire_resources() local
66 int status = theTLS.create(); in acquire_resources()
68 if( status ) in acquire_resources()
69 handle_perror(status, "TBB failed to initialize task scheduler TLS\n"); in acquire_resources()
81 int status = theTLS.destroy(); in release_resources() local
82 if( status ) in release_resources()
83 runtime_warning("failed to destroy task scheduler TLS: %s", std::strerror(status)); in release_resources()
93 ::rml::factory::status_type status = theRMLServerFactory.make_server( server, client ); in create_rml_server()
94 if( status != ::rml::factory::st_success ) { in create_rml_server()
96 …ning( "rml::tbb_factory::make_server failed with status %x, falling back on private rml", status ); in create_rml_server()
H A Dparallel_pipeline.cpp232 int status = end_of_input_tls.create(); in create_my_tls() local
233 if(status) in create_my_tls()
234 handle_perror(status, "TLS not allocated for filter"); in create_my_tls()
238 int status = end_of_input_tls.destroy(); in destroy_my_tls() local
239 if(status) in destroy_my_tls()
240 handle_perror(status, "Failed to destroy filter TLS"); in destroy_my_tls()
/oneTBB/include/oneapi/tbb/
H A Dconcurrent_priority_queue.h176 if (op_data.status == FAILED) in push()
184 if (op_data.status == FAILED) in push()
202 return op_data.status == SUCCEEDED; in try_pop()
268 call_itt_notify(acquired, &(op_list->status)); in handle_operations()
280 tmp->status.store(uintptr_t(SUCCEEDED), std::memory_order_release); in handle_operations()
300 tmp->status.store(uintptr_t(SUCCEEDED), std::memory_order_release); in handle_operations()
304 tmp->status.store(uintptr_t(FAILED), std::memory_order_release); in handle_operations()
316 tmp->status.store(uintptr_t(FAILED), std::memory_order_release); in handle_operations()
325 tmp->status.store(uintptr_t(SUCCEEDED), std::memory_order_release); in handle_operations()
330 tmp->status.store(uintptr_t(SUCCEEDED), std::memory_order_release); in handle_operations()
H A Dflow_graph.h1255 op_data.status = WAIT; in forward_task()
1263 } while (op_data.status ==SUCCEEDED); in forward_task()
1271 op->status.store(SUCCEEDED, std::memory_order_release); in internal_reg_succ()
1278 op->status.store(SUCCEEDED, std::memory_order_release); in internal_rem_succ()
1332 op->status.store(SUCCEEDED, std::memory_order_release); in internal_push()
1358 op->status.store(SUCCEEDED, std::memory_order_release); in internal_consume()
1425 return (op_data.status==SUCCEEDED); in try_get()
1436 return (op_data.status==SUCCEEDED); in try_reserve()
1470 if(ft && op_data.status ==FAILED) { in try_put_task()
1476 else if(!ft && op_data.status ==SUCCEEDED) { in try_put_task()
[all …]
H A Dtask_group.h647 status = tg.wait(); in operator()
652 task_group_status& status; variable
655 : tg(a_group), status(tgs) {} in wait_delegate()
662 status = tg.run_and_wait(func); in operator()
H A Dconcurrent_lru_cache.h120 (prev_op->status).store(1, std::memory_order_release); in handle_operations()
/oneTBB/test/tbbmalloc/
H A Dtest_malloc_shutdown_hang.cpp80 int status; in processSpawn() local
81 waitpid(pid, &status, 0); in processSpawn()
H A Dtest_malloc_overload.cpp373 std::string status, function_name; in FuncReplacementInfoCheck() local
374 s >> status >> function_name; in FuncReplacementInfoCheck()
376 if (status.find("Fail:") != status.npos) { in FuncReplacementInfoCheck()
H A Dtest_malloc_whitebox.cpp1390 int status; variable
1405 status = TBB_malloc_replacement_log(&func_replacement_log); in TestEmptyLog()
1407 REQUIRE_MESSAGE(status == -1, "Status is true, but log is empty"); in TestEmptyLog()
1415 status = TBB_malloc_replacement_log(&func_replacement_log); in TestLogOverload()
1420 REQUIRE_MESSAGE(status == 0, "False status, but all functions found"); in TestLogOverload()
1425 status = TBB_malloc_replacement_log(nullptr); in TestLogOverload()
1426 REQUIRE_MESSAGE(status == -1, "Status is true, but we have false search case"); in TestLogOverload()
1436 status = TBB_malloc_replacement_log(&func_replacement_log); in TestFalseSearchCase()
1439 REQUIRE_MESSAGE(status == -1, "Status is true, but we have false search case"); in TestFalseSearchCase()
1449 status = TBB_malloc_replacement_log(&func_replacement_log); in TestWrongFunctionInDll()
[all …]
/oneTBB/python/rml/
H A Dipc_server.cpp174 int status = setenv(name, sem_name, /*overwrite*/ 1); in set_sem_name() local
175 __TBB_ASSERT_EX(status == 0, nullptr); in set_sem_name()
202 int status = 0; in release_semaphores() local
210 status = sem_unlink( sem_name ); in release_semaphores()
211 if( status!=0 ) { in release_semaphores()
226 status = sem_unlink( sem_name ); in release_semaphores()
227 if( status!=0 ) { in release_semaphores()
/oneTBB/src/tbbmalloc_proxy/
H A Dfunction_replacement.cpp66 static void record(FunctionInfo functionInfo, const char * opcodeString, bool status) { in record() argument
73 replacement_status &= status; in record()
86 status ? "Success" : "Fail", functionInfo.funcName, functionInfo.dllName, opcodeString); in record()
/oneTBB/test/tbb/
H A Dtest_task_group.cpp462 tbb::task_group_status status = tbb::not_complete; in LaunchChildrenWithFunctor() local
465 status = g.wait(); in LaunchChildrenWithFunctor()
472 if (g_Throw && !exceptionCaught && status != tbb::canceled) { in LaunchChildrenWithFunctor()
503 tbb::task_group_status status = tg.wait(); in TestManualCancellationWithFunctor() local
504 CHECK_MESSAGE( status == tbb::canceled, "Task group reported invalid status." ); in TestManualCancellationWithFunctor()
H A Dtest_task_arena.cpp1585 std::atomic<arena_status> status{alive}; member
1638 if (curr_arena->status == arena_handler::alive) { in StressTestMixFunctionality()
1664 … if (curr_arena->status.compare_exchange_strong(curr_status, arena_handler::deleting)) { in StressTestMixFunctionality()
1674 curr_arena->status.store(arena_handler::deleted); in StressTestMixFunctionality()
1746 if (handler.status != arena_handler::deleted) delete handler.arena; in StressTestMixFunctionality()
/oneTBB/examples/parallel_for/tachyon/src/
H A Dvol.cpp313 std::size_t status; in LoadVol() local
331 status = fread(vol->data, 1, (vol->xres * vol->yres * vol->zres), dfile); in LoadVol()
/oneTBB/doc/main/reference/scalable_memory_pools/
H A Dmalloc_replacement_log.rst11 Provides information about the status of dynamic memory allocation replacement.
/oneTBB/src/tbbmalloc/
H A Dfrontend.cpp133 int status = pthread_key_create( &Tid_key, nullptr ); in init()
134 if ( status ) { in init()
145 BOOL status = !(TlsFree( Tid_key )); // fail is zero in destroy() local
147 int status = pthread_key_delete( Tid_key ); in destroy()
149 if ( status ) in destroy()
218 int status = pthread_key_create( &TLS_pointer_key, mallocThreadShutdownNotification ); in init()
219 if ( status ) in init()
H A Dlarge_objects.cpp196 MallocAggregatedOperation<CacheBinOperation>::type::status = st; in CacheBinOperation()
239 op->status.store(CBST_DONE, std::memory_order_release); in commitOperation()
/oneTBB/
H A Dthird-party-programs.txt227 …s to a typical or common use of that class of product, regardless of the status of the particular …