com.hazelcast.internal.networking.nio

Class NioNetworking

java.lang.Object

com.hazelcast.internal.networking.nio.NioNetworking

All Implemented Interfaces:

Networking

public final class NioNetworking
extends Object
implements Networking

A non blocking Networking implementation that makes use of Selector to have a limited set of io threads, handle an arbitrary number of connections.

Each NioChannel has 2 parts:

1. NioInboundPipeline: triggered by the NioThread when data is available in the socket. The NioInboundPipeline takes care of reading data from the socket and calling the appropriate InboundHandler
2. NioOutboundPipeline: triggered by the NioThread when either space is available in the socket for writing, or when there is something that needs to be written e.g. a Packet. The NioOutboundPipeline takes care of calling the appropriate OutboundHandler to convert the OutboundFrame to bytes in in the ByteBuffer and writing it to the socket.

By default the NioThread blocks on the Selector, but it can be put in a 'selectNow' mode that makes it spinning on the selector. This is an experimental feature and will cause the io threads to run hot. For this reason, when this feature is enabled, the number of io threads should be reduced (preferably 1).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NioNetworking.Context

Constructor Summary

Constructors

Constructor and Description
NioNetworking(NioNetworking.Context ctx)

Method Summary

Modifier and Type	Method and Description
Set<NioChannel>	getChannels()
NioThread[]	getInputThreads()
IOBalancer	getIOBalancer()
NioThread[]	getOutputThreads()
Channel	register(EndpointQualifier endpointQualifier, ChannelInitializerProvider channelInitializerProvider, SocketChannel socketChannel, boolean clientMode) Registers the SocketChannel to the EventLoop group and returns the created Channel.
void	shutdown() Shuts down Networking.
void	start() Starts Networking.

Methods inherited from class java.lang.Object

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

Constructor Detail

NioNetworking

public NioNetworking(NioNetworking.Context ctx)

Method Detail

getInputThreads

public NioThread[] getInputThreads()

getOutputThreads

public NioThread[] getOutputThreads()

getChannels

public Set<NioChannel> getChannels()

getIOBalancer

public IOBalancer getIOBalancer()

start

public void start()

Description copied from interface: Networking

Starts Networking.

Specified by:

start in interface Networking

shutdown

public void shutdown()

Description copied from interface: Networking

Shuts down Networking.

Specified by:

shutdown in interface Networking

register

public Channel register(EndpointQualifier endpointQualifier,
                        ChannelInitializerProvider channelInitializerProvider,
                        SocketChannel socketChannel,
                        boolean clientMode)
                 throws IOException

Description copied from interface: Networking

Registers the SocketChannel to the EventLoop group and returns the created Channel. The Channel is not yet started so that modifications can be made to the channel e.g. adding attributes. Once this is done the Channel.start() needs to be called. In the future we need to think about passing the socket channel because it binds Networking to tcp and this is not desirable.

Specified by:

register in interface Networking

Parameters:

endpointQualifier - the endpoint qualifier for this server socket

channelInitializerProvider - the class used for initializing the Channel after creation

socketChannel - the socketChannel to register

clientMode - if the channel is made in clientMode or server mode

Returns:

the created Channel

Throws:

IOException - when something failed while registering the socketChannel