40 …numa_binding_observer( d1::task_arena* ta, int num_slots, int numa_id, core_type_id core_type, int…  in numa_binding_observer()  argument
41         : task_scheduler_observer(*ta)  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()  argument
61 … new(allocate_memory(sizeof(numa_binding_observer))) numa_binding_observer(ta, num_slots, numa_id,…  in construct_binding_observer()
509 void __TBB_EXPORTED_FUNC initialize(d1::task_arena_base& ta) {  in initialize()  argument
510     task_arena_impl::initialize(ta);  in initialize()
512 void __TBB_EXPORTED_FUNC terminate(d1::task_arena_base& ta) {  in terminate()  argument
513     task_arena_impl::terminate(ta);  in terminate()
515 bool __TBB_EXPORTED_FUNC attach(d1::task_arena_base& ta) {  in attach()  argument
516     return task_arena_impl::attach(ta);  in attach()
518 void __TBB_EXPORTED_FUNC execute(d1::task_arena_base& ta, d1::delegate_base& d) {  in execute()  argument
519     task_arena_impl::execute(ta, d);  in execute()
521 void __TBB_EXPORTED_FUNC wait(d1::task_arena_base& ta) {  in wait()  argument
522     task_arena_impl::wait(ta);  in wait()
525 int __TBB_EXPORTED_FUNC max_concurrency(const d1::task_arena_base* ta) {  in max_concurrency()  argument
526     return task_arena_impl::max_concurrency(ta);  in max_concurrency()
529 void __TBB_EXPORTED_FUNC enqueue(d1::task& t, d1::task_arena_base* ta) {  in enqueue()  argument
530     task_arena_impl::enqueue(t, nullptr, ta);  in enqueue()
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()
537 void task_arena_impl::initialize(d1::task_arena_base& ta) {  in initialize()  argument
544         .set_core_type(ta.core_type())  in initialize()
545         .set_max_threads_per_core(ta.max_threads_per_core())  in initialize()
546         .set_numa_id(ta.my_numa_id);  in initialize()
549     if (ta.my_max_concurrency < 1) {  in initialize()
551         ta.my_max_concurrency = (int)default_concurrency(arena_constraints);  in initialize()
553         ta.my_max_concurrency = (int)governor::default_num_threads();  in initialize()
557 … __TBB_ASSERT(ta.my_arena.load(std::memory_order_relaxed) == nullptr, "Arena already initialized");  in initialize()
558     unsigned priority_level = arena_priority_level(ta.my_priority);  in initialize()
560 …arena& a = arena::create(thr_control, unsigned(ta.my_max_concurrency), ta.my_num_reserved_slots, p…  in initialize()
562     ta.my_arena.store(&a, std::memory_order_release);  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()  argument
570     arena* a = ta.my_arena.load(std::memory_order_relaxed);  in terminate()
574     ta.my_arena.store(nullptr, std::memory_order_relaxed);  in terminate()
577 bool task_arena_impl::attach(d1::task_arena_base& ta) {  in attach()  argument
578     __TBB_ASSERT(!ta.my_arena.load(std::memory_order_relaxed), nullptr);  in attach()
586         ta.my_num_reserved_slots = a->my_num_reserved_slots;  in attach()
587         ta.my_priority = arena_priority(a->my_priority_level);  in attach()
588         ta.my_max_concurrency = ta.my_num_reserved_slots + a->my_max_num_workers;  in attach()
589 …__TBB_ASSERT(arena::num_arena_slots(ta.my_max_concurrency, ta.my_num_reserved_slots) == a->my_num_…  in attach()
590         ta.my_arena.store(a, std::memory_order_release);  in attach()
598 void task_arena_impl::enqueue(d1::task& t, d1::task_group_context* c, d1::task_arena_base* ta) {  in enqueue()  argument
601     arena* a = ta ?  in enqueue()
602               ta->my_arena.load(std::memory_order_relaxed)  in enqueue()
740 void task_arena_impl::execute(d1::task_arena_base& ta, d1::delegate_base& d) {  in execute()  argument
741     arena* a = ta.my_arena.load(std::memory_order_relaxed);  in execute()
806 void task_arena_impl::wait(d1::task_arena_base& ta) {  in wait()  argument
807     arena* a = ta.my_arena.load(std::memory_order_relaxed);  in wait()
819 int task_arena_impl::max_concurrency(const d1::task_arena_base *ta) {  in max_concurrency()  argument
821     if( ta ) // for special cases of ta->max_concurrency()  in max_concurrency()
822         a = ta->my_arena.load(std::memory_order_relaxed);  in max_concurrency()
827         __TBB_ASSERT( !ta || ta->my_max_concurrency==1, nullptr);  in max_concurrency()
835     if (ta && ta->my_max_concurrency == 1) {  in max_concurrency()
840     if (ta) {  in max_concurrency()
842             .set_numa_id(ta->my_numa_id)  in max_concurrency()
843             .set_core_type(ta->core_type())  in max_concurrency()
844             .set_max_threads_per_core(ta->max_threads_per_core());  in max_concurrency()
849     __TBB_ASSERT(!ta || ta->my_max_concurrency==d1::task_arena_base::automatic, nullptr);  in max_concurrency()