org.apache.ignite.internal.processors.cache.distributed.dht

Class ClientCacheDhtTopologyFuture

java.lang.Object

org.apache.ignite.internal.util.future.GridFutureAdapter<AffinityTopologyVersion>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopologyFutureAdapter

org.apache.ignite.internal.processors.cache.distributed.dht.ClientCacheDhtTopologyFuture

All Implemented Interfaces:

IgniteInternalFuture<AffinityTopologyVersion>, GridDhtTopologyFuture

public class ClientCacheDhtTopologyFuture
extends GridDhtTopologyFutureAdapter

Topology future created for client cache start.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopologyFutureAdapter

GridDhtTopologyFutureAdapter.CacheGroupValidation

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopologyFutureAdapter

clusterIsActive, grpValidRes

Constructor Summary

Constructors

Constructor and Description
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer)
ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer, IgniteCheckedException e)

Method Summary

Modifier and Type	Method and Description
boolean	changedAffinity()
boolean	exchangeDone() Ready affinity future (GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion) is completed before GridFutureAdapter.onDone(Object, Throwable) is called on GridDhtPartitionsExchangeFuture, it is guaranteed that this method will return true if affinity ready future is finished.
AffinityTopologyVersion	initialVersion() Returns topology version when exchange started.
AffinityTopologyVersion	topologyVersion() Gets result topology version of this future.
String	toString()
void	validate(CacheGroupContext grp, Collection<ClusterNode> topNodes)

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTopologyFutureAdapter

hasLostPartitions, validateCache, validateCacheGroup

Methods inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

cancel, chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, onDone, onDone, reset, result

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

cancel, chain, chain, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result

Constructor Detail

ClientCacheDhtTopologyFuture

public ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer)

Parameters:

topVer - Topology version.

ClientCacheDhtTopologyFuture

public ClientCacheDhtTopologyFuture(AffinityTopologyVersion topVer,
                                    IgniteCheckedException e)

Parameters:

topVer - Topology version.

e - Error.

Method Detail

validate

public void validate(CacheGroupContext grp,
                     Collection<ClusterNode> topNodes)

Parameters:

grp - Cache group.

topNodes - Topology nodes.

initialVersion

public AffinityTopologyVersion initialVersion()

Returns topology version when exchange started. It can differ from result topology version if exchanges for multiple discovery events are merged. Initial version should not be used as version for cache operation since it is possible affinity for this version is never calculated.

Returns:

Topology version when exchange started.

exchangeDone

public boolean exchangeDone()

Ready affinity future (GridCachePartitionExchangeManager.affinityReadyFuture(AffinityTopologyVersion) is completed before GridFutureAdapter.onDone(Object, Throwable) is called on GridDhtPartitionsExchangeFuture, it is guaranteed that this method will return true if affinity ready future is finished.

Also this method returns false for merged exchange futures.

Returns:

True if exchange is finished and result topology version can be used.

topologyVersion

public AffinityTopologyVersion topologyVersion()

Gets result topology version of this future. Result version can differ from initial exchange version if exchanges for multiple discovery events are merged, in this case result version is version of last discovery event.

This method should be called only for finished topology future since result version is not known before exchange finished.

Returns:

Result topology version.

changedAffinity

public boolean changedAffinity()

Returns:

True if this exchange changed affinity.

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<AffinityTopologyVersion>