Uses of Class
org.apache.ignite.spi.communication.tcp.TcpCommunicationSpi

Packages that use TcpCommunicationSpi

Package	Description
org.apache.ignite.spi.communication.tcp.internal	Contains connection health-checkers for TCP/IP-based implementation of communication SPI.

Uses of TcpCommunicationSpi in org.apache.ignite.spi.communication.tcp.internal

Methods in org.apache.ignite.spi.communication.tcp.internal that return TcpCommunicationSpi

Modifier and Type	Method and Description
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setAckSendThreshold(int ackSndThreshold) Sets number of received messages per connection to node after which acknowledgment message is sent.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setAddressResolver(AddressResolver addrRslvr) Sets address resolver.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setConnectionsPerNode(int maxConnectionsPerNode) Sets number of connections to each remote node. if TcpCommunicationConfigInitializer.isUsePairedConnections() is true then number of connections is doubled and half is used for incoming and half for outgoing messages.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setConnectTimeout(long connTimeout) Sets connect timeout used when establishing connection with remote nodes.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setDirectBuffer(boolean directBuf) Sets flag to allocate direct or heap buffer in SPI.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setDirectSendBuffer(boolean directSndBuf) Sets whether to use direct buffer for sending.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setFilterReachableAddresses(boolean filterReachableAddresses) Setting this option to true enables filter for reachable addresses on creating tcp client.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setForceClientToServerConnections(boolean forceClientToSrvConnections) Applicable for clients only.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setIdleConnectionTimeout(long idleConnTimeout) Sets maximum idle connection timeout upon which a connection to client will be closed.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setLocalAddress(String locAddr) Sets local host address for socket binding.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setLocalPort(int locPort) Sets local port for socket binding.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setLocalPortRange(int locPortRange) Sets local port range for local host ports (value must greater than or equal to 0).
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setMaxConnectTimeout(long maxConnTimeout) Sets maximum connect timeout.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setMessageQueueLimit(int msgQueueLimit) Sets message queue limit for incoming and outgoing messages.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setName(String name) Sets SPI name.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setReconnectCount(int reconCnt) Sets maximum number of reconnect attempts used when establishing connection with remote nodes.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSelectorsCount(int selectorsCnt) Sets the count of selectors te be used in TCP server.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSelectorSpins(long selectorSpins) Defines how many non-blocking selector.selectNow() should be made before falling into selector.select(long) in NIO server.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSharedMemoryPort(int shmemPort) Sets local port to accept shared memory connections.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSlowClientQueueLimit(int slowClientQueueLimit) Sets slow client queue limit.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSocketReceiveBuffer(int sockRcvBuf) Sets receive buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSocketSendBuffer(int sockSndBuf) Sets send buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setSocketWriteTimeout(long sockWriteTimeout) Sets socket write timeout for TCP connection.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setTcpNoDelay(boolean tcpNoDelay) Sets value for TCP_NODELAY socket option.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize) Sets maximum number of stored unacknowledged messages per connection to node.
TcpCommunicationSpi	TcpCommunicationConfigInitializer.setUsePairedConnections(boolean usePairedConnections) Set this to true if TcpCommunicationSpi should maintain connection for outgoing and incoming messages separately.

Constructors in org.apache.ignite.spi.communication.tcp.internal with parameters of type TcpCommunicationSpi

Constructor and Description
ClusterStateProvider(Ignite ignite, Supplier<ClusterNode> locNodeSupplier, TcpCommunicationSpi tcpCommSpi, Supplier<Boolean> stoppedSupplier, Supplier<IgniteSpiContext> spiCtxWithoutLatchSupplier, IgniteLogger log, Supplier<Ignite> igniteExSupplier) Deprecated.
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)
TcpCommunicationConnectionCheckFuture(TcpCommunicationSpi spi, IgniteLogger log, GridNioServer nioSrvr, List<ClusterNode> nodes)