Struct wasmer_wasix::syscalls::journal::JournalSyscallPlayer

pub struct JournalSyscallPlayer<'a, 'c> {

    pub ctx: FunctionEnvMut<'c, WasiEnv>,
    pub bootstrapping: bool,
    pub journal_module_hash: Option<Box<[u8]>>,
    pub rewind: Option<RewindState>,
    pub cur_module_hash: Box<[u8]>,
    pub real_fd: HashSet<Fd>,
    pub connected_sockets_are_dead: bool,
    pub spawn_threads: BTreeMap<WasiThreadId, RewindState>,
    pub staged_differ_memory: Vec<(Range<u64>, Cow<'a, [u8]>)>,
    pub differ_memory: Vec<(Range<u64>, Cow<'a, [u8]>)>,
    pub stdout: Vec<(u64, Cow<'a, [u8]>, bool)>,
    pub stderr: Vec<(u64, Cow<'a, [u8]>, bool)>,
    pub stdout_fds: HashSet<u32>,
    pub stderr_fds: HashSet<u32>,
}

Fields

ctx: FunctionEnvMut<'c, WasiEnv>

bootstrapping: bool

journal_module_hash: Option<Box<[u8]>>

rewind: Option<RewindState>

cur_module_hash: Box<[u8]>

real_fd: HashSet<Fd>

connected_sockets_are_dead: bool

spawn_threads: BTreeMap<WasiThreadId, RewindState>

staged_differ_memory: Vec<(Range<u64>, Cow<'a, [u8]>)>

differ_memory: Vec<(Range<u64>, Cow<'a, [u8]>)>

stdout: Vec<(u64, Cow<'a, [u8]>, bool)>

stderr: Vec<(u64, Cow<'a, [u8]>, bool)>

stdout_fds: HashSet<u32>

stderr_fds: HashSet<u32>

Implementations

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_close_thread( &mut self, id: u32, exit_code: Option<ExitCode>, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_advise( &mut self, fd: Fd, offset: Filesize, len: Filesize, advice: Advice, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_allocate( &mut self, fd: Fd, offset: Filesize, len: Filesize, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_close( &mut self, fd: u32, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_dup( &mut self, original_fd: u32, copied_fd: u32, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_open( &mut self, fd: u32, dirfd: u32, dirflags: u32, path: Cow<'a, str>, o_flags: Oflags, fs_rights_base: Rights, fs_rights_inheriting: Rights, fs_flags: Fdflags, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_renumber( &mut self, old_fd: u32, new_fd: u32, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_seek( &mut self, fd: u32, offset: i64, whence: Whence, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_set_flags( &mut self, fd: Fd, flags: Fdflags, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_set_rights( &mut self, fd: Fd, fs_rights_base: Rights, fs_rights_inheriting: Rights, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_set_size( &mut self, fd: Fd, st_size: Filesize, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_set_times( &mut self, fd: Fd, st_atim: Timestamp, st_mtim: Timestamp, fst_flags: Fstflags, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_fd_write( &mut self, fd: u32, offset: u64, data: Cow<'a, [u8]>, is_64bit: bool, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_init_module( &mut self, wasm_hash: Box<[u8]>, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_path_set_times( &mut self, fd: Fd, flags: LookupFlags, path: Cow<'_, str>, st_atim: Timestamp, st_mtim: Timestamp, fst_flags: Fstflags, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_process_exit( &mut self, exit_code: Option<ExitCode>, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_set_thread( &mut self, id: u32, call_stack: Cow<'a, [u8]>, memory_stack: Cow<'a, [u8]>, store_data: Cow<'a, [u8]>, is_64bit: bool, start: ThreadStartType, layout: WasiMemoryLayout, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_snapshot( &mut self, when: SystemTime, trigger: SnapshotTrigger, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_tty_set( &mut self, tty: Tty, line_feeds: bool, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(crate) unsafe fn action_update_compressed_memory( &mut self, region: Range<u64>, compressed_data: Cow<'a, [u8]>, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(super) fn clear_ethereal( &mut self, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, )

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub(super) unsafe fn play_event( &mut self, next: JournalEntry<'a>, differ_ethereal: Option<&mut Vec<JournalEntry<'a>>>, ) -> Result<(), WasiRuntimeError>

impl<'a, 'c> JournalSyscallPlayer<'a, 'c>

pub fn new(ctx: FunctionEnvMut<'c, WasiEnv>, bootstrapping: bool) -> Self