Home
last modified time | relevance | path

Searched refs:task_dispatcher (Results 1 – 18 of 18) sorted by relevance

/oneTBB/src/tbb/
H A Dtask.cpp49 task_dispatcher& task_disp = sp->m_resume_task.m_target; in resume()
80 task_dispatcher& create_coroutine(thread_data& td) { in create_coroutine()
82 task_dispatcher* task_disp = td.my_arena->my_co_cache.pop(); in create_coroutine()
84 void* ptr = cache_aligned_allocate(sizeof(task_dispatcher)); in create_coroutine()
85 task_disp = new(ptr) task_dispatcher(td.my_arena); in create_coroutine()
95 void task_dispatcher::internal_suspend() { in internal_suspend()
101 task_dispatcher& default_task_disp = slot->default_task_dispatcher(); in internal_suspend()
113 void task_dispatcher::suspend(suspend_callback_type suspend_callback, void* user_callback) { in suspend()
124 bool task_dispatcher::resume(task_dispatcher& target) { in resume()
160 void task_dispatcher::do_post_resume_action() { in do_post_resume_action()
[all …]
H A Dthread_data.h42 class task_dispatcher; variable
113 , my_post_resume_action{ task_dispatcher::post_resume_action::none }
136 void attach_task_dispatcher(task_dispatcher&);
138 void enter_task_dispatcher(task_dispatcher& task_disp, std::uintptr_t stealing_threshold);
149 task_dispatcher* my_task_dispatcher;
177 void resume(task_dispatcher& target);
180 void set_post_resume_action(task_dispatcher::post_resume_action pra, void* arg) { in set_post_resume_action()
188 my_post_resume_action = task_dispatcher::post_resume_action::none; in clear_post_resume_action()
193 task_dispatcher::post_resume_action my_post_resume_action;
215 inline void thread_data::attach_task_dispatcher(task_dispatcher& task_disp) { in attach_task_dispatcher()
[all …]
H A Dtask_dispatcher.h94 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()
[all …]
H A Darena.h43 class task_dispatcher; variable
55 task_dispatcher** my_co_scheduler_cache;
75 void internal_task_dispatcher_cleanup(task_dispatcher* to_cleanup) { in internal_task_dispatcher_cleanup()
76 to_cleanup->~task_dispatcher(); in internal_task_dispatcher_cleanup()
82 std::size_t alloc_size = cache_capacity * sizeof(task_dispatcher*); in init()
83 my_co_scheduler_cache = (task_dispatcher**)cache_aligned_allocate(alloc_size); in init()
90 while (task_dispatcher* to_cleanup = pop()) { in cleanup()
98 void push(task_dispatcher* s) { in push()
99 task_dispatcher* to_cleanup = nullptr; in push()
118 task_dispatcher* pop() { in pop()
[all …]
H A Dtask_dispatcher.cpp121 task_dispatcher::execute_and_wait(&t, wait_ctx, w_ctx); in execute_and_wait()
126 task_dispatcher::execute_and_wait(nullptr, wait_ctx, w_ctx); in wait()
144 task_dispatcher* task_disp = td->my_task_dispatcher; in current_context()
153 void task_dispatcher::execute_and_wait(d1::task* t, d1::wait_context& wait_ctx, d1::task_group_cont… in execute_and_wait()
157 task_dispatcher& local_td = *tls->my_task_dispatcher; in execute_and_wait()
196 task_dispatcher& task_disp = *reinterpret_cast<task_dispatcher*>(addr); in co_local_wait_for_all()
204 /* [[noreturn]] */ void task_dispatcher::co_local_wait_for_all() noexcept { in co_local_wait_for_all()
227 d1::suspend_point task_dispatcher::get_suspend_point() { in get_suspend_point()
236 void task_dispatcher::init_suspend_point(arena* a, std::size_t stack_size) { in init_suspend_point()
H A Dscheduler_common.h94 task_dispatcher* task_disp{};
424 task_dispatcher& m_target;
425 explicit resume_task(task_dispatcher& target) : m_target(target) { in resume_task()
435 suspend_point_type(arena* a, std::size_t stack_size, task_dispatcher& target);
445 class alignas (max_nfs_size) task_dispatcher { in alignas()
499 task_dispatcher(const task_dispatcher&) = delete; in alignas()
503 task_dispatcher(arena* a); in alignas()
505 ~task_dispatcher() { in alignas()
556 bool resume(task_dispatcher& target); in alignas()
H A Dthread_control_monitor.h44 resume_node(market_context ctx, execution_data_ext& ed_ext, task_dispatcher& target) in resume_node()
89 task_dispatcher* my_curr_dispatcher;
90 task_dispatcher* my_target_dispatcher;
H A Darena.cpp209 task_dispatcher& task_disp = tls.my_arena_slot->default_task_dispatcher(); in process()
268 task_dispatcher* base_td_pointer = reinterpret_cast<task_dispatcher*>(my_slots + my_num_slots); in arena()
275 my_slots[i].my_default_task_dispatcher = new(base_td_pointer + i) task_dispatcher(this); in arena()
320 my_slots[i].my_default_task_dispatcher->~task_dispatcher(); in free_arena()
628 task_dispatcher& task_disp = td.my_arena_slot->default_task_dispatcher(); in nested_arena_context()
688 task_dispatcher* m_task_dispatcher{ nullptr };
857 task_dispatcher* dispatcher = tls->my_task_dispatcher; in isolate_within_arena()
H A Darena_slot.h91 friend class task_dispatcher; variable
96 task_dispatcher* my_default_task_dispatcher;
181 task_dispatcher& default_task_dispatcher() { in default_task_dispatcher()
H A Dgovernor.cpp203 task_dispatcher& task_disp = td.my_arena_slot->default_task_dispatcher(); in init_external_thread()
286 task_dispatcher* task_disp = td->my_task_dispatcher; in finalize_impl()
H A DCMakeLists.txt41 task_dispatcher.cpp
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h67 class task_dispatcher; variable
125 friend class r1::task_dispatcher;
/oneTBB/src/tbb/def/
H A Dlin64-tbb.def81 /* Task dispatcher (task_dispatcher.cpp) */
H A Dlin32-tbb.def81 /* Task dispatcher (task_dispatcher.cpp) */
H A Dmac64-tbb.def83 # Task dispatcher (task_dispatcher.cpp)
H A Dwin64-tbb.def75 ; Task dispatcher (task_dispatcher.cpp)
H A Dwin32-tbb.def75 ; Task dispatcher (task_dispatcher.cpp)
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h56 class task_dispatcher; variable
412 friend class r1::task_dispatcher;