| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.dht.preloader | |
| org.apache.ignite.internal.processors.cache.distributed.dht.topology |
| Modifier and Type | Method and Description |
|---|---|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions)
Creates partitions single message for all cache groups.
|
GridDhtPartitionsSingleMessage |
GridCachePartitionExchangeManager.createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId,
boolean clientOnlyExchange,
boolean sndCounters,
boolean newCntrMap,
ExchangeActions exchActions,
Collection<CacheGroupContext> grps)
Creates partitions single message for selected cache groups.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable 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.8.1 Release Date : May 21 2020