Lines Matching refs:current_thread
149 let id = if let Some(mut current_thread) = sched_state.current_thread.take() { in start()
150 let id = current_thread.id(); in start()
151 current_thread.state = State::Ready; in start()
152 sched_state.insert_in_run_queue_head(current_thread); in start()
207 current_thread: Option<ForeignBox<Thread>>, field
222 current_thread: None, in new()
235 let Some(mut current_thread) = self.current_thread.take() else { in move_current_thread_to_back()
238 let current_thread_id = current_thread.id(); in move_current_thread_to_back()
239 current_thread.state = State::Ready; in move_current_thread_to_back()
240 self.insert_in_run_queue_tail(current_thread); in move_current_thread_to_back()
245 let Some(mut current_thread) = self.current_thread.take() else { in move_current_thread_to_front()
248 let current_thread_id = current_thread.id(); in move_current_thread_to_front()
249 current_thread.state = State::Ready; in move_current_thread_to_front()
250 self.insert_in_run_queue_head(current_thread); in move_current_thread_to_front()
256 self.current_thread = Some(thread); in set_current_thread()
260 match &self.current_thread { in current_thread_id()
311 assert!(sched_state.current_thread.is_none()); in reschedule()
326 sched_state.current_thread = Some(new_thread); in reschedule()
388 let Some(mut current_thread) = sched_state.current_thread.take() else { in exit_thread()
391 let current_thread_id = current_thread.id(); in exit_thread()
393 info!("thread {:#x} exiting", current_thread.id()); in exit_thread()
394 current_thread.state = State::Stopped; in exit_thread()
432 let Some(mut thread) = self.sched_mut().current_thread.take() else { in wait()