@MXBeanDescription(value="MBean provide access to TCP-based communication SPI.") public interface TcpCommunicationSpiMBean extends IgniteSpiManagementMBean
Modifier and Type | Method and Description |
---|---|
void |
dumpStats()
Dumps SPI per-connection stats to logs.
|
int |
getAckSendThreshold()
Gets number of received messages per connection to node after which acknowledgment message is sent.
|
long |
getAckSendThresholdBytes()
Gets accrued size of received messages per connection to node after which acknowledgment message is sent.
|
long |
getAckSendThresholdMillis()
Gets number of milliseconds after which acknowledgment is sent (if there are unacked messages).
|
int |
getConnectionsPerNode()
Gets 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. |
long |
getConnectTimeout()
Gets connect timeout used when establishing connection
with remote nodes.
|
long |
getIdleConnectionTimeout()
Gets maximum idle connection time upon which idle connections
will be closed.
|
String |
getLocalAddress()
Gets local host address for socket binding.
|
int |
getLocalPort()
Gets local port for socket binding.
|
int |
getLocalPortRange()
Gets maximum number of local ports tried if all previously
tried ports are occupied.
|
long |
getMaxConnectTimeout()
Gets maximum connect timeout.
|
int |
getMessageQueueLimit()
Gets message queue limit for incoming and outgoing messages.
|
int |
getOutboundMessagesQueueSize()
Gets outbound messages queue size.
|
long |
getReceivedBytesCount()
Gets received bytes count.
|
Map<UUID,Long> |
getReceivedMessagesByNode()
Gets received messages counts (grouped by node).
|
Map<String,Long> |
getReceivedMessagesByType()
Gets received messages counts (grouped by type).
|
int |
getReceivedMessagesCount()
Gets received messages count.
|
int |
getReconnectCount()
Gets maximum number of reconnect attempts used when establishing connection
with remote nodes.
|
int |
getSelectorsCount()
Gets count of selectors used in TCP server.
|
long |
getSelectorSpins()
Defines how many non-blocking
selector.selectNow() should be made before
falling into selector.select(long) in NIO server. |
long |
getSentBytesCount()
Gets sent bytes count.
|
Map<UUID,Long> |
getSentMessagesByNode()
Gets sent messages counts (grouped by node).
|
Map<String,Long> |
getSentMessagesByType()
Gets sent messages counts (grouped by type).
|
int |
getSentMessagesCount()
Gets sent messages count.
|
int |
getSharedMemoryPort()
Gets local port for shared memory communication.
|
int |
getSlowClientQueueLimit()
Gets slow client queue limit.
|
int |
getSocketReceiveBuffer()
Gets receive buffer size for sockets created or accepted by this SPI.
|
int |
getSocketSendBuffer()
Gets send buffer size for sockets created or accepted by this SPI.
|
long |
getSocketWriteTimeout()
Gets socket write timeout for TCP connections.
|
int |
getUnacknowledgedMessagesBufferSize()
Gets maximum number of stored unacknowledged messages per connection to node.
|
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 |
isTcpNoDelay()
Gets value for
TCP_NODELAY socket option. |
boolean |
isUsePairedConnections()
Returns
true if TcpCommunicationSpi should
maintain connection for outgoing and incoming messages separately. |
getIgniteHome, getLocalNodeId, getName, getStartTimestamp, getStartTimestampFormatted, getUpTime, getUpTimeFormatted
@MXBeanDescription(value="Grid node IP address.") String getLocalAddress()
@MXBeanDescription(value="Port number.") int getLocalPort()
@MXBeanDescription(value="Paired connections used.") boolean isUsePairedConnections()
true
if TcpCommunicationSpi
should
maintain connection for outgoing and incoming messages separately.
In this case total number of connections between local and some remote node
is getConnectionsPerNode()
* 2.
Returns false
if each connection of getConnectionsPerNode()
should be used for outgoing and incoming messages.
Default is false
.
true
to use paired connections and false
otherwise.getConnectionsPerNode()
@MXBeanDescription(value="Connections per node.") int getConnectionsPerNode()
isUsePairedConnections()
is true
then number of connections is doubled and half is used for incoming and
half for outgoing messages.isUsePairedConnections()
@MXBeanDescription(value="Shared memory endpoint port number.") int getSharedMemoryPort()
@MXBeanDescription(value="Local port range.") int getLocalPortRange()
@MXBeanDescription(value="Maximum idle connection time.") long getIdleConnectionTimeout()
@MXBeanDescription(value="Flag that indicates whether direct or heap allocated buffer is used.") boolean isDirectBuffer()
@MXBeanDescription(value="Count of selectors used in TCP server.") int getSelectorsCount()
@MXBeanDescription(value="Sent messages count.") int getSentMessagesCount()
@MXBeanDescription(value="Sent bytes count.") long getSentBytesCount()
@MXBeanDescription(value="Received messages count.") int getReceivedMessagesCount()
@MXBeanDescription(value="Received bytes count.") long getReceivedBytesCount()
@MXBeanDescription(value="Received messages count grouped by message type.") Map<String,Long> getReceivedMessagesByType()
@MXBeanDescription(value="Received messages count grouped by sender node.") Map<UUID,Long> getReceivedMessagesByNode()
@MXBeanDescription(value="Sent messages count grouped by message type.") Map<String,Long> getSentMessagesByType()
@MXBeanDescription(value="Sent messages count grouped by receiver node.") Map<UUID,Long> getSentMessagesByNode()
@MXBeanDescription(value="Outbound messages queue size.") int getOutboundMessagesQueueSize()
@MXBeanDescription(value="Connect timeout.") long getConnectTimeout()
@MXBeanDescription(value="Maximum connect timeout.") long getMaxConnectTimeout()
@MXBeanDescription(value="Reconnect count on connection failure.") int getReconnectCount()
@MXBeanDescription(value="Selector thread busy-loop iterations.") long getSelectorSpins()
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.@MXBeanDescription(value="TCP_NODELAY socket option value.") boolean isTcpNoDelay()
TCP_NODELAY
socket option.True
if TCP delay is disabled.@MXBeanDescription(value="Direct send buffer.") boolean isDirectSendBuffer()
True
if direct buffers should be used.@MXBeanDescription(value="Socket receive buffer.") int getSocketReceiveBuffer()
If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE
.
@MXBeanDescription(value="Socket send buffer.") int getSocketSendBuffer()
If not provided, default is TcpCommunicationSpi.DFLT_SOCK_BUF_SIZE
.
@MXBeanDescription(value="Message queue size limit.") int getMessageQueueLimit()
@MXBeanDescription(value="Socket write timeout.") long getSocketWriteTimeout()
@MXBeanDescription(value="Number of received messages after which acknowledgment is sent.") int getAckSendThreshold()
@MXBeanDescription(value="Accrued size of received messages after which an acknowledgment is sent.") long getAckSendThresholdBytes()
@MXBeanDescription(value="Number of milliseconds after which an acknowledgment is sent (if there are unacknowledged messages).") long getAckSendThresholdMillis()
@MXBeanDescription(value="Maximum number of unacknowledged messages.") int getUnacknowledgedMessagesBufferSize()
@MXBeanDescription(value="Slow client queue limit.") int getSlowClientQueueLimit()
@MXBeanDescription(value="Dumps SPI statistics to logs.") void dumpStats()
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024