Uses of Class
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsSingleMessage
-
Packages that use GridDhtPartitionsSingleMessage 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 -
-
Uses of GridDhtPartitionsSingleMessage in org.apache.ignite.internal.processors.cache
Methods in org.apache.ignite.internal.processors.cache that return GridDhtPartitionsSingleMessage Modifier and Type Method Description GridDhtPartitionsSingleMessageGridCachePartitionExchangeManager. createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId, boolean clientOnlyExchange, boolean sndCounters, boolean newCntrMap, ExchangeActions exchActions)Creates partitions single message for all cache groups.GridDhtPartitionsSingleMessageGridCachePartitionExchangeManager. createPartitionsSingleMessage(@Nullable GridDhtPartitionExchangeId exchangeId, boolean clientOnlyExchange, boolean sndCounters, boolean newCntrMap, ExchangeActions exchActions, Collection<CacheGroupContext> grps)Creates partitions single message for selected cache groups. -
Uses of GridDhtPartitionsSingleMessage in org.apache.ignite.internal.processors.cache.distributed.dht.preloader
Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that return GridDhtPartitionsSingleMessage Modifier and Type Method Description @Nullable GridDhtPartitionsSingleMessageGridDhtPartitionsExchangeFuture. mergeJoinExchangeOnDone(GridDhtPartitionsExchangeFuture fut)Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type GridDhtPartitionsSingleMessage Modifier and Type Method Description booleanGridDhtPartitionsExchangeFuture. fastReplyOnSingleMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)Tries to fast reply withGridDhtPartitionsFullMessageon received single message in case of exchange future has already completed.voidGridDhtPartitionsExchangeFuture. 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.voidInitNewCoordinatorFuture. onMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)voidGridDhtPartitionsExchangeFuture. onReceiveSingleMessage(ClusterNode node, GridDhtPartitionsSingleMessage msg)Processing of received single message.voidGridDhtPartitionsExchangeFuture. waitAndReplyToNode(UUID nodeId, GridDhtPartitionsSingleMessage msg) -
Uses of GridDhtPartitionsSingleMessage in org.apache.ignite.internal.processors.cache.distributed.dht.topology
Method parameters in org.apache.ignite.internal.processors.cache.distributed.dht.topology with type arguments of type GridDhtPartitionsSingleMessage Modifier and Type Method Description voidGridDhtPartitionsStateValidator. 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 giventop.Map<Integer,Map<UUID,Long>>GridDhtPartitionsStateValidator. validatePartitionsUpdateCounters(GridDhtPartitionTopology top, Map<UUID,GridDhtPartitionsSingleMessage> messages, Set<UUID> ignoringNodes)Validate partitions update counters for giventop.
-