Package ej.wasi.io.socket

Class WasiSocket

java.lang.Object

ej.wasi.io.socket.WasiSocket

All Implemented Interfaces:

ReadableIO, WasiSocketOpt, WasiIO, WritableIO, WasiConstants, Closeable, AutoCloseable

public class WasiSocket
extends Object
implements WasiSocketOpt, ReadableIO, WritableIO, WasiConstants

Field Summary

Fields inherited from interface ej.wasi.WasiConstants

AF_INET, AF_INET6, BLOCKING_CONNECT_TIMEOUT, BUFFERED_INPUT_STREAM_SIZE, CLOCK_MONOTONIC, CLOCK_REALTIME, DIRENT_COOKIE_OFFSET, DIRENT_ENTRY_NAME_LENGTH_OFFSET, DIRENT_FILE_TYPE_OFFSET, DIRENT_INODE_OFFSET, DIRENT_SIZE, ERRNO_ACCES, ERRNO_ADDRINUSE, ERRNO_ADDRNOTAVAIL, ERRNO_AFNOSUPPORT, ERRNO_AGAIN, ERRNO_BADF, ERRNO_CONNREFUSED, ERRNO_EXIST, ERRNO_FAULT, ERRNO_HOSTUNREACH, ERRNO_INPROGRESS, ERRNO_INTR, ERRNO_INVAL, ERRNO_IO, ERRNO_ISCONN, ERRNO_ISDIR, ERRNO_MSGSIZE, ERRNO_NAMETOOLONG, ERRNO_NOENT, ERRNO_NOMEM, ERRNO_NOSYS, ERRNO_NOTCONN, ERRNO_NOTDIR, ERRNO_NOTEMPTY, ERRNO_NOTSOCK, ERRNO_NOTSUP, ERRNO_OVERFLOW, ERRNO_SPIPE, ERRNO_SUCCESS, EVENT_AVAILABLE_BYTE_OFFSET, EVENT_ERROR_OFFSET, EVENT_EVENT_TYPE_OFFSET, EVENT_READ_WRITE_HANGUP_OFFSET, EVENT_SIZE, EVENT_USER_DATA_OFFSET, FDFLAGS_APPEND_MASK, FDFLAGS_NON_BLOCK_MASK, FDSTAT_BASE_RIGHTS_OFFSET, FDSTAT_FILE_TYPE_OFFSET, FDSTAT_FLAGS_OFFSET, FDSTAT_INHERITING_RIGHTS_OFFSET, FILESTAT_FILESIZE_OFFSET, FILESTAT_FILETYPE_OFFSET, FILESTAT_INODE_OFFSET, FILESTAT_LAST_MODIFIED_TIME_OFFSET, IFF_LOOPBACK, IFF_RUNNING, IFF_UP, IOVEC_BUFFER_INDEX, IOVEC_BUFFER_LENGTH_INDEX, IOVEC_SIZE, IP_ADD_MEMBERSHIP, IP_DROP_MEMBERSHIP, IP_MULTICAST_IF, IP_MULTICAST_LOOP, IP_MULTICAST_TTL, IP_TTL, IPPROTO_IP, IPPROTO_IPV6, IPv4AddressSize, IPV6_JOIN_GROUP, IPV6_LEAVE_GROUP, IPV6_MULTICAST_HOPS, IPV6_MULTICAST_IF, IPV6_MULTICAST_LOOP, IPV6_UNICAST_HOPS, IPv6AddressSize, LOOKUPFLAGS_SYMLINK_FOLLOW_MASK, MILLIS_TO_NANO, NON_BLOCKING_TIMEOUT, OFLAGS_CREAT_MASK, OFLAGS_DIRECTORY_MASK, OFLAGS_EXCL_MASK, OFLAGS_TRUNC_MASK, POLLING_TIMEOUT, PREOPENTYPE_DIR, PREOPENTYPE_UNKNOWN, PRESTAT_PREOPEN_DIRNAME_OFFSET, PRESTAT_PREOPEN_TAG_OFFSET, RIFLAGS_MSG_PEEK_MASK, RIFLAGS_WAITALL_MASK, RIGHTS_ALL, RIGHTS_DIR, SDFLAGS_READ, SDFLAGS_WRITE, SO_BROADCAST, SO_RCVBUF, SO_REUSEADDR, SO_SNDBUF, SOCK_CLOEXEC, SOCK_NONBLOCK, SOCKET_LEVEL, UDP_PEEK_BUFFER_MAX_SIZE

Constructor Summary

Constructors

Constructor	Description
WasiSocket()
WasiSocket(Socket socket)

Method Summary

Modifier and Type	Method	Description
void	attachWasiSSL(WasiSSL wasiSSL)	Attach a WasiSSL context with the current WasiSocket.
int	available()	Retrieve the number of bytes available for reading on the socket.
void	close()	Closes this stream and releases any system resources associated with it.
int	connect(InetSocketAddress address)
boolean	getBroadcast()	Get the SO_BROADCAST socket option.
SocketAddress	getLocalSocketAddress()
int	getReceiveBufferSize()	Get the receive buffer size (SO_RCVBUF).
SocketAddress	getRemoteSocketAddress()
int	getSendBufferSize()	Get the send buffer size (SO_SNDBUF).
Socket	getSocket()
FileType	getType()	Gets the WasiIO file descriptor type.
WasiSSL	getWasiSSL()	Retrieve the associated WasiSSL context.
boolean	isConnected()
boolean	isConnectionReset()	Check whether the connection been reset by the peer.
boolean	isNonBlocking()
boolean	isReuseAddress()
int	read(byte[] data, int offset, int len)	Reads length bytes of data from this WasiIO into an array of bytes.
void	setBroadcast(boolean on)	Enable/disable the SO_BROADCAST socket option.
void	setNonBlocking(boolean nonBlockingMode)	Enable/disable the non blocking state on this WasiIO
void	setReceiveBufferSize(int size)	Set the receive buffer size (SO_RCVBUF).
void	setReuseAddress(boolean on)	Enable/disable the reuse address socket option.
void	setSendBufferSize(int size)	Set the send buffer size (SO_SNDBUF).
int	wasiShutdown(int how)
int	wasiSockReceive(int iovecListPtr, int iovecLen, int riFlags, int nbRecvPtr, int roFlagsPtr, byte[] memory)
int	wasiSockSend(int iovecListPtr, int iovecLen, int nbSendPtr, byte[] memory)
void	write(byte[] data, int offset, int len)	Writes length bytes from t he specified byte array starting at offset offset to this WasiIO.

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WasiSocket

public WasiSocket()

WasiSocket

public WasiSocket(Socket socket)
           throws IOException

Throws:

IOException

Method Detail

isConnected

public boolean isConnected()

connect

public int connect(InetSocketAddress address)

read

public int read(byte[] data,
                int offset,
                int len)
         throws IOException

Description copied from interface: ReadableIO

Reads length bytes of data from this WasiIO into an array of bytes.

Specified by:

read in interface ReadableIO

Parameters:

data - the buffer into which the data is read.

offset - the start offset in array b at which the data is written.

len - the maximum number of bytes to read.

Returns:

the total number of bytes read into the buffer or -1 if there is no more data.

Throws:

IOException - if an I/O error occurs.

write

public void write(byte[] data,
                  int offset,
                  int len)
           throws IOException

Description copied from interface: WritableIO

Writes length bytes from t he specified byte array starting at offset offset to this WasiIO.

Specified by:

write in interface WritableIO

Parameters:

data - the data to write.

offset - the starting offset.

len - the number of bytes to write.

Throws:

IOException - if an I/O error occurs.

close

public void close()
           throws IOException

Description copied from interface: Closeable

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException - if an I/O error occurs

available

public int available()
              throws IOException

Retrieve the number of bytes available for reading on the socket.

Specified by:

available in interface ReadableIO

Returns:

the number of bytes available for reading on the socket.

Throws:

IOException - if an I/O error occurs.

getType

public FileType getType()

Description copied from interface: WasiIO

Gets the WasiIO file descriptor type.

Specified by:

getType in interface WasiIO

Returns:

the WasiIO file descriptor type.

setNonBlocking

public void setNonBlocking(boolean nonBlockingMode)

Description copied from interface: WasiSocketOpt

Enable/disable the non blocking state on this WasiIO

Specified by:

setNonBlocking in interface ReadableIO

Specified by:

setNonBlocking in interface WasiSocketOpt

Parameters:

nonBlockingMode - whether to enable or disable the non-blocking socket option

setBroadcast

public void setBroadcast(boolean on)
                  throws IOException

Description copied from interface: WasiSocketOpt

Enable/disable the SO_BROADCAST socket option. Only meaningful for datagram sockets; stream sockets should ignore this call.

Specified by:

setBroadcast in interface WasiSocketOpt

Parameters:

on - whether to enable or disable broadcast

Throws:

IOException - if an I/O error occurs.

getBroadcast

public boolean getBroadcast()
                     throws IOException

Description copied from interface: WasiSocketOpt

Get the SO_BROADCAST socket option. Only meaningful for datagram sockets; stream and server sockets always return false.

Specified by:

getBroadcast in interface WasiSocketOpt

Returns:

whether broadcast is enabled

Throws:

IOException - if an I/O error occurs.

setReuseAddress

public void setReuseAddress(boolean on)
                     throws IOException

Description copied from interface: WasiSocketOpt

Enable/disable the reuse address socket option.

Specified by:

setReuseAddress in interface WasiSocketOpt

Parameters:

on - whether to enable or disable the reuse address socket option

Throws:

IOException - if an I/O error occurs.

setReceiveBufferSize

public void setReceiveBufferSize(int size)
                          throws IOException

Description copied from interface: WasiSocketOpt

Set the receive buffer size (SO_RCVBUF).

Specified by:

setReceiveBufferSize in interface WasiSocketOpt

Parameters:

size - the buffer size in bytes

Throws:

IOException - if an I/O error occurs.

getReceiveBufferSize

public int getReceiveBufferSize()
                         throws IOException

Description copied from interface: WasiSocketOpt

Get the receive buffer size (SO_RCVBUF).

Specified by:

getReceiveBufferSize in interface WasiSocketOpt

Returns:

the buffer size in bytes

Throws:

IOException - if an I/O error occurs.

setSendBufferSize

public void setSendBufferSize(int size)
                       throws IOException

Description copied from interface: WasiSocketOpt

Set the send buffer size (SO_SNDBUF).

Specified by:

setSendBufferSize in interface WasiSocketOpt

Parameters:

size - the buffer size in bytes

Throws:

IOException - if an I/O error occurs.

getSendBufferSize

public int getSendBufferSize()
                      throws IOException

Description copied from interface: WasiSocketOpt

Get the send buffer size (SO_SNDBUF).

Specified by:

getSendBufferSize in interface WasiSocketOpt

Returns:

the buffer size in bytes

Throws:

IOException - if an I/O error occurs.

getRemoteSocketAddress

@Nullable
public SocketAddress getRemoteSocketAddress()

getLocalSocketAddress

@Nullable
public SocketAddress getLocalSocketAddress()

isNonBlocking

public boolean isNonBlocking()

isReuseAddress

public boolean isReuseAddress()

wasiShutdown

public int wasiShutdown(int how)

getSocket

@Nullable
public Socket getSocket()

wasiSockReceive

public int wasiSockReceive(int iovecListPtr,
                           int iovecLen,
                           int riFlags,
                           int nbRecvPtr,
                           int roFlagsPtr,
                           byte[] memory)

wasiSockSend

public int wasiSockSend(int iovecListPtr,
                        int iovecLen,
                        int nbSendPtr,
                        byte[] memory)

isConnectionReset

public boolean isConnectionReset()
                          throws IOException

Check whether the connection been reset by the peer.

Returns:

connection reset status.

Throws:

IOException - if the socket is not connected or an I/O error occurs.

attachWasiSSL

public void attachWasiSSL(@Nullable
                          WasiSSL wasiSSL)

Attach a WasiSSL context with the current WasiSocket. It is used in WasiSSL.SSL_set_fd(WasmModule,int,int) to attach the newly created TLS socket to the WasiSocket file descriptor. It is used in WasiSSL.close() and WasiSSL.SSL_free(WasmModule,int) to detach the TLS socket from the current WasiSocket.

Parameters:

wasiSSL - the WasiSSL context.

getWasiSSL

@Nullable
public WasiSSL getWasiSSL()

Retrieve the associated WasiSSL context.

Returns:

the WasiSSL context.