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

Class GridDhtEmbeddedFuture<A,B>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

org.apache.ignite.internal.util.future.GridEmbeddedFuture<A,B>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtEmbeddedFuture<A,B>

All Implemented Interfaces:

Serializable, IgniteInternalFuture<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

Constructor Summary

Constructors

Constructor and Description
GridDhtEmbeddedFuture(IgniteBiClosure<B,Exception,A> c, IgniteInternalFuture<B> embedded)
GridDhtEmbeddedFuture(IgniteInternalFuture<B> embedded, IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c)

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.apache.ignite.internal.util.future.GridEmbeddedFuture

cancel, isCancelled

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

chain, duration, endTime, error, get, get, get, get0, getUninterruptibly, ignoreInterrupts, isDone, isFailed, listen, onCancelled, onDone, 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, equals, finalize, getClass, hashCode, 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

Constructor Detail

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture(IgniteBiClosure<B,Exception,A> c,
                     IgniteInternalFuture<B> embedded)

Parameters:

c - Closure.

embedded - Embedded.

GridDhtEmbeddedFuture

public GridDhtEmbeddedFuture(IgniteInternalFuture<B> embedded,
                     IgniteBiClosure<B,Exception,IgniteInternalFuture<A>> c)

Parameters:

embedded - Future to embed.

c - Embedding closure.

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>