Lines Matching refs:Waitable
762 Waitable::Host(task).set_event( in poll_and_block()
796 Waitable::Host(task).join(state, Some(set))?; in poll_and_block()
807 Waitable::Host(task).join(store.concurrent_state_mut(), None)?; in poll_and_block()
1362 Waitable::Guest(call.thread.task).set_event( in handle_work_item()
1877 fn wait_for_event(&mut self, waitable: Waitable) -> Result<()> { in wait_for_event()
1902 ) -> Result<Option<(Event, Option<(Waitable, u32)>)>> { in get_event() argument
1986 Waitable::Guest(guest_thread.task).delete_from(store.concurrent_state_mut())?; in handle_callback_code()
2340 Waitable::Guest(guest_thread.task).delete_from(state)?; in queue_call()
2493 Waitable::Guest(state.current_guest_thread()?.task).set_event( in prepare_call()
2687 let guest_waitable = Waitable::Guest(guest_thread.task); in start_call()
2776 Waitable::Guest(guest_thread.task).delete_from(state)?; in start_call()
2874 Waitable::Host(task).set_event(state, Some(Event::Subtask { status }))?; in first_poll()
3020 Waitable::Guest(guest_task).set_event(state, Some(Event::Subtask { status }))?; in task_complete()
3082 Waitable::from_instance(instance.as_mut(), caller_instance, waitable_handle)?; in waitable_join()
3129 (Waitable::Host(id), task.caller, true) in subtask_drop()
3138 Waitable::Guest(id), in subtask_drop()
3301 Waitable::Guest(guest_thread.task).delete_from(state)?; in thread_new_indirect()
3581 Waitable::Host(id), in subtask_cancel()
3587 (Waitable::Guest(id), thread) in subtask_cancel()
3601 if let Waitable::Host(host_task) = waitable { in subtask_cancel()
4611 enum Waitable { enum
4620 impl Waitable { implementation
4628 use crate::runtime::vm::component::Waitable; in from_instance()
4635 Waitable::Subtask { is_host: true } => Self::Host(TableId::new(waitable)), in from_instance()
4636 Waitable::Subtask { is_host: false } => Self::Guest(TableId::new(waitable)), in from_instance()
4637 Waitable::Stream | Waitable::Future => Self::Transmit(TableId::new(waitable)), in from_instance()
4660 Waitable::Host(id) => state.remove_child(id, old), in join()
4661 Waitable::Guest(id) => state.remove_child(id, old), in join()
4662 Waitable::Transmit(id) => state.remove_child(id, old), in join()
4670 Waitable::Host(id) => state.add_child(id, set), in join()
4671 Waitable::Guest(id) => state.add_child(id, set), in join()
4672 Waitable::Transmit(id) => state.add_child(id, set), in join()
4761 impl fmt::Debug for Waitable { implementation
4775 ready: BTreeSet<Waitable>,
5321 Waitable::Guest(self.task).delete_from(store.0.concurrent_state_mut())? in host_future_dropped()
5325 Waitable::Guest(self.task).delete_from(store.0.concurrent_state_mut())? in host_future_dropped()