Struct wasmer_wasix::os::task::thread::WasiThread

pub struct WasiThread { /* private fields */ }

Represents a running thread which allows a joiner to wait for the thread to exit

Implementations

impl WasiThread

pub fn new( pid: WasiProcessId, id: WasiThreadId, is_main: bool, status: Arc<OwnedTaskStatus>, guard: TaskCountGuard ) -> Self

pub fn pid(&self) -> WasiProcessId

Returns the process ID

pub fn tid(&self) -> WasiThreadId

Returns the thread ID

pub fn is_main(&self) -> bool

Returns true if this thread is the main thread

pub fn join_handle(&self) -> TaskJoinHandle

Get a join handle to watch the task status.

pub fn signals(&self) -> &Mutex<(Vec<Signal>, Vec<Waker>)>

pub fn set_status_running(&self)

pub fn set_or_get_exit_code_for_signal(&self, sig: Signal) -> ExitCode

Gets or sets the exit code based of a signal that was received Note: if the exit code was already set earlier this method will just return that earlier set exit code

pub fn set_status_finished(&self, res: Result<ExitCode, WasiRuntimeError>)

Marks the thread as finished (which will cause anyone that joined on it to wake up)

pub async fn join(&self) -> Result<ExitCode, Arc<WasiRuntimeError>>

Waits until the thread is finished or the timeout is reached

pub fn try_join(&self) -> Option<Result<ExitCode, Arc<WasiRuntimeError>>>

Attempts to join on the thread

pub fn signal(&self, signal: Signal)

Adds a signal for this thread to process

pub fn has_signal(&self, signals: &[Signal]) -> bool

Returns all the signals that are waiting to be processed

pub fn pop_signals_or_subscribe(&self, waker: &Waker) -> Option<Vec<Signal>>

Returns all the signals that are waiting to be processed

pub fn has_signals_or_subscribe(&self, waker: &Waker) -> bool

Returns all the signals that are waiting to be processed

pub fn pop_signals(&self) -> Vec<Signal>

Returns all the signals that are waiting to be processed

pub fn add_snapshot( &self, memory_stack: &[u8], memory_stack_corrected: &[u8], hash: u128, rewind_stack: &[u8], store_data: &[u8] )

Adds a stack snapshot and removes dead ones

pub fn get_snapshot(&self, hash: u128) -> Option<(BytesMut, Bytes, Bytes)>

Gets a snapshot that was previously addedf

pub fn copy_stack_from(&self, other: &WasiThread)

Trait Implementations

impl Clone for WasiThread

fn clone(&self) -> WasiThread

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for WasiThread

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

Formats the value using the given formatter.