Lines Matching refs:isolation

103     task_accessor::isolation(m_resume_task) = no_isolation;  in suspend_point_type()
126 execution_data_ext& ed, mail_inbox& inbox, isolation_type isolation, bool critical_allowed) in get_inbox_or_critical_task() argument
130 d1::task* result = get_critical_task(nullptr, ed, isolation, critical_allowed); in get_inbox_or_critical_task()
134 result = get_mailbox_task(inbox, ed, isolation); in get_inbox_or_critical_task()
138 if (isolation != no_isolation && !result && !inbox.empty() && inbox.is_idle_state(true)) { in get_inbox_or_critical_task()
148 isolation_type isolation, bool critical_allowed) in get_stream_or_critical_task() argument
152 d1::task* result = get_critical_task(nullptr, ed, isolation, critical_allowed); in get_stream_or_critical_task()
160 isolation_type isolation, bool critical_allowed) in steal_or_get_critical() argument
162 if (d1::task* t = a.steal_task(arena_index, random, ed, isolation)) { 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()
172 thread_data& tls, execution_data_ext& ed, Waiter& waiter, isolation_type isolation, in receive_or_steal_task() argument
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()
213 else if (fifo_allowed && isolation == no_isolation 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()
227 ed.isolation = task_accessor::isolation(*t); in receive_or_steal_task()
266 const isolation_type isolation = dl_guard.old_execute_data_ext.isolation; in local_wait_for_all() local
285 t = get_critical_task(t, ed, isolation, critical_allowed); in local_wait_for_all()
307 …_TBB_ASSERT(task_accessor::is_resume_task(*t) || isolation == no_isolation || isolation == ed.isol… in local_wait_for_all()
333 t = get_critical_task(t, ed, isolation, critical_allowed); in local_wait_for_all()
344 if (t || (slot.is_task_pool_published() && (t = slot.get_task(ed, isolation)))) { in local_wait_for_all()
347 ed.isolation = task_accessor::isolation(*t); in local_wait_for_all()
352 … *m_thread_data, ed, waiter, isolation, dl_guard.old_properties.fifo_tasks_allowed, in local_wait_for_all()
396 …::get_critical_task(d1::task* t, execution_data_ext& ed, isolation_type isolation, bool critical_a… in get_critical_task() argument
411 d1::task* crit_t = a.get_critical_task(slot.hint_for_critical_stream, isolation); in get_critical_task()
419 ed.isolation = task_accessor::isolation(*crit_t); in get_critical_task()
441 …patcher::get_mailbox_task(mail_inbox& my_inbox, execution_data_ext& ed, isolation_type isolation) { in get_mailbox_task() argument
442 while (task_proxy* const tp = my_inbox.pop(isolation)) { in get_mailbox_task()