Home
last modified time | relevance | path

Searched refs:thread_data (Results 1 – 25 of 25) sorted by relevance

/oneTBB/src/tbb/
H A Dgovernor.h30 class thread_data; variable
55 static basic_tls<thread_data*> theTLS;
99 static thread_data* get_thread_data() { in get_thread_data()
100 thread_data* td = theTLS.get(); in get_thread_data()
110 static void set_thread_data(thread_data& td) { in set_thread_data()
118 static thread_data* get_thread_data_if_initialized () { in get_thread_data_if_initialized()
122 static bool is_thread_data_set(thread_data* td) { in is_thread_data_set()
H A Dthread_data.h97 class thread_data : public ::rml::job
101 thread_data(unsigned short index, bool is_worker) in thread_data() function
120 ~thread_data() { in ~thread_data()
205 inline void thread_data::attach_arena(arena& a, std::size_t index) { in attach_arena()
213 inline bool thread_data::is_attached_to(arena* a) { return my_arena == a; } in is_attached_to()
215 inline void thread_data::attach_task_dispatcher(task_dispatcher& task_disp) { in attach_task_dispatcher()
222 inline void thread_data::detach_task_dispatcher() { in detach_task_dispatcher()
229 inline void thread_data::enter_task_dispatcher(task_dispatcher& task_disp, std::uintptr_t stealing_… in enter_task_dispatcher()
234 inline void thread_data::leave_task_dispatcher() { in leave_task_dispatcher()
239 inline void thread_data::propagate_task_group_state(std::atomic<std::uint32_t> d1::task_group_conte… in propagate_task_group_state()
H A Dthreading_control.h38 class thread_data; variable
62 void register_thread(thread_data& td);
63 void unregister_thread(thread_data& td);
110 void register_thread(thread_data& td);
111 void unregister_thread(thread_data& td);
H A Dtask.cpp42 thread_data& td = *governor::get_thread_data(); in suspend()
76 thread_data& td = *governor::get_thread_data(); in current_suspend_point()
80 task_dispatcher& create_coroutine(thread_data& td) { in create_coroutine()
127 thread_data* td = m_thread_data; in resume()
143 thread_data* td = m_thread_data; in resume()
161 thread_data* td = m_thread_data; in do_post_resume_action()
H A Dthread_dispatcher.cpp177 thread_data& td = static_cast<thread_data&>(j); in process()
211 thread_data* td = new (cache_aligned_allocate(sizeof(thread_data))) thread_data{ index, true }; in create_one_job()
218 my_threading_control.unregister_thread(static_cast<thread_data&>(j)); in cleanup()
H A Dcancellation_disseminator.h63 void register_thread(thread_data& td) { in register_thread()
68 void unregister_thread(thread_data& td) { in unregister_thread()
74 using thread_data_list_type = intrusive_list<thread_data>;
H A Dtask_dispatcher.cpp31 thread_data* tls = governor::get_thread_data(); in spawn()
43 thread_data* tls = governor::get_thread_data(); in spawn()
80 thread_data& tls = *governor::get_thread_data(); in submit()
135 thread_data* td = governor::get_thread_data_if_initialized(); in execution_slot()
141 thread_data* td = governor::get_thread_data(); in current_context()
155 thread_data* tls = governor::get_thread_data(); in execute_and_wait()
H A Dsmall_object_pool_impl.h32 class thread_data; variable
43 void deallocate_impl(void* ptr, std::size_t number_of_bytes, thread_data& td);
H A Dscheduler_common.h448 friend class thread_data; in alignas()
464 thread_data* m_thread_data{ nullptr }; in alignas()
493 d1::task* receive_or_steal_task(thread_data& tls, execution_data_ext& ed, Waiter& waiter, in alignas()
529 thread_data& get_thread_data() { in alignas()
577 static void register_with(d1::task_group_context&, thread_data*);
578 static void bind_to_impl(d1::task_group_context&, thread_data*);
579 static void bind_to(d1::task_group_context&, thread_data*);
H A Dgovernor.cpp197 thread_data& td = *new(cache_aligned_allocate(sizeof(thread_data))) thread_data(0, false); in init_external_thread()
220 thread_data* td = static_cast<thread_data*>(tls); in auto_terminate()
223 td->~thread_data(); in auto_terminate()
284 thread_data* td = governor::get_thread_data_if_initialized(); in finalize_impl()
H A Darena.cpp153 std::size_t arena::occupy_free_slot_in_range( thread_data& tls, std::size_t lower, std::size_t uppe… in occupy_free_slot_in_range()
168 std::size_t arena::occupy_free_slot(thread_data& tls) { in occupy_free_slot()
188 void arena::process(thread_data& tls) { in process()
443 void arena::enqueue_task(d1::task& t, d1::task_group_context& ctx, thread_data& td) { in enqueue_task()
579 thread_data* td = governor::get_thread_data_if_initialized(); in attach()
616 nested_arena_context(thread_data& td, arena& nested_arena, std::size_t slot_index) in nested_arena_context()
659 thread_data& td = *m_task_dispatcher->m_thread_data; in ~nested_arena_context()
743 thread_data* td = governor::get_thread_data(); in execute()
809 thread_data* td = governor::get_thread_data(); in wait()
823 else if( thread_data* td = governor::get_thread_data_if_initialized() ) in max_concurrency()
[all …]
H A Dthreading_control.cpp140 void threading_control_impl::register_thread(thread_data& td) { in register_thread()
143 void threading_control_impl::unregister_thread(thread_data& td) { in unregister_thread()
365 void threading_control::register_thread(thread_data& td) { in register_thread()
369 void threading_control::unregister_thread(thread_data& td) { in unregister_thread()
H A Darena.h348 void enqueue_task(d1::task&, d1::task_group_context&, thread_data&);
351 void process(thread_data&);
370 std::size_t occupy_free_slot(thread_data&);
372 std::size_t occupy_free_slot_in_range(thread_data& tls, std::size_t lower, std::size_t upper);
H A Dthread_dispatcher_client.h35 void process(thread_data& td) { in process()
H A Dtask_group_context.cpp105 void task_group_context_impl::register_with(d1::task_group_context& ctx, thread_data* td) { in register_with()
113 void task_group_context_impl::bind_to_impl(d1::task_group_context& ctx, thread_data* td) { in bind_to_impl()
165 void task_group_context_impl::bind_to(d1::task_group_context& ctx, thread_data* td) { in bind_to()
H A Dthread_control_monitor.h87 friend class thread_data;
H A Dmain.cpp39 basic_tls<thread_data*> governor::theTLS;
H A Dtask_dispatcher.h72 thread_data* td = ed_ext.task_disp->m_thread_data; in execute()
172 thread_data& tls, execution_data_ext& ed, Waiter& waiter, isolation_type isolation, in receive_or_steal_task()
407 thread_data& td = *m_thread_data; in get_critical_task()
H A Dco_context.h82 thread_data* my_thread_data{ nullptr };
238 thread_data* td = governor::get_thread_data(); in swap_coroutine()
H A Dsmall_object_pool.cpp85 void small_object_pool_impl::deallocate_impl(void* ptr, std::size_t number_of_bytes, thread_data& t… in deallocate_impl()
H A Darena_slot.h92 friend class thread_data; variable
H A Dobserver_proxy.cpp268 thread_data* td = governor::get_thread_data_if_initialized(); in observe()
H A Dconcurrent_monitor.h130 friend class thread_data; variable
/oneTBB/include/oneapi/tbb/detail/
H A D_task.h66 class thread_data; variable
124 friend class r1::thread_data;
/oneTBB/include/oneapi/tbb/
H A Dtask_group.h55 class thread_data; variable
230 …static_assert(sizeof(std::atomic<r1::thread_data*>) == sizeof(r1::context_list*), "To preserve bac…
411 friend class r1::thread_data;