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

Class GridDhtGetSingleFuture<K,V>

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

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

All Implemented Interfaces:

Serializable, IgniteInternalFuture<GridCacheEntryInfo>, GridDhtFuture<GridCacheEntryInfo>

public final class GridDhtGetSingleFuture<K,V>
extends GridFutureAdapter<GridCacheEntryInfo>
implements GridDhtFuture<GridCacheEntryInfo>

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
GridDhtGetSingleFuture(GridCacheContext<K,V> cctx, long msgId, UUID reader, KeyCacheObject key, Boolean addRdr, boolean readThrough, IgniteTxLocalEx tx, AffinityTopologyVersion topVer, UUID subjId, int taskNameHash, IgniteCacheExpiryPolicy expiryPlc, boolean skipVals)

Method Summary

Methods

Modifier and Type	Method and Description
IgniteUuid	futureId()
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.
boolean	onDone(GridCacheEntryInfo res, Throwable err) Callback to notify that future is finished.
GridCacheVersion	version()

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

GridDhtGetSingleFuture

public GridDhtGetSingleFuture(GridCacheContext<K,V> cctx,
                      long msgId,
                      UUID reader,
                      KeyCacheObject key,
                      Boolean addRdr,
                      boolean readThrough,
                      @Nullable
                      IgniteTxLocalEx tx,
                      @NotNull
                      AffinityTopologyVersion topVer,
                      @Nullable
                      UUID subjId,
                      int taskNameHash,
                      @Nullable
                      IgniteCacheExpiryPolicy expiryPlc,
                      boolean skipVals)

Parameters:

cctx - Context.

msgId - Message ID.

reader - Reader.

key - Key.

addRdr - Add reader flag.

readThrough - Read through flag.

tx - Transaction.

topVer - Topology version.

subjId - Subject ID.

taskNameHash - Task name hash code.

expiryPlc - Expiry policy.

skipVals - Skip values flag.

Method Detail

futureId

public IgniteUuid futureId()

Returns:

Future ID.

version

public GridCacheVersion version()

Returns:

Future version.

onDone

public boolean onDone(GridCacheEntryInfo 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<GridCacheEntryInfo>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

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

Returns:

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