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

Class GridDhtPartitionsExchangeFuture

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

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

All Implemented Interfaces:

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

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

Future for exchanging partition maps.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

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) 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)
DiscoveryEvent	discoveryEvent()
boolean	dummy()
boolean	dummyReassign()
boolean	equals(Object o)
GridDhtPartitionExchangeId	exchangeId()
boolean	forcePreload()
int	hashCode()
void	init() Starts activity.
boolean	isCacheAdded(int cacheId, AffinityTopologyVersion topVer)
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) 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	skipPreload()
boolean	stopping(int cacheId)
AffinityTopologyVersion	topologyVersion() Gets topology version of this future.
String	toString()
Throwable	validateCache(GridCacheContext cctx) Returns error is cache topology is not valid.

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

cancel, chain, duration, endTime, error, get, get, get, get0, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, onCancelled, onDone, onDone, onDone, result, startTime, tryAcquireShared, tryReleaseShared

Methods inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

acquire, acquireInterruptibly, acquireShared, acquireSharedInterruptibly, compareAndSetState, getExclusiveQueuedThreads, getFirstQueuedThread, getQueuedThreads, getQueueLength, getSharedQueuedThreads, getState, getWaitingThreads, getWaitQueueLength, hasContended, hasQueuedPredecessors, hasQueuedThreads, hasWaiters, isHeldExclusively, isQueued, owns, release, releaseShared, setState, tryAcquire, tryAcquireNanos, tryAcquireSharedNanos, tryRelease

Methods inherited from class java.util.concurrent.locks.AbstractOwnableSynchronizer

getExclusiveOwnerThread, setExclusiveOwnerThread

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, duration, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result, startTime

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)

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

Parameters:

cctx - Cache context.

discoEvt - Discovery event.

exchId - Exchange id.

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.

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)

Event callback.

Parameters:

exchId - Exchange ID.

discoEvt - Discovery event.

discoveryEvent

public DiscoveryEvent discoveryEvent()

Returns:

Discovery event.

exchangeId

public GridDhtPartitionExchangeId exchangeId()

Returns:

Exchange ID.

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

public Throwable validateCache(GridCacheContext cctx)

Returns error is cache topology is not valid.

Specified by:

validateCache in interface GridDhtTopologyFuture

Parameters:

cctx - Cache context.

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.

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>