Package org.elasticsearch.transport.nio

Class NioTransport

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.transport.TcpTransport

org.elasticsearch.transport.nio.NioTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, LifecycleComponent, Releasable, Transport

public class NioTransport
extends TcpTransport

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.transport.TcpTransport

TcpTransport.HttpOnTransportException, TcpTransport.NodeChannels, TcpTransport.ProfileSettings, TcpTransport.ScheduledPing

Nested classes/interfaces inherited from interface org.elasticsearch.transport.Transport

Transport.Connection

Field Summary

Fields

Modifier and Type	Field	Description
static Setting<java.lang.Integer>	NIO_ACCEPTOR_COUNT
static Setting<java.lang.Integer>	NIO_WORKER_COUNT
static java.lang.String	TRANSPORT_ACCEPTOR_THREAD_NAME_PREFIX
static java.lang.String	TRANSPORT_WORKER_THREAD_NAME_PREFIX

Fields inherited from class org.elasticsearch.common.component.AbstractComponent

deprecationLogger, logger, settings

Fields inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

lifecycle

Fields inherited from class org.elasticsearch.transport.TcpTransport

BIND_HOST, BIND_HOST_PROFILE, compress, CONNECTIONS_PER_NODE_BULK, CONNECTIONS_PER_NODE_PING, CONNECTIONS_PER_NODE_RECOVERY, CONNECTIONS_PER_NODE_REG, CONNECTIONS_PER_NODE_STATE, DEFAULT_FEATURES_SETTING, DEFAULT_PROFILE, defaultConnectionProfile, FEATURE_PREFIX, HOST, networkService, PING_DATA_SIZE, PING_SCHEDULE, PORT, PORT_PROFILE, profileSettings, PUBLISH_HOST, PUBLISH_HOST_PROFILE, PUBLISH_PORT, PUBLISH_PORT_PROFILE, scheduledPing, TCP_CONNECT_TIMEOUT, TCP_KEEP_ALIVE, TCP_KEEP_ALIVE_PROFILE, TCP_NO_DELAY, TCP_NO_DELAY_PROFILE, TCP_RECEIVE_BUFFER_SIZE, TCP_RECEIVE_BUFFER_SIZE_PROFILE, TCP_REUSE_ADDRESS, TCP_REUSE_ADDRESS_PROFILE, TCP_SEND_BUFFER_SIZE, TCP_SEND_BUFFER_SIZE_PROFILE, threadPool, TRANSPORT_CLIENT_BOSS_THREAD_NAME_PREFIX, TRANSPORT_SERVER_WORKER_THREAD_NAME_PREFIX

Fields inherited from interface org.elasticsearch.transport.Transport

TRANSPORT_TCP_COMPRESS

Constructor Summary

Constructors

Constructor	Description
NioTransport(Settings settings, ThreadPool threadPool, NetworkService networkService, BigArrays bigArrays, PageCacheRecycler pageCacheRecycler, NamedWriteableRegistry namedWriteableRegistry, CircuitBreakerService circuitBreakerService)

Method Summary

Modifier and Type	Method	Description
protected TcpNioServerSocketChannel	bind(java.lang.String name, java.net.InetSocketAddress address)
protected void	doStart()
protected SocketEventHandler	getSocketEventHandler(org.apache.logging.log4j.Logger logger)
protected TcpNioSocketChannel	initiateChannel(DiscoveryNode node, TimeValue connectTimeout, ActionListener<java.lang.Void> connectListener)
protected void	stopInternal()

Methods inherited from class org.elasticsearch.common.component.AbstractComponent

logDeprecatedSetting, logRemovedSetting, nodeName

Methods inherited from class org.elasticsearch.common.component.AbstractLifecycleComponent

addLifecycleListener, close, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from interface org.elasticsearch.common.component.LifecycleComponent

addLifecycleListener, lifecycleState, removeLifecycleListener, start, stop

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.common.lease.Releasable

close

Methods inherited from class org.elasticsearch.transport.TcpTransport

addressesFromString, bindServer, bindToPort, boundAddress, canCompress, connectToNode, disconnectFromNode, doClose, doStop, ensureOpen, executeHandshake, getConnection, getCurrentVersion, getInFlightRequestBreaker, getLocalAddresses, getProfileSettings, getStats, handleRequest, messageReceived, newRequestId, nodeConnected, onException, openConnection, profileBoundAddresses, resolveConnectionProfile, resolvePublishPort, sendErrorResponse, sendResponse, serverAcceptedChannel, setTransportService, validateMessageHeader, validateRequest

Field Detail

TRANSPORT_WORKER_THREAD_NAME_PREFIX

public static final java.lang.String TRANSPORT_WORKER_THREAD_NAME_PREFIX

See Also:

Constant Field Values

TRANSPORT_ACCEPTOR_THREAD_NAME_PREFIX

public static final java.lang.String TRANSPORT_ACCEPTOR_THREAD_NAME_PREFIX

See Also:

Constant Field Values

NIO_WORKER_COUNT

public static final Setting<java.lang.Integer> NIO_WORKER_COUNT

NIO_ACCEPTOR_COUNT

public static final Setting<java.lang.Integer> NIO_ACCEPTOR_COUNT

Constructor Detail

NioTransport

public NioTransport(Settings settings,
                    ThreadPool threadPool,
                    NetworkService networkService,
                    BigArrays bigArrays,
                    PageCacheRecycler pageCacheRecycler,
                    NamedWriteableRegistry namedWriteableRegistry,
                    CircuitBreakerService circuitBreakerService)

Method Detail

bind

protected TcpNioServerSocketChannel bind(java.lang.String name,
                                         java.net.InetSocketAddress address)
                                  throws java.io.IOException

Specified by:

bind in class TcpTransport

Throws:

java.io.IOException

initiateChannel

protected TcpNioSocketChannel initiateChannel(DiscoveryNode node,
                                              TimeValue connectTimeout,
                                              ActionListener<java.lang.Void> connectListener)
                                       throws java.io.IOException

Specified by:

initiateChannel in class TcpTransport

Throws:

java.io.IOException

doStart

protected void doStart()

Overrides:

doStart in class TcpTransport

stopInternal

protected void stopInternal()

Overrides:

stopInternal in class TcpTransport

getSocketEventHandler

protected SocketEventHandler getSocketEventHandler(org.apache.logging.log4j.Logger logger)