Module org.newsclub.net.unix

Package org.newsclub.net.unix

Class AFSocketImpl<A extends AFSocketAddress>

java.lang.Object

java.net.SocketImpl

org.newsclub.net.unix.AFSocketImpl<A>

Type Parameters:

A - The supported address type.

All Implemented Interfaces:

SocketOptions

public abstract class AFSocketImpl<A extends AFSocketAddress>
extends SocketImpl

junixsocket-based SocketImpl.

Author:

Christian Kohlschütter

Field Summary

Fields inherited from class java.net.SocketImpl

address, fd, localport, port

Fields inherited from interface java.net.SocketOptions

IP_MULTICAST_IF, IP_MULTICAST_IF2, IP_MULTICAST_LOOP, IP_TOS, SO_BINDADDR, SO_BROADCAST, SO_KEEPALIVE, SO_LINGER, SO_OOBINLINE, SO_RCVBUF, SO_REUSEADDR, SO_REUSEPORT, SO_SNDBUF, SO_TIMEOUT, TCP_NODELAY

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AFSocketImpl(AFAddressFamily<@NonNull A> addressFamily, FileDescriptor fdObj)	Creates a new AFSocketImpl instance.

Method Summary

Modifier and Type	Method	Description
protected final void	accept(SocketImpl socket)
protected final int	available()
protected final void	bind(InetAddress host, int port)
protected final void	close()
protected final void	connect(String host, int port)
protected final void	connect(InetAddress address, int port)
protected final void	connect(SocketAddress addr, int connectTimeout)
protected final void	create(boolean stream)
protected final FileDescriptor	getFileDescriptor()
protected final AFSocketImplExtensions<A>	getImplExtensions()	Returns the internal helper instance for address-specific extensions.
protected final InetAddress	getInetAddress()
protected final AFInputStream	getInputStream()
Object	getOption(int optID)
protected <T> T	getOption(SocketOption<T> name)
protected final Object	getOptionLenient(int optID)	Like getOption(int), but ignores exceptions for certain option IDs.
protected final AFOutputStream	getOutputStream()
protected final void	listen(int backlog)
protected final AFInputStream	newInputStream()	Creates a new InputStream for this socket.
protected final AFOutputStream	newOutputStream()	Creates a new OutputStream for this socket.
protected final void	sendUrgentData(int data)
void	setOption(int optID, Object value)
protected <T> void	setOption(SocketOption<T> name, T value)
protected final void	setOptionLenient(int optID, Object value)	Like setOption(int, Object), but ignores exceptions for certain option IDs.
protected final void	shutdown()	Shuts down both input and output at once.
protected final void	shutdownInput()
protected final void	shutdownOutput()
protected Set<SocketOption<?>>	supportedOptions()
protected final boolean	supportsUrgentData()
final String	toString()

Methods inherited from class java.net.SocketImpl

getLocalPort, getPort, setPerformancePreferences

Methods inherited from class java.lang.Object

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

Constructor Details

AFSocketImpl

protected AFSocketImpl(AFAddressFamily<@NonNull A> addressFamily,
 FileDescriptor fdObj)

Creates a new AFSocketImpl instance.

Parameters:

addressFamily - The address family.

fdObj - The socket's FileDescriptor.

Method Details

newInputStream

protected final AFInputStream newInputStream()

Creates a new InputStream for this socket.

Returns:

The new stream.

newOutputStream

protected final AFOutputStream newOutputStream()

Creates a new OutputStream for this socket.

Returns:

The new stream.

accept

protected final void accept(SocketImpl socket)
                     throws IOException

Specified by:

accept in class SocketImpl

Throws:

IOException

available

protected final int available()
                       throws IOException

Specified by:

available in class SocketImpl

Throws:

IOException

bind

protected final void bind(InetAddress host,
 int port)
                   throws IOException

Specified by:

bind in class SocketImpl

Throws:

IOException

close

protected final void close()
                    throws IOException

Specified by:

close in class SocketImpl

Throws:

IOException

connect

protected final void connect(String host,
 int port)
                      throws IOException

Specified by:

connect in class SocketImpl

Throws:

IOException

connect

protected final void connect(InetAddress address,
 int port)
                      throws IOException

Specified by:

connect in class SocketImpl

Throws:

IOException

connect

protected final void connect(SocketAddress addr,
 int connectTimeout)
                      throws IOException

Specified by:

connect in class SocketImpl

Throws:

IOException

create

protected final void create(boolean stream)
                     throws IOException

Specified by:

create in class SocketImpl

Throws:

IOException

getInputStream

protected final AFInputStream getInputStream()
                                      throws IOException

Specified by:

getInputStream in class SocketImpl

Throws:

IOException

getOutputStream

protected final AFOutputStream getOutputStream()
                                        throws IOException

Specified by:

getOutputStream in class SocketImpl

Throws:

IOException

listen

protected final void listen(int backlog)
                     throws IOException

Specified by:

listen in class SocketImpl

Throws:

IOException

supportsUrgentData

protected final boolean supportsUrgentData()

Overrides:

supportsUrgentData in class SocketImpl

sendUrgentData

protected final void sendUrgentData(int data)
                             throws IOException

Specified by:

sendUrgentData in class SocketImpl

Throws:

IOException

toString

public final String toString()

Overrides:

toString in class SocketImpl

getOption

public Object getOption(int optID)
                 throws SocketException

Throws:

SocketException

setOption

public void setOption(int optID,
 Object value)
               throws SocketException

Throws:

SocketException

getOptionLenient

protected final Object getOptionLenient(int optID)
                                 throws SocketException

Like getOption(int), but ignores exceptions for certain option IDs.

Parameters:

optID - The option ID.

Returns:

The value.

Throws:

SocketException - on error.

setOptionLenient

protected final void setOptionLenient(int optID,
 Object value)
                               throws SocketException

Like setOption(int, Object), but ignores exceptions for certain option IDs.

Parameters:

optID - The option ID.

value - The value.

Throws:

SocketException - on error.

shutdown

protected final void shutdown()
                       throws IOException

Shuts down both input and output at once. Equivalent to calling shutdownInput() and shutdownOutput().

Throws:

IOException - on error.

shutdownInput

protected final void shutdownInput()
                            throws IOException

Overrides:

shutdownInput in class SocketImpl

Throws:

IOException

shutdownOutput

protected final void shutdownOutput()
                             throws IOException

Overrides:

shutdownOutput in class SocketImpl

Throws:

IOException

getFileDescriptor

protected final FileDescriptor getFileDescriptor()

Overrides:

getFileDescriptor in class SocketImpl

getInetAddress

protected final InetAddress getInetAddress()

Overrides:

getInetAddress in class SocketImpl

setOption

protected <T> void setOption(SocketOption<T> name,
 T value)
                      throws IOException

Overrides:

setOption in class SocketImpl

Throws:

IOException

getOption

protected <T> T getOption(SocketOption<T> name)
                   throws IOException

Overrides:

getOption in class SocketImpl

Throws:

IOException

supportedOptions

protected Set<SocketOption<?>> supportedOptions()

Overrides:

supportedOptions in class SocketImpl

getImplExtensions

protected final AFSocketImplExtensions<A> getImplExtensions()

Returns the internal helper instance for address-specific extensions.

Returns:

The helper instance.

Throws:

UnsupportedOperationException - if such extensions are not supported for this address type.