Lines Matching refs:td
42 thread_data& td = *governor::get_thread_data(); in suspend() local
43 td.my_task_dispatcher->suspend(suspend_callback, user_callback); in suspend()
76 thread_data& td = *governor::get_thread_data(); in current_suspend_point() local
77 return td.my_task_dispatcher->get_suspend_point(); in current_suspend_point()
80 task_dispatcher& create_coroutine(thread_data& td) { in create_coroutine() argument
82 task_dispatcher* task_disp = td.my_arena->my_co_cache.pop(); 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()
91 td.my_arena->my_references += arena::ref_external; in create_coroutine()
127 thread_data* td = m_thread_data; in resume() local
129 __TBB_ASSERT(td != nullptr, "This task dispatcher must be attach to a thread data"); in resume()
130 …__TBB_ASSERT(td->my_task_dispatcher == this, "Thread data must be attached to this task dispatcher… in resume()
133 td->detach_task_dispatcher(); in resume()
134 td->attach_task_dispatcher(target); in resume()
143 thread_data* td = m_thread_data; in resume() local
144 __TBB_ASSERT(td != nullptr, "This task dispatcher must be attach to a thread data"); in resume()
145 …__TBB_ASSERT(td->my_task_dispatcher == this, "Thread data must be attached to this task dispatcher… in resume()
149 arena_slot* slot = td->my_arena_slot; in resume()
161 thread_data* td = m_thread_data; in do_post_resume_action() local
162 switch (td->my_post_resume_action) { in do_post_resume_action()
165 __TBB_ASSERT(td->my_post_resume_arg, "The post resume action must have an argument"); in do_post_resume_action()
166 static_cast<thread_control_monitor::resume_context*>(td->my_post_resume_arg)->notify(); in do_post_resume_action()
171 __TBB_ASSERT(td->my_post_resume_arg, "The post resume action must have an argument"); in do_post_resume_action()
172 task_dispatcher* to_cleanup = static_cast<task_dispatcher*>(td->my_post_resume_arg); in do_post_resume_action()
174 td->my_arena->on_thread_leaving(arena::ref_external); in do_post_resume_action()
176 td->my_arena->my_co_cache.push(to_cleanup); in do_post_resume_action()
181 __TBB_ASSERT(td->my_post_resume_arg, "The post resume action must have an argument"); in do_post_resume_action()
182 suspend_point_type* sp = static_cast<suspend_point_type*>(td->my_post_resume_arg); in do_post_resume_action()
189 td->my_arena->get_waiting_threads_monitor().notify(is_our_suspend_point); in do_post_resume_action()
193 … __TBB_ASSERT(td->my_post_resume_action == post_resume_action::none, "Unknown post resume action"); in do_post_resume_action()
194 … __TBB_ASSERT(td->my_post_resume_arg == nullptr, "The post resume argument should not be set"); in do_post_resume_action()
196 td->clear_post_resume_action(); in do_post_resume_action()