Module org.elasticsearch.server

Package org.elasticsearch.transport

Class ClusterConnectionManager

java.lang.Object

org.elasticsearch.transport.ClusterConnectionManager

All Implemented Interfaces:

Closeable, AutoCloseable, ConnectionManager

public class ClusterConnectionManager
extends Object
implements ConnectionManager

This class manages node connections within a cluster. The connection is opened by the underlying transport. Once the connection is opened, this class manages the connection. This includes closing the connection when the connection manager is closed.

Nested Class Summary

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

ConnectionManager.ConnectionValidator, ConnectionManager.DelegatingNodeConnectionListener

Constructor Summary

Constructors

Constructor	Description
ClusterConnectionManager(Settings settings, Transport transport, ThreadContext threadContext)
ClusterConnectionManager(ConnectionProfile connectionProfile, Transport transport, ThreadContext threadContext)

Method Summary

Modifier and Type	Method	Description
void	addListener(TransportConnectionListener listener)
void	close()
void	closeNoBlock()
void	connectToNode(DiscoveryNode node, ConnectionProfile connectionProfile, ConnectionManager.ConnectionValidator connectionValidator, ActionListener<Releasable> listener)	Connects to the given node, or acquires another reference to an existing connection to the given node if a connection already exists.
void	disconnectFromNode(DiscoveryNode node)	Disconnected from the given node, if not connected, will do nothing.
Set<DiscoveryNode>	getAllConnectedNodes()
Transport.Connection	getConnection(DiscoveryNode node)	Returns a connection for the given node if the node is connected.
ConnectionProfile	getConnectionProfile()
boolean	nodeConnected(DiscoveryNode node)	Returns true if the node is connected.
void	openConnection(DiscoveryNode node, ConnectionProfile connectionProfile, ActionListener<Transport.Connection> listener)
void	removeListener(TransportConnectionListener listener)
int	size()	Returns the number of nodes this manager is connected to.

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterConnectionManager

public ClusterConnectionManager(Settings settings,
 Transport transport,
 ThreadContext threadContext)

ClusterConnectionManager

public ClusterConnectionManager(ConnectionProfile connectionProfile,
 Transport transport,
 ThreadContext threadContext)

Method Details

addListener

public void addListener(TransportConnectionListener listener)

Specified by:

addListener in interface ConnectionManager

removeListener

public void removeListener(TransportConnectionListener listener)

Specified by:

removeListener in interface ConnectionManager

openConnection

public void openConnection(DiscoveryNode node,
 ConnectionProfile connectionProfile,
 ActionListener<Transport.Connection> listener)

Specified by:

openConnection in interface ConnectionManager

connectToNode

public void connectToNode(DiscoveryNode node,
 @Nullable
 ConnectionProfile connectionProfile,
 ConnectionManager.ConnectionValidator connectionValidator,
 ActionListener<Releasable> listener)
                   throws ConnectTransportException

Connects to the given node, or acquires another reference to an existing connection to the given node if a connection already exists.

Specified by:

connectToNode in interface ConnectionManager

Parameters:

connectionProfile - the profile to use if opening a new connection. Only used in tests, this is null in production.

connectionValidator - a callback to validate the connection before it is exposed (e.g. to nodeConnected(org.elasticsearch.cluster.node.DiscoveryNode)).

listener - completed on the calling thread or by the ConnectionManager.ConnectionValidator; in production the ConnectionManager.ConnectionValidator will complete the listener on the generic thread pool (see TransportService.connectionValidator(org.elasticsearch.cluster.node.DiscoveryNode)). If successful, completed with a Releasable which will release this connection (and close it if no other references to it are held).

Throws:

ConnectTransportException

getConnection

public Transport.Connection getConnection(DiscoveryNode node)

Returns a connection for the given node if the node is connected. Connections returned from this method must not be closed. The lifecycle of this connection is maintained by this connection manager

Specified by:

getConnection in interface ConnectionManager

Throws:

NodeNotConnectedException - if the node is not connected

See Also:

• connectToNode(DiscoveryNode, ConnectionProfile, ConnectionValidator, ActionListener)

nodeConnected

public boolean nodeConnected(DiscoveryNode node)

Returns true if the node is connected.

Specified by:

nodeConnected in interface ConnectionManager

disconnectFromNode

public void disconnectFromNode(DiscoveryNode node)

Disconnected from the given node, if not connected, will do nothing.

Specified by:

disconnectFromNode in interface ConnectionManager

size

public int size()

Returns the number of nodes this manager is connected to.

Specified by:

size in interface ConnectionManager

getAllConnectedNodes

public Set<DiscoveryNode> getAllConnectedNodes()

Specified by:

getAllConnectedNodes in interface ConnectionManager

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface ConnectionManager

closeNoBlock

public void closeNoBlock()

Specified by:

closeNoBlock in interface ConnectionManager

getConnectionProfile

public ConnectionProfile getConnectionProfile()

Specified by:

getConnectionProfile in interface ConnectionManager