Struct WasiSocketsCtxView

pub struct WasiSocketsCtxView<'a> {
    pub ctx: &'a mut WasiSocketsCtx,
    pub table: &'a mut ResourceTable,
}

Fields

ctx: &'a mut WasiSocketsCtx

table: &'a mut ResourceTable

Trait Implementations

impl Host for WasiSocketsCtxView<'_>

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

Get a handle to the default network.

impl Host for WasiSocketsCtxView<'_>

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 Host for WasiSocketsCtxView<'_>

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

Create a new TCP socket.

impl Host for WasiSocketsCtxView<'_>

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

Create a new UDP socket.

impl Host for WasiSocketsCtxView<'_>

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 HostIncomingDatagramStream for WasiSocketsCtxView<'_>

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

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

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

impl HostIncomingDatagramStream for WasiSocketsCtxView<'_>

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 HostNetwork for WasiSocketsCtxView<'_>

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

impl HostOutgoingDatagramStream for WasiSocketsCtxView<'_>

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

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

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

impl HostOutgoingDatagramStream for WasiSocketsCtxView<'_>

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 HostResolveAddressStream for WasiSocketsCtxView<'_>

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

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

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

impl HostTcpSocket for WasiSocketsCtxView<'_>

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<DynInputStream>, Resource<DynOutputStream>)>

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<DynInputStream>, Resource<DynOutputStream>)>

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

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 HostTcpSocket for WasiSocketsCtxView<'_>

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 HostUdpSocket for WasiSocketsCtxView<'_>

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

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

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

impl HostUdpSocket for WasiSocketsCtxView<'_>

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 Host for WasiSocketsCtxView<'_>

impl Host for WasiSocketsCtxView<'_>

impl Host for WasiSocketsCtxView<'_>

impl Host for WasiSocketsCtxView<'_>