org.gridgain.client.impl.connection

Class GridClientConnectionManagerImpl

java.lang.Object

org.gridgain.client.impl.connection.GridClientConnectionManagerImpl

All Implemented Interfaces:

GridClientConnectionManager

public class GridClientConnectionManagerImpl
extends Object
implements GridClientConnectionManager

Cached connections manager.

Constructor Summary

Constructors

Constructor and Description
GridClientConnectionManagerImpl(UUID clientId, SSLContext sslCtx, GridClientConfiguration cfg, Collection<InetSocketAddress> routers, GridClientTopology top, Byte protoId) Constructs connection manager.

Method Summary

Methods

Modifier and Type	Method and Description
protected GridClientConnection	connect(UUID nodeId, Collection<InetSocketAddress> srvs) Creates a connected facade and returns it.
protected GridClientConnection	connect(UUID nodeId, InetSocketAddress addr) Create new connection to specified server.
GridClientConnection	connection(GridClientNode node) Gets active communication facade.
GridClientConnection	connection(UUID nodeId, Collection<InetSocketAddress> srvs) Returns connection to one of the given addresses.
void	init(Collection<InetSocketAddress> srvs) Tries to open initial connection and fetch topology using given server addresses.
void	stop(boolean waitCompletion) Closes all opened connections.
void	terminateConnection(GridClientConnection conn, GridClientNode node, Throwable e) Callback method, which should be called by clients when they get connectivity errors.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridClientConnectionManagerImpl

public GridClientConnectionManagerImpl(UUID clientId,
                               SSLContext sslCtx,
                               GridClientConfiguration cfg,
                               Collection<InetSocketAddress> routers,
                               GridClientTopology top,
                               Byte protoId)
                                throws GridClientException

Constructs connection manager.

Parameters:

clientId - Client ID.

sslCtx - SSL context to enable secured connection or null to use unsecured one.

cfg - Client configuration.

routers - Routers or empty collection to use endpoints from topology info.

top - Topology.

protoId - Custom protocol ID (optional).

Throws:

GridClientException - If failed to start.

Method Detail

init

public void init(Collection<InetSocketAddress> srvs)
          throws GridClientException,
                 InterruptedException

Tries to open initial connection and fetch topology using given server addresses.

Specified by:

init in interface GridClientConnectionManager

Parameters:

srvs - Collection server addresses.

Throws:

GridClientAuthenticationException - If connection failed to authenticate on server.

GridClientException - If manager failed to initialise,

InterruptedException - If manager was interrupted while waiting for connection.

connection

public GridClientConnection connection(GridClientNode node)
                                throws GridClientClosedException,
                                       GridServerUnreachableException,
                                       InterruptedException

Gets active communication facade.

Specified by:

connection in interface GridClientConnectionManager

Parameters:

node - Remote node to which connection should be established.

Returns:

Connection to use for operations, targeted for the given node.

Throws:

GridServerUnreachableException - If none of the servers can be reached after the exception.

GridClientClosedException - If client was closed manually.

InterruptedException - If connection was interrupted.

connection

public GridClientConnection connection(@Nullable
                              UUID nodeId,
                              Collection<InetSocketAddress> srvs)
                                throws GridServerUnreachableException,
                                       GridClientClosedException,
                                       InterruptedException

Returns connection to one of the given addresses.

Parameters:

nodeId - UUID of node for mapping with connection. null if no need of mapping.

srvs - Collection of addresses to connect to.

Returns:

Connection to use for operations, targeted for the given node.

Throws:

GridServerUnreachableException - If connection can't be established.

GridClientClosedException - If connections manager has been closed already.

InterruptedException - If connection was interrupted.

connect

protected GridClientConnection connect(@Nullable
                           UUID nodeId,
                           Collection<InetSocketAddress> srvs)
                                throws GridServerUnreachableException,
                                       InterruptedException

Creates a connected facade and returns it. Called either from constructor or inside a write lock.

Parameters:

nodeId - UUID of node for mapping with connection. null if no need of mapping.

srvs - List of server addresses that this method will try to connect to.

Returns:

Established connection.

Throws:

GridServerUnreachableException - If none of the servers can be reached.

InterruptedException - If connection was interrupted.

connect

protected GridClientConnection connect(@Nullable
                           UUID nodeId,
                           InetSocketAddress addr)
                                throws IOException,
                                       GridClientException,
                                       InterruptedException

Create new connection to specified server.

Parameters:

nodeId - UUID of node for mapping with connection. null if no need of mapping.

addr - Remote socket to connect.

Returns:

Established connection.

Throws:

IOException - If connection failed.

GridClientException - If protocol error happened.

InterruptedException - If thread was interrupted before connection was established.

terminateConnection

public void terminateConnection(GridClientConnection conn,
                       GridClientNode node,
                       Throwable e)

Callback method, which should be called by clients when they get connectivity errors. It's main purpose is to allow connection manager to terminate broken connection early and, try to establish a new one for the consequent GridClientConnectionManager.connection(GridClientNode) calls.

Specified by:

terminateConnection in interface GridClientConnectionManager

Parameters:

conn - Failed connection.

node - Connected node.

e - Error that caused connection termination.

stop

public void stop(boolean waitCompletion)

Closes all opened connections.

Specified by:

stop in interface GridClientConnectionManager

Parameters:

waitCompletion - If true waits for all pending requests to be proceeded.