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

Class GridDhtTxLocalAdapter

java.lang.Object

org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter

org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter

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

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, IgniteInternalTx, IgniteTxLocalEx, GridTimeoutObject

Direct Known Subclasses:

GridDhtTxLocal, GridNearTxLocal

public abstract class GridDhtTxLocalAdapter
extends IgniteTxLocalAdapter

Replicated user transaction.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter

IgniteTxLocalAdapter.FinishClosure<T>, IgniteTxLocalAdapter.PLC1<T>, IgniteTxLocalAdapter.PLC2<T>, IgniteTxLocalAdapter.PMC<T>, IgniteTxLocalAdapter.PostLockClosure1<T>, IgniteTxLocalAdapter.PostLockClosure2<T>, IgniteTxLocalAdapter.PostMissClosure<T>

Nested classes/interfaces inherited from interface org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

IgniteInternalTx.FinalizationStatus

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<UUID,GridDistributedTxMapping>	dhtMap DHT mappings.
protected boolean	explicitLock
protected AtomicBoolean	mapped Mapped flag.
protected Map<UUID,GridDistributedTxMapping>	nearMap Near mappings.

Fields inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter

activeCacheIds, commitErr, doneFlag, implicitRes, minVer, needRetVal, readView, txMap, writeView

Fields inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter

cctx, concurrency, endVer, implicit, implicitSingle, internal, invalidate, isDone, isolation, loc, log, nodeId, onePhaseCommit, startTime, startVer, storeEnabled, subjId, syncCommit, syncRollback, taskName, taskNameHash, threadId, timeout, topVer, transform, txNodes, txSize, writeVer, xidVer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridDhtTxLocalAdapter() Empty constructor required for Externalizable.
protected	GridDhtTxLocalAdapter(GridCacheSharedContext cctx, GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, boolean sys, boolean explicitLock, GridIoPolicy plc, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, UUID subjId, int taskNameHash)

Method Summary

Methods

Modifier and Type	Method and Description
void	addDhtMapping(Map<UUID,GridDistributedTxMapping> mappings)
IgniteInternalFuture<Boolean>	addEntry(long msgId, IgniteTxEntry e)
void	addInvalidPartition(GridCacheContext ctx, int part)
void	addLockTransactionNode(ClusterNode node)
void	addNearMapping(Map<UUID,GridDistributedTxMapping> mappings)
protected abstract IgniteInternalFuture<Boolean>	addReader(long msgId, GridDhtCacheEntry cached, IgniteTxEntry entry, AffinityTopologyVersion topVer) Adds reader to cached entry.
protected IgniteInternalFuture<GridNearTxPrepareResponse>	chainOnePhasePrepare(GridDhtTxPrepareFuture prepFut)
protected abstract void	clearPrepareFuture(GridDhtTxPrepareFuture fut) Removes previously created prepare future from atomic reference.
protected boolean	commitOnPrepare()
boolean	explicitLock()
void	explicitLock(boolean explicitLock)
boolean	finish(boolean commit) Finishes transaction (either commit or rollback).
Set<ClusterNode>	lockTransactionNodes()
protected void	mapExplicitLocks() Map explicit locks.
protected abstract IgniteUuid	nearFutureId()
protected abstract IgniteUuid	nearMiniId()
protected abstract UUID	nearNodeId()
boolean	needsCompletedVersions()
void	needsCompletedVersions(boolean needsCompletedVers)
Collection<GridCacheVersion>	pendingVersions()
void	pendingVersions(Collection<GridCacheVersion> pendingVers)
boolean	removeMapping(UUID nodeId)
void	rollback() Rolls back this transaction.
protected abstract void	sendFinishReply(boolean commit, Throwable err)
String	toString()

Methods inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter

accessPolicy, activeCacheIds, addActiveCache, addEntry, allEntries, alternateVersions, batchStoreCommit, checkValid, commit, commitAfterLock, commitError, commitError, committedVersions, completedBase, completedVersions, empty, enlistWrite, entry, entryEx, entryEx, entryExpireTime, entryTtl, eventNodeId, getAllAsync, hasWriteKey, implicitSingleResult, implicitSingleResult, init, initResult, invokeAsync, isStarted, loadMissing, masterNodeIds, minVersion, needReturnValue, needReturnValue, onOwnerChanged, originatingNodeId, peek, postLockWrite, prepare, putAllAsync, putAllDrAsync, readEntries, readMap, readSet, removeAllAsync, removeAllDrAsync, removed, rolledbackVersions, seal, sendTransformedValues, tmCommit, updateExplicitVersion, userCommit, userPrepare, userRollback, writeEntries, writeMap, writeSet

Methods inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter

applyTransformClosures, awaitCompletion, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, concurrency, conflictResolve, currentPrepareFuture, dht, done, endTime, endVersion, endVersion, enforceSerializable, equals, evictNearEntry, finalizationStatus, finishFuture, hashCode, hasTransforms, implicit, implicitSingle, initCommitVersion, internal, invalidate, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, localResult, lock, lockTimeout, log, markFinalizing, markPreparing, near, nearXidVersion, nodeId, onePhaseCommit, onePhaseCommit, onRemap, onTimeout, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, proxy, readCommitted, readExternal, readResolve, remainingTime, repeatableRead, replicated, resolveTaskName, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, storeEnabled, storeEnabled, stores, storeUsed, subjectId, syncCommit, syncCommit, syncRollback, syncRollback, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, timeoutId, topologyVersion, topologyVersion, topologyVersionSnapshot, transactionNodes, transactionNodes, uncommit, unlock, updateNearCache, user, writeExternal, writeVersion, writeVersion, xid, xidVersion

Methods inherited from class org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, readExternalMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

addMeta, close, colocated, commitAsync, commitVersion, commitVersion, concurrency, currentPrepareFuture, dht, done, endVersion, endVersion, enforceSerializable, finishFuture, hasTransforms, implicit, implicitSingle, internal, invalidate, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, localResult, markFinalizing, markPreparing, meta, near, nearXidVersion, nodeId, onePhaseCommit, onRemap, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, prepareAsync, proxy, readCommitted, remainingTime, removeMeta, repeatableRead, replicated, rollbackAsync, serializable, setRollbackOnly, size, startTime, startVersion, state, state, storeEnabled, storeUsed, subjectId, syncCommit, syncRollback, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, topologyVersion, topologyVersion, topologyVersionSnapshot, transactionNodes, user, writeVersion, writeVersion, xid, xidVersion

Methods inherited from interface org.apache.ignite.internal.processors.timeout.GridTimeoutObject

endTime, onTimeout, timeoutId

Field Detail

nearMap

protected Map<UUID,GridDistributedTxMapping> nearMap

Near mappings.

dhtMap

protected Map<UUID,GridDistributedTxMapping> dhtMap

DHT mappings.

mapped

protected AtomicBoolean mapped

Mapped flag.

explicitLock

protected boolean explicitLock

Constructor Detail

GridDhtTxLocalAdapter

protected GridDhtTxLocalAdapter()

Empty constructor required for Externalizable.

GridDhtTxLocalAdapter

protected GridDhtTxLocalAdapter(GridCacheSharedContext cctx,
                     GridCacheVersion xidVer,
                     boolean implicit,
                     boolean implicitSingle,
                     boolean sys,
                     boolean explicitLock,
                     GridIoPolicy plc,
                     TransactionConcurrency concurrency,
                     TransactionIsolation isolation,
                     long timeout,
                     boolean invalidate,
                     boolean storeEnabled,
                     int txSize,
                     @Nullable
                     UUID subjId,
                     int taskNameHash)

Parameters:

xidVer - Transaction version.

implicit - Implicit flag.

implicitSingle - Implicit-with-single-key flag.

cctx - Cache context.

sys - System flag.

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

txSize - Expected transaction size.

Method Detail

addLockTransactionNode

public void addLockTransactionNode(ClusterNode node)

Parameters:

node - Node.

lockTransactionNodes

@Nullable
public Set<ClusterNode> lockTransactionNodes()

Returns:

Nodes where transactions were started on lock step.

nearNodeId

protected abstract UUID nearNodeId()

Returns:

Near node id.

nearFutureId

protected abstract IgniteUuid nearFutureId()

Returns:

Near future ID.

nearMiniId

protected abstract IgniteUuid nearMiniId()

Returns:

Near future mini ID.

addReader

@Nullable
protected abstract IgniteInternalFuture<Boolean> addReader(long msgId,
                                               GridDhtCacheEntry cached,
                                               IgniteTxEntry entry,
                                               AffinityTopologyVersion topVer)

Adds reader to cached entry.

Parameters:

msgId - Message ID.

cached - Cached entry.

entry - Transaction entry.

topVer - Topology version.

Returns:

True if reader was added as a result of this call.

sendFinishReply

protected abstract void sendFinishReply(boolean commit,
                   @Nullable
                   Throwable err)

Parameters:

commit - Commit flag.

err - Error, if any.

needsCompletedVersions

public void needsCompletedVersions(boolean needsCompletedVers)

Parameters:

needsCompletedVers - True if needs completed versions.

needsCompletedVersions

public boolean needsCompletedVersions()

Specified by:

needsCompletedVersions in interface IgniteInternalTx

Overrides:

needsCompletedVersions in class IgniteTxAdapter

Returns:

True if transaction needs completed versions for processing.

pendingVersions

public Collection<GridCacheVersion> pendingVersions()

Returns:

Versions for all pending locks that were in queue before tx locks were released.

pendingVersions

public void pendingVersions(Collection<GridCacheVersion> pendingVers)

Parameters:

pendingVers - Versions for all pending locks that were in queue before tx locsk were released.

explicitLock

public boolean explicitLock()

Returns:

Explicit lock flag.

explicitLock

public void explicitLock(boolean explicitLock)

Parameters:

explicitLock - Explicit lock flag.

mapExplicitLocks

protected void mapExplicitLocks()

Map explicit locks.

addDhtMapping

public void addDhtMapping(Map<UUID,GridDistributedTxMapping> mappings)

Parameters:

mappings - Mappings to add.

addNearMapping

public void addNearMapping(Map<UUID,GridDistributedTxMapping> mappings)

Parameters:

mappings - Mappings to add.

removeMapping

public boolean removeMapping(UUID nodeId)

Parameters:

nodeId - Node ID.

Returns:

True if mapping was removed.

addInvalidPartition

public void addInvalidPartition(GridCacheContext ctx,
                       int part)

Specified by:

addInvalidPartition in interface IgniteInternalTx

Overrides:

addInvalidPartition in class IgniteTxAdapter

Parameters:

ctx - Cache context.

part - Invalid partition.

addEntry

@Nullable
public IgniteInternalFuture<Boolean> addEntry(long msgId,
                                              IgniteTxEntry e)
                                       throws IgniteCheckedException

Parameters:

msgId - Message ID.

e - Entry to add.

Returns:

Future for active transactions for the time when reader was added.

Throws:

IgniteCheckedException - If failed.

finish

public boolean finish(boolean commit)
               throws IgniteCheckedException

Finishes transaction (either commit or rollback).

Parameters:

commit - True if commit, false if rollback.

Returns:

True if state has been changed.

Throws:

IgniteCheckedException - If finish failed.

clearPrepareFuture

protected abstract void clearPrepareFuture(GridDhtTxPrepareFuture fut)

Removes previously created prepare future from atomic reference.

Parameters:

fut - Expected future.

commitOnPrepare

protected final boolean commitOnPrepare()

Returns:

True if transaction is finished on prepare step.

chainOnePhasePrepare

protected final IgniteInternalFuture<GridNearTxPrepareResponse> chainOnePhasePrepare(GridDhtTxPrepareFuture prepFut)

Parameters:

prepFut - Prepare future.

Returns:

If transaction if finished on prepare step returns future which is completed after transaction finish.

rollback

public void rollback()
              throws IgniteCheckedException

Rolls back this transaction.

Throws:

IgniteCheckedException - If rollback failed.

toString

public String toString()

Overrides:

toString in class IgniteTxLocalAdapter