Package org.elasticsearch.transport

Class TransportService

java.lang.Object

org.elasticsearch.common.component.AbstractComponent

org.elasticsearch.common.component.AbstractLifecycleComponent

org.elasticsearch.transport.TransportService

All Implemented Interfaces:

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

public class TransportService
extends AbstractLifecycleComponent

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TransportService.ContextRestoreResponseHandler<T extends TransportResponse>	This handler wrapper ensures that the response thread executes with the correct thread context.
static class	TransportService.HandshakeResponse

Field Summary

Fields

Modifier and Type	Field	Description
protected ClusterName	clusterName
static java.lang.String	DIRECT_RESPONSE_PROFILE
static java.lang.String	HANDSHAKE_ACTION_NAME
static TransportInterceptor	NOOP_TRANSPORT_INTERCEPTOR
protected TaskManager	taskManager
protected ThreadPool	threadPool
static Setting<java.util.List<java.lang.String>>	TRACE_LOG_EXCLUDE_SETTING
static Setting<java.util.List<java.lang.String>>	TRACE_LOG_INCLUDE_SETTING
protected Transport	transport

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

deprecationLogger, logger, settings

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

lifecycle

Constructor Summary

Constructors

Constructor	Description
TransportService(Settings settings, Transport transport, ThreadPool threadPool, TransportInterceptor transportInterceptor, java.util.function.Function<BoundTransportAddress,DiscoveryNode> localNodeFactory, ClusterSettings clusterSettings, java.util.Set<java.lang.String> taskHeaders)	Build the service.

Method Summary

Modifier and Type	Method	Description
void	acceptIncomingRequests()	start accepting incoming requests.
void	addConnectionListener(TransportConnectionListener listener)
TransportAddress[]	addressesFromString(java.lang.String address, int perAddressLimit)
BoundTransportAddress	boundAddress()
void	connectToNode(DiscoveryNode node)
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile)	Connect to the specified node with the given connection profile
protected TaskManager	createTaskManager(Settings settings, ThreadPool threadPool, java.util.Set<java.lang.String> taskHeaders)
void	disconnectFromNode(DiscoveryNode node)
protected void	doClose()
protected void	doStart()
protected void	doStop()
Transport.Connection	getConnection(DiscoveryNode node)	Returns either a real transport connection or a local node connection if we are using the local node optimization.
protected java.util.concurrent.ExecutorService	getExecutorService()	The executor service for this transport service.
java.util.List<java.lang.String>	getLocalAddresses()
DiscoveryNode	getLocalNode()
RemoteClusterService	getRemoteClusterService()
RequestHandlerRegistry	getRequestHandler(java.lang.String action)
TaskManager	getTaskManager()
ThreadPool	getThreadPool()	Returns the internal thread pool
DiscoveryNode	handshake(Transport.Connection connection, long handshakeTimeout)	Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with.
TransportService.HandshakeResponse	handshake(Transport.Connection connection, long handshakeTimeout, java.util.function.Predicate<ClusterName> clusterNamePredicate)	Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with.
TransportInfo	info()
boolean	nodeConnected(DiscoveryNode node)	Returns true iff the given node is already connected.
void	onNodeDisconnected(DiscoveryNode node)
TransportResponseHandler	onResponseReceived(long requestId)	called by the Transport implementation when a response or an exception has been received for a previously sent request (before any processing or deserialization was done).
Transport.Connection	openConnection(DiscoveryNode node, ConnectionProfile profile)	Establishes and returns a new connection to the given node.
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.lang.String executor, boolean forceExecution, boolean canTripCircuitBreaker, Writeable.Reader<Request> requestReader, TransportRequestHandler<Request> handler)	Registers a new request handler
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.lang.String executor, Writeable.Reader<Request> requestReader, TransportRequestHandler<Request> handler)	Registers a new request handler
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.util.function.Supplier<Request> request, java.lang.String executor, boolean forceExecution, boolean canTripCircuitBreaker, TransportRequestHandler<Request> handler)	Registers a new request handler
<Request extends TransportRequest> void	registerRequestHandler(java.lang.String action, java.util.function.Supplier<Request> requestFactory, java.lang.String executor, TransportRequestHandler<Request> handler)	Registers a new request handler
void	removeConnectionListener(TransportConnectionListener listener)
<T extends TransportResponse> void	sendChildRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, Task parentTask, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendChildRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, Task parentTask, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendChildRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, Task parentTask, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportResponseHandler<T> handler)
<T extends TransportResponse> void	sendRequest(Transport.Connection connection, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
TransportStats	stats()
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportRequestOptions options, TransportResponseHandler<T> handler)
<T extends TransportResponse> TransportFuture<T>	submitRequest(DiscoveryNode node, java.lang.String action, TransportRequest request, TransportResponseHandler<T> handler)
protected boolean	traceEnabled()
protected void	traceReceivedRequest(long requestId, java.lang.String action)
protected void	traceReceivedResponse(long requestId, DiscoveryNode sourceNode, java.lang.String action)
protected void	traceRequestSent(DiscoveryNode node, long requestId, java.lang.String action, TransportRequestOptions options)
protected void	traceResponseSent(long requestId, java.lang.String action)
protected void	traceResponseSent(long requestId, java.lang.String action, java.lang.Exception e)
protected void	traceUnresolvedResponse(long requestId)

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 class java.lang.Object

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

Field Detail

DIRECT_RESPONSE_PROFILE

public static final java.lang.String DIRECT_RESPONSE_PROFILE

See Also:

Constant Field Values

HANDSHAKE_ACTION_NAME

public static final java.lang.String HANDSHAKE_ACTION_NAME

See Also:

Constant Field Values

transport

protected final Transport transport

threadPool

protected final ThreadPool threadPool

clusterName

protected final ClusterName clusterName

taskManager

protected final TaskManager taskManager

NOOP_TRANSPORT_INTERCEPTOR

public static final TransportInterceptor NOOP_TRANSPORT_INTERCEPTOR

TRACE_LOG_INCLUDE_SETTING

public static final Setting<java.util.List<java.lang.String>> TRACE_LOG_INCLUDE_SETTING

TRACE_LOG_EXCLUDE_SETTING

public static final Setting<java.util.List<java.lang.String>> TRACE_LOG_EXCLUDE_SETTING

Constructor Detail

TransportService

public TransportService(Settings settings,
                        Transport transport,
                        ThreadPool threadPool,
                        TransportInterceptor transportInterceptor,
                        java.util.function.Function<BoundTransportAddress,DiscoveryNode> localNodeFactory,
                        @Nullable
                        ClusterSettings clusterSettings,
                        java.util.Set<java.lang.String> taskHeaders)

Build the service.

Parameters:

clusterSettings - if non null, the TransportService will register with the ClusterSettings for settings updates for TRACE_LOG_EXCLUDE_SETTING and TRACE_LOG_INCLUDE_SETTING.

Method Detail

getRemoteClusterService

public RemoteClusterService getRemoteClusterService()

getLocalNode

public DiscoveryNode getLocalNode()

getTaskManager

public TaskManager getTaskManager()

createTaskManager

protected TaskManager createTaskManager(Settings settings,
                                        ThreadPool threadPool,
                                        java.util.Set<java.lang.String> taskHeaders)

getExecutorService

protected java.util.concurrent.ExecutorService getExecutorService()

The executor service for this transport service.

Returns:

the executor service

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent

doClose

protected void doClose()
                throws java.io.IOException

Specified by:

doClose in class AbstractLifecycleComponent

Throws:

java.io.IOException

acceptIncomingRequests

public final void acceptIncomingRequests()

start accepting incoming requests. when the transport layer starts up it will block any incoming requests until this method is called

info

public TransportInfo info()

stats

public TransportStats stats()

boundAddress

public BoundTransportAddress boundAddress()

getLocalAddresses

public java.util.List<java.lang.String> getLocalAddresses()

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Returns true iff the given node is already connected.

connectToNode

public void connectToNode(DiscoveryNode node)
                   throws ConnectTransportException

Throws:

ConnectTransportException

connectToNode

public void connectToNode(DiscoveryNode node,
                          ConnectionProfile connectionProfile)

Connect to the specified node with the given connection profile

Parameters:

node - the node to connect to

connectionProfile - the connection profile to use when connecting to this node

openConnection

public Transport.Connection openConnection(DiscoveryNode node,
                                           ConnectionProfile profile)
                                    throws java.io.IOException

Establishes and returns a new connection to the given node. The connection is NOT maintained by this service, it's the callers responsibility to close the connection once it goes out of scope.

Parameters:

node - the node to connect to

profile - the connection profile to use

Throws:

java.io.IOException

handshake

public DiscoveryNode handshake(Transport.Connection connection,
                               long handshakeTimeout)
                        throws ConnectTransportException

Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with. The handshake will fail if the cluster name on the target node mismatches the local cluster name.

Parameters:

connection - the connection to a specific node

handshakeTimeout - handshake timeout

Returns:

the connected node

Throws:

ConnectTransportException - if the connection failed

java.lang.IllegalStateException - if the handshake failed

handshake

public TransportService.HandshakeResponse handshake(Transport.Connection connection,
                                                    long handshakeTimeout,
                                                    java.util.function.Predicate<ClusterName> clusterNamePredicate)
                                             throws ConnectTransportException

Executes a high-level handshake using the given connection and returns the discovery node of the node the connection was established with. The handshake will fail if the cluster name on the target node doesn't match the local cluster name.

Parameters:

connection - the connection to a specific node

handshakeTimeout - handshake timeout

clusterNamePredicate - cluster name validation predicate

Returns:

the handshake response

Throws:

ConnectTransportException - if the connection failed

java.lang.IllegalStateException - if the handshake failed

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

addConnectionListener

public void addConnectionListener(TransportConnectionListener listener)

removeConnectionListener

public void removeConnectionListener(TransportConnectionListener listener)

submitRequest

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                                      java.lang.String action,
                                                                      TransportRequest request,
                                                                      TransportResponseHandler<T> handler)
                                                               throws TransportException

Throws:

TransportException

submitRequest

public <T extends TransportResponse> TransportFuture<T> submitRequest(DiscoveryNode node,
                                                                      java.lang.String action,
                                                                      TransportRequest request,
                                                                      TransportRequestOptions options,
                                                                      TransportResponseHandler<T> handler)
                                                               throws TransportException

Throws:

TransportException

sendRequest

public <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                      java.lang.String action,
                                                      TransportRequest request,
                                                      TransportResponseHandler<T> handler)

sendRequest

public final <T extends TransportResponse> void sendRequest(DiscoveryNode node,
                                                            java.lang.String action,
                                                            TransportRequest request,
                                                            TransportRequestOptions options,
                                                            TransportResponseHandler<T> handler)

sendRequest

public final <T extends TransportResponse> void sendRequest(Transport.Connection connection,
                                                            java.lang.String action,
                                                            TransportRequest request,
                                                            TransportRequestOptions options,
                                                            TransportResponseHandler<T> handler)

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Returns either a real transport connection or a local node connection if we are using the local node optimization.

Throws:

NodeNotConnectedException - if the given node is not connected

sendChildRequest

public final <T extends TransportResponse> void sendChildRequest(DiscoveryNode node,
                                                                 java.lang.String action,
                                                                 TransportRequest request,
                                                                 Task parentTask,
                                                                 TransportRequestOptions options,
                                                                 TransportResponseHandler<T> handler)

sendChildRequest

public <T extends TransportResponse> void sendChildRequest(Transport.Connection connection,
                                                           java.lang.String action,
                                                           TransportRequest request,
                                                           Task parentTask,
                                                           TransportResponseHandler<T> handler)

sendChildRequest

public <T extends TransportResponse> void sendChildRequest(Transport.Connection connection,
                                                           java.lang.String action,
                                                           TransportRequest request,
                                                           Task parentTask,
                                                           TransportRequestOptions options,
                                                           TransportResponseHandler<T> handler)

addressesFromString

public TransportAddress[] addressesFromString(java.lang.String address,
                                              int perAddressLimit)
                                       throws java.net.UnknownHostException

Throws:

java.net.UnknownHostException

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.util.function.Supplier<Request> requestFactory,
                                                                      java.lang.String executor,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

requestFactory - a callable to be used construct new instances for streaming

executor - The executor the request handling will be executed on

handler - The handler itself that implements the request handling

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.lang.String executor,
                                                                      Writeable.Reader<Request> requestReader,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

requestReader - a callable to be used construct new instances for streaming

executor - The executor the request handling will be executed on

handler - The handler itself that implements the request handling

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.util.function.Supplier<Request> request,
                                                                      java.lang.String executor,
                                                                      boolean forceExecution,
                                                                      boolean canTripCircuitBreaker,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

request - The request class that will be used to construct new instances for streaming

executor - The executor the request handling will be executed on

forceExecution - Force execution on the executor queue and never reject it

canTripCircuitBreaker - Check the request size and raise an exception in case the limit is breached.

handler - The handler itself that implements the request handling

registerRequestHandler

public <Request extends TransportRequest> void registerRequestHandler(java.lang.String action,
                                                                      java.lang.String executor,
                                                                      boolean forceExecution,
                                                                      boolean canTripCircuitBreaker,
                                                                      Writeable.Reader<Request> requestReader,
                                                                      TransportRequestHandler<Request> handler)

Registers a new request handler

Parameters:

action - The action the request handler is associated with

requestReader - The request class that will be used to construct new instances for streaming

executor - The executor the request handling will be executed on

forceExecution - Force execution on the executor queue and never reject it

canTripCircuitBreaker - Check the request size and raise an exception in case the limit is breached.

handler - The handler itself that implements the request handling

traceEnabled

protected boolean traceEnabled()

traceResponseSent

protected void traceResponseSent(long requestId,
                                 java.lang.String action,
                                 java.lang.Exception e)

getRequestHandler

public RequestHandlerRegistry getRequestHandler(java.lang.String action)

onResponseReceived

public TransportResponseHandler onResponseReceived(long requestId)

called by the Transport implementation when a response or an exception has been received for a previously sent request (before any processing or deserialization was done). Returns the appropriate response handler or null if not found.

onNodeDisconnected

public void onNodeDisconnected(DiscoveryNode node)

traceReceivedRequest

protected void traceReceivedRequest(long requestId,
                                    java.lang.String action)

traceResponseSent

protected void traceResponseSent(long requestId,
                                 java.lang.String action)

traceReceivedResponse

protected void traceReceivedResponse(long requestId,
                                     DiscoveryNode sourceNode,
                                     java.lang.String action)

traceUnresolvedResponse

protected void traceUnresolvedResponse(long requestId)

traceRequestSent

protected void traceRequestSent(DiscoveryNode node,
                                long requestId,
                                java.lang.String action,
                                TransportRequestOptions options)

getThreadPool

public ThreadPool getThreadPool()

Returns the internal thread pool