Home
last modified time | relevance | path

Searched defs:ctx (Results 1 – 23 of 23) sorted by relevance

/oneTBB/src/tbb/
H A Dtask_group_context.cpp54 void task_group_context_impl::destroy(d1::task_group_context& ctx) { in destroy()
84 void task_group_context_impl::initialize(d1::task_group_context& ctx) { in initialize()
165 void task_group_context_impl::bind_to(d1::task_group_context& ctx, thread_data* td) { in bind_to()
226 bool task_group_context_impl::cancel_group_execution(d1::task_group_context& ctx) { in cancel_group_execution()
244 void task_group_context_impl::reset(d1::task_group_context& ctx) { in reset()
259 void task_group_context_impl::capture_fp_settings(d1::task_group_context& ctx) { in capture_fp_settings()
336 void __TBB_EXPORTED_FUNC initialize(d1::task_group_context& ctx) { in initialize()
339 void __TBB_EXPORTED_FUNC destroy(d1::task_group_context& ctx) { in destroy()
342 void __TBB_EXPORTED_FUNC reset(d1::task_group_context& ctx) { in reset()
345 bool __TBB_EXPORTED_FUNC cancel_group_execution(d1::task_group_context& ctx) { in cancel_group_execution()
[all …]
H A Daddress_waiter.cpp77 auto predicate = [address, target_context] (address_context ctx) { in notify_by_address()
87 auto predicate = [address] (address_context ctx) { in notify_by_address_one()
97 auto predicate = [address] (address_context ctx) { in notify_by_address_all()
H A Dtask_dispatcher.cpp30 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx) { in spawn()
42 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx, d1::slot_id id) { in spawn()
77 void __TBB_EXPORTED_FUNC submit(d1::task& t, d1::task_group_context& ctx, arena* a, std::uintptr_t … in submit()
H A Dthread_control_monitor.h44 resume_node(market_context ctx, execution_data_ext& ed_ext, task_dispatcher& target) in resume_node()
H A Dtask.cpp186 auto is_our_suspend_point = [sp] (market_context ctx) { in do_post_resume_action()
H A Darena.cpp443 void arena::enqueue_task(d1::task& t, d1::task_group_context& ctx, thread_data& td) { in enqueue_task()
533 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_group_context& ctx, d1::task_arena_base* ta)… in enqueue()
606 auto* ctx = c ? c : a->my_default_ctx; in enqueue() local
724 m_monitor.notify([this] (std::uintptr_t ctx) { in finalize()
H A Dthread_data.h245 d1::task_group_context& ctx = __TBB_get_object_ref(d1::task_group_context, my_node, &(*it)); in propagate_task_group_state() local
H A Dconcurrent_monitor.h107 wait_node(Context ctx) : my_context(ctx), my_is_in_list(false) {} in wait_node()
H A Dscheduler_common.h165 void set_ctx(const d1::task_group_context* ctx) { in set_ctx()
/oneTBB/test/conformance/
H A Dconformance_task_group_context.cpp29 oneapi::tbb::task_group_context ctx; variable
33 oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::bound }; variable
37 oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::isolated variable
46 …oneapi::tbb::task_group_context ctx{ oneapi::tbb::task_group_context::bound, oneapi::tbb::task_gro… variable
/oneTBB/include/oneapi/tbb/detail/
H A D_task_handle.h49 …task_handle_task(d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocator& al… in task_handle_task()
60 d1::task_group_context& ctx() const { return m_ctx; } in ctx() function
H A D_task.h180 inline void spawn(task& t, task_group_context& ctx) { in spawn()
185 inline void spawn(task& t, task_group_context& ctx, slot_id id) { in spawn()
196 inline void wait(wait_context& wait_ctx, task_group_context& ctx) { in wait()
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h100 …function_task(FF&& f, d1::wait_context& wo, d1::task_group_context& ctx, d1::small_object_allocato… in function_task()
403 const task_group_context& ctx = actual_context(); in traits() local
557 task_group_base(task_group_context& ctx) in task_group_base()
599 task_group(task_group_context& ctx) : task_group_base(ctx) {} in task_group()
640 spawn_delegate(task* a_task, task_group_context& ctx) in spawn_delegate()
677 isolated_task_group(task_group_context& ctx) : task_group(ctx) {} in isolated_task_group()
715 task_group_context* ctx = current_context(); in is_current_task_group_canceling() local
H A Dtask_arena.h104 auto& ctx = task_handle_accessor::ctx_of(th); in enqueue_impl() local
435 friend void submit(task& t, task_arena& ta, task_group_context& ctx, bool as_critical) { in submit()
H A Dpartitioner.h498 void spawn_task(task& t, task_group_context& ctx) { in spawn_task()
515 void spawn_task(task& t, task_group_context& ctx) { in spawn_task()
551 void spawn_task(task& t, task_group_context& ctx) { in spawn_task()
/oneTBB/test/tbb/
H A Dtest_eh_algorithms.cpp50 tbb::task_group_context* ctx = tbb::task::current_context(); in increment() local
282 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()() local
338 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()() local
506 ParForLauncher ( tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParForLauncher()
895 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()() local
945 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()() local
1170 ParForEachWorker ( tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParForEachWorker()
1181 tbb::task_group_context ctx; in TestCancelation1_parallel_for_each() local
1359 void run ( tbb::task_group_context& ctx ) { in run()
1438 tbb::task_group_context ctx(tbb::task_group_context::isolated); in operator ()() local
[all …]
H A Dtest_parallel_reduce.cpp158 ParallelReduceRunner( tbb::task_group_context& ctx ) in ParallelReduceRunner()
200 ParallelDeterministicReduceRunner( tbb::task_group_context& ctx ) in ParallelDeterministicReduceRunner()
H A Dtest_resumable_tasks.cpp62 void submit(tbb::task::suspend_point ctx) { in submit()
210 void submit(tbb::task::suspend_point ctx) { in submit()
H A Dtest_parallel_for.cpp258 ParallelForRunner( tbb::task_group_context& ctx ) in ParallelForRunner()
H A Dtest_task_arena.cpp267 tbb::task_group_context ctx; in operator ()() local
775 …( utils::FastRandom<>& rnd, const Body &body, Partitioner& p, tbb::task_group_context* ctx = nullp… in RunTwoBodies()
807 tbb::task_group_context ctx; in RunNextLevel() local
967 tbb::task_group_context ctx; in operator ()() local
994 tbb::task_group_context ctx; in TestEnqueue() local
H A Dtest_scheduler_mix.cpp560 tbb::task_group_context ctx; in do_it() local
H A Dtest_task_group.cpp1197 tbb::task_group_context ctx; in should_fail() local
/oneTBB/test/common/
H A Dexception_handling.h305 tbb::task_group_context ctx; variable