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

Class GridDhtTxAbstractEnlistFuture<T>

java.lang.Object

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

org.apache.ignite.internal.processors.cache.GridCacheFutureAdapter<T>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxAbstractEnlistFuture<T>

All Implemented Interfaces:

IgniteInternalFuture<T>, DhtLockFuture<T>, GridCacheFuture<T>

Direct Known Subclasses:

GridDhtTxEnlistFuture, GridDhtTxQueryAbstractEnlistFuture

public abstract class GridDhtTxAbstractEnlistFuture<T>
extends GridCacheFutureAdapter<T>
implements DhtLockFuture<T>

Abstract future processing transaction enlisting and locking.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	GridDhtTxAbstractEnlistFuture.LockTimeoutObject Lock request timeout object.

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheContext<?,?>	cctx Cache registry.
protected IgniteUuid	futId Future ID.
protected boolean	hasNearNodeUpdates There are keys belonging to backup partitions on near node.
protected GridCacheVersion	lockVer Lock version.
protected IgniteLogger	log Logger.
protected MvccSnapshot	mvccSnapshot
protected IgniteUuid	nearFutId Future ID.
protected GridCacheVersion	nearLockVer Near lock version.
protected int	nearMiniId Future ID.
protected UUID	nearNodeId Near node ID.
protected Set<UUID>	newDhtNodes New DHT nodes.
protected int[]	parts Partitions.
protected boolean	skipNearNodeUpdates Do not send DHT requests to near node.
protected long	threadId Thread.
protected long	timeout Lock timeout.
protected GridDhtTxAbstractEnlistFuture.LockTimeoutObject	timeoutObj Timeout object.
protected GridDhtTxLocalAdapter	tx Transaction.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridDhtTxAbstractEnlistFuture(UUID nearNodeId, GridCacheVersion nearLockVer, MvccSnapshot mvccSnapshot, long threadId, IgniteUuid nearFutId, int nearMiniId, int[] parts, GridDhtTxLocalAdapter tx, long timeout, GridCacheContext<?,?> cctx, CacheEntryPredicate filter)

Method Summary

Modifier and Type	Method and Description
protected void	clearLockFuture() Clears lock future.
protected abstract UpdateSourceIterator<?>	createIterator() Gets source to be updated iterator.
IgniteUuid	futureId()
void	init()
void	markNotTrackable() Marks this future as non-trackable.
boolean	needResult() Gets need previous value flag.
boolean	onDone(T res, Throwable err) Callback to notify that future is finished.
protected abstract void	onEntryProcessed(KeyCacheObject key, GridCacheUpdateTxResult res) Entry processed callback.
void	onError(Throwable error)
boolean	onNodeLeft(UUID nodeId) Callback for when node left.
void	onResult(UUID nodeId, GridDhtTxQueryEnlistResponse res) Callback on backup response.
protected abstract T	result0() Gets query result.
protected IgniteTxTimeoutCheckedException	timeoutException()
boolean	trackable()

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheFutureAdapter

duration, onDone, startTime

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

cancel, chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, onDone, onDone, onDone, reset, result, toString

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, chain, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result

Field Detail

futId

protected final IgniteUuid futId

Future ID.

cctx

@GridToStringExclude
protected final GridCacheContext<?,?> cctx

Cache registry.

log

@GridToStringExclude
protected final IgniteLogger log

Logger.

threadId

protected final long threadId

Thread.

nearFutId

protected final IgniteUuid nearFutId

Future ID.

nearMiniId

protected final int nearMiniId

Future ID.

parts

protected final int[] parts

Partitions.

tx

protected final GridDhtTxLocalAdapter tx

Transaction.

lockVer

protected final GridCacheVersion lockVer

Lock version.

mvccSnapshot

protected final MvccSnapshot mvccSnapshot

newDhtNodes

protected Set<UUID> newDhtNodes

New DHT nodes.

nearNodeId

protected final UUID nearNodeId

Near node ID.

nearLockVer

protected final GridCacheVersion nearLockVer

Near lock version.

timeoutObj

@GridToStringExclude
protected GridDhtTxAbstractEnlistFuture.LockTimeoutObject timeoutObj

Timeout object.

timeout

protected final long timeout

Lock timeout.

skipNearNodeUpdates

protected boolean skipNearNodeUpdates

Do not send DHT requests to near node.

hasNearNodeUpdates

protected boolean hasNearNodeUpdates

There are keys belonging to backup partitions on near node.

Constructor Detail

GridDhtTxAbstractEnlistFuture

protected GridDhtTxAbstractEnlistFuture(UUID nearNodeId,
                                        GridCacheVersion nearLockVer,
                                        MvccSnapshot mvccSnapshot,
                                        long threadId,
                                        IgniteUuid nearFutId,
                                        int nearMiniId,
                                        @Nullable
                                        int[] parts,
                                        GridDhtTxLocalAdapter tx,
                                        long timeout,
                                        GridCacheContext<?,?> cctx,
                                        @Nullable
                                        CacheEntryPredicate filter)

Parameters:

nearNodeId - Near node ID.

nearLockVer - Near lock version.

mvccSnapshot - Mvcc snapshot.

threadId - Thread ID.

nearFutId - Near future id.

nearMiniId - Near mini future id.

parts - Partitions.

tx - Transaction.

timeout - Lock acquisition timeout.

cctx - Cache context.

filter - Filter.

Method Detail

createIterator

protected abstract UpdateSourceIterator<?> createIterator()
                                                   throws IgniteCheckedException

Gets source to be updated iterator.

Returns:

iterator.

Throws:

IgniteCheckedException - If failed.

result0

protected abstract T result0()

Gets query result.

Returns:

Query result.

needResult

public boolean needResult()

Gets need previous value flag.

Returns:

True if previous value is required.

onEntryProcessed

protected abstract void onEntryProcessed(KeyCacheObject key,
                                         GridCacheUpdateTxResult res)

Entry processed callback.

Parameters:

key - Entry key.

res - Update result.

init

public void init()

clearLockFuture

protected void clearLockFuture()

Clears lock future.

onResult

public void onResult(UUID nodeId,
                     GridDhtTxQueryEnlistResponse res)

Callback on backup response.

Parameters:

nodeId - Backup node.

res - Response.

trackable

public boolean trackable()

Specified by:

trackable in interface GridCacheFuture<T>

Returns:

True if future should be tracked.

markNotTrackable

public void markNotTrackable()

Marks this future as non-trackable.

Specified by:

markNotTrackable in interface GridCacheFuture<T>

futureId

public IgniteUuid futureId()

Specified by:

futureId in interface GridCacheFuture<T>

Returns:

Unique identifier for this future.

onNodeLeft

public boolean onNodeLeft(UUID nodeId)

Callback for when node left.

Specified by:

onNodeLeft in interface GridCacheFuture<T>

Parameters:

nodeId - Left node ID.

Returns:

True if future cared about this node.

onDone

public boolean onDone(@Nullable
                      T res,
                      @Nullable
                      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<T>

Parameters:

res - Optional result.

err - Optional error.

Returns:

True if result was set by this call.

onError

public void onError(Throwable error)

Specified by:

onError in interface DhtLockFuture<T>

Parameters:

error - Error.

timeoutException

@NotNull
protected IgniteTxTimeoutCheckedException timeoutException()

Returns:

Timeout exception.