Package org.elasticsearch.transport.nio

Class NioGroup

java.lang.Object

org.elasticsearch.transport.nio.NioGroup

All Implemented Interfaces:

java.lang.AutoCloseable

public class NioGroup
extends java.lang.Object
implements java.lang.AutoCloseable

The NioGroup is a group of selectors for interfacing with java nio. When it is started it will create the configured number of socket and acceptor selectors. Each selector will be running in a dedicated thread. Server connections can be bound using the bindServerChannel(InetSocketAddress, ChannelFactory) method. Client connections can be opened using the openChannel(InetSocketAddress, ChannelFactory) method.

The logic specific to a particular channel is provided by the ChannelFactory passed to the method when the channel is created. This is what allows an NioGroup to support different channel types.

Constructor Summary

Constructors

Constructor

Description

NioGroup(org.apache.logging.log4j.Logger logger, java.util.concurrent.ThreadFactory acceptorThreadFactory, int acceptorCount, java.util.function.BiFunction<org.apache.logging.log4j.Logger,java.util.function.Supplier<SocketSelector>,AcceptorEventHandler> acceptorEventHandlerFunction, java.util.concurrent.ThreadFactory socketSelectorThreadFactory, int socketSelectorCount, java.util.function.Function<org.apache.logging.log4j.Logger,SocketEventHandler> socketEventHandlerFunction)

Method Summary

Modifier and Type	Method	Description
<S extends NioServerSocketChannel> S	bindServerChannel(java.net.InetSocketAddress address, ChannelFactory<S,?> factory)
void	close()
<S extends NioSocketChannel> S	openChannel(java.net.InetSocketAddress address, ChannelFactory<?,S> factory)

Methods inherited from class java.lang.Object

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

Constructor Detail

NioGroup

public NioGroup(org.apache.logging.log4j.Logger logger,
                java.util.concurrent.ThreadFactory acceptorThreadFactory,
                int acceptorCount,
                java.util.function.BiFunction<org.apache.logging.log4j.Logger,java.util.function.Supplier<SocketSelector>,AcceptorEventHandler> acceptorEventHandlerFunction,
                java.util.concurrent.ThreadFactory socketSelectorThreadFactory,
                int socketSelectorCount,
                java.util.function.Function<org.apache.logging.log4j.Logger,SocketEventHandler> socketEventHandlerFunction)
         throws java.io.IOException

Throws:

java.io.IOException

Method Detail

bindServerChannel

public <S extends NioServerSocketChannel> S bindServerChannel(java.net.InetSocketAddress address,
                                                              ChannelFactory<S,?> factory)
                                                       throws java.io.IOException

Throws:

java.io.IOException

openChannel

public <S extends NioSocketChannel> S openChannel(java.net.InetSocketAddress address,
                                                  ChannelFactory<?,S> factory)
                                           throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException