Struct 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>

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

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

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,

async 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 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.

fn exit_with_code(&mut self, status_code: u8) -> Result<()>

Exit the current instance and any linked instances, reporting the specified status code to the host.

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 paths.

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,

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

Provide file advisory information on a descriptor.

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

Synchronize the data of a file to disk.

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

Get flags associated with a descriptor.

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

Get the dynamic type of a descriptor.

async 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.

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

Adjust the timestamps of an open file or directory.

async 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.

async 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.

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

Read directory entries from a directory.

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

Synchronize the data and metadata of a file to disk.

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

Create a directory.

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

Return the attributes of an open file or directory.

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

Return the attributes of a file or directory.

async 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.

async 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.

async 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<()>

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

Read the contents of a symbolic link.

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

Remove a directory.

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

Rename a filesystem object.

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

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

async 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.

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

Test whether two descriptors refer to the same filesystem object.

async 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.

async 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> 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,

async 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> 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,

async 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.

async 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.

async 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> 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.

async fn send( &mut self, this: Resource<OutgoingDatagramStream>, datagrams: Vec<OutgoingDatagram>, ) -> SocketResult<u64>

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,

async 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 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.

async 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.

async 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 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.

async 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, dest: Resource<OutputStream>, src: Resource<InputStream>, len: u64, ) -> StreamResult<u64>

Read from one stream and write to another.

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

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,

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

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

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

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,

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

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

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

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

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,

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

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

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

async fn stream( &mut self, this: Resource<UdpSocket>, remote_address: Option<IpSocketAddress>, ) -> SocketResult<(Resource<IncomingDatagramStream>, Resource<OutgoingDatagramStream>)>

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,