Lines Matching refs:arena
76 void arena::on_thread_leaving(unsigned ref_param) { in on_thread_leaving()
153 std::size_t arena::occupy_free_slot_in_range( thread_data& tls, std::size_t lower, std::size_t uppe… in occupy_free_slot_in_range()
168 std::size_t arena::occupy_free_slot(thread_data& tls) { in occupy_free_slot()
183 std::uintptr_t arena::calculate_stealing_threshold() { in calculate_stealing_threshold()
188 void arena::process(thread_data& tls) { in process()
249 arena::arena(threading_control* control, unsigned num_slots, unsigned num_reserved_slots, unsigned … in arena() function in tbb::detail::r1::arena
286 arena& arena::allocate_arena(threading_control* control, unsigned num_slots, unsigned num_reserved_… in allocate_arena()
289 …__TBB_ASSERT( sizeof(base_type) + sizeof(arena_slot) == sizeof(arena), "All arena data fields must… in allocate_arena()
298 arena(control, num_slots, num_reserved_slots, priority_level); in allocate_arena()
301 void arena::free_arena () { in free_arena()
336 this->~arena(); in free_arena()
343 bool arena::has_enqueued_tasks() { in has_enqueued_tasks()
347 void arena::request_workers(int mandatory_delta, int workers_delta, bool wakeup_threads) { in request_workers()
358 bool arena::has_tasks() { in has_tasks()
372 void arena::out_of_work() { in out_of_work()
390 void arena::set_top_priority(bool is_top_priority) { in set_top_priority()
394 bool arena::is_top_priority() const { in is_top_priority()
398 bool arena::try_join() { in try_join()
400 my_references += arena::ref_worker; in try_join()
406 void arena::set_allotment(unsigned allotment) { in set_allotment()
412 int arena::update_concurrency(unsigned allotment) { in update_concurrency()
420 std::pair<int, int> arena::update_request(int mandatory_delta, int workers_delta) { in update_request()
439 thread_control_monitor& arena::get_waiting_threads_monitor() { in get_waiting_threads_monitor()
443 void arena::enqueue_task(d1::task& t, d1::task_group_context& ctx, thread_data& td) { in enqueue_task()
451 arena& arena::create(threading_control* control, unsigned num_slots, unsigned num_reserved_slots, u… in create()
455 arena& a = arena::allocate_arena(control, num_slots, num_reserved_slots, arena_priority_level); in create()
560 …arena& a = arena::create(thr_control, unsigned(ta.my_max_concurrency), ta.my_num_reserved_slots, p… in initialize()
570 arena* a = ta.my_arena.load(std::memory_order_relaxed); in terminate()
573 a->on_thread_leaving(arena::ref_external); in terminate()
581 arena* a = td->my_arena; in attach()
585 a->my_references += arena::ref_external; in attach()
589 …__TBB_ASSERT(arena::num_arena_slots(ta.my_max_concurrency, ta.my_num_reserved_slots) == a->my_num_… in attach()
601 arena* a = ta ? in enqueue()
616 nested_arena_context(thread_data& td, arena& nested_arena, std::size_t slot_index) in nested_arena_context()
686 arena* m_orig_arena{ nullptr };
741 arena* a = ta.my_arena.load(std::memory_order_relaxed); in execute()
749 if (index1 == arena::out_of_arena) { in execute()
757 size_t index2 = arena::out_of_arena; in execute()
765 if (index2 != arena::out_of_arena) { in execute()
774 if (index2 == arena::out_of_arena) { in execute()
807 arena* a = ta.my_arena.load(std::memory_order_relaxed); in wait()
820 arena* a = nullptr; in max_concurrency()