junixsocket 2.10.1 · org.newsclub.net.unix.AFSocketImpl

Modifier and Type	Class and Description
private class	AFSocketImpl.AFInputStreamImpl
private class	AFSocketImpl.AFOutputStreamImpl
pack-priv static class	AFSocketImpl.AFSocketStreamCore When the `AFSocketImpl` becomes unreachable (but not yet closed), we must ensure that the underlying socket and all related file descriptors are closed.

Modifier and Type	Field and Description
private final AFAddressFamily<A>	addressFamily
pack-priv final AncillaryDataSupport	ancillaryDataSupport
private final AtomicBoolean	bound
private final AtomicBoolean	closed
private volatile boolean	closedInputStream
private volatile boolean	closedOutputStream
private final AtomicBoolean	connected
private final AFSocketImpl.AFSocketStreamCore	core
private Boolean	createType
private AFSocketImplExtensions<A>	implExtensions
private final AFInputStream	in
private final AFOutputStream	out
private boolean	reuseAddr
private static final int	SHUTDOWN_RD_WR
private int	shutdownState
private final AtomicInteger	socketTimeout

Access	Constructor and Description
protected	AFSocketImpl(AFAddressFamily<@NonNull A> The address family. addressFamily, FileDescriptor The socket's `FileDescriptor`. fdObj) Creates a new `AFSocketImpl` instance.

Method Summary

Modifier and Type	Method and Description
protected final void	accept(SocketImpl the accepted connection. socket) Implements abstract java.net.SocketImpl.accept. Accepts a connection.
pack-priv final boolean	accept0(SocketImpl socket)
protected final int	available() Implements abstract java.net.SocketImpl.available. Returns the number of bytes that can be read from this socket without blocking.
pack-priv final void	bind(SocketAddress addr, int options)
protected final void	bind(InetAddress an IP address that belongs to a local interface. host, int the port number. port) Implements abstract java.net.SocketImpl.bind. Binds this socket to the specified local IP address and port number.
private void	checkClose()
private static boolean	checkWriteInterruptedException(int bytesTransferred)
protected final void	close() Implements abstract java.net.SocketImpl.close. Closes this socket.
protected final void	connect(String the name of the remote host. host, int the port number. port) Implements abstract java.net.SocketImpl.connect. Connects this socket to the specified port on the named host.
protected final void	connect(InetAddress the IP address of the remote host. address, int the port number. port) Implements abstract java.net.SocketImpl.connect. Connects this socket to the specified port number on the specified host.
protected final void	connect(SocketAddress the Socket address of the remote host. addr, int the timeout value, in milliseconds, or zero for no timeout. connectTimeout) Implements abstract java.net.SocketImpl.connect. Connects this socket to the specified port number on the specified host.
pack-priv final boolean	connect0(SocketAddress addr, int connectTimeout)
protected final void	create(boolean if `true`, create a stream socket; otherwise, create a datagram socket. stream) Implements abstract java.net.SocketImpl.create. Creates either a stream or a datagram socket.
pack-priv final void	createSocket(FileDescriptor fdTarget, AFSocketType type)
pack-priv final void	ensureAncillaryReceiveBufferSize(int minSize)
private static int	expectBoolean(Object value)
private static int	expectInteger(Object value)
pack-priv final AFAddressFamily<A>	getAddressFamily()
pack-priv AncillaryDataSupport	getAncillaryDataSupport()
pack-priv final int	getAncillaryReceiveBufferSize()
pack-priv final AFSocketCore	getCore()
pack-priv final FileDescriptor	getFD()
protected final FileDescriptor	getFileDescriptor() Overrides java.net.SocketImpl.getFileDescriptor. Returns the value of this socket's `fd` field.
protected final synchronized AFSocketImplExtensions<A>	Returns: The helper instance. getImplExtensions() Returns the internal helper instance for address-specific extensions.
protected final InetAddress	getInetAddress() Overrides java.net.SocketImpl.getInetAddress. Returns the value of this socket's `address` field.
protected final AFInputStream	getInputStream() Implements abstract java.net.SocketImpl.getInputStream. Returns an input stream for this socket.
pack-priv final int	getLocalPort1()
pack-priv final @Nullable A	getLocalSocketAddress()
public Object	getOption(int an `int` identifying the option to fetch optID) Implements java.net.SocketOptions.getOption. Fetch the value of an option.
protected <T> T	getOption(SocketOption<T> The socket option name) Overrides java.net.SocketImpl.getOption. Called to get a socket option.
private Object	getOption0(int optID)
pack-priv static final Object	getOptionDefault(FileDescriptor fdesc, int optID, AtomicInteger acceptTimeout, AFAddressFamily<?> af)
protected final Object	Returns: The value. getOptionLenient(int The option ID. optID) Like `getOption(int)`, but ignores exceptions for certain option IDs.
protected final AFOutputStream	getOutputStream() Implements abstract java.net.SocketImpl.getOutputStream. Returns an output stream for this socket.
pack-priv final int	getRemotePort()
pack-priv final @Nullable A	getRemoteSocketAddress()
pack-priv final boolean	isBound()
pack-priv boolean	isClosed()
pack-priv final boolean	isConnected()
protected final void	listen(int the maximum length of the queue. backlog) Implements abstract java.net.SocketImpl.listen. Sets the maximum queue length for incoming connection indications (a request to connect) to the `count` argument.
protected final AFInputStream	Returns: The new stream. newInputStream() Creates a new `InputStream` for this socket.
protected final AFOutputStream	Returns: The new stream. newOutputStream() Creates a new `OutputStream` for this socket.
pack-priv final int	read(ByteBuffer dst, ByteBuffer socketAddressBuffer)
pack-priv final SocketAddress	receive(ByteBuffer dst)
pack-priv final int	send(ByteBuffer src, SocketAddress target)
protected final void	sendUrgentData(int The byte of data to send data) Implements abstract java.net.SocketImpl.sendUrgentData. Send one byte of urgent data on the socket.
pack-priv final void	setAncillaryReceiveBufferSize(int size)
public void	setOption(int identifies the option optID, Object the parameter of the socket option value) Implements java.net.SocketOptions.setOption. Enable/disable the option specified by `optID`.
protected <T> void	setOption(SocketOption<T> The socket option name, T The value of the socket option. A value of `null` may be valid for some options. value) Overrides java.net.SocketImpl.setOption. Called to set a socket option.
private void	setOption0(int optID, Object value)
pack-priv static final void	setOptionDefault(FileDescriptor fdesc, int optID, Object value, AtomicInteger acceptTimeout)
protected final void	setOptionLenient(int The option ID. optID, Object The value. value) Like `setOption(int, Object)`, but ignores exceptions for certain option IDs.
pack-priv final void	setSocketAddress(AFSocketAddress socketAddress)
protected final void	shutdown() Shuts down both input and output at once.
protected final void	shutdownInput() Overrides java.net.SocketImpl.shutdownInput. Places the input stream for this socket at "end of stream".
protected final void	shutdownOutput() Overrides java.net.SocketImpl.shutdownOutput. Disables the output stream for this socket.
protected Set<SocketOption<?>>	supportedOptions() Overrides java.net.SocketImpl.supportedOptions. Returns a set of SocketOptions supported by this impl and by this impl's socket (Socket or ServerSocket)
protected final boolean	supportsUrgentData() Overrides java.net.SocketImpl.supportsUrgentData. Returns whether or not this SocketImpl supports sending urgent data.
public final String	toString() Overrides java.net.SocketImpl.toString. Returns the address and port of this socket as a `String`.
pack-priv final void	updatePorts(int local, int remote)
pack-priv final int	write(ByteBuffer src)

public abstract Class AFSocketImpl<A extends AFSocketAddress>

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary