Home
last modified time | relevance | path

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

12

/oneTBB/src/tbb/
H A Dtask_group_context.cpp60 ctx.my_context_list->remove(ctx.my_node); in destroy()
74 poison_pointer(ctx.my_parent); in destroy()
85 ITT_TASK_GROUP(&ctx, ctx.my_name, nullptr); in initialize()
87 ctx.my_node.my_next_node = &ctx.my_node; in initialize()
88 ctx.my_node.my_prev_node = &ctx.my_node; in initialize()
89 ctx.my_cpu_ctl_env = 0; in initialize()
94 ctx.my_parent = nullptr; in initialize()
97 ctx.my_itt_caller = nullptr; in initialize()
110 ctx.my_context_list->push_front(ctx.my_node); in register_with()
123 copy_fp_settings(ctx, *ctx.my_parent); in bind_to_impl()
[all …]
H A Daddress_waiter.cpp77 auto predicate = [address, target_context] (address_context ctx) { in notify_by_address() argument
78 return ctx.my_address == address && ctx.my_context == target_context; in notify_by_address()
87 auto predicate = [address] (address_context ctx) { in notify_by_address_one() argument
88 return ctx.my_address == address; in notify_by_address_one()
97 auto predicate = [address] (address_context ctx) { in notify_by_address_all() argument
98 return ctx.my_address == address; 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() argument
32 task_group_context_impl::bind_to(ctx, tls); in spawn()
36 task_accessor::context(t) = &ctx; in spawn()
42 void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx, d1::slot_id id) { in spawn() argument
44 task_group_context_impl::bind_to(ctx, tls); in spawn()
50 task_accessor::context(t) = &ctx; in spawn()
77 void __TBB_EXPORTED_FUNC submit(d1::task& t, d1::task_group_context& ctx, arena* a, std::uintptr_t … in submit() argument
83 task_group_context_impl::bind_to(ctx, &tls); in submit()
84 task_accessor::context(t) = &ctx; in submit()
H A Dscheduler_common.h165 void set_ctx(const d1::task_group_context* ctx) { in set_ctx() argument
166 if (!ctx) in set_ctx()
168 const d1::cpu_ctl_env* ctl = reinterpret_cast<const d1::cpu_ctl_env*>(&ctx->my_cpu_ctl_env); in set_ctx()
174 if (report_tasks && ctx != curr_ctx) { in set_ctx()
181 ITT_TASK_BEGIN(ctx, ctx->my_name, nullptr); in set_ctx()
182 curr_ctx = ctx; in set_ctx()
585 static void copy_fp_settings(d1::task_group_context& ctx, const d1::task_group_context& src);
H A Dthread_control_monitor.h44 resume_node(market_context ctx, execution_data_ext& ed_ext, task_dispatcher& target) in resume_node() argument
45 : base_type(ctx), my_curr_dispatcher(ed_ext.task_disp), my_target_dispatcher(&target) in resume_node()
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
246 if ((ctx.*mptr_state).load(std::memory_order_relaxed) != new_state) in propagate_task_group_state()
247 task_group_context_impl::propagate_task_group_state(ctx, mptr_state, src, new_state); in propagate_task_group_state()
H A Darena.cpp443 void arena::enqueue_task(d1::task& t, d1::task_group_context& ctx, thread_data& td) { in enqueue_task() argument
444 task_group_context_impl::bind_to(ctx, &td); in enqueue_task()
445 task_accessor::context(t) = &ctx; in enqueue_task()
533 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_group_context& ctx, d1::task_arena_base* ta)… in enqueue() argument
534 task_arena_impl::enqueue(t, &ctx, ta); in enqueue()
606 auto* ctx = c ? c : a->my_default_ctx; in enqueue() local
607 assert_pointer_valid(ctx, "context pointer should not be null"); in enqueue()
611 a->enqueue_task(t, *ctx, *td); in enqueue()
724 m_monitor.notify([this] (std::uintptr_t ctx) { in finalize() argument
725 return ctx == std::uintptr_t(&m_delegate); in finalize()
H A Dconcurrent_monitor.h107 wait_node(Context ctx) : my_context(ctx), my_is_in_list(false) {} in wait_node() argument
109 wait_node(Context ctx) : my_context(ctx) {}
H A Dtask.cpp186 auto is_our_suspend_point = [sp] (market_context ctx) { in do_post_resume_action() argument
187 return std::uintptr_t(sp) == ctx.my_uniq_addr; in do_post_resume_action()
/oneTBB/test/conformance/
H A Dconformance_task_group_context.cpp29 oneapi::tbb::task_group_context ctx; variable
30 utils::suppress_unused_warning(ctx);
34 utils::suppress_unused_warning(ctx);
39 utils::suppress_unused_warning(ctx);
47 ctx.capture_fp_settings();
48 CHECK_FALSE(ctx.is_group_execution_cancelled());
49 CHECK(ctx.cancel_group_execution());
50 CHECK(ctx.is_group_execution_cancelled());
51 ctx.reset();
52 CHECK_FALSE(ctx.is_group_execution_cancelled());
[all …]
H A Dconformance_parallel_invoke.cpp188 ParInvokeLauncher ( oneapi::tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParInvokeLauncher()
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h50 TBB_EXPORT void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx);
51 TBB_EXPORT void __TBB_EXPORTED_FUNC spawn(d1::task& t, d1::task_group_context& ctx, d1::slot_id id);
53 TBB_EXPORT void __TBB_EXPORTED_FUNC wait(d1::wait_context&, d1::task_group_context& ctx);
180 inline void spawn(task& t, task_group_context& ctx) { in spawn() argument
182 r1::spawn(t, ctx); in spawn()
185 inline void spawn(task& t, task_group_context& ctx, slot_id id) { in spawn() argument
187 r1::spawn(t, ctx, id); in spawn()
196 inline void wait(wait_context& wait_ctx, task_group_context& ctx) { in wait() argument
197 r1::wait(wait_ctx, ctx); in wait()
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() argument
51 , m_ctx(ctx) in task_handle_task()
60 d1::task_group_context& ctx() const { return m_ctx; } in ctx() function
99 return th.m_handle->ctx(); in ctx_of()
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h101 : task_handle_task{wo, ctx, alloc}, in function_task()
403 const task_group_context& ctx = actual_context(); in traits() local
404 t |= ctx.my_traits.fp_settings ? fp_settings : 0; in traits()
557 task_group_base(task_group_context& ctx) in task_group_base() argument
559 , m_context(&ctx) in task_group_base()
599 task_group(task_group_context& ctx) : task_group_base(ctx) {} in task_group() argument
640 spawn_delegate(task* a_task, task_group_context& ctx) in spawn_delegate() argument
641 : task_to_spawn(a_task), context(ctx) in spawn_delegate()
677 isolated_task_group(task_group_context& ctx) : task_group(ctx) {} in isolated_task_group() argument
715 task_group_context* ctx = current_context(); in is_current_task_group_canceling() local
[all …]
H A Dpartitioner.h372 void spawn_task(task& t, task_group_context& ctx) { in spawn_task()
374 spawn(t, ctx, slot_id(my_head)); in spawn_task()
376 spawn(t, ctx); in spawn_task()
498 void spawn_task(task& t, task_group_context& ctx) { in spawn_task() argument
499 spawn(t, ctx); in spawn_task()
515 void spawn_task(task& t, task_group_context& ctx) { in spawn_task() argument
516 spawn(t, ctx); in spawn_task()
551 void spawn_task(task& t, task_group_context& ctx) { in spawn_task() argument
555 spawn(t, ctx, slot_id(my_head / factor)); in spawn_task()
557 spawn(t, ctx, my_array[my_head]); in spawn_task()
[all …]
H A Dtask_arena.h104 auto& ctx = task_handle_accessor::ctx_of(th); in enqueue_impl() local
107 r1::enqueue(*task_handle_accessor::release(th), ctx, ta); in enqueue_impl()
435 friend void submit(task& t, task_arena& ta, task_group_context& ctx, bool as_critical) { in submit() argument
438 r1::submit(t, ctx, ta.my_arena.load(std::memory_order_relaxed), as_critical ? 1 : 0); in submit()
/oneTBB/test/tbb/
H A Dtest_eh_algorithms.cpp51 REQUIRE(ctx != nullptr); in increment()
52 context_map[ctx]++; in increment()
506 ParForLauncher ( tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParForLauncher() argument
526 Cancellator2 ( tbb::task_group_context& ctx, intptr_t ) : m_GroupToCancel(ctx) {} in Cancellator2() argument
1170 ParForEachWorker ( tbb::task_group_context& ctx ) : my_ctx(ctx) {} in ParForEachWorker() argument
1181 tbb::task_group_context ctx; in TestCancelation1_parallel_for_each() local
1182 Cancellator cancellator(ctx, threshold); in TestCancelation1_parallel_for_each()
1365 ctx in run()
1441 testPipeline.run(ctx); in operator ()()
1515 testPipeline.run(ctx); in operator ()()
[all …]
H A Dtest_parallel_for_each.cpp214 …l_for_each_with_iterator = requires( Iterator it, const Body& body, tbb::task_group_context ctx ) {
216 tbb::parallel_for_each(it, it, body, ctx);
222 … const Body& body, tbb::task_group_context ctx ) {
224 tbb::parallel_for_each(cbs, body, ctx);
226 tbb::parallel_for_each(const_cbs, body, ctx);
H A Dtest_resumable_tasks.cpp62 void submit(tbb::task::suspend_point ctx) { in submit() argument
64 m_tagQueue.push(ctx); in submit()
210 void submit(tbb::task::suspend_point ctx) { in submit() argument
212 m_tagQueue.push(ctx); in submit()
247 void operator()(tbb::task::suspend_point ctx) { in operator ()()
249 m_asyncActivity.submit(ctx); in operator ()()
H A Dtest_task_arena.cpp267 tbb::task_group_context ctx; in operator ()() local
268 tbb::detail::d1::wait(myWait, ctx); in operator ()()
775 …ls::FastRandom<>& rnd, const Body &body, Partitioner& p, tbb::task_group_context* ctx = nullptr ) { in RunTwoBodies() argument
777 if (ctx ) in RunTwoBodies()
778 tbb::parallel_for( 0, 2, body, p, *ctx ); in RunTwoBodies()
807 tbb::task_group_context ctx; in RunNextLevel() local
808 … RunTwoBodies( rnd, HeavyMixTestBody(myRandom, myIsolatedLevel, myNestedLevel + 1), p, &ctx ); in RunNextLevel()
967 tbb::task_group_context ctx; in operator ()() local
971 tbb::detail::d1::execute_and_wait(root, ctx, waiter, ctx); in operator ()()
994 tbb::task_group_context ctx; in TestEnqueue() local
[all …]
H A Dtest_parallel_reduce.cpp158 ParallelReduceRunner( tbb::task_group_context& ctx ) in ParallelReduceRunner() argument
159 : my_ctx(ctx) {} in ParallelReduceRunner()
200 ParallelDeterministicReduceRunner( tbb::task_group_context& ctx ) in ParallelDeterministicReduceRunner() argument
201 : my_ctx(ctx) {} in ParallelDeterministicReduceRunner()
H A Dtest_parallel_for.cpp258 ParallelForRunner( tbb::task_group_context& ctx ) in ParallelForRunner() argument
259 : my_ctx(ctx) {} in ParallelForRunner()
H A Dtest_scheduler_mix.cpp560 tbb::task_group_context ctx; in do_it() local
562 tbb::detail::d1::wait(wctx, ctx); in do_it()
/oneTBB/test/common/
H A Dexception_handling.h280 Cancellator( tbb::task_group_context& ctx, intptr_t threshold ) in Cancellator()
281 : m_groupToCancel(ctx), m_cancellationThreshold(threshold) in Cancellator()
305 tbb::task_group_context ctx; variable
308 CancellatorT cancellator(ctx, threshold);
309 LauncherT launcher(ctx);
/oneTBB/doc/main/tbb_userguide/
H A DFloating_Point_Settings.rst18 task_group_context ctx( task_group_context::isolated,
26 task_group_context ctx;
27 ctx.capture_fp_settings();

12