Lines Matching refs:task_dispatcher
73 … td->set_post_resume_action(task_dispatcher::post_resume_action::register_waiter, &monitor_node); in execute()
86 …ed_ext.task_disp->m_thread_data->set_post_resume_action(task_dispatcher::post_resume_action::notif… in execute()
94 inline suspend_point_type::suspend_point_type(arena* a, size_t stack_size, task_dispatcher& task_di… in suspend_point_type()
114 inline task_dispatcher::task_dispatcher(arena* a) { in task_dispatcher() function
119 inline bool task_dispatcher::can_steal() { in can_steal()
125 inline d1::task* task_dispatcher::get_inbox_or_critical_task( in get_inbox_or_critical_task()
146 inline d1::task* task_dispatcher::get_stream_or_critical_task( in get_stream_or_critical_task()
158 inline d1::task* task_dispatcher::steal_or_get_critical( in steal_or_get_critical()
171 d1::task* task_dispatcher::receive_or_steal_task( in receive_or_steal_task()
243 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter ) { in local_wait_for_all()
249 task_dispatcher& task_disp; in local_wait_for_all()
380 inline void task_dispatcher::recall_point() { in recall_point()
396 inline d1::task* task_dispatcher::get_critical_task(d1::task* t, execution_data_ext& ed, isolation_… in get_critical_task()
436 inline d1::task* task_dispatcher::get_critical_task(d1::task* t, execution_data_ext&, isolation_typ… in get_critical_task()
441 inline d1::task* task_dispatcher::get_mailbox_task(mail_inbox& my_inbox, execution_data_ext& ed, is… in get_mailbox_task()
455 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter) { in local_wait_for_all()