| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsSingleMessage |
GridDhtPartitionsExchangeFuture.mergeJoinExchangeOnDone(GridDhtPartitionsExchangeFuture fut) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDhtPartitionsExchangeFuture.fastReplyOnSingleMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Tries to fast reply with
GridDhtPartitionsFullMessage on received single message
in case of exchange future has already completed. |
void |
GridDhtPartitionsExchangeFuture.forceClientReconnect(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Method is called on coordinator in situation when initial ExchangeFuture created on client join event was preempted
from exchange history because of IGNITE_EXCHANGE_HISTORY_SIZE property.
|
void |
InitNewCoordinatorFuture.onMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg) |
void |
GridDhtPartitionsExchangeFuture.onReceiveSingleMessage(ClusterNode node,
GridDhtPartitionsSingleMessage msg)
Processing of received single message.
|
void |
GridDhtPartitionsExchangeFuture.waitAndReplyToNode(UUID nodeId,
GridDhtPartitionsSingleMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtPartitionsStateValidator.validatePartitionCountersAndSizes(GridDhtPartitionsExchangeFuture fut,
GridDhtPartitionTopology top,
Map<UUID,GridDhtPartitionsSingleMessage> messages)
Validates partition states - update counters and cache sizes for all nodes.
|
Map<Integer,Map<UUID,Long>> |
GridDhtPartitionsStateValidator.validatePartitionsSizes(GridDhtPartitionTopology top,
Map<UUID,GridDhtPartitionsSingleMessage> messages,
Set<UUID> ignoringNodes)
Validate partitions cache sizes for given
top. |
Map<Integer,Map<UUID,Long>> |
GridDhtPartitionsStateValidator.validatePartitionsUpdateCounters(GridDhtPartitionTopology top,
Map<UUID,GridDhtPartitionsSingleMessage> messages,
Set<UUID> ignoringNodes)
Validate partitions update counters for given
top. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019