Uses of Class
org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture

Packages that use GridDhtPartitionsExchangeFuture

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
org.apache.ignite.internal.processors.cache.persistence	This package contain cache with persistence implementation.
org.apache.ignite.internal.processors.cache.persistence.snapshot
org.apache.ignite.internal.processors.platform
org.apache.ignite.internal.processors.query

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
@Nullable GridDhtPartitionsExchangeFuture	GridCachePartitionExchangeManager.lastFinishedFuture()
GridDhtPartitionsExchangeFuture	GridCachePartitionExchangeManager.lastTopologyFuture()

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
List<GridDhtPartitionsExchangeFuture>	GridCachePartitionExchangeManager.exchangeFutures()

Methods in org.apache.ignite.internal.processors.cache with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
void	CacheAffinitySharedManager.applyAffinityFromFullMessage(GridDhtPartitionsExchangeFuture fut, Map<Integer,CacheGroupAffinityMessage> idealAffDiff) Applies affinity diff from the received full message.
void	WalStateManager.changeLocalStatesOnExchangeDone(AffinityTopologyVersion topVer, GridDhtPartitionsExchangeFuture exchFut) Change local WAL state before exchange is done.
void	GridCachePartitionExchangeManager.dumpDebugInfo(@Nullable GridDhtPartitionsExchangeFuture exchFut)
void	CacheAffinitySharedManager.forceCloseCaches(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions) Called during the rollback of the exchange partitions procedure in order to stop the given cache even if it's not fully initialized (e.g. failed on cache init stage).
@Nullable GridDhtPreloaderAssignments	GridCachePreloader.generateAssignments(GridDhtPartitionExchangeId exchId, @Nullable GridDhtPartitionsExchangeFuture exchFut)
GridDhtPreloaderAssignments	GridCachePreloaderAdapter.generateAssignments(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>>	CacheAffinitySharedManager.initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut)
IgniteInternalFuture<?>	CacheAffinitySharedManager.initCoordinatorCaches(GridDhtPartitionsExchangeFuture fut, boolean newAff)
IgniteInternalFuture<?>	CacheAffinitySharedManager.initStartedCaches(boolean crd, GridDhtPartitionsExchangeFuture fut, Collection<DynamicCacheDescriptor> descs) Initialized affinity for cache received from node joining on this exchange.
void	GridCachePartitionExchangeManager.lastFinishedFuture(GridDhtPartitionsExchangeFuture fut)
boolean	GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut, GridDhtPartitionsFullMessage msg)
boolean	GridCachePartitionExchangeManager.mergeExchangesOnCoordinator(GridDhtPartitionsExchangeFuture curFut, @Nullable AffinityTopologyVersion threshold)
void	CacheAffinitySharedManager.onBaselineTopologyChanged(GridDhtPartitionsExchangeFuture fut, boolean crd)
IgniteInternalFuture<?>	CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions) Called on exchange initiated for cache start/stop request.
boolean	CacheAffinitySharedManager.onCentralizedAffinityChange(GridDhtPartitionsExchangeFuture fut, boolean crd) Called on exchange initiated by server node leave or custom event with centralized affinity assignment.
void	CacheAffinitySharedManager.onChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg) Called on exchange initiated by CacheAffinityChangeMessage which sent after rebalance finished.
void	CacheAffinitySharedManager.onClientEvent(GridDhtPartitionsExchangeFuture fut) Called on exchange initiated by client node join/fail.
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onCustomEventWithEnforcedAffinityReassignment(GridDhtPartitionsExchangeFuture fut) Calculates affinity on coordinator for custom event types that require centralized assignment.
void	CacheAffinitySharedManager.onCustomMessageNoAffinityChange(GridDhtPartitionsExchangeFuture fut, @Nullable ExchangeActions exchActions)
void	CacheAffinitySharedManager.onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, CacheAffinityChangeMessage msg) Called when received CacheAffinityChangeMessage which should complete exchange.
void	CacheAffinitySharedManager.onExchangeFreeSwitch(GridDhtPartitionsExchangeFuture fut) Called on exchange initiated by baseline server node leave on fully-rebalanced topology.
Set<Integer>	CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut, Map<Integer,CacheGroupAffinityMessage> receivedAff, AffinityTopologyVersion resTopVer)
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onReassignmentEnforced(GridDhtPartitionsExchangeFuture fut) Calculates new affinity assignment on coordinator and creates affinity diff messages for other nodes.
void	CacheAffinitySharedManager.onServerJoin(GridDhtPartitionsExchangeFuture fut, boolean crd) Called on exchange initiated by server node join.
void	CacheAffinitySharedManager.onServerJoinWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut, boolean crd)
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onServerLeftWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut)
void	GridCachePreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
void	GridCachePreloaderAdapter.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
void	ExchangeDiscoveryEvents.processEvents(GridDhtPartitionsExchangeFuture fut)
boolean	GridCachePreloader.rebalanceRequired(GridDhtPartitionsExchangeFuture exchFut)
boolean	GridCachePreloaderAdapter.rebalanceRequired(GridDhtPartitionsExchangeFuture exchFut)

Constructors in org.apache.ignite.internal.processors.cache with parameters of type GridDhtPartitionsExchangeFuture

Constructor and Description
ExchangeContext(GridCacheSharedContext<?,?> cctx, boolean crd, GridDhtPartitionsExchangeFuture fut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
int	GridDhtPartitionsExchangeFuture.compareTo(GridDhtPartitionsExchangeFuture fut)
void	GridDhtPartitionsExchangeFuture.finishMerged(AffinityTopologyVersion resVer, GridDhtPartitionsExchangeFuture exchFut) Finish merged future to allow GridCachePartitionExchangeManager.ExchangeFutureSet cleanup.
GridDhtPreloaderAssignments	GridDhtPreloader.generateAssignments(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
void	InitNewCoordinatorFuture.init(GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionsExchangeFuture.mergeJoinExchange(GridDhtPartitionsExchangeFuture fut) Merges this exchange with given one.
@Nullable GridDhtPartitionsSingleMessage	GridDhtPartitionsExchangeFuture.mergeJoinExchangeOnDone(GridDhtPartitionsExchangeFuture fut)
default void	PartitionsExchangeAware.onDoneAfterTopologyUnlock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process completion; called after topology is unlocked.
default void	PartitionsExchangeAware.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process completion; called before topology is unlocked.
default void	PartitionsExchangeAware.onInitAfterTopologyLock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process initialization; called after topology is locked.
default void	PartitionsExchangeAware.onInitBeforeTopologyLock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process initialization; called before topology is locked.
void	GridDhtPreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
boolean	GridDhtPreloader.rebalanceRequired(GridDhtPartitionsExchangeFuture exchFut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.distributed.dht.topology

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.topology with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
boolean	GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
boolean	GridDhtPartitionTopologyImpl.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
boolean	GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
void	GridDhtPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean affReady, boolean updateMoving) Pre-initializes this topology.
void	GridDhtPartitionTopologyImpl.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean affReady, boolean updateMoving) Pre-initializes this topology.
void	GridClientPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean initParts, boolean updateMoving) Pre-initializes this topology.
boolean	GridDhtPartitionTopology.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut) Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopologyImpl.detectLostPartitions(AffinityTopologyVersion resTopVer, GridDhtPartitionsExchangeFuture fut) Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridClientPartitionTopology.detectLostPartitions(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture fut) Checks if there is at least one owner for each partition in the cache topology for a local node.
boolean	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridDhtPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
void	GridDhtPartitionTopologyImpl.onExchangeDone(@Nullable GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
void	GridClientPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
Map<UUID,Set<Integer>>	GridDhtPartitionTopology.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut) Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
Map<UUID,Set<Integer>>	GridDhtPartitionTopologyImpl.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut) Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
Map<UUID,Set<Integer>>	GridClientPartitionTopology.resetOwners(Map<Integer,Set<UUID>> ownersByUpdCounters, Set<Integer> haveHist, GridDhtPartitionsExchangeFuture exchFut) Calculates nodes and partitions which have non-actual state (based on LWM value) and must be rebalanced.
boolean	GridDhtPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeResVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridDhtPartitionTopologyImpl.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap incomeCntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
boolean	GridClientPartitionTopology.update(@Nullable AffinityTopologyVersion exchangeVer, GridDhtPartitionFullMap partMap, @Nullable CachePartitionFullCountersMap cntrMap, Set<Integer> partsToReload, @Nullable Map<Integer,Long> partSizes, @Nullable AffinityTopologyVersion msgTopVer, @Nullable GridDhtPartitionsExchangeFuture exchFut, @Nullable Set<Integer> lostParts)
void	GridDhtPartitionsStateValidator.validatePartitionCountersAndSizes(GridDhtPartitionsExchangeFuture fut, GridDhtPartitionTopology top, Map<UUID,GridDhtPartitionsSingleMessage> messages) Validates partition states - update counters and cache sizes for all nodes.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.persistence

Methods in org.apache.ignite.internal.processors.cache.persistence with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
void	GridCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture fut)
void	IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
void	GridCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture exchangeFut)
void	IgniteCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.cache.persistence.snapshot

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
void	IgniteSnapshotManager.onDoneBeforeTopologyUnlock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process completion; called before topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.platform

Methods in org.apache.ignite.internal.processors.platform with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
void	PlatformContextImpl.onDoneAfterTopologyUnlock(GridDhtPartitionsExchangeFuture fut) Callback from exchange process completion; called after topology is unlocked.

Uses of GridDhtPartitionsExchangeFuture in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query with parameters of type GridDhtPartitionsExchangeFuture

Modifier and Type	Method and Description
void	GridQueryProcessor.beforeExchange(GridDhtPartitionsExchangeFuture fut) Prepare index rebuild futures if needed before exchange.