Home
last modified time | relevance | path

Searched refs:my_context (Results 1 – 9 of 9) sorted by relevance

/oneTBB/src/tbb/
H A Dco_context.h89 coroutine_type() : my_context(), my_stack(), my_stack_size() {}
90 ucontext_t my_context;
324 err = getcontext(&c.my_context); in create_coroutine()
327 c.my_context.uc_link = nullptr; in create_coroutine()
329 c.my_context.uc_stack.ss_sp = (char*)c.my_stack; in create_coroutine()
330 c.my_context.uc_stack.ss_size = c.my_stack_size; in create_coroutine()
331 c.my_context.uc_stack.ss_flags = 0; in create_coroutine()
340 makecontext(&c.my_context, (coroutine_func_t)co_local_wait_for_all, 2, hi, lo); in create_coroutine()
344 int err = getcontext(&c.my_context); in current_coroutine()
349 int err = swapcontext(&prev_coroutine.my_context, &new_coroutine.my_context); in swap_coroutine()
H A Daddress_waiter.cpp32 my_address(address), my_context(context) in address_context()
36 std::uintptr_t my_context{0}; member
78 return ctx.my_address == address && ctx.my_context == target_context; in notify_by_address()
H A Dconcurrent_monitor.h107 wait_node(Context ctx) : my_context(ctx), my_is_in_list(false) {} in wait_node()
109 wait_node(Context ctx) : my_context(ctx) {}
132 Context my_context{};
371 if (predicate(node->my_context)) { in notify_relaxed()
406 if (predicate(node->my_context)) { in notify_one_relaxed()
H A Dparallel_pipeline.cpp42 my_context(cxt), in pipeline()
73 task_group_context& my_context; member in tbb::detail::r1::pipeline
285 … r1::spawn( *alloc.new_object<stage_task>(ed, my_pipeline, alloc ), my_pipeline.my_context ); in try_spawn_stage_task()
345 r1::spawn(*clone, my_pipeline.my_context); in spawn_stage_task()
/oneTBB/include/oneapi/tbb/detail/
H A D_flow_graph_impl.h284 wait(my_wait_context, *my_context); in wait_for_all()
286 cancelled = my_context->is_group_execution_cancelled(); in wait_for_all()
288 my_context->reset(); in wait_for_all()
295 if (!(my_context->traits() & task_group_context::concurrent_wait)) { in wait_for_all()
296 my_context->reset(); // consistent with behavior in catch() in wait_for_all()
336 task_group_context *my_context; variable
439 submit( *critical_task, *g.my_task_arena, *g.my_context, /*as_critical=*/true ); in prioritize_task()
451 submit( *gt, *g.my_task_arena, *g.my_context in spawn_in_graph_arena()
468 submit( *gt, *g.my_task_arena, *g.my_context, /*as_critical=*/false); in enqueue_in_graph_arena()
/oneTBB/include/oneapi/tbb/
H A Dparallel_sort.h187 task_group_context my_context(PARALLEL_SORT); in parallel_quick_sort()
201 quick_sort_pretest_body<RandomAccessIterator, Compare>(comp, my_context), in parallel_quick_sort()
203 my_context); in parallel_quick_sort()
205 if( my_context.is_group_execution_cancelled() ) in parallel_quick_sort()
H A Dflow_graph.h432 …my_context = new (r1::cache_aligned_allocate(sizeof(task_group_context))) task_group_context(FLOW_… in graph()
438 …my_wait_context(0), my_context(&use_this_context), my_nodes(nullptr), my_nodes_last(nullptr), my_t… in graph()
450 my_context->~task_group_context(); in ~graph()
451 r1::cache_aligned_deallocate(my_context); in ~graph()
493 my_context->reset(); in reset()
508 my_context->cancel_group_execution(); in cancel()
/oneTBB/test/tbb/
H A Dtest_task_arena.cpp1077 …ze ), my_num_tasks(num_tasks), my_waiters( waiters ), my_processed( processed ), my_context(tgc) {} in TestMultipleWaitsArenaWait()
1082 tbb::detail::d1::wait(*my_waiters[my_idx], my_context); in operator ()()
1095 tbb::task_group_context& my_context; member in TestMultipleWaitsArenaWait
1102 …s( num_tasks ), my_arena( a ), my_waiters( waiters ), my_processed( processed ), my_context(tgc) {} in TestMultipleWaitsThreadBody()
1104 …MultipleWaitsArenaWait( idx, my_bunch_size, my_num_tasks, my_waiters, my_processed, my_context ) ); in operator ()()
1113 tbb::task_group_context& my_context; member in TestMultipleWaitsThreadBody
H A Dtest_flow_graph_whitebox.cpp333 g.my_context->cancel_group_execution(); in TestFunctionNode()
596 g.my_context->cancel_group_execution(); in TestMultifunctionNode()