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	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)	Deprecated. This property is ignored and will be removed in future releases.
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	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)