| Package | Description |
|---|---|
| org.apache.ignite.internal.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.apache.ignite.spi.communication.tcp |
Contains default TCP/IP-based implementation for communication SPI.
|
| org.apache.ignite.spi.communication.tcp.internal |
Contains connection health-checkers for TCP/IP-based implementation of communication SPI.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridAbstractCommunicationClient
Implements basic lifecycle for communication clients.
|
class |
GridShmemCommunicationClient |
class |
GridTcpNioCommunicationClient
Grid client for NIO server.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCommunicationClient |
TcpCommunicationSpi.createTcpClient(ClusterNode node,
int connIdx)
Establish TCP connection to remote node and returns client.
|
| Modifier and Type | Method and Description |
|---|---|
GridCommunicationClient[] |
ConnectionClientPool.clientFor(UUID id) |
@Nullable GridCommunicationClient |
ConnectionClientPool.createCommunicationClient(ClusterNode node,
int connIdx) |
@Nullable GridCommunicationClient |
ConnectionClientPool.createShmemClient(ClusterNode node,
int connIdx,
Integer port) |
GridCommunicationClient |
GridNioServerWrapper.createTcpClient(ClusterNode node,
int connIdx,
boolean backwardCompatibility)
Deprecated.
Establish TCP connection to remote node and returns client.
|
GridCommunicationClient |
ConnectionClientPool.reserveClient(ClusterNode node,
int connIdx)
Returns existing or just created client to node.
|
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<GridCommunicationClient> |
ConnectionClientPool.getFut(ConnectionKey connKey) |
GridFutureAdapter<GridCommunicationClient> |
ConnectionClientPool.putIfAbsentFut(ConnectionKey key,
GridFutureAdapter<GridCommunicationClient> fut) |
| Modifier and Type | Method and Description |
|---|---|
void |
ConnectionClientPool.addNodeClient(ClusterNode node,
int connIdx,
GridCommunicationClient addClient) |
String |
ConnectionClientPool.clientString(GridCommunicationClient client,
ClusterNode node)
Returns the string representation of client with protection from null client value.
|
boolean |
ConnectionClientPool.removeNodeClient(UUID nodeId,
GridCommunicationClient rmvClient) |
| Modifier and Type | Method and Description |
|---|---|
GridFutureAdapter<GridCommunicationClient> |
ConnectionClientPool.putIfAbsentFut(ConnectionKey key,
GridFutureAdapter<GridCommunicationClient> fut) |
void |
ConnectionClientPool.removeFut(ConnectionKey connKey,
GridFutureAdapter<GridCommunicationClient> fut) |
| Constructor and Description |
|---|
GridNioServerWrapper(IgniteLogger log,
TcpCommunicationConfiguration cfg,
AttributeNames attributeNames,
Tracing tracing,
Function<UUID,ClusterNode> nodeGetter,
Supplier<ClusterNode> locNodeSupplier,
ConnectGateway connectGate,
ClusterStateProvider stateProvider,
Supplier<IgniteExceptionRegistry> eRegistrySupplier,
CommunicationWorker commWorker,
IgniteConfiguration igniteCfg,
GridNioServerListener<Message> srvLsnr,
String igniteInstanceName,
WorkersRegistry workersRegistry,
@Nullable GridMetricManager metricMgr,
ThrowableBiFunction<ClusterNode,Integer,GridCommunicationClient,IgniteCheckedException> createTcpClientFun,
CommunicationListener<Message> lsnr,
TcpHandshakeExecutor tcpHandshakeExecutor)
Deprecated.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.0 Release Date : September 11 2021