org.gridgain.grid.kernal.processors.cache.distributed.dht.preloader

Class GridDhtPartitionsExchangeFuture<K,V>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

org.gridgain.grid.util.future.GridFutureAdapter<Long>

org.gridgain.grid.kernal.processors.cache.distributed.dht.preloader.GridDhtPartitionsExchangeFuture<K,V>

All Implemented Interfaces:

Externalizable, Serializable, Comparable<GridDhtPartitionsExchangeFuture<K,V>>, GridFuture<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.gridgain.grid.util.future.GridFutureAdapter

ctx

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
int	compareTo(GridDhtPartitionsExchangeFuture<K,V> fut)
boolean	equals(Object o)
int	hashCode()
boolean	onDone(Long res, Throwable err) Callback to notify that future is finished.
void	onNodeLeft(UUID nodeId)
GridDiscoveryTopologySnapshot	topologySnapshot() Gets a topology snapshot for the topology version represented by the future.
String	toString()

Methods inherited from class org.gridgain.grid.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.gridgain.grid.GridFuture

cancel, chain, concurrentNotify, concurrentNotify, duration, get, get, get, isCancelled, isDone, listenAsync, startTime, stopListenAsync, syncNotify, syncNotify

Constructor Detail

GridDhtPartitionsExchangeFuture

public GridDhtPartitionsExchangeFuture(GridCacheContext<K,V> cctx,
                               boolean reassign,
                               GridDiscoveryEvent 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(GridCacheContext<K,V> cctx,
                               GridDiscoveryEvent 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()

Empty constructor required for Externalizable.

Method Detail

topologySnapshot

public GridDiscoveryTopologySnapshot topologySnapshot()
                                               throws GridException

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

Specified by:

topologySnapshot in interface GridDhtTopologyFuture

Returns:

Topology snapshot for particular topology version.

Throws:

GridException - If topology future failed.

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.

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>