Lines Matching refs:task_group_context
54 void task_group_context_impl::destroy(d1::task_group_context& ctx) { in destroy()
58 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) == d1::task_group_context::state::bound,… in destroy()
81 ctx.my_state.store(d1::task_group_context::state::dead, std::memory_order_release); in destroy()
84 void task_group_context_impl::initialize(d1::task_group_context& ctx) { in initialize()
93 ctx.my_state.store(d1::task_group_context::state::created, std::memory_order_relaxed); in initialize()
105 void task_group_context_impl::register_with(d1::task_group_context& ctx, thread_data* td) { in register_with()
113 void task_group_context_impl::bind_to_impl(d1::task_group_context& ctx, thread_data* td) { in bind_to_impl()
115 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) == d1::task_group_context::state::locked… in bind_to_impl()
126 …arent->my_may_have_children.load(std::memory_order_relaxed) != d1::task_group_context::may_have_ch… in bind_to_impl()
127 …ctx.my_parent->my_may_have_children.store(d1::task_group_context::may_have_children, std::memory_o… in bind_to_impl()
165 void task_group_context_impl::bind_to(d1::task_group_context& ctx, thread_data* td) { in bind_to()
166 d1::task_group_context::state state = ctx.my_state.load(std::memory_order_acquire); in bind_to()
167 if (state <= d1::task_group_context::state::locked) { in bind_to()
168 if (state == d1::task_group_context::state::created && in bind_to()
170 …((std::atomic<typename std::underlying_type<d1::task_group_context::state>::type>&)ctx.my_state).c… in bind_to()
171 (typename std::underlying_type<d1::task_group_context::state>::type&)state, in bind_to()
172 …(typename std::underlying_type<d1::task_group_context::state>::type)d1::task_group_context::state:… in bind_to()
174 ctx.my_state.compare_exchange_strong(state, d1::task_group_context::state::locked) in bind_to()
181 d1::task_group_context::state release_state{}; in bind_to()
186 release_state = d1::task_group_context::state::isolated; in bind_to()
189 release_state = d1::task_group_context::state::bound; in bind_to()
194 spin_wait_while_eq(ctx.my_state, d1::task_group_context::state::locked); in bind_to()
196 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) != d1::task_group_context::state::create… in bind_to()
197 …__TBB_ASSERT(ctx.my_state.load(std::memory_order_relaxed) != d1::task_group_context::state::locked… in bind_to()
200 …ask_group_state(d1::task_group_context& ctx, std::atomic<std::uint32_t> d1::task_group_context::* … in propagate_task_group_state()
216 …for (d1::task_group_context* ancestor = ctx.my_parent; ancestor != nullptr; ancestor = ancestor->m… in propagate_task_group_state()
218 for (d1::task_group_context* c = &ctx; c != ancestor; c = c->my_parent) in propagate_task_group_state()
226 bool task_group_context_impl::cancel_group_execution(d1::task_group_context& ctx) { in cancel_group_execution()
235 …)->my_arena->my_threading_control->propagate_task_group_state(&d1::task_group_context::my_cancella… in cancel_group_execution()
239 bool task_group_context_impl::is_group_execution_cancelled(const d1::task_group_context& ctx) { in is_group_execution_cancelled()
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()
272 …oid task_group_context_impl::copy_fp_settings(d1::task_group_context& ctx, const d1::task_group_co… in copy_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()
348 bool __TBB_EXPORTED_FUNC is_group_execution_cancelled(d1::task_group_context& ctx) { in is_group_execution_cancelled()
351 void __TBB_EXPORTED_FUNC capture_fp_settings(d1::task_group_context& ctx) { in capture_fp_settings()