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

pub struct WasiThread {
    state: Arc<WasiThreadState>,
    layout: WasiMemoryLayout,
    start: ThreadStartType,
    rewind: Option<RewindResult>,
}

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

Fields

state: Arc<WasiThreadState>

layout: WasiMemoryLayout

start: ThreadStartType

rewind: Option<RewindResult>

Implementations

impl WasiThread

pub fn id(&self) -> WasiThreadId

pub(crate) fn set_rewind(&mut self, rewind: RewindResult)

Sets that a rewind will take place

pub(crate) fn take_rewind(&mut self) -> Option<RewindResult>

Pops any rewinds that need to take place

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(crate) fn set_memory_layout(&mut self, layout: WasiMemoryLayout)

Gets the memory layout for this thread

impl WasiThread

pub fn new( pid: WasiProcessId, id: WasiThreadId, is_main: bool, status: Arc<OwnedTaskStatus>, guard: TaskCountGuard, layout: WasiMemoryLayout, start: ThreadStartType, ) -> 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 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 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.