Lines Matching refs:d1

40 …numa_binding_observer( d1::task_arena* ta, int num_slots, int numa_id, core_type_id core_type, int…  in numa_binding_observer()
58 numa_binding_observer* construct_binding_observer( d1::task_arena* ta, int num_slots, int numa_id, … in construct_binding_observer()
218 d1::task* t = tls.my_task_dispatcher->local_wait_for_all(nullptr, waiter); in process()
265 my_default_ctx = new (cache_aligned_allocate(sizeof(d1::task_group_context))) in arena()
266d1::task_group_context{ d1::task_group_context::isolated, d1::task_group_context::fp_settings }; in arena()
443 void arena::enqueue_task(d1::task& t, d1::task_group_context& ctx, thread_data& td) { in enqueue_task()
451 …ned num_slots, unsigned num_reserved_slots, unsigned arena_priority_level, d1::constraints constra… in create()
488 return d1::num_priority_levels - unsigned(int(a_priority) / d1::priority_stride); in arena_priority_level()
493 (d1::num_priority_levels - priority_level) * d1::priority_stride in arena_priority()
500 static void initialize(d1::task_arena_base&);
501 static void terminate(d1::task_arena_base&);
502 static bool attach(d1::task_arena_base&);
503 static void execute(d1::task_arena_base&, d1::delegate_base&);
504 static void wait(d1::task_arena_base&);
505 static int max_concurrency(const d1::task_arena_base*);
506 static void enqueue(d1::task&, d1::task_group_context*, d1::task_arena_base*);
509 void __TBB_EXPORTED_FUNC initialize(d1::task_arena_base& ta) { in initialize()
512 void __TBB_EXPORTED_FUNC terminate(d1::task_arena_base& ta) { in terminate()
515 bool __TBB_EXPORTED_FUNC attach(d1::task_arena_base& ta) { in attach()
518 void __TBB_EXPORTED_FUNC execute(d1::task_arena_base& ta, d1::delegate_base& d) { in execute()
521 void __TBB_EXPORTED_FUNC wait(d1::task_arena_base& ta) { in wait()
525 int __TBB_EXPORTED_FUNC max_concurrency(const d1::task_arena_base* ta) { in max_concurrency()
529 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_arena_base* ta) { in enqueue()
533 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_group_context& ctx, d1::task_arena_base* ta)… in enqueue()
537 void task_arena_impl::initialize(d1::task_arena_base& ta) { in initialize()
540 d1::constraints arena_constraints; in initialize()
543 arena_constraints = d1::constraints{} in initialize()
565 …static_cast<d1::task_arena*>(&ta), a.my_num_slots, ta.my_numa_id, ta.core_type(), ta.max_threads_p… in initialize()
569 void task_arena_impl::terminate(d1::task_arena_base& ta) { in terminate()
577 bool task_arena_impl::attach(d1::task_arena_base& ta) { in attach()
598 void task_arena_impl::enqueue(d1::task& t, d1::task_group_context* c, d1::task_arena_base* ta) { in enqueue()
650 ed_ext.affinity_slot = d1::no_slot; in nested_arena_context()
694 class delegated_task : public d1::task {
695 d1::delegate_base& m_delegate;
697 d1::wait_context& m_wait_ctx;
699 d1::task* execute(d1::execution_data& ed) override { in execute()
718 d1::task* cancel(d1::execution_data&) override { in cancel()
730 delegated_task(d1::delegate_base& d, concurrent_monitor& s, d1::wait_context& wo) in delegated_task()
740 void task_arena_impl::execute(d1::task_arena_base& ta, d1::delegate_base& d) { in execute()
751 d1::wait_context wo(1); in execute()
752 d1::task_group_context exec_context(d1::task_group_context::isolated); in execute()
806 void task_arena_impl::wait(d1::task_arena_base& ta) { in wait()
819 int task_arena_impl::max_concurrency(const d1::task_arena_base *ta) { in max_concurrency()
841 d1::constraints arena_constraints = d1::constraints{} in max_concurrency()
849 __TBB_ASSERT(!ta || ta->my_max_concurrency==d1::task_arena_base::automatic, nullptr); in max_concurrency()
853 void isolate_within_arena(d1::delegate_base& d, std::intptr_t isolation) { in isolate_within_arena()