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

Class GridDhtPartitionsExchangeFuture

java.lang.Object

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

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

All Implemented Interfaces:

Comparable<GridDhtPartitionsExchangeFuture>, IgniteInternalFuture<AffinityTopologyVersion>, CachePartitionExchangeWorkerTask, GridDhtTopologyFuture

public class GridDhtPartitionsExchangeFuture
extends GridFutureAdapter<AffinityTopologyVersion>
implements Comparable<GridDhtPartitionsExchangeFuture>, GridDhtTopologyFuture, CachePartitionExchangeWorkerTask

Future for exchanging partition maps.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DUMP_PENDING_OBJECTS_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx, boolean reassign, DiscoveryEvent discoEvt, GridDhtPartitionExchangeId exchId) Dummy future created to trigger reassignments if partition topology changed while preloading.
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx, DiscoveryEvent discoEvt, GridDhtPartitionExchangeId exchId, GridFutureAdapter<Boolean> forcedRebFut) Force preload future created to trigger reassignments if partition topology changed while preloading.
GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx, ReadWriteLock busyLock, GridDhtPartitionExchangeId exchId, Collection<DynamicCacheChangeRequest> reqs, CacheAffinityChangeMessage affChangeMsg)

Method Summary

Methods

Modifier and Type	Method and Description
void	affinityChangeMessage(CacheAffinityChangeMessage affChangeMsg)
void	cacheChangeRequests(Collection<DynamicCacheChangeRequest> reqs)
boolean	cacheStarted(int cacheId)
void	cleanUp() Cleans up resources to avoid excessive memory usage.
int	compareTo(GridDhtPartitionsExchangeFuture fut)
DiscoCache	discoCache()
DiscoveryEvent	discoveryEvent()
boolean	dummy()
boolean	dummyReassign()
boolean	equals(Object o)
GridDhtPartitionExchangeId	exchangeId()
GridFutureAdapter<Boolean>	forcedRebalanceFuture()
boolean	forcePreload()
int	hashCode()
void	init() Starts activity.
boolean	isCacheAdded(int cacheId, AffinityTopologyVersion topVer)
ClusterState	newClusterState()
boolean	onAdded()
void	onAffinityChangeMessage(ClusterNode node, CacheAffinityChangeMessage msg) Affinity change message callback, processed from the same thread as onNodeLeft(org.apache.ignite.cluster.ClusterNode).
boolean	onDone(AffinityTopologyVersion res, Throwable err) Callback to notify that future is finished.
void	onEvent(GridDhtPartitionExchangeId exchId, DiscoveryEvent discoEvt, DiscoCache discoCache) Event callback.
void	onNodeLeft(ClusterNode node) Node left callback, processed from the same thread as onAffinityChangeMessage(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage).
void	onReceive(ClusterNode node, GridDhtPartitionsFullMessage msg)
void	onReceive(ClusterNode node, GridDhtPartitionsSingleMessage msg)
boolean	reassign()
boolean	reconnectOnError(Throwable e)
boolean	skipPreload()
boolean	stopping(int cacheId)
AffinityTopologyVersion	topologyVersion() Gets topology version of this future.
String	toString()
Throwable	validateCache(GridCacheContext cctx, boolean recovery, boolean read, Object key, Collection<?> keys) Returns error is cache topology is not valid.

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, 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

Field Detail

DUMP_PENDING_OBJECTS_THRESHOLD

public static final int DUMP_PENDING_OBJECTS_THRESHOLD

Constructor Detail

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
                               boolean reassign,
                               DiscoveryEvent discoEvt,
                               GridDhtPartitionExchangeId exchId)

Dummy future created to trigger reassignments if partition topology changed while preloading.

Parameters:

cctx - Cache context.

reassign - Dummy reassign flag.

discoEvt - Discovery event.

exchId - Exchange id.

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
                               DiscoveryEvent discoEvt,
                               GridDhtPartitionExchangeId exchId,
                               GridFutureAdapter<Boolean> forcedRebFut)

Force preload future created to trigger reassignments if partition topology changed while preloading.

Parameters:

cctx - Cache context.

discoEvt - Discovery event.

exchId - Exchange id.

forcedRebFut - Forced Rebalance future.

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture(GridCacheSharedContext cctx,
                               ReadWriteLock busyLock,
                               GridDhtPartitionExchangeId exchId,
                               Collection<DynamicCacheChangeRequest> reqs,
                               CacheAffinityChangeMessage affChangeMsg)

Parameters:

cctx - Cache context.

busyLock - Busy lock.

exchId - Exchange ID.

reqs - Cache change requests.

affChangeMsg - Affinity change message.

Method Detail

cacheChangeRequests

public void cacheChangeRequests(Collection<DynamicCacheChangeRequest> reqs)

Parameters:

reqs - Cache change requests.

affinityChangeMessage

public void affinityChangeMessage(CacheAffinityChangeMessage affChangeMsg)

Parameters:

affChangeMsg - Affinity change message.

topologyVersion

public AffinityTopologyVersion topologyVersion()

Gets topology version of this future.

Specified by:

topologyVersion in interface GridDhtTopologyFuture

Returns:

Topology version.

skipPreload

public boolean skipPreload()

Returns:

Skip preload flag.

dummy

public boolean dummy()

Returns:

Dummy flag.

forcePreload

public boolean forcePreload()

Returns:

Force preload flag.

reassign

public boolean reassign()

Returns:

Dummy reassign flag.

dummyReassign

public boolean dummyReassign()

Returns:

True if dummy reassign.

discoCache

public DiscoCache discoCache()

Returns:

Discovery cache.

isCacheAdded

public boolean isCacheAdded(int cacheId,
                   AffinityTopologyVersion topVer)

Parameters:

cacheId - Cache ID to check.

topVer - Topology version.

Returns:

True if cache was added during this exchange.

cacheStarted

public boolean cacheStarted(int cacheId)

Parameters:

cacheId - Cache ID.

Returns:

True if non-client cache was added during this exchange.

onAdded

public boolean onAdded()

Returns:

True

onEvent

public void onEvent(GridDhtPartitionExchangeId exchId,
           DiscoveryEvent discoEvt,
           DiscoCache discoCache)

Event callback.

Parameters:

exchId - Exchange ID.

discoEvt - Discovery event.

discoCache - Discovery data cache.

newClusterState

public ClusterState newClusterState()

discoveryEvent

public DiscoveryEvent discoveryEvent()

Returns:

Discovery event.

exchangeId

public GridDhtPartitionExchangeId exchangeId()

Returns:

Exchange ID.

forcedRebalanceFuture

@Nullable
public GridFutureAdapter<Boolean> forcedRebalanceFuture()

Returns:

Forced Rebalance future.

init

public void init()
          throws IgniteInterruptedCheckedException

Starts activity.

Throws:

IgniteInterruptedCheckedException - If interrupted.

stopping

public boolean stopping(int cacheId)

Parameters:

cacheId - Cache ID to check.

Returns:

True if cache is stopping by this exchange.

onDone

public boolean onDone(@Nullable
             AffinityTopologyVersion res,
             @Nullable
             Throwable err)

Callback to notify that future is finished. Note that if non-null exception is passed in the result value will be ignored.

Overrides:

onDone in class GridFutureAdapter<AffinityTopologyVersion>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

validateCache

@Nullable
public Throwable validateCache(GridCacheContext cctx,
                               boolean recovery,
                               boolean read,
                               @Nullable
                               Object key,
                               @Nullable
                               Collection<?> keys)

Returns error is cache topology is not valid.

Specified by:

validateCache in interface GridDhtTopologyFuture

Parameters:

cctx - Cache context.

recovery - True if cache operation is done in recovery mode. Then it will only check for cache active state and topology validator result.

read - True if validating read operation, false if validating write.

key - Key (optimization to avoid collection creation).

keys - Keys involved in a cache operation.

Returns:

valid ot not.

cleanUp

public void cleanUp()

Cleans up resources to avoid excessive memory usage.

onReceive

public void onReceive(ClusterNode node,
             GridDhtPartitionsSingleMessage msg)

Parameters:

node - Sender node.

msg - Single partition info.

onReceive

public void onReceive(ClusterNode node,
             GridDhtPartitionsFullMessage msg)

Parameters:

node - Sender node.

msg - Full partition info.

onAffinityChangeMessage

public void onAffinityChangeMessage(ClusterNode node,
                           CacheAffinityChangeMessage msg)

Affinity change message callback, processed from the same thread as onNodeLeft(org.apache.ignite.cluster.ClusterNode).

Parameters:

node - Message sender node.

msg - Message.

onNodeLeft

public void onNodeLeft(ClusterNode node)

Node left callback, processed from the same thread as onAffinityChangeMessage(org.apache.ignite.cluster.ClusterNode, org.apache.ignite.internal.processors.cache.CacheAffinityChangeMessage).

Parameters:

node - Left node.

reconnectOnError

public boolean reconnectOnError(Throwable e)

Parameters:

e - Exception.

Returns:

True if local node should try reconnect in case of error.

compareTo

public int compareTo(GridDhtPartitionsExchangeFuture fut)

Specified by:

compareTo in interface Comparable<GridDhtPartitionsExchangeFuture>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class GridFutureAdapter<AffinityTopologyVersion>