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

Class GridDhtEmbeddedFuture<A,B>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

org.gridgain.grid.util.future.GridEmbeddedFuture<A,B>

org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtEmbeddedFuture<A,B>

All Implemented Interfaces:

Externalizable, Serializable, GridFuture<A>, GridDhtFuture<A>

public class GridDhtEmbeddedFuture<A,B>
extends GridEmbeddedFuture<A,B>
implements GridDhtFuture<A>

Embedded DHT future.

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

Constructor Summary

Constructors

Constructor and Description
GridDhtEmbeddedFuture() Empty constructor required for Externalizable.
GridDhtEmbeddedFuture(GridFuture<B> embedded, GridBiClosure<B,Exception,GridFuture<A>> c, GridKernalContext ctx)
GridDhtEmbeddedFuture(GridKernalContext ctx, GridFuture<B> embedded, GridBiClosure<B,Exception,A> c)
GridDhtEmbeddedFuture(GridKernalContext ctx, GridFuture<B> embedded, GridBiClosure<B,Exception,A> c, Collection<Integer> invalidParts)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<Integer>	invalidPartitions() Node that future should be able to provide keys to retry before it completes, so it's not necessary to wait till future is done to get retry keys.
String	toString()

Methods inherited from class org.gridgain.grid.util.future.GridEmbeddedFuture

cancel, isCancelled

Methods inherited from class org.gridgain.grid.util.future.GridFutureAdapter

chain, checkValid, concurrentNotify, concurrentNotify, duration, endTime, error, get, get, get, get0, isDone, isFailed, isValid, listenAsync, onCancelled, onDone, 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, equals, finalize, getClass, hashCode, 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

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture()

Empty constructor required for Externalizable.

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture(GridKernalContext ctx,
                     GridFuture<B> embedded,
                     GridBiClosure<B,Exception,A> c)

Parameters:

ctx - Context.

embedded - Embedded.

c - Closure.

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture(GridFuture<B> embedded,
                     GridBiClosure<B,Exception,GridFuture<A>> c,
                     GridKernalContext ctx)

Parameters:

embedded - Future to embed.

c - Embedding closure.

ctx - Kernal context.

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture(GridKernalContext ctx,
                     GridFuture<B> embedded,
                     GridBiClosure<B,Exception,A> c,
                     Collection<Integer> invalidParts)

Parameters:

ctx - Context.

embedded - Embedded.

c - Closure.

invalidParts - Retries.

Method Detail

invalidPartitions

public Collection<Integer> invalidPartitions()

Node that future should be able to provide keys to retry before it completes, so it's not necessary to wait till future is done to get retry keys.

Specified by:

invalidPartitions in interface GridDhtFuture<A>

Returns:

Keys to retry because this node is no longer a primary or backup.

toString

public String toString()

Overrides:

toString in class GridEmbeddedFuture<A,B>