Module org.newsclub.net.unix

Package org.newsclub.net.unix

Class AFSelectorProvider<A extends AFSocketAddress>

java.lang.Object

java.nio.channels.spi.SelectorProvider

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

Type Parameters:

A - The concrete AFSocketAddress that is supported by this type.

Direct Known Subclasses:

AFSYSTEMSelectorProvider, AFTIPCSelectorProvider, AFUNIXSelectorProvider, AFVSOCKSelectorProvider

public abstract class AFSelectorProvider<A extends AFSocketAddress>
extends SelectorProvider

Service-provider class for junixsocket selectors and selectable channels.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AFSelectorProvider()	Constructs a new AFSelectorProvider.

Method Summary

Modifier and Type	Method	Description
protected abstract AFAddressFamily<@NonNull A>	addressFamily()	Returns the address family supported by this implementation.
protected final int	domainId()	Returns the domain ID for the supported protocol, as specified by NativeUnixSocket.
protected abstract AFSocket<A>	newSocket()	Constructs a new socket.
protected abstract <Y extends AFSomeSocket> AFSocketPair<Y>	newSocketPair(Y s1, Y s2)	Constructs a new socket pair from two sockets.
abstract AFDatagramChannel<A>	openDatagramChannel()
AFDatagramChannel<A>	openDatagramChannel(ProtocolFamily family)
abstract AFDatagramChannel<A>	openDatagramChannel(AFSocketType type)	Opens a DatagramChannel using the given socket type.
AFSocketPair<? extends AFDatagramChannel<A>>	openDatagramChannelPair()	Opens a socket pair of interconnected datagram channels.
AFSocketPair<? extends AFDatagramChannel<A>>	openDatagramChannelPair(AFSocketType type)	Opens a socket pair of interconnected DatagramChannels, using the given AFSocketType.
final AFPipe	openPipe()
final AbstractSelector	openSelector()
abstract AFServerSocketChannel<A>	openServerSocketChannel()
AFServerSocketChannel<A>	openServerSocketChannel(ProtocolFamily family)
abstract AFServerSocketChannel<A>	openServerSocketChannel(SocketAddress sa)	Opens a server-socket channel bound on the given SocketAddress.
AFSocketChannel<A>	openSocketChannel()
AFSocketChannel<A>	openSocketChannel(ProtocolFamily family)
abstract AFSocketChannel<A>	openSocketChannel(SocketAddress sa)	Opens a socket channel connected to the given SocketAddress.
AFSocketPair<? extends AFSocketChannel<A>>	openSocketChannelPair()	Opens a socket pair of interconnected channels.
protected abstract ProtocolFamily	protocolFamily()	Returns the protocol family supported by this implementation.
static SelectorProvider	provider()	Returns the singleton instance for an "fallback" provider that supports the methods taking ProtocolFamily, as long as a junixsocket-specific AFProtocolFamily is used.

Methods inherited from class java.nio.channels.spi.SelectorProvider

inheritedChannel

Methods inherited from class java.lang.Object

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

Constructor Details

AFSelectorProvider

protected AFSelectorProvider()

Constructs a new AFSelectorProvider.

Method Details

newSocketPair

protected abstract <Y extends AFSomeSocket>
AFSocketPair<Y> newSocketPair(Y s1,
 Y s2)

Constructs a new socket pair from two sockets.

Type Parameters:

Y - The type of the pair.

Parameters:

s1 - Some socket, the first one.

s2 - Some socket, the second one.

Returns:

The pair.

newSocket

protected abstract AFSocket<A> newSocket()
                                  throws IOException

Constructs a new socket.

Returns:

The socket instance.

Throws:

IOException - on error.

protocolFamily

protected abstract ProtocolFamily protocolFamily()

Returns the protocol family supported by this implementation.

Returns:

The protocol family.

addressFamily

protected abstract AFAddressFamily<@NonNull A> addressFamily()

Returns the address family supported by this implementation.

Returns:

The address family.

domainId

protected final int domainId()

Returns the domain ID for the supported protocol, as specified by NativeUnixSocket.

Returns:

The domain ID.

openSocketChannelPair

public AFSocketPair<? extends AFSocketChannel<A>> openSocketChannelPair()
                                                                 throws IOException

Opens a socket pair of interconnected channels.

Returns:

The new channel pair.

Throws:

IOException - on error.

openDatagramChannelPair

public AFSocketPair<? extends AFDatagramChannel<A>> openDatagramChannelPair()
                                                                     throws IOException

Opens a socket pair of interconnected datagram channels.

Returns:

The new channel pair.

Throws:

IOException - on error.

openDatagramChannelPair

public AFSocketPair<? extends AFDatagramChannel<A>> openDatagramChannelPair(AFSocketType type)
                                                                     throws IOException

Opens a socket pair of interconnected DatagramChannels, using the given AFSocketType.

Parameters:

type - The socket type.

Returns:

The new channel pair.

Throws:

IOException - on error.

openDatagramChannel

public abstract AFDatagramChannel<A> openDatagramChannel()
                                                  throws IOException

Specified by:

openDatagramChannel in class SelectorProvider

Throws:

IOException

openDatagramChannel

public abstract AFDatagramChannel<A> openDatagramChannel(AFSocketType type)
                                                  throws IOException

Opens a DatagramChannel using the given socket type.

Parameters:

type - The socket type.

Returns:

the new channel

Throws:

IOException - on error.

openPipe

public final AFPipe openPipe()
                      throws IOException

Specified by:

openPipe in class SelectorProvider

Throws:

IOException

openSelector

public final AbstractSelector openSelector()
                                    throws IOException

Specified by:

openSelector in class SelectorProvider

Throws:

IOException

openServerSocketChannel

public abstract AFServerSocketChannel<A> openServerSocketChannel()
                                                          throws IOException

Specified by:

openServerSocketChannel in class SelectorProvider

Throws:

IOException

openServerSocketChannel

public abstract AFServerSocketChannel<A> openServerSocketChannel(SocketAddress sa)
                                                          throws IOException

Opens a server-socket channel bound on the given SocketAddress.

Parameters:

sa - The socket address to bind on.

Returns:

The new channel

Throws:

IOException - on error.

openSocketChannel

public AFSocketChannel<A> openSocketChannel()
                                     throws IOException

Specified by:

openSocketChannel in class SelectorProvider

Throws:

IOException

openSocketChannel

public abstract AFSocketChannel<A> openSocketChannel(SocketAddress sa)
                                              throws IOException

Opens a socket channel connected to the given SocketAddress.

Parameters:

sa - The socket address to connect to.

Returns:

The new channel

Throws:

IOException - on error.

openSocketChannel

public AFSocketChannel<A> openSocketChannel(ProtocolFamily family)
                                     throws IOException

Overrides:

openSocketChannel in class SelectorProvider

Throws:

IOException

openServerSocketChannel

public AFServerSocketChannel<A> openServerSocketChannel(ProtocolFamily family)
                                                 throws IOException

Overrides:

openServerSocketChannel in class SelectorProvider

Throws:

IOException

openDatagramChannel

public AFDatagramChannel<A> openDatagramChannel(ProtocolFamily family)
                                         throws IOException

Specified by:

openDatagramChannel in class SelectorProvider

Throws:

IOException

provider

public static SelectorProvider provider()

Returns the singleton instance for an "fallback" provider that supports the methods taking ProtocolFamily, as long as a junixsocket-specific AFProtocolFamily is used.

Returns:

The instance.