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
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

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
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, GridDhtPartitionsFullMessage msg) Applies affinity diff from the received full message.
void	GridCachePartitionExchangeManager.dumpDebugInfo(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).
GridDhtPreloaderAssignments	GridCachePreloader.generateAssignments(GridDhtPartitionExchangeId exchId, 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.
boolean	GridCachePartitionExchangeManager.mergeExchanges(GridDhtPartitionsExchangeFuture curFut, GridDhtPartitionsFullMessage msg)
boolean	GridCachePartitionExchangeManager.mergeExchangesOnCoordinator(GridDhtPartitionsExchangeFuture curFut)
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, boolean crd, CacheAffinityChangeMessage msg) Called on exchange initiated by CacheAffinityChangeMessage which sent after rebalance finished.
void	CacheAffinitySharedManager.onClientEvent(GridDhtPartitionsExchangeFuture fut, boolean crd) 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, boolean crd, ExchangeActions exchActions)
void	CacheAffinitySharedManager.onExchangeChangeAffinityMessage(GridDhtPartitionsExchangeFuture exchFut, boolean crd, CacheAffinityChangeMessage msg) Called when received CacheAffinityChangeMessage which should complete exchange.
void	CacheAffinitySharedManager.onLocalJoin(GridDhtPartitionsExchangeFuture fut, GridDhtPartitionsFullMessage msg, AffinityTopologyVersion resTopVer)
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(AffinityTopologyVersion rebTopVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridCachePreloaderAdapter.rebalanceRequired(AffinityTopologyVersion rebTopVer, GridDhtPartitionsExchangeFuture exchFut)

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

Constructor and Description
ExchangeContext(boolean crd, boolean newMvccCrd, 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)
GridDhtPreloaderAssignments	GridDhtPreloader.generateAssignments(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
void	InitNewCoordinatorFuture.init(GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionsExchangeFuture.mergeJoinExchange(GridDhtPartitionsExchangeFuture fut) Merges this exchange with given one.
GridDhtPartitionsSingleMessage	GridDhtPartitionsExchangeFuture.mergeJoinExchangeOnDone(GridDhtPartitionsExchangeFuture fut)
void	GridDhtPreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
boolean	GridDhtPreloader.rebalanceRequired(AffinityTopologyVersion rebTopVer, 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	GridClientPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
boolean	GridDhtPartitionTopology.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
boolean	GridDhtPartitionTopologyImpl.afterExchange(GridDhtPartitionsExchangeFuture exchFut) Post-initializes this topology.
void	GridClientPartitionTopology.beforeExchange(GridDhtPartitionsExchangeFuture exchFut, boolean initParts, boolean updateMoving) Pre-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.
boolean	GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
boolean	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridClientPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
void	GridDhtPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
void	GridDhtPartitionTopologyImpl.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.
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
boolean	GridCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture fut)
boolean	IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
void	GridCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
void	IgniteCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)