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
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
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
GridDhtPreloaderAssignments	GridCachePreloaderAdapter.assign(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
GridDhtPreloaderAssignments	GridCachePreloader.assign(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
void	GridCachePartitionExchangeManager.dumpDebugInfo(GridDhtPartitionsExchangeFuture exchFut)
IgniteInternalFuture<Map<Integer,Map<Integer,List<UUID>>>>	CacheAffinitySharedManager.initAffinityOnNodeLeft(GridDhtPartitionsExchangeFuture fut)
IgniteInternalFuture<?>	CacheAffinitySharedManager.initCoordinatorCaches(GridDhtPartitionsExchangeFuture fut, boolean newAff)
void	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.mergeExchangesOnServerLeft(GridDhtPartitionsExchangeFuture fut, GridDhtPartitionsFullMessage msg)
void	CacheAffinitySharedManager.onBaselineTopologyChanged(GridDhtPartitionsExchangeFuture fut, boolean crd)
void	CacheAffinitySharedManager.onCacheChangeRequest(GridDhtPartitionsExchangeFuture fut, boolean crd, ExchangeActions exchActions) Called on exchange initiated for cache start/stop request.
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.
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)
boolean	CacheAffinitySharedManager.onServerLeft(GridDhtPartitionsExchangeFuture fut, boolean crd) Called on exchange initiated by server node leave.
Map<Integer,CacheGroupAffinityMessage>	CacheAffinitySharedManager.onServerLeftWithExchangeMergeProtocol(GridDhtPartitionsExchangeFuture fut)
void	GridCachePreloaderAdapter.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
void	GridCachePreloader.onTopologyChanged(GridDhtPartitionsExchangeFuture lastFut)
void	ExchangeDiscoveryEvents.processEvents(GridDhtPartitionsExchangeFuture fut)

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

Constructor and Description
ExchangeContext(boolean crd, GridDhtPartitionsExchangeFuture fut)

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

Methods in org.apache.ignite.internal.processors.cache.distributed.dht 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.
void	GridDhtPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridDhtPartitionTopologyImpl.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
void	GridClientPartitionTopology.initPartitionsWhenAffinityReady(AffinityTopologyVersion affVer, GridDhtPartitionsExchangeFuture exchFut)
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	GridClientPartitionTopology.onExchangeDone(GridDhtPartitionsExchangeFuture fut, AffinityAssignment assignment, boolean updateRebalanceVer) Callback on exchange done.

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
GridDhtPreloaderAssignments	GridDhtPreloader.assign(GridDhtPartitionExchangeId exchId, GridDhtPartitionsExchangeFuture exchFut)
int	GridDhtPartitionsExchangeFuture.compareTo(GridDhtPartitionsExchangeFuture fut)
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)

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	IgniteCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture discoEvt)
void	GridCacheDatabaseSharedManager.beforeExchange(GridDhtPartitionsExchangeFuture fut)
void	IgniteCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)
void	GridCacheDatabaseSharedManager.rebuildIndexesIfNeeded(GridDhtPartitionsExchangeFuture fut)