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

Class GridNearTxPrepareFutureAdapter

java.lang.Object

java.util.concurrent.locks.AbstractOwnableSynchronizer

java.util.concurrent.locks.AbstractQueuedSynchronizer

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

org.apache.ignite.internal.util.future.GridCompoundFuture<GridNearTxPrepareResponse,IgniteInternalTx>

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

All Implemented Interfaces:

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

Direct Known Subclasses:

GridNearOptimisticTxPrepareFutureAdapter, GridNearPessimisticTxPrepareFuture

public abstract class GridNearTxPrepareFutureAdapter
extends GridCompoundFuture<GridNearTxPrepareResponse,IgniteInternalTx>
implements GridCacheMvccFuture<IgniteInternalTx>

Common code for tx prepare in optimistic and pessimistic modes.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.locks.AbstractQueuedSynchronizer

AbstractQueuedSynchronizer.ConditionObject

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheSharedContext<?,?>	cctx Context.
protected Throwable	err Error.
protected static AtomicReferenceFieldUpdater<GridNearTxPrepareFutureAdapter,Throwable>	ERR_UPD Error updater.
protected IgniteUuid	futId Future ID.
protected static IgniteLogger	log Logger.
protected static AtomicReference<IgniteLogger>	logRef Logger reference.
protected static IgniteLogger	msgLog Logger.
protected boolean	trackable Trackable flag.
protected GridNearTxLocal	tx Transaction.
protected GridDhtTxMapping	txMapping Full information about transaction nodes mapping.

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

sync

Constructor Summary

Constructors

Constructor and Description
GridNearTxPrepareFutureAdapter(GridCacheSharedContext cctx, GridNearTxLocal tx)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	checkOnePhase() Checks if mapped transaction can be committed on one phase.
IgniteUuid	futureId()
void	markNotTrackable() Marks this future as non-trackable.
protected void	onPrepareResponse(GridDistributedTxMapping m, GridNearTxPrepareResponse res)
abstract void	onResult(UUID nodeId, GridNearTxPrepareResponse res)
abstract void	prepare() Prepares transaction.
boolean	trackable()
IgniteInternalTx	tx()
GridCacheVersion	version()

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

add, apply, cancel, clear, future, futures, futuresCount, hasPending, ignoreFailure, initialized, markInitialized, toString

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

chain, duration, endTime, error, get, get, get, get0, getUninterruptibly, ignoreInterrupts, isCancelled, isDone, isFailed, listen, logger, 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.processors.cache.GridCacheMvccFuture

onOwnerChanged

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheFuture

onNodeLeft

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

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

Field Detail

logRef

protected static final AtomicReference<IgniteLogger> logRef

Logger reference.

ERR_UPD

protected static final AtomicReferenceFieldUpdater<GridNearTxPrepareFutureAdapter,Throwable> ERR_UPD

Error updater.

log

protected static IgniteLogger log

Logger.

msgLog

protected static IgniteLogger msgLog

Logger.

cctx

protected GridCacheSharedContext<?,?> cctx

Context.

futId

@GridToStringInclude
protected IgniteUuid futId

Future ID.

tx

@GridToStringInclude
protected GridNearTxLocal tx

Transaction.

err

@GridToStringExclude
protected volatile Throwable err

Error.

trackable

protected boolean trackable

Trackable flag.

txMapping

protected GridDhtTxMapping txMapping

Full information about transaction nodes mapping.

Constructor Detail

GridNearTxPrepareFutureAdapter

public GridNearTxPrepareFutureAdapter(GridCacheSharedContext cctx,
                              GridNearTxLocal tx)

Parameters:

cctx - Context.

tx - Transaction.

Method Detail

futureId

public IgniteUuid futureId()

Specified by:

futureId in interface GridCacheFuture<IgniteInternalTx>

Returns:

Unique identifier for this future.

version

public GridCacheVersion version()

Specified by:

version in interface GridCacheMvccFuture<IgniteInternalTx>

Returns:

Future version.

markNotTrackable

public void markNotTrackable()

Marks this future as non-trackable.

Specified by:

markNotTrackable in interface GridCacheFuture<IgniteInternalTx>

trackable

public boolean trackable()

Specified by:

trackable in interface GridCacheFuture<IgniteInternalTx>

Returns:

True if future should be tracked.

tx

public IgniteInternalTx tx()

Returns:

Transaction.

prepare

public abstract void prepare()

Prepares transaction.

onResult

public abstract void onResult(UUID nodeId,
            GridNearTxPrepareResponse res)

Parameters:

nodeId - Sender.

res - Result.

checkOnePhase

protected final void checkOnePhase()

Checks if mapped transaction can be committed on one phase. One-phase commit can be done if transaction maps to one primary node and not more than one backup.

onPrepareResponse

protected final void onPrepareResponse(GridDistributedTxMapping m,
                     GridNearTxPrepareResponse res)

Parameters:

m - Mapping.

res - Response.