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

Class GridNearOptimisticTxPrepareFutureAdapter

java.lang.Object

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

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

org.apache.ignite.internal.processors.cache.GridCacheCompoundFuture<GridNearTxPrepareResponse,IgniteInternalTx>

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

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

All Implemented Interfaces:

Serializable, IgniteInternalFuture<IgniteInternalTx>, GridCacheFuture<IgniteInternalTx>, GridCacheVersionedFuture<IgniteInternalTx>, IgniteInClosure<IgniteInternalFuture<GridNearTxPrepareResponse>>

Direct Known Subclasses:

GridNearOptimisticSerializableTxPrepareFuture, GridNearOptimisticTxPrepareFuture

public abstract class GridNearOptimisticTxPrepareFutureAdapter
extends GridNearTxPrepareFutureAdapter

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	GridNearOptimisticTxPrepareFutureAdapter.KeyLockFuture Keys lock future.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareFutureAdapter

cctx, err, ERR_UPD, futId, log, logRef, msgLog, trackable, tx

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridNearOptimisticTxPrepareFutureAdapter(GridCacheSharedContext cctx, GridNearTxLocal tx)

Method Summary

Modifier and Type	Method and Description
void	prepare() Prepares transaction.
protected abstract void	prepare0(boolean remap, boolean topLocked)
protected void	prepareOnTopology(boolean remap, Runnable c)
protected GridDhtTopologyFuture	topologyReadLock() Acquires topology read lock.
protected void	topologyReadUnlock() Releases topology read lock.

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxPrepareFutureAdapter

futureId, markNotTrackable, onResult, trackable, tx, version

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

duration, onDone, startTime

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

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

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

chain, chain, error, get, get, get, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, onCancelled, 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.GridCacheVersionedFuture

onOwnerChanged

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

Constructor Detail

GridNearOptimisticTxPrepareFutureAdapter

protected GridNearOptimisticTxPrepareFutureAdapter(GridCacheSharedContext cctx,
                                                   GridNearTxLocal tx)

Parameters:

cctx - Context.

tx - Transaction.

Method Detail

prepare

public final void prepare()

Prepares transaction.

Specified by:

prepare in class GridNearTxPrepareFutureAdapter

topologyReadLock

protected final GridDhtTopologyFuture topologyReadLock()

Acquires topology read lock.

Returns:

Topology ready future.

topologyReadUnlock

protected final void topologyReadUnlock()

Releases topology read lock.

prepareOnTopology

protected final void prepareOnTopology(boolean remap,
                                       @Nullable
                                       Runnable c)

Parameters:

remap - Remap flag.

c - Optional closure to run after map.

prepare0

protected abstract void prepare0(boolean remap,
                                 boolean topLocked)

Parameters:

remap - Remap flag.

topLocked - True if thread already acquired lock preventing topology change.