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

Class GridDhtPartitionsExchangeFuture<K,V>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

org.apache.ignite.internal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture<K,V>

All Implemented Interfaces:

Externalizable, Serializable, Comparable<GridDhtPartitionsExchangeFuture<K,V>>, IgniteInternalFuture<Long>, GridDhtTopologyFuture

public class GridDhtPartitionsExchangeFuture<K,V>
extends GridFutureAdapter<Long>
implements Comparable<GridDhtPartitionsExchangeFuture<K,V>>, 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 inherited from class org.apache.ignite.internal.util.future.GridFutureAdapter

ctx

Constructor Summary

Constructors

Constructor and Description
GridDhtPartitionsExchangeFuture() Empty constructor required for Externalizable.
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx, boolean reassign, DiscoveryEvent discoEvt, GridDhtPartitionExchangeId exchId) Dummy future created to trigger reassignments if partition topology changed while preloading.
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx, DiscoveryEvent discoEvt, GridDhtPartitionExchangeId exchId) Force preload future created to trigger reassignments if partition topology changed while preloading.
GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> cctx, ReadWriteLock busyLock, GridDhtPartitionExchangeId exchId)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanUp() Cleans up resources to avoid excessive memory usage.
int	compareTo(GridDhtPartitionsExchangeFuture<K,V> fut)
DiscoveryEvent	discoveryEvent()
boolean	dummy()
boolean	dummyReassign()
boolean	equals(Object o)
GridDhtPartitionExchangeId	exchangeId()
boolean	forcePreload()
int	hashCode()
void	init() Starts activity.
boolean	onAdded()
boolean	onDone(Long res, Throwable err) Callback to notify that future is finished.
void	onEvent(GridDhtPartitionExchangeId exchId, DiscoveryEvent discoEvt) Event callback.
void	onNodeLeft(UUID nodeId)
void	onReceive(UUID nodeId, GridDhtPartitionsFullMessage<K,V> msg)
void	onReceive(UUID nodeId, GridDhtPartitionsSingleMessage<K,V> msg)
boolean	reassign()
GridDiscoveryTopologySnapshot	topologySnapshot() Gets a topology snapshot for the topology version represented by the future.
String	toString()

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

cancel, chain, checkValid, concurrentNotify, concurrentNotify, duration, endTime, error, get, get, get, get0, isCancelled, isDone, isFailed, isValid, listenAsync, onCancelled, onDone, onDone, onDone, readExternal, result, startTime, stopListenAsync, syncNotify, syncNotify, tryAcquireShared, tryReleaseShared, writeExternal

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, concurrentNotify, concurrentNotify, duration, get, get, get, isCancelled, isDone, listenAsync, startTime, stopListenAsync, syncNotify, syncNotify

Constructor Detail

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture(GridCacheSharedContext<K,V> 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<K,V> 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<K,V> cctx,
                               ReadWriteLock busyLock,
                               GridDhtPartitionExchangeId exchId)

Parameters:

cctx - Cache context.

busyLock - Busy lock.

exchId - Exchange ID.

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture()

Empty constructor required for Externalizable.

Method Detail

topologySnapshot

public GridDiscoveryTopologySnapshot topologySnapshot()
                                               throws IgniteCheckedException

Gets a topology snapshot for the topology version represented by the future. Note that by the time partition exchange completes some nodes from the snapshot may leave the grid. One should use discovery service to check if the node is valid.

This method will block until the topology future is ready.

Specified by:

topologySnapshot in interface GridDhtTopologyFuture

Returns:

Topology snapshot for particular topology version.

Throws:

IgniteCheckedException - If topology future failed.

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.

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.

onDone

public boolean onDone(Long res,
             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<Long>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

cleanUp

public void cleanUp()

Cleans up resources to avoid excessive memory usage.

onReceive

public void onReceive(UUID nodeId,
             GridDhtPartitionsSingleMessage<K,V> msg)

Parameters:

nodeId - Sender node id.

msg - Single partition info.

onReceive

public void onReceive(UUID nodeId,
             GridDhtPartitionsFullMessage<K,V> msg)

Parameters:

nodeId - Sender node ID.

msg - Full partition info.

onNodeLeft

public void onNodeLeft(UUID nodeId)

Parameters:

nodeId - Left node id.

compareTo

public int compareTo(GridDhtPartitionsExchangeFuture<K,V> fut)

Specified by:

compareTo in interface Comparable<GridDhtPartitionsExchangeFuture<K,V>>

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