Struct ContextSwitchingEnvironment

pub(crate) struct ContextSwitchingEnvironment {
    inner: Arc<ContextSwitchingEnvironmentInner>,
}

The context-switching environment represents all state for WASIX context-switching on a single host thread.

Fields

inner: Arc<ContextSwitchingEnvironmentInner>

Implementations

impl ContextSwitchingEnvironment

fn new(spawner: ThreadLocalSpawner) -> Self

pub(crate) fn run_main_context( ctx: &WasiFunctionEnv, store: Store, entrypoint: Function, params: Vec<Value>, ) -> (Store, Result<Box<[Value]>, RuntimeError>)

Run the main context function in a context-switching environment

This call blocks until the entrypoint returns or traps

pub(crate) fn active_context_id(&self) -> u64

Get the ID of the currently active context

pub(crate) fn main_context_id(&self) -> u64

Get the id of the main context (0)

pub(crate) fn destroy_context(&self, target_context_id: &u64) -> bool

pub(crate) fn switch_context( &self, target_context_id: u64, ) -> Result<impl Future<Output = Result<(), RuntimeError>> + Send + Sync + use<> + 'static, ContextSwitchError>

Unblock the target context and suspend own context

If this function succeeds, you MUST await the returned future

pub(crate) fn create_context<F>(&self, entrypoint: F) -> u64

where F: Future<Output = Result<(), RuntimeError>> + 'static,

Create a new context and spawn it onto the thread-local executor

The entrypoint function is called when the context is unblocked for the first time

If entrypoint returns, it must be a RuntimeError, as it is not allowed to return normally. If the RuntimeError is a ContextCanceled, the context will just exit silently. Otherwise, the error will be propagated to the main context.

If the context is cancelled before it is unblocked, the entrypoint will not be called

Trait Implementations

impl Debug for ContextSwitchingEnvironment

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.