46     d1::task* t = nullptr;  in get_self_recall_task()  local
50         t = &sp->m_resume_task;  in get_self_recall_task()
54     return t;  in get_self_recall_task()
162     if (d1::task* t = a.steal_task(arena_index, random, ed, isolation)) {  in steal_or_get_critical()  local
163         ed.context = task_accessor::context(*t);  in steal_or_get_critical()
164         ed.isolation = task_accessor::isolation(*t);  in steal_or_get_critical()
165         return get_critical_task(t, ed, isolation, critical_allowed);  in steal_or_get_critical()
177     d1::task* t = nullptr;  in receive_or_steal_task()  local
196         __TBB_ASSERT(t == nullptr, nullptr);  in receive_or_steal_task()
199         if (!waiter.continue_execution(slot, t)) {  in receive_or_steal_task()
200             __TBB_ASSERT(t == nullptr, nullptr);  in receive_or_steal_task()
204         if (t != nullptr) {  in receive_or_steal_task()
207         else if ((t = get_inbox_or_critical_task(ed, inbox, isolation, critical_allowed))) {  in receive_or_steal_task()
210 …else if ((t = get_stream_or_critical_task(ed, a, resume_stream, resume_hint, isolation, critical_a…  in receive_or_steal_task()
214 …&& (t = get_stream_or_critical_task(ed, a, fifo_stream, fifo_hint, isolation, critical_allowed))) {  in receive_or_steal_task()
218 …  && (t = steal_or_get_critical(ed, a, arena_index, tls.my_random, isolation, critical_allowed))) {  in receive_or_steal_task()
222             t = get_critical_task(t, ed, isolation, critical_allowed);  in receive_or_steal_task()
225         if (t != nullptr) {  in receive_or_steal_task()
226             ed.context = task_accessor::context(*t);  in receive_or_steal_task()
227             ed.isolation = task_accessor::isolation(*t);  in receive_or_steal_task()
239     return t;  in receive_or_steal_task()
243 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter ) {  in local_wait_for_all()  argument
276     ed.context = t ? task_accessor::context(*t) : nullptr;  in local_wait_for_all()
285     t = get_critical_task(t, ed, isolation, critical_allowed);  in local_wait_for_all()
286     if (t && m_thread_data->my_inbox.is_idle_state(true)) {  in local_wait_for_all()
301                 while (t != nullptr) {  in local_wait_for_all()
302                     assert_task_valid(t);  in local_wait_for_all()
307 …__TBB_ASSERT(task_accessor::is_resume_task(*t) || isolation == no_isolation || isolation == ed.iso…  in local_wait_for_all()
309                     if (Waiter::postpone_execution(*t)) {  in local_wait_for_all()
310 …               __TBB_ASSERT(task_accessor::is_resume_task(*t) && dl_guard.old_properties.outermost,  in local_wait_for_all()
312                         return t;  in local_wait_for_all()
318                     ITT_CALLEE_ENTER(ITTPossible, t, itt_caller);  in local_wait_for_all()
321                         t = t->cancel(ed);  in local_wait_for_all()
323                         t = t->execute(ed);  in local_wait_for_all()
333                     t = get_critical_task(t, ed, isolation, critical_allowed);  in local_wait_for_all()
340                 if (!waiter.continue_execution(slot, t)) {  in local_wait_for_all()
344                 if (t || (slot.is_task_pool_published() && (t = slot.get_task(ed, isolation)))) {  in local_wait_for_all()
346                     ed.context = task_accessor::context(*t);  in local_wait_for_all()
347                     ed.isolation = task_accessor::isolation(*t);  in local_wait_for_all()
351                 t = receive_or_steal_task<ITTPossible>(  in local_wait_for_all()
355             } while (t != nullptr); // main dispatch loop  in local_wait_for_all()
367     __TBB_ASSERT(t == nullptr, nullptr);  in local_wait_for_all()
396 inline d1::task* task_dispatcher::get_critical_task(d1::task* t, execution_data_ext& ed, isolation_…  in get_critical_task()  argument
403         return t;  in get_critical_task()
414         if (t != nullptr) {  in get_critical_task()
416             r1::spawn(*t, *ed.context);  in get_critical_task()
427         t = crit_t;  in get_critical_task()
433     return t;  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()  argument
437     return t;  in get_critical_task()
455 d1::task* task_dispatcher::local_wait_for_all(d1::task* t, Waiter& waiter) {  in local_wait_for_all()  argument
457         return local_wait_for_all</*ITTPossible = */ true>(t, waiter);  in local_wait_for_all()
459         return local_wait_for_all</*ITTPossible = */ false>(t, waiter);  in local_wait_for_all()