Lines Matching refs:a
24 static inline void spawn_and_notify(d1::task& t, arena_slot* slot, arena* a) { in spawn_and_notify() argument
26 a->advertise_new_work<arena::work_spawned>(); in spawn_and_notify()
33 arena* a = tls->my_arena; in spawn() local
39 spawn_and_notify(t, slot, a); in spawn()
45 arena* a = tls->my_arena; in spawn() local
54 if ( id != d1::no_slot && id != tls->my_arena_index && id < a->my_num_slots) { in spawn()
65 proxy->outbox = &a->mailbox(id); in spawn()
71 spawn_and_notify(*proxy, slot, a); in spawn()
73 spawn_and_notify(t, slot, a); in spawn()
77 void __TBB_EXPORTED_FUNC submit(d1::task& t, d1::task_group_context& ctx, arena* a, std::uintptr_t … in submit() argument
79 assert_pointer_valid(a); in submit()
90 if ( tls.is_attached_to(a) ) { in submit()
94 a->my_critical_task_stream.push( &t, subsequent_lane_selector(slot->critical_hint()) ); in submit()
106 a->my_critical_task_stream.push( &t, lane_selector ); in submit()
111 a->my_fifo_task_stream.push( &t, lane_selector ); in submit()
116 a->advertise_new_work<arena::work_spawned>(); in submit()
215 arena* a = m_thread_data->my_arena; in co_local_wait_for_all() local
216 coroutine_waiter waiter(*a); in co_local_wait_for_all()
236 void task_dispatcher::init_suspend_point(arena* a, std::size_t stack_size) { in init_suspend_point() argument
239 suspend_point_type(a, stack_size, *this); in init_suspend_point()