org.apache.ignite.spi.communication.tcp.internal

Class TcpCommunicationConfigInitializer

java.lang.Object

org.apache.ignite.spi.IgniteSpiAdapter

org.apache.ignite.spi.communication.tcp.internal.TcpCommunicationConfigInitializer

All Implemented Interfaces:

CommunicationSpi<Message>, IgniteSpi

Direct Known Subclasses:

TcpCommunicationSpi

public abstract class TcpCommunicationConfigInitializer
extends IgniteSpiAdapter
implements CommunicationSpi<Message>

Only may implement it TcpCommunicationSpi.

Field Summary

Fields

Modifier and Type	Field and Description
protected AttributeNames	attributeNames Attribute names.
protected TcpCommunicationConfiguration	cfg Config.
protected ConnectionPolicy	connPlc Connection policy.
protected TcpCommunicationMetricsListener	metricsLsnr Statistics.
protected IpcSharedMemoryServerEndpoint	shmemSrv Shared memory server.
protected Tracing	tracing Tracing.

Fields inherited from class org.apache.ignite.spi.IgniteSpiAdapter

ignite, igniteInstanceName, log

Constructor Summary

Constructors

Constructor and Description
TcpCommunicationConfigInitializer()

Method Summary

Modifier and Type	Method and Description
int	boundPort()
long	failureDetectionTimeout() Returns failure detection timeout set to use for network related operations.
boolean	failureDetectionTimeoutEnabled() Checks whether failure detection timeout is enabled for this IgniteSpi.
void	failureDetectionTimeoutEnabled(boolean enabled) Enables or disables failure detection timeout.
boolean	forceClientToServerConnections()
int	getAckSendThreshold() See setAckSendThreshold(int).
AddressResolver	getAddressResolver() See setAddressResolver(AddressResolver).
int	getConnectionsPerNode() See setConnectionsPerNode(int).
long	getConnectTimeout() See setConnectTimeout(long).
long	getIdleConnectionTimeout() See setIdleConnectionTimeout(long).
String	getLocalAddress() See setLocalAddress(String).
int	getLocalPort() See setLocalPort(int).
int	getLocalPortRange() See setLocalPortRange(int).
long	getMaxConnectTimeout() Gets maximum connect timeout.
int	getMessageQueueLimit() Gets message queue limit for incoming and outgoing messages.
Map<String,Object>	getNodeAttributes() This method is called before SPI starts (before method IgniteSpi.spiStart(String) is called).
int	getReconnectCount() Gets maximum number of reconnect attempts used when establishing connection with remote nodes.
int	getSelectorsCount() See setSelectorsCount(int).
long	getSelectorSpins() See setSelectorSpins(long).
int	getSharedMemoryPort() See setSharedMemoryPort(int).
int	getSlowClientQueueLimit() See setSlowClientQueueLimit(int).
int	getSocketReceiveBuffer() See setSocketReceiveBuffer(int).
int	getSocketSendBuffer() See setSocketSendBuffer(int).
long	getSocketWriteTimeout() See setSocketWriteTimeout(long).
int	getUnacknowledgedMessagesBufferSize() See setUnacknowledgedMessagesBufferSize(int).
protected void	injectResources(Ignite ignite) Injects resources.
boolean	isDirectBuffer() Gets flag that indicates whether direct or heap allocated buffer is used.
boolean	isDirectSendBuffer() Gets flag defining whether direct send buffer should be used.
boolean	isFilterReachableAddresses() Gets value for FILTER_REACHABLE_ADDRESSES socket option.
boolean	isTcpNoDelay() Gets value for TCP_NODELAY socket option.
boolean	isUsePairedConnections() See setUsePairedConnections(boolean).
protected @Nullable IpcSharedMemoryServerEndpoint	resetShmemServer() Creates new shared memory communication server.
TcpCommunicationSpi	setAckSendThreshold(int ackSndThreshold) Sets number of received messages per connection to node after which acknowledgment message is sent.
TcpCommunicationSpi	setAddressResolver(AddressResolver addrRslvr) Sets address resolver.
void	setConnectionRequestor(ConnectionRequestor connectionRequestor)
TcpCommunicationSpi	setConnectionsPerNode(int maxConnectionsPerNode) Sets number of connections to each remote node. if isUsePairedConnections() is true then number of connections is doubled and half is used for incoming and half for outgoing messages.
TcpCommunicationSpi	setConnectTimeout(long connTimeout) Sets connect timeout used when establishing connection with remote nodes.
TcpCommunicationSpi	setDirectBuffer(boolean directBuf) Sets flag to allocate direct or heap buffer in SPI.
TcpCommunicationSpi	setDirectSendBuffer(boolean directSndBuf) Sets whether to use direct buffer for sending.
TcpCommunicationSpi	setFilterReachableAddresses(boolean filterReachableAddresses) Setting this option to true enables filter for reachable addresses on creating tcp client.
TcpCommunicationSpi	setForceClientToServerConnections(boolean forceClientToSrvConnections) Applicable for clients only.
TcpCommunicationSpi	setIdleConnectionTimeout(long idleConnTimeout) Sets maximum idle connection timeout upon which a connection to client will be closed.
TcpCommunicationSpi	setLocalAddress(String locAddr) Sets local host address for socket binding.
TcpCommunicationSpi	setLocalPort(int locPort) Sets local port for socket binding.
TcpCommunicationSpi	setLocalPortRange(int locPortRange) Sets local port range for local host ports (value must greater than or equal to 0).
TcpCommunicationSpi	setMaxConnectTimeout(long maxConnTimeout) Sets maximum connect timeout.
TcpCommunicationSpi	setMessageQueueLimit(int msgQueueLimit) Sets message queue limit for incoming and outgoing messages.
TcpCommunicationSpi	setName(String name) Sets SPI name.
TcpCommunicationSpi	setReconnectCount(int reconCnt) Sets maximum number of reconnect attempts used when establishing connection with remote nodes.
TcpCommunicationSpi	setSelectorsCount(int selectorsCnt) Sets the count of selectors te be used in TCP server.
TcpCommunicationSpi	setSelectorSpins(long selectorSpins) Defines how many non-blocking selector.selectNow() should be made before falling into selector.select(long) in NIO server.
TcpCommunicationSpi	setSharedMemoryPort(int shmemPort) Sets local port to accept shared memory connections.
TcpCommunicationSpi	setSlowClientQueueLimit(int slowClientQueueLimit) Sets slow client queue limit.
TcpCommunicationSpi	setSocketReceiveBuffer(int sockRcvBuf) Sets receive buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	setSocketSendBuffer(int sockSndBuf) Sets send buffer size for sockets created or accepted by this SPI.
TcpCommunicationSpi	setSocketWriteTimeout(long sockWriteTimeout) Sets socket write timeout for TCP connection.
TcpCommunicationSpi	setTcpNoDelay(boolean tcpNoDelay) Sets value for TCP_NODELAY socket option.
TcpCommunicationSpi	setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize) Sets maximum number of stored unacknowledged messages per connection to node.
TcpCommunicationSpi	setUsePairedConnections(boolean usePairedConnections) Set this to true if TcpCommunicationSpi should maintain connection for outgoing and incoming messages separately.

Methods inherited from class org.apache.ignite.spi.IgniteSpiAdapter

addTimeoutObject, assertParameter, checkConfigurationConsistency0, clientFailureDetectionTimeout, configInfo, createSpiAttributeName, getConsistentAttributeNames, getExceptionRegistry, getLocalNode, getName, getSpiContext, ignite, initFailureDetectionTimeout, injectables, isNodeStopping, onBeforeStart, onClientDisconnected, onClientReconnected, onContextDestroyed, onContextDestroyed0, onContextInitialized, onContextInitialized0, registerMBean, removeTimeoutObject, started, startInfo, startStopwatch, stopInfo, unregisterMBean

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.ignite.spi.communication.CommunicationSpi

getOutboundMessagesQueueSize, getReceivedBytesCount, getReceivedMessagesCount, getSentBytesCount, getSentMessagesCount, resetMetrics, sendMessage, setListener

Methods inherited from interface org.apache.ignite.spi.IgniteSpi

getName, onClientDisconnected, onClientReconnected, onContextDestroyed, onContextInitialized, spiStart, spiStop

Field Detail

cfg

protected final TcpCommunicationConfiguration cfg

Config.

attributeNames

protected AttributeNames attributeNames

Attribute names.

shmemSrv

protected IpcSharedMemoryServerEndpoint shmemSrv

Shared memory server.

metricsLsnr

protected TcpCommunicationMetricsListener metricsLsnr

Statistics.

connPlc

protected ConnectionPolicy connPlc

Connection policy.

tracing

protected Tracing tracing

Tracing.

Constructor Detail

TcpCommunicationConfigInitializer

public TcpCommunicationConfigInitializer()

Method Detail

setAddressResolver

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setAddressResolver(AddressResolver addrRslvr)

Sets address resolver.

Parameters:

addrRslvr - Address resolver.

Returns:

this for chaining.

getAddressResolver

public AddressResolver getAddressResolver()

See setAddressResolver(AddressResolver).

Returns:

Address resolver.

injectResources

@IgniteInstanceResource
protected void injectResources(Ignite ignite)

Injects resources.

Overrides:

injectResources in class IgniteSpiAdapter

Parameters:

ignite - Ignite.

setLocalAddress

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setLocalAddress(String locAddr)

Sets local host address for socket binding. Note that one node could have additional addresses beside the loopback one. This configuration parameter is optional.

Parameters:

locAddr - IP address. Default value is any available local IP address.

Returns:

this for chaining.

getLocalAddress

public String getLocalAddress()

See setLocalAddress(String).

Returns:

Grid node IP address.

setLocalPort

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setLocalPort(int locPort)

Sets local port for socket binding.

If not provided, default value is TcpCommunicationSpi.DFLT_PORT.

Parameters:

locPort - Port number.

Returns:

this for chaining.

getLocalPort

public int getLocalPort()

See setLocalPort(int).

Returns:

Port number.

setLocalPortRange

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setLocalPortRange(int locPortRange)

Sets local port range for local host ports (value must greater than or equal to 0). If provided local port (see setLocalPort(int)} is occupied, implementation will try to increment the port number for as long as it is less than initial value plus this range.

If port range value is 0, then implementation will try bind only to the port provided by setLocalPort(int) method and fail if binding to this port did not succeed.

Local port range is very useful during development when more than one grid nodes need to run on the same physical machine.

If not provided, default value is TcpCommunicationSpi.DFLT_PORT_RANGE.

Parameters:

locPortRange - New local port range.

Returns:

this for chaining.

getLocalPortRange

public int getLocalPortRange()

See setLocalPortRange(int).

Returns:

Local Port range.

isUsePairedConnections

public boolean isUsePairedConnections()

See setUsePairedConnections(boolean).

Returns:

true to use paired connections and false otherwise.

setUsePairedConnections

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setUsePairedConnections(boolean usePairedConnections)

Set this to true if TcpCommunicationSpi should maintain connection for outgoing and incoming messages separately. In this case total number of connections between local and each remote node is getConnectionsPerNode() * 2.

Set this to false if each connection of getConnectionsPerNode() should be used for outgoing and incoming messages. In this case total number of connections between local and each remote node is getConnectionsPerNode().

Default is false.

Parameters:

usePairedConnections - true to use paired connections and false otherwise.

Returns:

this for chaining.

See Also:

getConnectionsPerNode()

setConnectionsPerNode

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setConnectionsPerNode(int maxConnectionsPerNode)

Sets number of connections to each remote node. if isUsePairedConnections() is true then number of connections is doubled and half is used for incoming and half for outgoing messages.

Parameters:

maxConnectionsPerNode - Number of connections per node.

Returns:

this for chaining.

See Also:

isUsePairedConnections()

getConnectionsPerNode

public int getConnectionsPerNode()

See setConnectionsPerNode(int).

Returns:

Number of connections per node.

setSharedMemoryPort

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSharedMemoryPort(int shmemPort)

Sets local port to accept shared memory connections.

If set to -1 shared memory communication will be disabled.

If not provided, default value is TcpCommunicationSpi.DFLT_SHMEM_PORT.

Parameters:

shmemPort - Port number.

Returns:

this for chaining.

getSharedMemoryPort

public int getSharedMemoryPort()

See setSharedMemoryPort(int).

Returns:

Port number.

setIdleConnectionTimeout

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setIdleConnectionTimeout(long idleConnTimeout)

Sets maximum idle connection timeout upon which a connection to client will be closed.

If not provided, default value is TcpCommunicationSpi.DFLT_IDLE_CONN_TIMEOUT.

Parameters:

idleConnTimeout - Maximum idle connection time.

Returns:

this for chaining.

getIdleConnectionTimeout

public long getIdleConnectionTimeout()

See setIdleConnectionTimeout(long).

Returns:

Maximum idle connection time.

getSocketWriteTimeout

public long getSocketWriteTimeout()

See setSocketWriteTimeout(long).

Returns:

Socket write timeout for TCP connections.

setSocketWriteTimeout

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSocketWriteTimeout(long sockWriteTimeout)

Sets socket write timeout for TCP connection. If message can not be written to socket within this time then connection is closed and reconnect is attempted.

Default to TcpCommunicationSpi.DFLT_SOCK_WRITE_TIMEOUT.

Parameters:

sockWriteTimeout - Socket write timeout for TCP connection.

Returns:

this for chaining.

getAckSendThreshold

public int getAckSendThreshold()

See setAckSendThreshold(int).

Returns:

Number of received messages after which acknowledgment is sent.

setAckSendThreshold

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setAckSendThreshold(int ackSndThreshold)

Sets number of received messages per connection to node after which acknowledgment message is sent.

Default to TcpCommunicationSpi.DFLT_ACK_SND_THRESHOLD.

Parameters:

ackSndThreshold - Number of received messages after which acknowledgment is sent.

Returns:

this for chaining.

getUnacknowledgedMessagesBufferSize

public int getUnacknowledgedMessagesBufferSize()

See setUnacknowledgedMessagesBufferSize(int).

Returns:

Maximum number of unacknowledged messages.

setUnacknowledgedMessagesBufferSize

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setUnacknowledgedMessagesBufferSize(int unackedMsgsBufSize)

Sets maximum number of stored unacknowledged messages per connection to node. If number of unacknowledged messages exceeds this number then connection to node is closed and reconnect is attempted.

Parameters:

unackedMsgsBufSize - Maximum number of unacknowledged messages.

Returns:

this for chaining.

setConnectTimeout

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setConnectTimeout(long connTimeout)

Sets connect timeout used when establishing connection with remote nodes.

0 is interpreted as infinite timeout.

If not provided, default value is TcpCommunicationSpi.DFLT_CONN_TIMEOUT.

When this property is explicitly set IgniteConfiguration.getFailureDetectionTimeout() is ignored.

Parameters:

connTimeout - Connect timeout.

Returns:

this for chaining.

getConnectTimeout

public long getConnectTimeout()

See setConnectTimeout(long).

Returns:

Connect timeout.

setMaxConnectTimeout

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setMaxConnectTimeout(long maxConnTimeout)

Sets maximum connect timeout. If handshake is not established within connect timeout, then SPI tries to repeat handshake procedure with increased connect timeout. Connect timeout can grow till maximum timeout value, if maximum timeout value is reached then the handshake is considered as failed.

0 is interpreted as infinite timeout.

If not provided, default value is TcpCommunicationSpi.DFLT_MAX_CONN_TIMEOUT.

When this property is explicitly set IgniteConfiguration.getFailureDetectionTimeout() is ignored.

Parameters:

maxConnTimeout - Maximum connect timeout.

Returns:

this for chaining.

getMaxConnectTimeout

public long getMaxConnectTimeout()

Gets maximum connect timeout.

Returns:

Maximum connect timeout.

setReconnectCount

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setReconnectCount(int reconCnt)

Sets maximum number of reconnect attempts used when establishing connection with remote nodes.

If not provided, default value is TcpCommunicationSpi.DFLT_RECONNECT_CNT.

When this property is explicitly set IgniteConfiguration.getFailureDetectionTimeout() is ignored.

Parameters:

reconCnt - Maximum number of reconnection attempts.

Returns:

this for chaining.

getReconnectCount

public int getReconnectCount()

Gets maximum number of reconnect attempts used when establishing connection with remote nodes.

Returns:

Reconnects count.

setDirectBuffer

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setDirectBuffer(boolean directBuf)

Sets flag to allocate direct or heap buffer in SPI. If value is true, then SPI will use ByteBuffer.allocateDirect(int) call. Otherwise, SPI will use ByteBuffer.allocate(int) call.

If not provided, default value is true.

Parameters:

directBuf - Flag indicates to allocate direct or heap buffer in SPI.

Returns:

this for chaining.

isDirectBuffer

public boolean isDirectBuffer()

Gets flag that indicates whether direct or heap allocated buffer is used.

Returns:

Flag that indicates whether direct or heap allocated buffer is used.

isDirectSendBuffer

public boolean isDirectSendBuffer()

Gets flag defining whether direct send buffer should be used.

Returns:

True if direct buffers should be used.

setDirectSendBuffer

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setDirectSendBuffer(boolean directSndBuf)

Sets whether to use direct buffer for sending. If not provided default is false.

Parameters:

directSndBuf - True to use direct buffers for send.

Returns:

this for chaining.

setSelectorsCount

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSelectorsCount(int selectorsCnt)

Sets the count of selectors te be used in TCP server.

If not provided, default value is TcpCommunicationSpi.DFLT_SELECTORS_CNT.

Parameters:

selectorsCnt - Selectors count.

Returns:

this for chaining.

getSelectorsCount

public int getSelectorsCount()

See setSelectorsCount(int).

Returns:

Count of selectors in TCP server.

getSelectorSpins

public long getSelectorSpins()

See setSelectorSpins(long).

Returns:

Selector thread busy-loop iterations.

setSelectorSpins

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSelectorSpins(long selectorSpins)

Defines how many non-blocking selector.selectNow() should be made before falling into selector.select(long) in NIO server. Long value. Default is 0. Can be set to Long.MAX_VALUE so selector threads will never block.

Parameters:

selectorSpins - Selector thread busy-loop iterations.

Returns:

this for chaining.

setConnectionRequestor

public void setConnectionRequestor(ConnectionRequestor connectionRequestor)

setTcpNoDelay

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setTcpNoDelay(boolean tcpNoDelay)

Sets value for TCP_NODELAY socket option. Each socket will be opened using provided value.

Setting this option to true disables Nagle's algorithm for socket decreasing latency and delivery time for small messages.

For systems that work under heavy network load it is advisable to set this value to false.

If not provided, default value is TcpCommunicationSpi.DFLT_TCP_NODELAY.

Parameters:

tcpNoDelay - True to disable TCP delay.

Returns:

this for chaining.

isTcpNoDelay

public boolean isTcpNoDelay()

Gets value for TCP_NODELAY socket option.

Returns:

True if TCP delay is disabled.

isFilterReachableAddresses

public boolean isFilterReachableAddresses()

Gets value for FILTER_REACHABLE_ADDRESSES socket option.

Returns:

True if needed to filter reachable addresses.

setFilterReachableAddresses

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setFilterReachableAddresses(boolean filterReachableAddresses)

Setting this option to true enables filter for reachable addresses on creating tcp client.

Usually its advised to set this value to false.

If not provided, default value is TcpCommunicationSpi.DFLT_FILTER_REACHABLE_ADDRESSES.

Parameters:

filterReachableAddresses - True to filter reachable addresses.

Returns:

this for chaining.

setSocketReceiveBuffer

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSocketReceiveBuffer(int sockRcvBuf)

Sets receive buffer size for sockets created or accepted by this SPI.

If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE.

Parameters:

sockRcvBuf - Socket receive buffer size.

Returns:

this for chaining.

getSocketReceiveBuffer

public int getSocketReceiveBuffer()

See setSocketReceiveBuffer(int).

Returns:

Socket receive buffer size.

setSocketSendBuffer

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSocketSendBuffer(int sockSndBuf)

Sets send buffer size for sockets created or accepted by this SPI.

If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE.

Parameters:

sockSndBuf - Socket send buffer size.

Returns:

this for chaining.

getSocketSendBuffer

public int getSocketSendBuffer()

See setSocketSendBuffer(int).

Returns:

Socket send buffer size.

setMessageQueueLimit

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setMessageQueueLimit(int msgQueueLimit)

Sets message queue limit for incoming and outgoing messages.

When set to positive number send queue is limited to the configured value. 0 disables the size limitations.

If not provided, default is TcpCommunicationSpi.DFLT_MSG_QUEUE_LIMIT.

Parameters:

msgQueueLimit - Send queue size limit.

Returns:

this for chaining.

getMessageQueueLimit

public int getMessageQueueLimit()

Gets message queue limit for incoming and outgoing messages.

Returns:

Send queue size limit.

getSlowClientQueueLimit

public int getSlowClientQueueLimit()

See setSlowClientQueueLimit(int).

Returns:

Slow client queue limit.

failureDetectionTimeoutEnabled

public void failureDetectionTimeoutEnabled(boolean enabled)

Enables or disables failure detection timeout.

Overrides:

failureDetectionTimeoutEnabled in class IgniteSpiAdapter

Parameters:

enabled - true if enable, false otherwise.

failureDetectionTimeoutEnabled

public boolean failureDetectionTimeoutEnabled()

Checks whether failure detection timeout is enabled for this IgniteSpi.

Overrides:

failureDetectionTimeoutEnabled in class IgniteSpiAdapter

Returns:

true if enabled, false otherwise.

failureDetectionTimeout

public long failureDetectionTimeout()

Returns failure detection timeout set to use for network related operations.

Overrides:

failureDetectionTimeout in class IgniteSpiAdapter

Returns:

failure detection timeout in milliseconds or 0 if the timeout is disabled.

forceClientToServerConnections

public boolean forceClientToServerConnections()

Returns:

Force client to server connections flag.

See Also:

setForceClientToServerConnections(boolean)

setForceClientToServerConnections

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setForceClientToServerConnections(boolean forceClientToSrvConnections)

Applicable for clients only. Sets PSI in the mode when server node cannot open TCP connection to the current node. Possile reasons for that may be specific network configurations or security rules. In this mode, when server needs the connection with client, it uses DiscoverySpi protocol to notify client about it. After that client opens the required connection from its side.

setSlowClientQueueLimit

@IgniteSpiConfiguration(optional=true)
public TcpCommunicationSpi setSlowClientQueueLimit(int slowClientQueueLimit)

Sets slow client queue limit.

When set to a positive number, communication SPI will monitor clients outbound message queue sizes and will drop those clients whose queue exceeded this limit.

This value should be set to less or equal value than getMessageQueueLimit() which controls message back-pressure for server nodes. The default value for this parameter is 0 which means unlimited.

Parameters:

slowClientQueueLimit - Slow client queue limit.

Returns:

this for chaining.

boundPort

public int boundPort()

Returns:

Bound TCP server port.

setName

public TcpCommunicationSpi setName(String name)

Sets SPI name.

Overrides:

setName in class IgniteSpiAdapter

Parameters:

name - SPI name.

Returns:

this for chaining.

getNodeAttributes

public Map<String,Object> getNodeAttributes()
                                     throws IgniteSpiException

This method is called before SPI starts (before method IgniteSpi.spiStart(String) is called). It allows SPI implementation to add attributes to a local node. Kernal collects these attributes from all SPI implementations loaded up and then passes it to discovery SPI so that they can be exchanged with other nodes.

Specified by:

getNodeAttributes in interface IgniteSpi

Overrides:

getNodeAttributes in class IgniteSpiAdapter

Returns:

Map of local node attributes this SPI wants to add.

Throws:

IgniteSpiException - Throws in case of any error.

resetShmemServer

@Nullable
protected @Nullable IpcSharedMemoryServerEndpoint resetShmemServer()
                                                                      throws IgniteCheckedException

Creates new shared memory communication server.

Returns:

Server.

Throws:

IgniteCheckedException - If failed.