Home
last modified time | relevance | path

Searched refs:my_task_dispatcher (Results 1 – 7 of 7) sorted by relevance

/oneTBB/src/tbb/
H A Dthread_data.h104 , my_task_dispatcher{ nullptr }
123 poison_pointer(my_task_dispatcher); in ~thread_data()
149 task_dispatcher* my_task_dispatcher; variable
216 __TBB_ASSERT(my_task_dispatcher == nullptr, nullptr); in attach_task_dispatcher()
219 my_task_dispatcher = &task_disp; in attach_task_dispatcher()
223 __TBB_ASSERT(my_task_dispatcher != nullptr, nullptr); in detach_task_dispatcher()
224 __TBB_ASSERT(my_task_dispatcher->m_thread_data == this, nullptr); in detach_task_dispatcher()
225 my_task_dispatcher->m_thread_data = nullptr; in detach_task_dispatcher()
226 my_task_dispatcher = nullptr; in detach_task_dispatcher()
235 my_task_dispatcher->set_stealing_threshold(0); in leave_task_dispatcher()
H A Dtask_dispatcher.cpp38 task_accessor::isolation(t) = tls->my_task_dispatcher->m_execute_data_ext.isolation; in spawn()
47 execution_data_ext& ed = tls->my_task_dispatcher->m_execute_data_ext; in spawn()
86 task_accessor::isolation(t) = tls.my_task_dispatcher->m_execute_data_ext.isolation; in submit()
142 assert_pointers_valid(td, td->my_task_dispatcher); in current_context()
144 task_dispatcher* task_disp = td->my_task_dispatcher; in current_context()
149 return td->my_task_dispatcher->m_execute_data_ext.context; in current_context()
156 __TBB_ASSERT(tls->my_task_dispatcher != nullptr, nullptr); in execute_and_wait()
157 task_dispatcher& local_td = *tls->my_task_dispatcher; in execute_and_wait()
163 task_accessor::isolation(*t) = tls->my_task_dispatcher->m_execute_data_ext.isolation; in execute_and_wait()
219 __TBB_ASSERT(this == m_thread_data->my_task_dispatcher, nullptr); in co_local_wait_for_all()
H A Dtask.cpp43 td.my_task_dispatcher->suspend(suspend_callback, user_callback); in suspend()
77 return td.my_task_dispatcher->get_suspend_point(); in current_suspend_point()
130 …__TBB_ASSERT(td->my_task_dispatcher == this, "Thread data must be attached to this task dispatcher… in resume()
145 …__TBB_ASSERT(td->my_task_dispatcher == this, "Thread data must be attached to this task dispatcher… in resume()
H A Darena.cpp218 d1::task* t = tls.my_task_dispatcher->local_wait_for_all(nullptr, waiter); in process()
225 __TBB_ASSERT(tls.my_task_dispatcher == &task_disp, nullptr); in process()
617 : m_orig_execute_data_ext(td.my_task_dispatcher->m_execute_data_ext) in nested_arena_context()
642 m_task_dispatcher = td.my_task_dispatcher; in nested_arena_context()
647 execution_data_ext& ed_ext = td.my_task_dispatcher->m_execute_data_ext; in nested_arena_context()
651 ed_ext.task_disp = td.my_task_dispatcher; in nested_arena_context()
656 __TBB_ASSERT(td.my_task_dispatcher, nullptr); in nested_arena_context()
681 td.my_task_dispatcher->m_execute_data_ext = m_orig_execute_data_ext; in ~nested_arena_context()
856 assert_pointers_valid(tls, tls->my_task_dispatcher); in isolate_within_arena()
857 task_dispatcher* dispatcher = tls->my_task_dispatcher; in isolate_within_arena()
[all …]
H A Dtask_group_context.cpp118 ctx.my_parent = td->my_task_dispatcher->m_execute_data_ext.context; in bind_to_impl()
180 __TBB_ASSERT(td->my_task_dispatcher->m_execute_data_ext.context != nullptr, nullptr); in bind_to()
182 …if (td->my_task_dispatcher->m_execute_data_ext.context == td->my_arena->my_default_ctx || !ctx.my_… in bind_to()
H A Dtask_dispatcher.h245 __TBB_ASSERT(m_thread_data->my_task_dispatcher == this, nullptr); in local_wait_for_all()
258 __TBB_ASSERT(task_disp.m_thread_data->my_task_dispatcher == &task_disp, nullptr); in local_wait_for_all()
336 __TBB_ASSERT(m_thread_data->my_task_dispatcher == this, nullptr); in local_wait_for_all()
H A Dgovernor.cpp286 task_dispatcher* task_disp = td->my_task_dispatcher; in finalize_impl()