Lines Matching refs:thread
579 thread: QualifiedThreadId,
588 thread: QualifiedThreadId,
593 thread: QualifiedThreadId,
654 thread: QualifiedThreadId, field
671 .get_mut(self.thread.task)? in is_ready()
715 Self::ResumeThread(instance, thread) => f in fmt()
718 .field(thread) in fmt()
795 let set = state.get_mut(caller.thread)?.sync_call_set; in poll_and_block()
800 thread: caller, in poll_and_block()
829 match instance.get_event(store, call.thread.task, set, true)? { in handle_guest_call()
834 let task = state.get_mut(call.thread.task)?; in handle_guest_call()
840 call.thread, in handle_guest_call()
843 let old_thread = store.set_thread(call.thread)?; in handle_guest_call()
846 call.thread in handle_guest_call()
853 .get_mut(call.thread.task)? in handle_guest_call()
864 .get_mut(call.thread.task)? in handle_guest_call()
873 call.thread, in handle_guest_call()
1343 WorkItem::ResumeThread(_, thread) => { in handle_work_item()
1345 &mut self.0.concurrent_state_mut().get_mut(thread.thread)?.state, in handle_work_item()
1358 let task = state.get_mut(call.thread.task)?; in handle_work_item()
1362 Waitable::Guest(call.thread.task).set_event( in handle_work_item()
1371 let instance = state.get_mut(call.thread.task)?.instance; in handle_work_item()
1376 .insert(call.thread, call.kind); in handle_work_item()
1457 let thread = state.current_thread; in enter_guest_sync_call() localVariable
1458 let instance = if let Some(thread) = thread.guest() { in enter_guest_sync_call()
1459 Some(state.get_mut(thread.task)?.instance) in enter_guest_sync_call()
1474 if let Some(thread) = thread.guest() { in enter_guest_sync_call()
1475 Caller::Guest { thread: *thread } in enter_guest_sync_call()
1480 caller: thread, in enter_guest_sync_call()
1502 thread: guest_thread, in enter_guest_sync_call()
1513 let thread = match self.set_thread(CurrentThread::None)?.guest() { in exit_guest_sync_call() localVariable
1517 let instance = self.concurrent_state_mut().get_mut(thread.task)?.instance; in exit_guest_sync_call()
1521 thread, in exit_guest_sync_call()
1526 let task = state.get_mut(thread.task)?; in exit_guest_sync_call()
1528 &Caller::Guest { thread } => thread.into(), in exit_guest_sync_call()
1534 let task = state.get_mut(thread.task)?; in exit_guest_sync_call()
1536 state.delete(thread.task)?.dispose(state)?; in exit_guest_sync_call()
1615 CurrentThread::Guest(thread) => { in may_enter()
1616 let task = state.get_mut(thread.task)?; in may_enter()
1629 Caller::Guest { thread } => thread.into(), in may_enter()
1646 fn set_thread(&mut self, thread: impl Into<CurrentThread>) -> Result<CurrentThread> { in set_thread()
1652 let old_thread = mem::replace(&mut state.current_thread, thread.into()); in set_thread()
1722 for (thread, kind) in in partition_pending()
1725 let call = GuestCall { thread, kind }; in partition_pending()
1733 .insert(call.thread, call.kind); in partition_pending()
1773 state.get_mut(ot.thread)?.state = GuestThreadState::Running; in resume_fiber()
1792 SuspendReason::Yielding { thread, .. } => { in resume_fiber()
1793 state.get_mut(thread.thread)?.state = GuestThreadState::Ready(fiber); in resume_fiber()
1794 let instance = state.get_mut(thread.task)?.instance.index; in resume_fiber()
1795 state.push_low_priority(WorkItem::ResumeThread(instance, thread)); in resume_fiber()
1797 SuspendReason::ExplicitlySuspending { thread, .. } => { in resume_fiber()
1798 state.get_mut(thread.thread)?.state = GuestThreadState::Suspended(fiber); in resume_fiber()
1800 SuspendReason::Waiting { set, thread, .. } => { in resume_fiber()
1804 .insert(thread, WaitMode::Fiber(fiber)); in resume_fiber()
1827 SuspendReason::Yielding { thread, .. } in suspend()
1828 | SuspendReason::Waiting { thread, .. } in suspend()
1829 | SuspendReason::ExplicitlySuspending { thread, .. } => Some(thread.task), in suspend()
1859 .map(|thread| self.concurrent_state_mut().may_block(thread.task)) in suspend()
1881 let set = state.get_mut(caller.thread)?.sync_call_set; in wait_for_event()
1885 thread: caller, in wait_for_event()
2002 thread: guest_thread, in handle_callback_code()
2035 thread: guest_thread, in handle_callback_code()
2051 .get_mut(guest_thread.thread)? in handle_callback_code()
2078 let thread_data = state.get_mut(guest_thread.thread)?; in cleanup_thread()
2103 store.concurrent_state_mut().delete(guest_thread.thread)?; in cleanup_thread()
2106 task.threads.remove(&guest_thread.thread); in cleanup_thread()
2158 .get_mut(guest_thread.thread)? in queue_call()
2212 guest_thread.thread, in queue_call()
2236 state.get_mut(t.thread)?.state = GuestThreadState::Running; in queue_call()
2251 guest_thread.thread, in queue_call()
2358 thread: guest_thread, in queue_call()
2537 let thread = state.current_guest_thread()?; in prepare_call() localVariable
2539 state.get_mut(thread.task)?.sync_result = SyncResult::Produced( in prepare_call()
2557 Caller::Guest { thread: old_thread }, in prepare_call()
2575 thread: guest_thread, in prepare_call()
2661 let Caller::Guest { thread: caller } = &task.caller else { in start_call()
2689 let set = state.get_mut(caller.thread)?.sync_call_set; in start_call()
2710 thread: caller, in start_call()
2761 store.0.concurrent_state_mut().get_mut(caller.thread)?.state = GuestThreadState::Running; in start_call()
3136 if let Caller::Guest { thread } = task.caller { in subtask_drop()
3139 thread, in subtask_drop()
3242 let thread_id = store.concurrent_state_mut().current_guest_thread()?.thread; in thread_index()
3298 state.get_mut(t.thread)?.state = GuestThreadState::Running; in thread_new_indirect()
3334 let thread = state.get_mut(guest_thread.thread)?; in resume_thread() localVariable
3336 match mem::replace(&mut thread.state, GuestThreadState::Running) { in resume_thread()
3342 thread: guest_thread, in resume_thread()
3360 thread.state = GuestThreadState::Ready(fiber); in resume_thread()
3366 thread.state = other; in resume_thread()
3430 SuspensionTarget::SomeSuspended(thread) => { in suspension_intrinsic()
3431 self.resume_thread(store, caller, thread, true, false)? in suspension_intrinsic()
3433 SuspensionTarget::Some(thread) => { in suspension_intrinsic()
3434 self.resume_thread(store, caller, thread, true, true)? in suspension_intrinsic()
3441 thread: guest_thread, in suspension_intrinsic()
3449 thread: guest_thread, in suspension_intrinsic()
3493 .get_mut(guest_thread.thread)? in waitable_check()
3503 thread: guest_thread, in waitable_check()
3586 if let Caller::Guest { thread } = store.concurrent_state_mut().get_mut(id)?.caller { in subtask_cancel()
3587 (Waitable::Guest(id), thread) in subtask_cancel()
3648 let thread = mem::take(&mut task.threads).into_iter().next().unwrap(); in subtask_cancel() localVariable
3650 concurrent_state.delete(thread)?; in subtask_cancel()
3656 pending.retain(|thread, _| thread.task != guest_task); in subtask_cancel()
3672 for thread in task.threads.clone() { in subtask_cancel()
3673 let thread = QualifiedThreadId { in subtask_cancel() localVariable
3675 thread, in subtask_cancel()
3678 .get_mut(thread.thread)? in subtask_cancel()
3682 let item = match concurrent_state.get_mut(set)?.waiting.remove(&thread) { in subtask_cancel()
3687 thread, in subtask_cancel()
3699 thread: caller, in subtask_cancel()
4310 thread: QualifiedThreadId,
4330 thread: TableId<GuestThread>, field
4336 thread: TableId<GuestThread>, in qualify()
4339 task: state.get_mut(thread)?.parent_task, in qualify()
4340 thread, in qualify()
4349 .field(&self.thread.rep()) in fmt()
4718 if let Some((thread, mode)) = state.get_mut(set)?.waiting.pop_first() { in mark_ready()
4719 let wake_on_cancel = state.get_mut(thread.thread)?.wake_on_cancel.take(); in mark_ready()
4725 state.get_mut(thread.task)?.instance.index, in mark_ready()
4727 thread, in mark_ready()
4949 } else if let Some(thread) = entry.downcast_mut::<GuestThread>() { in take_fibers_and_futures()
4951 mem::replace(&mut thread.state, GuestThreadState::Completed) in take_fibers_and_futures()
5077 fn promote_thread_work_item(&mut self, thread: QualifiedThreadId) -> bool { in promote_thread_work_item()
5079 WorkItem::ResumeThread(_, t) | WorkItem::GuestCall(_, GuestCall { thread: t, .. }) => { in promote_thread_work_item()
5080 *t == thread in promote_thread_work_item()
5109 let thread = self.current_guest_thread()?; in context_get() localVariable
5110 let val = self.get_mut(thread.thread)?.context[usize::try_from(slot)?]; in context_get()
5117 let thread = self.current_guest_thread()?; in context_set() localVariable
5119 self.get_mut(thread.thread)?.context[usize::try_from(slot)?] = val; in context_set()
5126 let thread = self.current_guest_thread()?; in take_pending_cancellation() localVariable
5127 if let Some(event) = self.get_mut(thread.task)?.event.take() { in take_pending_cancellation()
5289 thread: QualifiedThreadId, field
5302 task: self.thread.task, in task_id()
5408 let thread = state.push(new_thread)?; in prepare_call() localVariable
5409 state.get_mut(task)?.threads.insert(thread); in prepare_call()
5417 thread: QualifiedThreadId { task, thread }, in prepare_call()
5436 thread, in queue_call()
5442 queue_call0(store.as_context_mut(), handle, thread, param_count)?; in queue_call()