Struct wasmtime_wasi::WasiImpl

#[repr(transparent)]
pub struct WasiImpl<T>(pub T);

A small newtype wrapper which serves as the basis for implementations of Host WASI traits in this crate.

This type is used as the basis for the implementation of all Host traits generated by bindgen! for WASI interfaces. This is used automatically with add_to_linker_sync and add_to_linker_async.

This type is otherwise provided if you’re calling the add_to_linker functions generated by bindgen! from the bindings module. In this situation you’ll want to create a value of this type in the closures added to a Linker.

Tuple Fields

0: T

Trait Implementations

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn now(&mut self) -> Result<Datetime>

Read the current value of the clock.

fn resolution(&mut self) -> Result<Datetime>

Query the resolution of the clock.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn now(&mut self) -> Result<Instant>

Read the current value of the clock.

fn resolution(&mut self) -> Result<Instant>

Query the resolution of the clock. Returns the duration of time corresponding to a clock tick.

fn subscribe_instant(&mut self, when: Instant) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the specified instant has occurred.

fn subscribe_duration( &mut self, duration: WasiDuration, ) -> Result<Resource<Pollable>>

Create a pollable that will resolve after the specified duration has elapsed from the time this function is invoked.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn convert_stream_error(&mut self, err: StreamError) -> Result<StreamError>

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn convert_error_code(&mut self, error: SocketError) -> Result<ErrorCode>

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_random_bytes(&mut self, len: u64) -> Result<Vec<u8>>

Return len cryptographically-secure random or pseudo-random bytes.

fn get_random_u64(&mut self) -> Result<u64>

Return a cryptographically-secure random or pseudo-random u64 value.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_insecure_random_bytes(&mut self, len: u64) -> Result<Vec<u8>>

Return len insecure pseudo-random bytes.

fn get_insecure_random_u64(&mut self) -> Result<u64>

Return an insecure pseudo-random u64 value.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn insecure_seed(&mut self) -> Result<(u64, u64)>

Return a 128-bit value that may contain a pseudo-random value.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn create_tcp_socket( &mut self, address_family: IpAddressFamily, ) -> SocketResult<Resource<TcpSocket>>

Create a new TCP socket.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_environment(&mut self) -> Result<Vec<(String, String)>>

Get the POSIX-style environment variables.

fn get_arguments(&mut self) -> Result<Vec<String>>

Get the POSIX-style arguments to the program.

fn initial_cwd(&mut self) -> Result<Option<String>>

Return a path that programs should use as their initial current working directory, interpreting . as shorthand for this.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn create_udp_socket( &mut self, address_family: IpAddressFamily, ) -> SocketResult<Resource<UdpSocket>>

Create a new UDP socket.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn resolve_addresses( &mut self, network: Resource<Network>, name: String, ) -> Result<Resource<ResolveAddressStream>, SocketError>

Resolve an internet host name to a list of IP addresses.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn poll<'life0, 'async_trait>( &'life0 mut self, pollables: Vec<Resource<Pollable>>, ) -> Pin<Box<dyn Future<Output = Result<Vec<u32>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Poll for completion on a set of pollables.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn poll(&mut self, pollables: Vec<Resource<Pollable>>) -> Result<Vec<u32>>

Poll for completion on a set of pollables.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_stdin(&mut self) -> Result<Resource<InputStream>, Error>

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_stdout(&mut self) -> Result<Resource<OutputStream>, Error>

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_stderr(&mut self) -> Result<Resource<OutputStream>, Error>

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_terminal_stdin(&mut self) -> Result<Option<Resource<TerminalInput>>>

If stdin is connected to a terminal, return a terminal-input handle allowing further interaction with it.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn exit(&mut self, status: Result<(), ()>) -> Result<()>

Exit the current instance and any linked instances.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_terminal_stdout(&mut self) -> Result<Option<Resource<TerminalOutput>>>

If stdout is connected to a terminal, return a terminal-output handle allowing further interaction with it.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_terminal_stderr(&mut self) -> Result<Option<Resource<TerminalOutput>>>

If stderr is connected to a terminal, return a terminal-output handle allowing further interaction with it.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn convert_error_code(&mut self, err: FsError) -> Result<ErrorCode>

fn filesystem_error_code( &mut self, err: Resource<Error>, ) -> Result<Option<ErrorCode>>

Attempts to extract a filesystem-related error-code from the stream error provided.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn get_directories( &mut self, ) -> Result<Vec<(Resource<Descriptor>, String)>, Error>

Return the set of preopened directories, and their path.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn convert_error_code(&mut self, err: FsError) -> Result<ErrorCode>

fn filesystem_error_code( &mut self, err: Resource<Error>, ) -> Result<Option<ErrorCode>>

Attempts to extract a filesystem-related error-code from the stream error provided.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn instance_network(&mut self) -> Result<Resource<Network>, Error>

Get a handle to the default network.

impl<T> Host for WasiImpl<T>

where T: WasiView,

fn convert_stream_error(&mut self, err: StreamError) -> Result<StreamError>

impl<T> HostDescriptor for WasiImpl<T>

where T: WasiView,

fn advise( &mut self, fd: Resource<Descriptor>, offset: Filesize, len: Filesize, advice: Advice, ) -> FsResult<()>

Provide file advisory information on a descriptor.

fn sync_data(&mut self, fd: Resource<Descriptor>) -> FsResult<()>

Synchronize the data of a file to disk.

fn get_flags(&mut self, fd: Resource<Descriptor>) -> FsResult<DescriptorFlags>

Get flags associated with a descriptor.

fn get_type(&mut self, fd: Resource<Descriptor>) -> FsResult<DescriptorType>

Get the dynamic type of a descriptor.

fn set_size(&mut self, fd: Resource<Descriptor>, size: Filesize) -> FsResult<()>

Adjust the size of an open file. If this increases the file’s size, the extra bytes are filled with zeros.

fn set_times( &mut self, fd: Resource<Descriptor>, atim: NewTimestamp, mtim: NewTimestamp, ) -> FsResult<()>

Adjust the timestamps of an open file or directory.

fn read( &mut self, fd: Resource<Descriptor>, len: Filesize, offset: Filesize, ) -> FsResult<(Vec<u8>, bool)>

Read from a descriptor, without using and updating the descriptor’s offset.

fn write( &mut self, fd: Resource<Descriptor>, buf: Vec<u8>, offset: Filesize, ) -> FsResult<Filesize>

Write to a descriptor, without using and updating the descriptor’s offset.

fn read_directory( &mut self, fd: Resource<Descriptor>, ) -> FsResult<Resource<DirectoryEntryStream>>

Read directory entries from a directory.

fn sync(&mut self, fd: Resource<Descriptor>) -> FsResult<()>

Synchronize the data and metadata of a file to disk.

fn create_directory_at( &mut self, fd: Resource<Descriptor>, path: String, ) -> FsResult<()>

Create a directory.

fn stat(&mut self, fd: Resource<Descriptor>) -> FsResult<DescriptorStat>

Return the attributes of an open file or directory.

fn stat_at( &mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, ) -> FsResult<DescriptorStat>

Return the attributes of a file or directory.

fn set_times_at( &mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, atim: NewTimestamp, mtim: NewTimestamp, ) -> FsResult<()>

Adjust the timestamps of a file or directory.

fn link_at( &mut self, fd: Resource<Descriptor>, old_path_flags: PathFlags, old_path: String, new_descriptor: Resource<Descriptor>, new_path: String, ) -> FsResult<()>

Create a hard link.

fn open_at( &mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, oflags: OpenFlags, flags: DescriptorFlags, ) -> FsResult<Resource<Descriptor>>

Open a file or directory.

fn drop(&mut self, fd: Resource<Descriptor>) -> Result<()>

fn readlink_at( &mut self, fd: Resource<Descriptor>, path: String, ) -> FsResult<String>

Read the contents of a symbolic link.

fn remove_directory_at( &mut self, fd: Resource<Descriptor>, path: String, ) -> FsResult<()>

Remove a directory.

fn rename_at( &mut self, fd: Resource<Descriptor>, old_path: String, new_fd: Resource<Descriptor>, new_path: String, ) -> FsResult<()>

Rename a filesystem object.

fn symlink_at( &mut self, fd: Resource<Descriptor>, src_path: String, dest_path: String, ) -> FsResult<()>

Create a symbolic link (also known as a “symlink”).

fn unlink_file_at( &mut self, fd: Resource<Descriptor>, path: String, ) -> FsResult<()>

Unlink a filesystem object that is not a directory.

fn read_via_stream( &mut self, fd: Resource<Descriptor>, offset: Filesize, ) -> FsResult<Resource<InputStream>>

Return a stream for reading from a file, if available.

fn write_via_stream( &mut self, fd: Resource<Descriptor>, offset: Filesize, ) -> FsResult<Resource<OutputStream>>

Return a stream for writing to a file, if available.

fn append_via_stream( &mut self, fd: Resource<Descriptor>, ) -> FsResult<Resource<OutputStream>>

Return a stream for appending to a file, if available.

fn is_same_object( &mut self, a: Resource<Descriptor>, b: Resource<Descriptor>, ) -> Result<bool>

Test whether two descriptors refer to the same filesystem object.

fn metadata_hash( &mut self, fd: Resource<Descriptor>, ) -> FsResult<MetadataHashValue>

Return a hash of the metadata associated with a filesystem object referred to by a descriptor.

fn metadata_hash_at( &mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, ) -> FsResult<MetadataHashValue>

Return a hash of the metadata associated with a filesystem object referred to by a directory descriptor and a relative path.

impl<T> HostDescriptor for WasiImpl<T>

where T: WasiView,

fn advise<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, offset: Filesize, len: Filesize, advice: Advice, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Provide file advisory information on a descriptor.

fn sync_data<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Synchronize the data of a file to disk.

fn get_flags<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<DescriptorFlags>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get flags associated with a descriptor.

fn get_type<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<DescriptorType>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get the dynamic type of a descriptor.

fn set_size<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, size: Filesize, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adjust the size of an open file. If this increases the file’s size, the extra bytes are filled with zeros.

fn set_times<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, atim: NewTimestamp, mtim: NewTimestamp, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adjust the timestamps of an open file or directory.

fn read<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, len: Filesize, offset: Filesize, ) -> Pin<Box<dyn Future<Output = FsResult<(Vec<u8>, bool)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read from a descriptor, without using and updating the descriptor’s offset.

fn write<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, buf: Vec<u8>, offset: Filesize, ) -> Pin<Box<dyn Future<Output = FsResult<Filesize>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Write to a descriptor, without using and updating the descriptor’s offset.

fn read_directory<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<Resource<DirectoryEntryStream>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read directory entries from a directory.

fn sync<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Synchronize the data and metadata of a file to disk.

fn create_directory_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a directory.

fn stat<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<DescriptorStat>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return the attributes of an open file or directory.

fn stat_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<DescriptorStat>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return the attributes of a file or directory.

fn set_times_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, atim: NewTimestamp, mtim: NewTimestamp, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Adjust the timestamps of a file or directory.

fn link_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, old_path_flags: PathFlags, old_path: String, new_descriptor: Resource<Descriptor>, new_path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a hard link.

fn open_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, oflags: OpenFlags, flags: DescriptorFlags, ) -> Pin<Box<dyn Future<Output = FsResult<Resource<Descriptor>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Open a file or directory.

fn drop(&mut self, fd: Resource<Descriptor>) -> Result<()>

fn readlink_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read the contents of a symbolic link.

fn remove_directory_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove a directory.

fn rename_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, old_path: String, new_fd: Resource<Descriptor>, new_path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Rename a filesystem object.

fn symlink_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, src_path: String, dest_path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Create a symbolic link (also known as a “symlink”).

fn unlink_file_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Unlink a filesystem object that is not a directory.

fn read_via_stream( &mut self, fd: Resource<Descriptor>, offset: Filesize, ) -> FsResult<Resource<InputStream>>

Return a stream for reading from a file, if available.

fn write_via_stream( &mut self, fd: Resource<Descriptor>, offset: Filesize, ) -> FsResult<Resource<OutputStream>>

Return a stream for writing to a file, if available.

fn append_via_stream( &mut self, fd: Resource<Descriptor>, ) -> FsResult<Resource<OutputStream>>

Return a stream for appending to a file, if available.

fn is_same_object<'life0, 'async_trait>( &'life0 mut self, a: Resource<Descriptor>, b: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Test whether two descriptors refer to the same filesystem object.

fn metadata_hash<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, ) -> Pin<Box<dyn Future<Output = FsResult<MetadataHashValue>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return a hash of the metadata associated with a filesystem object referred to by a descriptor.

fn metadata_hash_at<'life0, 'async_trait>( &'life0 mut self, fd: Resource<Descriptor>, path_flags: PathFlags, path: String, ) -> Pin<Box<dyn Future<Output = FsResult<MetadataHashValue>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return a hash of the metadata associated with a filesystem object referred to by a directory descriptor and a relative path.

impl<T> HostDirectoryEntryStream for WasiImpl<T>

where T: WasiView,

fn read_directory_entry( &mut self, stream: Resource<DirectoryEntryStream>, ) -> FsResult<Option<DirectoryEntry>>

Read a single directory entry from a directory-entry-stream.

fn drop(&mut self, stream: Resource<DirectoryEntryStream>) -> Result<()>

impl<T> HostDirectoryEntryStream for WasiImpl<T>

where T: WasiView,

fn read_directory_entry<'life0, 'async_trait>( &'life0 mut self, stream: Resource<DirectoryEntryStream>, ) -> Pin<Box<dyn Future<Output = FsResult<Option<DirectoryEntry>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read a single directory entry from a directory-entry-stream.

fn drop(&mut self, stream: Resource<DirectoryEntryStream>) -> Result<()>

impl<T> HostError for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, err: Resource<Error>) -> Result<()>

fn to_debug_string(&mut self, err: Resource<Error>) -> Result<String>

Returns a string that is suitable to assist humans in debugging this error.

impl<T> HostIncomingDatagramStream for WasiImpl<T>

where T: WasiView,

fn receive( &mut self, this: Resource<IncomingDatagramStream>, max_results: u64, ) -> SocketResult<Vec<IncomingDatagram>>

Receive messages on the socket.

fn subscribe( &mut self, this: Resource<IncomingDatagramStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the stream is ready to receive again.

fn drop(&mut self, this: Resource<IncomingDatagramStream>) -> Result<(), Error>

impl<T> HostIncomingDatagramStream for WasiImpl<T>

where T: WasiView,

fn receive( &mut self, self_: Resource<IncomingDatagramStream>, max_results: u64, ) -> Result<Vec<IncomingDatagram>, SocketError>

Receive messages on the socket.

fn subscribe( &mut self, self_: Resource<IncomingDatagramStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the stream is ready to receive again.

fn drop(&mut self, rep: Resource<IncomingDatagramStream>) -> Result<()>

impl<T> HostInputStream for WasiImpl<T>

where T: WasiView,

fn drop<'life0, 'async_trait>( &'life0 mut self, stream: Resource<InputStream>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn read( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<Vec<u8>>

Perform a non-blocking read from the stream.

fn blocking_read<'life0, 'async_trait>( &'life0 mut self, stream: Resource<InputStream>, len: u64, ) -> Pin<Box<dyn Future<Output = StreamResult<Vec<u8>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read bytes from a stream, after blocking until at least one byte can be read. Except for blocking, behavior is identical to read.

fn skip(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<u64>

Skip bytes from a stream. Returns number of bytes skipped.

fn blocking_skip<'life0, 'async_trait>( &'life0 mut self, stream: Resource<InputStream>, len: u64, ) -> Pin<Box<dyn Future<Output = StreamResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Skip bytes from a stream, after blocking until at least one byte can be skipped. Except for blocking behavior, identical to skip.

fn subscribe( &mut self, stream: Resource<InputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once either the specified stream has bytes available to read or the other end of the stream has been closed. The created pollable is a child resource of the input-stream. Implementations may trap if the input-stream is dropped before all derived pollables created with this function are dropped.

impl<T> HostInputStream for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, stream: Resource<InputStream>) -> Result<()>

fn read( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<Vec<u8>>

Perform a non-blocking read from the stream.

fn blocking_read( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<Vec<u8>>

Read bytes from a stream, after blocking until at least one byte can be read. Except for blocking, behavior is identical to read.

fn skip(&mut self, stream: Resource<InputStream>, len: u64) -> StreamResult<u64>

Skip bytes from a stream. Returns number of bytes skipped.

fn blocking_skip( &mut self, stream: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Skip bytes from a stream, after blocking until at least one byte can be skipped. Except for blocking behavior, identical to skip.

fn subscribe( &mut self, stream: Resource<InputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once either the specified stream has bytes available to read or the other end of the stream has been closed. The created pollable is a child resource of the input-stream. Implementations may trap if the input-stream is dropped before all derived pollables created with this function are dropped.

impl<T> HostNetwork for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, this: Resource<Network>) -> Result<(), Error>

impl<T> HostOutgoingDatagramStream for WasiImpl<T>

where T: WasiView,

fn check_send( &mut self, this: Resource<OutgoingDatagramStream>, ) -> SocketResult<u64>

Check readiness for sending. This function never blocks.

fn send<'life0, 'async_trait>( &'life0 mut self, this: Resource<OutgoingDatagramStream>, datagrams: Vec<OutgoingDatagram>, ) -> Pin<Box<dyn Future<Output = SocketResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send messages on the socket.

fn subscribe( &mut self, this: Resource<OutgoingDatagramStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the stream is ready to send again.

fn drop(&mut self, this: Resource<OutgoingDatagramStream>) -> Result<(), Error>

impl<T> HostOutgoingDatagramStream for WasiImpl<T>

where T: WasiView,

fn check_send( &mut self, self_: Resource<OutgoingDatagramStream>, ) -> Result<u64, SocketError>

Check readiness for sending. This function never blocks.

fn send( &mut self, self_: Resource<OutgoingDatagramStream>, datagrams: Vec<OutgoingDatagram>, ) -> Result<u64, SocketError>

Send messages on the socket.

fn subscribe( &mut self, self_: Resource<OutgoingDatagramStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the stream is ready to send again.

fn drop(&mut self, rep: Resource<OutgoingDatagramStream>) -> Result<()>

impl<T> HostOutputStream for WasiImpl<T>

where T: WasiView,

fn drop<'life0, 'async_trait>( &'life0 mut self, stream: Resource<OutputStream>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64>

Check readiness for writing. This function never blocks.

fn write( &mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> StreamResult<()>

Perform a write. This function never blocks.

fn subscribe( &mut self, stream: Resource<OutputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the output-stream is ready for more writing, or an error has occurred. When this pollable is ready, check-write will return ok(n) with n>0, or an error.

fn blocking_write_and_flush<'life0, 'async_trait>( &'life0 mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a write of up to 4096 bytes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn blocking_write_zeroes_and_flush<'life0, 'async_trait>( &'life0 mut self, stream: Resource<OutputStream>, len: u64, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Perform a write of up to 4096 zeroes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn write_zeroes( &mut self, stream: Resource<OutputStream>, len: u64, ) -> StreamResult<()>

Write zeroes to a stream.

fn flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()>

Request to flush buffered output. This function never blocks.

fn blocking_flush<'life0, 'async_trait>( &'life0 mut self, stream: Resource<OutputStream>, ) -> Pin<Box<dyn Future<Output = StreamResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Request to flush buffered output, and block until flush completes and stream is ready for writing again.

fn splice( &mut self, dest: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another.

fn blocking_splice<'life0, 'async_trait>( &'life0 mut self, dest: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> Pin<Box<dyn Future<Output = StreamResult<u64>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Read from one stream and write to another, with blocking.

impl<T> HostOutputStream for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, stream: Resource<OutputStream>) -> Result<()>

fn check_write(&mut self, stream: Resource<OutputStream>) -> StreamResult<u64>

Check readiness for writing. This function never blocks.

fn write( &mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> StreamResult<()>

Perform a write. This function never blocks.

fn blocking_write_and_flush( &mut self, stream: Resource<OutputStream>, bytes: Vec<u8>, ) -> StreamResult<()>

Perform a write of up to 4096 bytes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn blocking_write_zeroes_and_flush( &mut self, stream: Resource<OutputStream>, len: u64, ) -> StreamResult<()>

Perform a write of up to 4096 zeroes, and then flush the stream. Block until all of these operations are complete, or an error occurs.

fn subscribe( &mut self, stream: Resource<OutputStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the output-stream is ready for more writing, or an error has occurred. When this pollable is ready, check-write will return ok(n) with n>0, or an error.

fn write_zeroes( &mut self, stream: Resource<OutputStream>, len: u64, ) -> StreamResult<()>

Write zeroes to a stream.

fn flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()>

Request to flush buffered output. This function never blocks.

fn blocking_flush(&mut self, stream: Resource<OutputStream>) -> StreamResult<()>

Request to flush buffered output, and block until flush completes and stream is ready for writing again.

fn splice( &mut self, dst: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another.

fn blocking_splice( &mut self, dst: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another, with blocking.

impl<T> HostPollable for WasiImpl<T>

where T: WasiView,

fn block<'life0, 'async_trait>( &'life0 mut self, pollable: Resource<Pollable>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

block returns immediately if the pollable is ready, and otherwise blocks until ready.

fn ready<'life0, 'async_trait>( &'life0 mut self, pollable: Resource<Pollable>, ) -> Pin<Box<dyn Future<Output = Result<bool>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Return the readiness of a pollable. This function never blocks.

fn drop(&mut self, pollable: Resource<Pollable>) -> Result<()>

impl<T> HostPollable for WasiImpl<T>

where T: WasiView,

fn ready(&mut self, pollable: Resource<Pollable>) -> Result<bool>

Return the readiness of a pollable. This function never blocks.

fn block(&mut self, pollable: Resource<Pollable>) -> Result<()>

block returns immediately if the pollable is ready, and otherwise blocks until ready.

fn drop(&mut self, pollable: Resource<Pollable>) -> Result<()>

impl<T> HostResolveAddressStream for WasiImpl<T>

where T: WasiView,

fn resolve_next_address( &mut self, resource: Resource<ResolveAddressStream>, ) -> Result<Option<IpAddress>, SocketError>

Returns the next address from the resolver.

fn subscribe( &mut self, resource: Resource<ResolveAddressStream>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the stream is ready for I/O.

fn drop(&mut self, resource: Resource<ResolveAddressStream>) -> Result<()>

impl<T> HostTcpSocket for WasiImpl<T>

where T: WasiView,

fn start_bind<'life0, 'async_trait>( &'life0 mut self, this: Resource<TcpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> Pin<Box<dyn Future<Output = SocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

fn start_connect<'life0, 'async_trait>( &'life0 mut self, this: Resource<TcpSocket>, network: Resource<Network>, remote_address: IpSocketAddress, ) -> Pin<Box<dyn Future<Output = SocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Connect to a remote endpoint.

fn finish_connect( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<(Resource<InputStream>, Resource<OutputStream>)>

fn start_listen(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

Start listening for new connections.

fn finish_listen(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

fn accept( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<(Resource<TcpSocket>, Resource<InputStream>, Resource<OutputStream>)>

Accept a new client socket.

fn local_address( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<IpSocketAddress>

Get the bound local address.

fn remote_address( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<IpSocketAddress>

Get the remote address.

fn is_listening(&mut self, this: Resource<TcpSocket>) -> Result<bool, Error>

Whether the socket is in the listening state.

fn address_family( &mut self, this: Resource<TcpSocket>, ) -> Result<IpAddressFamily, Error>

Whether this is a IPv4 or IPv6 socket.

fn set_listen_backlog_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

Hints the desired listen queue size. Implementations are free to ignore this.

fn keep_alive_enabled( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<bool>

Enables or disables keepalive.

fn set_keep_alive_enabled( &mut self, this: Resource<TcpSocket>, value: bool, ) -> SocketResult<()>

fn keep_alive_idle_time( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

Amount of time the connection has to be idle before TCP starts sending keepalive packets.

fn set_keep_alive_idle_time( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn keep_alive_interval( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

The time between keepalive packets.

fn set_keep_alive_interval( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn keep_alive_count(&mut self, this: Resource<TcpSocket>) -> SocketResult<u32>

The maximum amount of keepalive packets TCP should send before aborting the connection.

fn set_keep_alive_count( &mut self, this: Resource<TcpSocket>, value: u32, ) -> SocketResult<()>

fn hop_limit(&mut self, this: Resource<TcpSocket>) -> SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_hop_limit( &mut self, this: Resource<TcpSocket>, value: u8, ) -> SocketResult<()>

fn receive_buffer_size( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn send_buffer_size(&mut self, this: Resource<TcpSocket>) -> SocketResult<u64>

fn set_send_buffer_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn subscribe(&mut self, this: Resource<TcpSocket>) -> Result<Resource<Pollable>>

Create a pollable which can be used to poll for, or block on, completion of any of the asynchronous operations of this socket.

fn shutdown( &mut self, this: Resource<TcpSocket>, shutdown_type: ShutdownType, ) -> SocketResult<()>

Initiate a graceful shutdown.

fn drop(&mut self, this: Resource<TcpSocket>) -> Result<(), Error>

impl<T> HostTcpSocket for WasiImpl<T>

where T: WasiView,

fn start_bind( &mut self, self_: Resource<TcpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> Result<(), SocketError>

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, self_: Resource<TcpSocket>) -> Result<(), SocketError>

fn start_connect( &mut self, self_: Resource<TcpSocket>, network: Resource<Network>, remote_address: IpSocketAddress, ) -> Result<(), SocketError>

Connect to a remote endpoint.

fn finish_connect( &mut self, self_: Resource<TcpSocket>, ) -> Result<(Resource<InputStream>, Resource<OutputStream>), SocketError>

fn start_listen( &mut self, self_: Resource<TcpSocket>, ) -> Result<(), SocketError>

Start listening for new connections.

fn finish_listen( &mut self, self_: Resource<TcpSocket>, ) -> Result<(), SocketError>

fn accept( &mut self, self_: Resource<TcpSocket>, ) -> Result<(Resource<TcpSocket>, Resource<InputStream>, Resource<OutputStream>), SocketError>

Accept a new client socket.

fn local_address( &mut self, self_: Resource<TcpSocket>, ) -> Result<IpSocketAddress, SocketError>

Get the bound local address.

fn remote_address( &mut self, self_: Resource<TcpSocket>, ) -> Result<IpSocketAddress, SocketError>

Get the remote address.

fn is_listening(&mut self, self_: Resource<TcpSocket>) -> Result<bool>

Whether the socket is in the listening state.

fn address_family( &mut self, self_: Resource<TcpSocket>, ) -> Result<IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn set_listen_backlog_size( &mut self, self_: Resource<TcpSocket>, value: u64, ) -> Result<(), SocketError>

Hints the desired listen queue size. Implementations are free to ignore this.

fn keep_alive_enabled( &mut self, self_: Resource<TcpSocket>, ) -> Result<bool, SocketError>

Enables or disables keepalive.

fn set_keep_alive_enabled( &mut self, self_: Resource<TcpSocket>, value: bool, ) -> Result<(), SocketError>

fn keep_alive_idle_time( &mut self, self_: Resource<TcpSocket>, ) -> Result<Duration, SocketError>

Amount of time the connection has to be idle before TCP starts sending keepalive packets.

fn set_keep_alive_idle_time( &mut self, self_: Resource<TcpSocket>, value: Duration, ) -> Result<(), SocketError>

fn keep_alive_interval( &mut self, self_: Resource<TcpSocket>, ) -> Result<Duration, SocketError>

The time between keepalive packets.

fn set_keep_alive_interval( &mut self, self_: Resource<TcpSocket>, value: Duration, ) -> Result<(), SocketError>

fn keep_alive_count( &mut self, self_: Resource<TcpSocket>, ) -> Result<u32, SocketError>

The maximum amount of keepalive packets TCP should send before aborting the connection.

fn set_keep_alive_count( &mut self, self_: Resource<TcpSocket>, value: u32, ) -> Result<(), SocketError>

fn hop_limit(&mut self, self_: Resource<TcpSocket>) -> Result<u8, SocketError>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_hop_limit( &mut self, self_: Resource<TcpSocket>, value: u8, ) -> Result<(), SocketError>

fn receive_buffer_size( &mut self, self_: Resource<TcpSocket>, ) -> Result<u64, SocketError>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, self_: Resource<TcpSocket>, value: u64, ) -> Result<(), SocketError>

fn send_buffer_size( &mut self, self_: Resource<TcpSocket>, ) -> Result<u64, SocketError>

fn set_send_buffer_size( &mut self, self_: Resource<TcpSocket>, value: u64, ) -> Result<(), SocketError>

fn subscribe( &mut self, self_: Resource<TcpSocket>, ) -> Result<Resource<Pollable>>

Create a pollable which can be used to poll for, or block on, completion of any of the asynchronous operations of this socket.

fn shutdown( &mut self, self_: Resource<TcpSocket>, shutdown_type: ShutdownType, ) -> Result<(), SocketError>

Initiate a graceful shutdown.

fn drop(&mut self, rep: Resource<TcpSocket>) -> Result<()>

impl<T> HostTerminalInput for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, r: Resource<TerminalInput>) -> Result<()>

impl<T> HostTerminalOutput for WasiImpl<T>

where T: WasiView,

fn drop(&mut self, r: Resource<TerminalOutput>) -> Result<()>

impl<T> HostUdpSocket for WasiImpl<T>

where T: WasiView,

fn start_bind<'life0, 'async_trait>( &'life0 mut self, this: Resource<UdpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> Pin<Box<dyn Future<Output = SocketResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, this: Resource<UdpSocket>) -> SocketResult<()>

fn stream<'life0, 'async_trait>( &'life0 mut self, this: Resource<UdpSocket>, remote_address: Option<IpSocketAddress>, ) -> Pin<Box<dyn Future<Output = SocketResult<(Resource<IncomingDatagramStream>, Resource<OutgoingDatagramStream>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Set up inbound & outbound communication channels, optionally to a specific peer.

fn local_address( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<IpSocketAddress>

Get the current bound address.

fn remote_address( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<IpSocketAddress>

Get the address the socket is currently streaming to.

fn address_family( &mut self, this: Resource<UdpSocket>, ) -> Result<IpAddressFamily, Error>

Whether this is a IPv4 or IPv6 socket.

fn unicast_hop_limit(&mut self, this: Resource<UdpSocket>) -> SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_unicast_hop_limit( &mut self, this: Resource<UdpSocket>, value: u8, ) -> SocketResult<()>

fn receive_buffer_size( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<u64>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, this: Resource<UdpSocket>, value: u64, ) -> SocketResult<()>

fn send_buffer_size(&mut self, this: Resource<UdpSocket>) -> SocketResult<u64>

fn set_send_buffer_size( &mut self, this: Resource<UdpSocket>, value: u64, ) -> SocketResult<()>

fn subscribe(&mut self, this: Resource<UdpSocket>) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the socket is ready for I/O.

fn drop(&mut self, this: Resource<UdpSocket>) -> Result<(), Error>

impl<T> HostUdpSocket for WasiImpl<T>

where T: WasiView,

fn start_bind( &mut self, self_: Resource<UdpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> Result<(), SocketError>

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, self_: Resource<UdpSocket>) -> Result<(), SocketError>

fn stream( &mut self, self_: Resource<UdpSocket>, remote_address: Option<IpSocketAddress>, ) -> Result<(Resource<IncomingDatagramStream>, Resource<OutgoingDatagramStream>), SocketError>

Set up inbound & outbound communication channels, optionally to a specific peer.

fn local_address( &mut self, self_: Resource<UdpSocket>, ) -> Result<IpSocketAddress, SocketError>

Get the current bound address.

fn remote_address( &mut self, self_: Resource<UdpSocket>, ) -> Result<IpSocketAddress, SocketError>

Get the address the socket is currently streaming to.

fn address_family( &mut self, self_: Resource<UdpSocket>, ) -> Result<IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn unicast_hop_limit( &mut self, self_: Resource<UdpSocket>, ) -> Result<u8, SocketError>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_unicast_hop_limit( &mut self, self_: Resource<UdpSocket>, value: u8, ) -> Result<(), SocketError>

fn receive_buffer_size( &mut self, self_: Resource<UdpSocket>, ) -> Result<u64, SocketError>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, self_: Resource<UdpSocket>, value: u64, ) -> Result<(), SocketError>

fn send_buffer_size( &mut self, self_: Resource<UdpSocket>, ) -> Result<u64, SocketError>

fn set_send_buffer_size( &mut self, self_: Resource<UdpSocket>, value: u64, ) -> Result<(), SocketError>

fn subscribe( &mut self, self_: Resource<UdpSocket>, ) -> Result<Resource<Pollable>>

Create a pollable which will resolve once the socket is ready for I/O.

fn drop(&mut self, rep: Resource<UdpSocket>) -> Result<()>

impl<T: WasiView> WasiView for WasiImpl<T>

fn table(&mut self) -> &mut ResourceTable

Yields mutable access to the internal resource management that this context contains.

fn ctx(&mut self) -> &mut WasiCtx

Yields mutable access to the configuration used for this context.

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,

impl<T> Host for WasiImpl<T>

where T: WasiView,