Struct wasmer_wasix::fs::WasiFs

source ·
pub struct WasiFs {
    pub preopen_fds: RwLock<Vec<u32>>,
    pub fd_map: Arc<RwLock<FdList>>,
    pub current_dir: Mutex<String>,
    pub root_fs: WasiFsRoot,
    pub root_inode: InodeGuard,
    pub has_unioned: Arc<Mutex<HashSet<PackageId>>>,
    is_wasix: AtomicBool,
    pub(crate) init_preopens: Vec<PreopenedDir>,
    pub(crate) init_vfs_preopens: Vec<String>,
}
Expand description

Warning, modifying these fields directly may cause invariants to break and should be considered unsafe. These fields may be made private in a future release

Fields§

§preopen_fds: RwLock<Vec<u32>>§fd_map: Arc<RwLock<FdList>>§current_dir: Mutex<String>§root_fs: WasiFsRoot§root_inode: InodeGuard§has_unioned: Arc<Mutex<HashSet<PackageId>>>§is_wasix: AtomicBool§init_preopens: Vec<PreopenedDir>§init_vfs_preopens: Vec<String>

Implementations§

source§

impl WasiFs

source

pub fn is_wasix(&self) -> bool

source

pub fn set_is_wasix(&self, is_wasix: bool)

source

pub fn fork(&self) -> Self

Forking the WasiState is used when either fork or vfork is called

source

pub async fn close_all(&self)

Closes all the file handles.

source

pub async fn conditional_union( &self, binary: &BinaryPackage, ) -> Result<(), FsError>

Will conditionally union the binary file system with this one if it has not already been unioned

source

pub(crate) fn new_with_preopen( inodes: &WasiInodes, preopens: &[PreopenedDir], vfs_preopens: &[String], fs_backing: WasiFsRoot, ) -> Result<Self, String>

Created for the builder API. like new but with more information

source

pub(crate) fn relative_path_to_absolute(&self, path: String) -> String

Converts a relative path into an absolute path

source

fn new_init( fs_backing: WasiFsRoot, inodes: &WasiInodes, st_ino: Inode, ) -> Result<Self, String>

Private helper function to init the filesystem, called in new and new_with_preopen

source

pub unsafe fn open_dir_all( &mut self, inodes: &WasiInodes, base: WasiFd, name: String, rights: Rights, rights_inheriting: Rights, flags: Fdflags, ) -> Result<WasiFd, FsError>

This function is like create dir all, but it also opens it. Function is unsafe because it may break invariants and hasn’t been tested. This is an experimental function and may be removed

§Safety
  • Virtual directories created with this function must not conflict with the standard operation of the WASI filesystem. This is vague and unlikely in pratice. Join the discussion for what the newer, safer WASI FS APIs should look like.
source

pub fn open_file_at( &mut self, inodes: &WasiInodes, base: WasiFd, file: Box<dyn VirtualFile + Send + Sync + 'static>, open_flags: u16, name: String, rights: Rights, rights_inheriting: Rights, flags: Fdflags, ) -> Result<WasiFd, FsError>

Opens a user-supplied file in the directory specified with the name and flags given

source

pub fn swap_file( &self, fd: WasiFd, file: Box<dyn VirtualFile + Send + Sync + 'static>, ) -> Result<Option<Box<dyn VirtualFile + Send + Sync + 'static>>, FsError>

Change the backing of a given file descriptor Returns the old backing TODO: add examples

source

pub fn filestat_resync_size(&self, fd: WasiFd) -> Result<Filesize, Errno>

refresh size from filesystem

source

pub fn set_current_dir(&self, path: &str)

Changes the current directory

source

pub fn get_current_dir( &self, inodes: &WasiInodes, base: WasiFd, ) -> Result<(InodeGuard, String), Errno>

Gets the current directory

source

pub(crate) fn get_current_dir_inner( &self, inodes: &WasiInodes, base: WasiFd, symlink_count: u32, ) -> Result<(InodeGuard, String), Errno>

source

fn get_inode_at_path_inner( &self, inodes: &WasiInodes, cur_inode: InodeGuard, path_str: &str, symlink_count: u32, follow_symlinks: bool, ) -> Result<InodeGuard, Errno>

Internal part of the core path resolution function which implements path traversal logic such as resolving relative path segments (such as . and ..) and resolving symlinks (while preventing infinite loops/stack overflows).

TODO: expand upon exactly what the state of the returned value is, explaining lazy-loading from the real file system and synchronizing between them.

This is where a lot of the magic happens, be very careful when editing this code.

TODO: write more tests for this code

source

fn path_into_pre_open_and_relative_path<'path>( &self, path: &'path Path, ) -> Result<(WasiFd, &'path Path), Errno>

Finds the preopened directory that is the “best match” for the given path and returns a path relative to this preopened directory.

The “best match” is the preopened directory that has the longest prefix of the given path. For example, given preopened directories [a, a/b, a/c] and the path a/b/c/file, we will return the fd corresponding to the preopened directory, a/b and the relative path c/file.

In the case of a tie, the later preopened fd is preferred.

source

pub(crate) fn path_depth_from_fd( &self, fd: WasiFd, inode: InodeGuard, ) -> Result<usize, Errno>

finds the number of directories between the fd and the inode if they’re connected expects inode to point to a directory

source

pub(crate) fn get_inode_at_path( &self, inodes: &WasiInodes, base: WasiFd, path: &str, follow_symlinks: bool, ) -> Result<InodeGuard, Errno>

gets a host file from a base directory and a path this function ensures the fs remains sandboxed

source

pub(crate) fn get_parent_inode_at_path( &self, inodes: &WasiInodes, base: WasiFd, path: &Path, follow_symlinks: bool, ) -> Result<(InodeGuard, String), Errno>

Returns the parent Dir or Root that the file at a given path is in and the file name stripped off

source

pub fn get_fd(&self, fd: WasiFd) -> Result<Fd, Errno>

source

pub fn get_fd_inode(&self, fd: WasiFd) -> Result<InodeGuard, Errno>

source

pub fn filestat_fd(&self, fd: WasiFd) -> Result<Filestat, Errno>

source

pub fn fdstat(&self, fd: WasiFd) -> Result<Fdstat, Errno>

source

pub fn prestat_fd(&self, fd: WasiFd) -> Result<Prestat, Errno>

source

pub(crate) fn prestat_fd_inner(&self, inode_val: &InodeVal) -> Prestat

source

pub async fn flush(&self, fd: WasiFd) -> Result<(), Errno>

source

pub(crate) fn create_inode( &self, inodes: &WasiInodes, kind: Kind, is_preopened: bool, name: String, ) -> Result<InodeGuard, Errno>

Creates an inode and inserts it given a Kind and some extra data

source

pub(crate) fn create_inode_with_default_stat( &self, inodes: &WasiInodes, kind: Kind, is_preopened: bool, name: Cow<'static, str>, ) -> InodeGuard

Creates an inode and inserts it given a Kind, does not assume the file exists.

source

pub(crate) fn create_inode_with_stat( &self, inodes: &WasiInodes, kind: Kind, is_preopened: bool, name: Cow<'static, str>, stat: Filestat, ) -> InodeGuard

Creates an inode with the given filestat and inserts it.

source

pub fn create_fd( &self, rights: Rights, rights_inheriting: Rights, flags: Fdflags, open_flags: u16, inode: InodeGuard, ) -> Result<WasiFd, Errno>

source

pub fn with_fd( &self, rights: Rights, rights_inheriting: Rights, flags: Fdflags, open_flags: u16, inode: InodeGuard, idx: WasiFd, ) -> Result<(), Errno>

source

pub fn create_fd_ext( &self, rights: Rights, rights_inheriting: Rights, flags: Fdflags, open_flags: u16, inode: InodeGuard, idx: Option<WasiFd>, exclusive: bool, ) -> Result<WasiFd, Errno>

source

pub fn clone_fd(&self, fd: WasiFd) -> Result<WasiFd, Errno>

source

pub unsafe fn remove_inode( &self, inodes: &WasiInodes, ino: Inode, ) -> Option<Arc<InodeVal>>

Low level function to remove an inode, that is it deletes the WASI FS’s knowledge of a file.

This function returns the inode if it existed and was removed.

§Safety
  • The caller must ensure that all references to the specified inode have been removed from the filesystem.
source

pub(crate) fn create_stdout(&self, inodes: &WasiInodes)

source

pub(crate) fn create_stdin(&self, inodes: &WasiInodes)

source

pub(crate) fn create_stderr(&self, inodes: &WasiInodes)

source

pub(crate) fn create_rootfd(&self) -> Result<(), String>

source

pub(crate) fn create_preopens( &self, inodes: &WasiInodes, ignore_duplicates: bool, ) -> Result<(), String>

source

pub(crate) fn create_std_dev_inner( &self, inodes: &WasiInodes, handle: Box<dyn VirtualFile + Send + Sync + 'static>, name: &'static str, raw_fd: WasiFd, rights: Rights, fd_flags: Fdflags, st_ino: Inode, )

source

pub fn get_stat_for_kind(&self, kind: &Kind) -> Result<Filestat, Errno>

source

pub(crate) fn close_fd(&self, fd: WasiFd) -> Result<(), Errno>

Closes an open FD, handling all details such as FD being preopen

Trait Implementations§

source§

impl Debug for WasiFs

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl !Freeze for WasiFs

§

impl !RefUnwindSafe for WasiFs

§

impl Send for WasiFs

§

impl Sync for WasiFs

§

impl Unpin for WasiFs

§

impl !UnwindSafe for WasiFs

Blanket Implementations§

source§

impl<T> Any for T
where T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
§

impl<T> ArchivePointee for T

§

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.
§

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.
source§

impl<T> Borrow<T> for T
where T: ?Sized,

source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

source§

fn from(t: T) -> T

Returns the argument unchanged.

§

impl<T> Instrument for T

§

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided [Span], returning an Instrumented wrapper. Read more
§

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more
source§

impl<T, U> Into<U> for T
where U: From<T>,

source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> IntoEither for T

source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
§

impl<T> LayoutRaw for T

§

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Returns the layout of the type.
§

impl<T> Pointable for T

§

const ALIGN: usize = _

The alignment of pointer.
§

type Init = T

The type for initializers.
§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
§

impl<T> Pointee for T

§

type Metadata = ()

The metadata type for pointers and references to this type.
source§

impl<T> Same for T

§

type Output = T

Should always be Self
source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
§

impl<T> Upcastable for T
where T: Any + Debug + 'static,

§

fn upcast_any_ref(&self) -> &(dyn Any + 'static)

§

fn upcast_any_mut(&mut self) -> &mut (dyn Any + 'static)

§

fn upcast_any_box(self: Box<T>) -> Box<dyn Any>

§

impl<T> Upcastable for T
where T: Any + Send + Sync + 'static,

§

fn upcast_any_ref(&self) -> &(dyn Any + 'static)

upcast ref
§

fn upcast_any_mut(&mut self) -> &mut (dyn Any + 'static)

upcast mut ref
§

fn upcast_any_box(self: Box<T>) -> Box<dyn Any>

upcast boxed dyn
§

impl<V, T> VZip<V> for T
where V: MultiLane<T>,

§

fn vzip(self) -> V

§

impl<T> WithSubscriber for T

§

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a [WithDispatch] wrapper. Read more
§

impl<A, B, T> HttpServerConnExec<A, B> for T
where B: Body,