| Package | Description |
|---|---|
| org.gridgain.grid.spi.discovery.tcp.internal |
Contains internal implementation.
|
| org.gridgain.grid.spi.discovery.tcp.messages |
Contains implementation messages.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoveryStatistics.onMessageProcessingFinished(GridTcpDiscoveryAbstractMessage msg)
Collects necessary stats for message processed by SPI.
|
void |
GridTcpDiscoveryStatistics.onMessageProcessingStarted(GridTcpDiscoveryAbstractMessage msg)
Collects necessary stats for message processed by SPI.
|
void |
GridTcpDiscoveryStatistics.onMessageReceived(GridTcpDiscoveryAbstractMessage msg)
Collects necessary stats for message received by SPI.
|
void |
GridTcpDiscoveryStatistics.onMessageSent(GridTcpDiscoveryAbstractMessage msg,
long time)
Called by coordinator when ring message is sent.
|
void |
GridTcpDiscoveryStatistics.onRingMessageReceived(GridTcpDiscoveryAbstractMessage msg)
Called by coordinator when ring message makes full pass.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridTcpDiscoveryAuthFailedMessage
Message telling joining node that its authentication failed on coordinator.
|
class |
GridTcpDiscoveryCheckFailedMessage
Message telling joining node that it failed coordinator's validation check.
|
class |
GridTcpDiscoveryDiscardMessage
Message sent by coordinator when some operation handling is over.
|
class |
GridTcpDiscoveryDuplicateIdMessage
Message telling joining node that new topology already contain
different node with same ID.
|
class |
GridTcpDiscoveryHandshakeRequest
Handshake request.
|
class |
GridTcpDiscoveryHandshakeResponse
Handshake response.
|
class |
GridTcpDiscoveryHeartbeatMessage
Heartbeat message.
|
class |
GridTcpDiscoveryJoinRequestMessage
Initial message sent by a node that wants to enter topology.
|
class |
GridTcpDiscoveryLoopbackProblemMessage
Message telling joining node that it has loopback problem (misconfiguration).
|
class |
GridTcpDiscoveryNodeAddedMessage
Message telling nodes that new node should be added to topology.
|
class |
GridTcpDiscoveryNodeAddFinishedMessage
Sent by coordinator across the ring to finish node add process.
|
class |
GridTcpDiscoveryNodeFailedMessage
Sent by node that has detected node failure to coordinator across the ring,
then sent by coordinator across the ring.
|
class |
GridTcpDiscoveryNodeLeftMessage
Sent by node that is stopping to coordinator across the ring,
then sent by coordinator across the ring.
|
class |
GridTcpDiscoveryStatusCheckMessage
Message sent by node to its next to ensure that next node and
connection to it are alive.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<GridTcpDiscoveryAbstractMessage> |
GridTcpDiscoveryNodeAddedMessage.messages()
Gets pending messages sent to new node by its previous.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoveryNodeAddedMessage.messages(Collection<GridTcpDiscoveryAbstractMessage> msgs)
Sets pending messages to send to new node.
|
Copyright © 2014. All rights reserved.