Home
last modified time | relevance | path

Searched refs:task_disp (Results 1 – 10 of 10) sorted by relevance

/oneTBB/src/tbb/
H A Dtask_dispatcher.h72 thread_data* td = ed_ext.task_disp->m_thread_data; in execute()
87 ed_ext.task_disp->get_suspend_point()); in execute()
90 ed_ext.task_disp->resume(m_target); in execute()
97 , m_co_context(stack_size, &task_disp) in suspend_point_type()
98 , m_resume_task(task_disp) in suspend_point_type()
116 m_execute_data_ext.task_disp = this; in task_dispatcher()
249 task_dispatcher& task_disp; in local_wait_for_all() member
255 task_disp.m_properties = old_properties; in local_wait_for_all()
257 …__TBB_ASSERT(task_disp.m_thread_data && governor::is_thread_data_set(task_disp.m_thread_data), nul… in local_wait_for_all()
258 __TBB_ASSERT(task_disp.m_thread_data->my_task_dispatcher == &task_disp, nullptr); in local_wait_for_all()
[all …]
H A Dtask_dispatcher.cpp132 assert_pointers_valid(ed_ext->task_disp, ed_ext->task_disp->m_thread_data); in execution_slot()
133 return ed_ext->task_disp->m_thread_data->my_arena_index; in execution_slot()
144 task_dispatcher* task_disp = td->my_task_dispatcher; in current_context() local
145 if (task_disp->m_properties.outermost) { in current_context()
196 task_dispatcher& task_disp = *reinterpret_cast<task_dispatcher*>(addr); in co_local_wait_for_all() local
197 assert_pointers_valid(task_disp.m_thread_data, task_disp.m_thread_data->my_arena); in co_local_wait_for_all()
198 …task_disp.set_stealing_threshold(task_disp.m_thread_data->my_arena->calculate_stealing_threshold()… in co_local_wait_for_all()
199 __TBB_ASSERT(task_disp.can_steal(), nullptr); in co_local_wait_for_all()
200 task_disp.co_local_wait_for_all(); in co_local_wait_for_all()
H A Dthread_data.h138 void enter_task_dispatcher(task_dispatcher& task_disp, std::uintptr_t stealing_threshold);
215 inline void thread_data::attach_task_dispatcher(task_dispatcher& task_disp) { in attach_task_dispatcher() argument
217 __TBB_ASSERT(task_disp.m_thread_data == nullptr, nullptr); in attach_task_dispatcher()
218 task_disp.m_thread_data = this; in attach_task_dispatcher()
219 my_task_dispatcher = &task_disp; in attach_task_dispatcher()
229 inline void thread_data::enter_task_dispatcher(task_dispatcher& task_disp, std::uintptr_t stealing_… in enter_task_dispatcher() argument
230 task_disp.set_stealing_threshold(stealing_threshold); in enter_task_dispatcher()
231 attach_task_dispatcher(task_disp); in enter_task_dispatcher()
H A Dtask.cpp49 task_dispatcher& task_disp = sp->m_resume_task.m_target; in resume() local
58 if (task_disp.m_properties.critical_task_allowed) { in resume()
82 task_dispatcher* task_disp = td.my_arena->my_co_cache.pop(); in create_coroutine() local
83 if (!task_disp) { in create_coroutine()
85 task_disp = new(ptr) task_dispatcher(td.my_arena); in create_coroutine()
86 …task_disp->init_suspend_point(td.my_arena, td.my_arena->my_threading_control->worker_stack_size()); in create_coroutine()
92 return *task_disp; in create_coroutine()
H A Darena.cpp210 tls.enter_task_dispatcher(task_disp, calculate_stealing_threshold()); in process()
211 __TBB_ASSERT(task_disp.can_steal(), nullptr); in process()
225 __TBB_ASSERT(tls.my_task_dispatcher == &task_disp, nullptr); in process()
629 … td.enter_task_dispatcher(task_disp, m_orig_execute_data_ext.task_disp->m_stealing_threshold); in nested_arena_context()
651 ed_ext.task_disp = td.my_task_dispatcher; in nested_arena_context()
678 td.attach_task_dispatcher(*m_orig_execute_data_ext.task_disp); in ~nested_arena_context()
702 __TBB_ASSERT(&ed_ext.task_disp->m_execute_data_ext == &ed, in execute()
706 …ed_ext.task_disp->m_execute_data_ext.context = ed_ext.task_disp->get_thread_data().my_arena->my_de… in execute()
707 bool fifo_task_allowed = ed_ext.task_disp->allow_fifo_task(true); in execute()
711 ed_ext.task_disp->m_execute_data_ext = orig_execute_data_ext; in execute()
[all …]
H A Dgovernor.cpp203 task_dispatcher& task_disp = td.my_arena_slot->default_task_dispatcher(); in init_external_thread() local
204 td.enter_task_dispatcher(task_disp, calculate_stealing_threshold(stack_base, stack_size)); in init_external_thread()
286 task_dispatcher* task_disp = td->my_task_dispatcher; in finalize_impl() local
287 __TBB_ASSERT(task_disp, nullptr); in finalize_impl()
288 … if (task_disp->m_properties.outermost && !td->my_is_worker) { // is not inside a parallel region in finalize_impl()
H A Dsmall_object_pool.cpp34 auto& tls = static_cast<const execution_data_ext&>(ed).task_disp->get_thread_data(); in allocate()
80 auto& tls = static_cast<const execution_data_ext&>(ed).task_disp->get_thread_data(); in deallocate()
H A Darena_slot.cpp129 ed.task_disp->m_thread_data->my_arena->advertise_new_work<arena::wakeup>(); in get_task()
139 ed.task_disp->m_thread_data->my_arena->advertise_new_work<arena::wakeup>(); in get_task()
H A Dthread_control_monitor.h45 : base_type(ctx), my_curr_dispatcher(ed_ext.task_disp), my_target_dispatcher(&target) in resume_node()
H A Dscheduler_common.h94 task_dispatcher* task_disp{};