Home
last modified time | relevance | path

Searched refs:Waitable (Results 1 – 4 of 4) sorted by relevance

/wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/component/
H A Dhandle_table.rs43 pub enum Waitable { enum
566 pub fn waitable_rep(&mut self, idx: u32) -> Result<(u32, Waitable)> { in waitable_rep() argument
568 Slot::GuestTask { rep } => Ok((*rep, Waitable::Subtask { is_host: false })), in waitable_rep()
569 Slot::HostTask { rep } => Ok((*rep, Waitable::Subtask { is_host: true })), in waitable_rep()
570 Slot::Future { rep, .. } => Ok((*rep, Waitable::Future)), in waitable_rep()
571 Slot::Stream { rep, .. } => Ok((*rep, Waitable::Stream)), in waitable_rep()
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/
H A Dconcurrent.rs762 Waitable::Host(task).set_event( in poll_and_block()
3129 (Waitable::Host(id), task.caller, true) in subtask_drop()
3138 Waitable::Guest(id), in subtask_drop()
3581 Waitable::Host(id), in subtask_cancel()
3587 (Waitable::Guest(id), thread) in subtask_cancel()
4611 enum Waitable { enum
4620 impl Waitable { implementation
4628 use crate::runtime::vm::component::Waitable; in from_instance()
4637 Waitable::Stream | Waitable::Future => Self::Transmit(TableId::new(waitable)), in from_instance()
4761 impl fmt::Debug for Waitable { implementation
[all …]
/wasmtime-44.0.1/crates/wasmtime/src/runtime/component/concurrent/
H A Dfutures_and_streams.rs2 use super::{Event, GlobalErrorContextRefCount, Waitable, WaitableCommon};
3867 let waitable = Waitable::Transmit(handle); in wait_for_write()
3894 let waitable = Waitable::Transmit(transmit.write_handle); in cancel_write()
3954 let waitable = Waitable::Transmit(handle); in wait_for_read()
3982 let waitable = Waitable::Transmit(transmit.read_handle); in cancel_read()
4555 Waitable::Transmit(TableId::<TransmitHandle>::new(waitable)).take_event(self) in take_event()
4559 Waitable::Transmit(TableId::<TransmitHandle>::new(waitable)).set_event(self, Some(event)) in set_event()
4573 let waitable = Waitable::Transmit(TableId::<TransmitHandle>::new(waitable)); in update_event()
4661 impl Waitable { impl
/wasmtime-44.0.1/crates/wasmtime/src/runtime/vm/
H A Dcomponent.rs46 pub use self::handle_table::{ThreadHandleTable, TransmitLocalState, Waitable};