CommunicationWorker(String igniteInstanceName,
IgniteLogger log,
TcpCommunicationConfiguration cfg,
AttributeNames attrs,
ConnectionClientPool clientPool,
Supplier<FailureProcessor> failureProcessorSupplier,
Function<UUID,ClusterNode> nodeGetter,
Function<UUID,Boolean> pingNode,
Supplier<IgniteExceptionRegistry> eRegistrySupplier,
GridNioServerWrapper nioSrvWrapper,
WorkersRegistry workersRegistry,
String spiName) |
ConnectionClientPool(TcpCommunicationConfiguration cfg,
AttributeNames attrs,
IgniteLogger log,
TcpCommunicationMetricsListener metricsLsnr,
Supplier<ClusterNode> locNodeSupplier,
Function<UUID,ClusterNode> nodeGetter,
Supplier<MessageFormatter> msgFormatterSupplier,
WorkersRegistry registry,
TcpCommunicationSpi tcpCommSpi,
GridTimeoutProcessor timeObjProcessor,
ClusterStateProvider clusterStateProvider,
GridNioServerWrapper nioSrvWrapper) |
InboundConnectionHandler(IgniteLogger log,
TcpCommunicationConfiguration cfg,
Function<UUID,ClusterNode> nodeGetter,
Supplier<ClusterNode> locNodeSupplier,
ClusterStateProvider stateProvider,
ConnectionClientPool clientPool,
CommunicationWorker commWorker,
ConnectGateway connectGate,
Supplier<FailureProcessor> failureProcessorSupplier,
AttributeNames attributeNames,
TcpCommunicationMetricsListener metricsLsnr,
GridNioServerWrapper nioSrvWrapper,
CountDownLatch ctxInitLatch,
boolean client,
Supplier<Ignite> igniteExSupplier,
CommunicationListener<Message> lsnr) |