Struct wasmer_wasix::os::task::thread::WasiThreadHandle

pub struct WasiThreadHandle {
    protected: Arc<WasiThreadHandleProtected>,
}

Fields

protected: Arc<WasiThreadHandleProtected>

Implementations

impl WasiThreadHandle

pub(crate) fn new( thread: WasiThread, inner: &Arc<(Mutex<WasiProcessInner>, Condvar)>, ) -> WasiThreadHandle

pub fn id(&self) -> WasiThreadId

pub fn as_thread(&self) -> WasiThread

Methods from Deref<Target = WasiThread>

pub fn id(&self) -> WasiThreadId

pub fn thread_start_type(&self) -> ThreadStartType

Gets the thread start type for this thread

pub(crate) fn has_rewind_of_type(&self, type_: HandleRewindType) -> bool

Returns true if a rewind of a particular type has been queued for processed by a rewind operation

pub(crate) fn set_deep_sleeping(&self, val: bool)

Sets a flag that tells others if this thread is currently deep sleeping

pub(crate) fn is_deep_sleeping(&self) -> bool

Reads a flag that determines if this thread is currently deep sleeping

pub(crate) fn set_checkpointing(&self, val: bool)

Sets a flag that tells others that this thread is currently check pointing itself

pub(crate) fn is_check_pointing(&self) -> bool

Reads a flag that determines if this thread is currently check pointing itself or not

pub(crate) fn memory_layout(&self) -> &WasiMemoryLayout

Gets the memory layout for this thread

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 async fn wait_for_signal(&self)

Waits for a signal to arrive

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 WasiThreadHandle

fn clone(&self) -> WasiThreadHandle

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for WasiThreadHandle

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

Formats the value using the given formatter.

impl Deref for WasiThreadHandle

type Target = WasiThread

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.