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

Class GridNearTxAbstractEnlistFuture<T>

java.lang.Object

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

org.apache.ignite.internal.util.future.GridCompoundFuture<T,T>

org.apache.ignite.internal.util.future.GridCompoundIdentityFuture<T>

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

org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxAbstractEnlistFuture<T>

All Implemented Interfaces:

Serializable, IgniteInternalFuture<T>, GridCacheFuture<T>, GridCacheVersionedFuture<T>, IgniteInClosure<IgniteInternalFuture<T>>

Direct Known Subclasses:

GridNearTxEnlistFuture, GridNearTxQueryAbstractEnlistFuture

public abstract class GridNearTxAbstractEnlistFuture<T>
extends GridCacheCompoundIdentityFuture<T>
implements GridCacheVersionedFuture<T>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheContext<?,?>	cctx Cache context.
protected IgniteUuid	futId Mvcc future id.
protected GridCacheVersion	lockVer Lock version.
protected IgniteLogger	log Logger.
protected MvccSnapshot	mvccSnapshot MVCC snapshot.
protected long	threadId Initiated thread id.
protected long	timeout
protected org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxAbstractEnlistFuture.LockTimeoutObject	timeoutObj Timeout object.
protected AffinityTopologyVersion	topVer
protected GridNearTxLocal	tx Transaction.

Constructor Summary

Constructors

Constructor and Description
GridNearTxAbstractEnlistFuture(GridCacheContext<?,?> cctx, GridNearTxLocal tx, long timeout, @Nullable IgniteReducer<T,T> rdc)

Method Summary

Modifier and Type	Method and Description
protected void	checkCompleted()
protected void	clearLocalFuture(GridDhtTxAbstractEnlistFuture fut)
IgniteUuid	futureId()
void	init()
protected void	logDebug(IgniteLogger log, String msg)
protected void	logError(IgniteLogger log, String msg, Throwable e)
protected abstract void	map(boolean topLocked) Start iterating the data rows and form batches.
void	markNotTrackable() Marks this future as non-trackable.
boolean	onCancelled() Callback to notify that future is cancelled.
boolean	onDone(T res, @Nullable Throwable err, boolean cancelled)
boolean	onOwnerChanged(GridCacheEntryEx entry, GridCacheMvccCandidate owner)
abstract Set<UUID>	pendingResponseNodes()
protected long	remainingTime() Gets remaining allowed time.
protected @NotNull IgniteTxTimeoutCheckedException	timeoutException()
boolean	trackable()
protected void	updateLocalFuture(GridDhtTxAbstractEnlistFuture fut)
protected void	updateMappings(ClusterNode node)
GridCacheVersion	version()

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

duration, startTime

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

toString

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

add, apply, cancel, clear, future, futures, futuresCountNoLock, hasFutures, hasPending, ignoreFailure, initialized, markInitialized, processFailure

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

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

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.processors.cache.GridCacheFuture

duration, onNodeLeft, startTime

Methods inherited from interface org.apache.ignite.internal.IgniteInternalFuture

cancel, chain, chain, error, get, get, get, getUninterruptibly, isCancelled, isDone, listen, result

Field Detail

cctx

@GridToStringExclude
protected final GridCacheContext<?,?> cctx

Cache context.

tx

protected final GridNearTxLocal tx

Transaction.

topVer

protected AffinityTopologyVersion topVer

mvccSnapshot

protected MvccSnapshot mvccSnapshot

MVCC snapshot.

log

@GridToStringExclude
protected final IgniteLogger log

Logger.

timeout

protected long timeout

threadId

protected final long threadId

Initiated thread id.

futId

protected final IgniteUuid futId

Mvcc future id.

lockVer

protected final GridCacheVersion lockVer

Lock version.

timeoutObj

@GridToStringExclude
protected org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxAbstractEnlistFuture.LockTimeoutObject timeoutObj

Timeout object.

Constructor Detail

GridNearTxAbstractEnlistFuture

public GridNearTxAbstractEnlistFuture(GridCacheContext<?,?> cctx,
                                      GridNearTxLocal tx,
                                      long timeout,
                                      @Nullable
                                      @Nullable IgniteReducer<T,T> rdc)

Parameters:

cctx - Cache context.

tx - Transaction.

timeout - Timeout.

rdc - Compound future reducer.

Method Detail

init

public void init()

updateMappings

protected void updateMappings(ClusterNode node)
                       throws IgniteCheckedException

Parameters:

node - Primary node.

Throws:

IgniteCheckedException - if future is already completed.

updateLocalFuture

protected void updateLocalFuture(GridDhtTxAbstractEnlistFuture fut)
                          throws IgniteCheckedException

Parameters:

fut - Local enlist future.

Throws:

IgniteCheckedException - if future is already completed.

clearLocalFuture

protected void clearLocalFuture(GridDhtTxAbstractEnlistFuture fut)
                         throws IgniteCheckedException

Parameters:

fut - Local enlist future.

Throws:

IgniteCheckedException - if future is already completed.

checkCompleted

protected void checkCompleted()
                       throws IgniteCheckedException

Throws:

IgniteCheckedException - if future is already completed.

onCancelled

public boolean onCancelled()

Callback to notify that future is cancelled.

Overrides:

onCancelled in class GridFutureAdapter<T>

Returns:

True if cancel flag was set by this call.

onDone

public boolean onDone(@Nullable
                      T res,
                      @Nullable
                      @Nullable Throwable err,
                      boolean cancelled)

Overrides:

onDone in class GridCacheCompoundIdentityFuture<T>

Parameters:

res - Result.

err - Error.

cancelled - True if future is being cancelled.

Returns:

True if result was set by this call.

logError

protected void logError(IgniteLogger log,
                        String msg,
                        Throwable e)

Overrides:

logError in class GridCompoundFuture<T,T>

Parameters:

log - IgniteLogger.

msg - ShortMessage.

e - Exception.

logDebug

protected void logDebug(IgniteLogger log,
                        String msg)

Overrides:

logDebug in class GridCompoundFuture<T,T>

Parameters:

log - IgniteLogger.

msg - ShortMessage.

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>

version

public GridCacheVersion version()

Specified by:

version in interface GridCacheVersionedFuture<T>

Returns:

Future version.

onOwnerChanged

public boolean onOwnerChanged(GridCacheEntryEx entry,
                              GridCacheMvccCandidate owner)

Specified by:

onOwnerChanged in interface GridCacheVersionedFuture<T>

Parameters:

entry - Entry which received new owner.

owner - Owner.

Returns:

True if future cares about this entry.

futureId

public IgniteUuid futureId()

Specified by:

futureId in interface GridCacheFuture<T>

Returns:

Unique identifier for this future.

remainingTime

protected long remainingTime()
                      throws IgniteTxTimeoutCheckedException

Gets remaining allowed time.

Returns:

Remaining time. 0 if timeout isn't specified. -1 if time is out.

Throws:

IgniteTxTimeoutCheckedException - If timed out.

timeoutException

@NotNull
protected @NotNull IgniteTxTimeoutCheckedException timeoutException()

Returns:

Timeout exception.

map

protected abstract void map(boolean topLocked)

Start iterating the data rows and form batches.

Parameters:

topLocked - Whether topology was already locked.

pendingResponseNodes

public abstract Set<UUID> pendingResponseNodes()

Returns:

Nodes from which current future waits responses.