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,
ClusterStateProvider clusterStateProvider,
GridNioServerWrapper nioSrvWrapper,
String igniteInstanceName) |
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.
|
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) |