org.gridgain.grid.kernal.processors.cache.distributed.dht

Class GridDhtTxLocal<K,V>

java.lang.Object

org.gridgain.grid.util.lang.GridMetadataAwareAdapter

org.gridgain.grid.kernal.processors.cache.GridCacheTxAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.GridCacheTxLocalAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtTxLocalAdapter<K,V>

org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtTxLocal<K,V>

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, GridCacheTx, GridMetadataAware, GridCacheMappedVersion, GridCacheTxEx<K,V>, GridCacheTxLocalEx<K,V>, GridTimeoutObject

public class GridDhtTxLocal<K,V>
extends GridDhtTxLocalAdapter<K,V>
implements GridCacheMappedVersion

Replicated user transaction.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheTxLocalAdapter

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

Nested classes/interfaces inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

GridCacheTxEx.FinalizationStatus

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtTxLocalAdapter

dhtMap, nearMap

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheTxLocalAdapter

commitErr, doneFlag, minVer, readView, txMap, writeView

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheTxAdapter

cctx, concurrency, endVer, grpLockKey, implicit, implicitSingle, internal, invalidate, isDone, isolation, loc, log, nodeId, onePhaseCommit, startTime, startVer, storeEnabled, subjId, swapOrOffheapEnabled, threadId, timeout, txSize, writeVer, xidVer

Constructor Summary

Constructors

Constructor and Description
GridDhtTxLocal() Empty constructor required for Externalizable.

Method Summary

Methods

Modifier and Type	Method and Description
protected GridFuture<Boolean>	addReader(long msgId, GridDhtCacheEntry<K,V> cached, GridCacheTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected void	clearPrepareFuture(GridDhtTxPrepareFuture<K,V> fut) Removes previously created prepare future from atomic reference.
GridFuture<GridCacheTx>	commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
boolean	dht()
UUID	eventNodeId()
boolean	finish(boolean commit) Finishes transaction (either commit or rollback).
GridFuture<GridCacheTxEx<K,V>>	future()
protected boolean	isBatchUpdate()
protected boolean	isSingleUpdate()
GridCacheVersion	mappedVersion() Mapping should occur only if this interface returns a non-null value.
Collection<UUID>	masterNodeIds()
GridUuid	nearFinishFutureId()
void	nearFinishFutureId(GridUuid nearFinFutId)
GridUuid	nearFinishMiniId()
void	nearFinishMiniId(GridUuid nearFinMiniId)
protected GridUuid	nearFutureId()
protected GridUuid	nearMiniId()
protected UUID	nearNodeId()
GridCacheVersion	nearXidVersion()
UUID	originatingNodeId() Gets node ID which directly started this transaction.
UUID	otherNodeId() Gets ID of additional node involved.
GridFuture<GridCacheTxEx<K,V>>	prepareAsync() Prepare stage.
GridFuture<GridCacheTxEx<K,V>>	prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<K,GridCacheVersion> verMap, long msgId, GridUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTx>	rollbackAsync() TODO-gg-4004 Put rollback async on public API? Asynchronously rollback this transaction.
protected void	sendFinishReply(boolean commit, Throwable err)
String	toString()
Map<UUID,Collection<UUID>>	transactionNodes()
protected void	updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.
protected boolean	updateNearCache() Checks whether near cache should be updated.

Methods inherited from class org.gridgain.grid.kernal.processors.cache.distributed.dht.GridDhtTxLocalAdapter

addEntry, addGroupTxMapping, addInvalidPartition, addLocalCandidates, localCandidates, mapExplicitLocks, needsCompletedVersions, needsCompletedVersions, pendingVersions, pendingVersions, removeMapping, rollback, syncCommit, syncRollback

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheTxLocalAdapter

addEntry, allEntries, alternateVersions, batchStoreCommit, checkValid, commit, commitAfterLock, commitError, commitError, committedVersions, completedBase, completedVersions, empty, enlistWrite, entry, entryEx, entryEx, getAllAsync, groupLockAsync, hasReadKey, hasWriteKey, init, isStarted, loadMissing, minVersion, onOwnerChanged, partitionLock, peek, postLockWrite, prepare, put, putAll, putAllAsync, putAllDr, putAllDrAsync, putAsync, putAsync, putx, putx, putxAsync, putxAsync, putxAsync0, readEntries, readMap, readSet, remove, removeAll, removeAllAsync, removeAllDr, removeAllDrAsync, removeAsync, removed, removex, removexAsync, removexAsync0, rolledbackVersions, seal, sendTransformedValues, tmCommit, transform, transformAll, transformAllAsync, transformAsync, transformCompute, userCommit, userPrepare, userRollback, writeEntries, writeMap, writeSet

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheTxAdapter

applyTransformClosures, awaitCompletion, awaitSignal, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, concurrency, done, drResolveConflict, endTime, endVersion, endVersion, enforceSerializable, equals, evictNearEntry, finalizationStatus, finishFuture, groupLock, groupLockEntry, groupLockKey, hashCode, implicit, implicitSingle, initCommitVersion, internal, invalidate, invalidPartitions, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, near, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, readExternal, readResolve, recoveryWrites, recoveryWrites, remainingTime, repeatableRead, replicated, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, subjectId, systemInvalidate, threadId, timedOut, timeout, timeout, timeoutId, topologyVersion, topologyVersion, unlock, user, writeExternal, writeVersion, writeVersion, xid, xidVersion

Methods inherited from class org.gridgain.grid.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, 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.gridgain.grid.kernal.processors.cache.GridCacheTxLocalEx

groupLockEntry

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

colocated, commitVersion, commitVersion, done, endVersion, endVersion, enforceSerializable, finishFuture, groupLock, groupLockKey, implicitSingle, internal, invalidate, invalidPartitions, isSystemInvalidate, local, markFinalizing, markPreparing, near, onePhaseCommit, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, recoveryWrites, remainingTime, repeatableRead, replicated, serializable, size, startVersion, state, subjectId, systemInvalidate, timedOut, topologyVersion, topologyVersion, user, writeVersion, writeVersion, xidVersion

Methods inherited from interface org.gridgain.grid.cache.GridCacheTx

close, concurrency, implicit, isInvalidate, isolation, isRollbackOnly, nodeId, setRollbackOnly, startTime, state, threadId, timeout, timeout, xid

Methods inherited from interface org.gridgain.grid.GridMetadataAware

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Methods inherited from interface org.gridgain.grid.kernal.processors.timeout.GridTimeoutObject

endTime, onTimeout, timeoutId

Constructor Detail

GridDhtTxLocal

public GridDhtTxLocal()

Empty constructor required for Externalizable.

Method Detail

transactionNodes

public Map<UUID,Collection<UUID>> transactionNodes()

Specified by:

transactionNodes in interface GridCacheTxEx<K,V>

Overrides:

transactionNodes in class GridCacheTxAdapter<K,V>

Returns:

Transaction nodes mapping (primary node -> related backup nodes).

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface GridCacheTxEx<K,V>

Overrides:

eventNodeId in class GridCacheTxLocalAdapter<K,V>

Returns:

Event node ID.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface GridCacheTxEx<K,V>

Overrides:

masterNodeIds in class GridCacheTxLocalAdapter<K,V>

Returns:

Master node IDs.

otherNodeId

public UUID otherNodeId()

Gets ID of additional node involved. For example, in DHT case, other node is near node ID.

Specified by:

otherNodeId in interface GridCacheTxEx<K,V>

Overrides:

otherNodeId in class GridCacheTxAdapter<K,V>

Returns:

Parent node IDs.

originatingNodeId

public UUID originatingNodeId()

Gets node ID which directly started this transaction. In case of DHT local transaction it will be near node ID, in case of DHT remote transaction it will be primary node ID, in case of replicated remote transaction it will be starter node ID.

Specified by:

originatingNodeId in interface GridCacheTxEx<K,V>

Overrides:

originatingNodeId in class GridCacheTxLocalAdapter<K,V>

Returns:

Originating node ID.

nearNodeId

protected UUID nearNodeId()

Specified by:

nearNodeId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near node id.

nearXidVersion

public GridCacheVersion nearXidVersion()

Specified by:

nearXidVersion in interface GridCacheTxEx<K,V>

Overrides:

nearXidVersion in class GridCacheTxAdapter<K,V>

Returns:

Near transaction ID.

mappedVersion

public GridCacheVersion mappedVersion()

Mapping should occur only if this interface returns a non-null value.

Specified by:

mappedVersion in interface GridCacheMappedVersion

Returns:

Mapped version.

nearFutureId

protected GridUuid nearFutureId()

Specified by:

nearFutureId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near future ID.

nearMiniId

protected GridUuid nearMiniId()

Specified by:

nearMiniId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near future mini ID.

dht

public boolean dht()

Specified by:

dht in interface GridCacheTxEx<K,V>

Overrides:

dht in class GridCacheTxAdapter<K,V>

Returns:

True if DHT transaction.

isBatchUpdate

protected boolean isBatchUpdate()

Overrides:

isBatchUpdate in class GridCacheTxLocalAdapter<K,V>

Returns:

True if updates should be batched up.

isSingleUpdate

protected boolean isSingleUpdate()

Overrides:

isSingleUpdate in class GridCacheTxLocalAdapter<K,V>

Returns:

True if updates should be done individually.

updateNearCache

protected boolean updateNearCache()

Checks whether near cache should be updated.

Overrides:

updateNearCache in class GridCacheTxAdapter<K,V>

Returns:

Flag indicating whether near cache should be updated.

nearFinishFutureId

public GridUuid nearFinishFutureId()

Returns:

Near future ID.

nearFinishFutureId

public void nearFinishFutureId(GridUuid nearFinFutId)

Parameters:

nearFinFutId - Near future ID.

nearFinishMiniId

public GridUuid nearFinishMiniId()

Returns:

Near future mini ID.

future

public GridFuture<GridCacheTxEx<K,V>> future()

Specified by:

future in interface GridCacheTxLocalEx<K,V>

Returns:

Future for this transaction.

nearFinishMiniId

public void nearFinishMiniId(GridUuid nearFinMiniId)

Parameters:

nearFinMiniId - Near future mini ID.

addReader

@Nullable
protected GridFuture<Boolean> addReader(long msgId,
                                     GridDhtCacheEntry<K,V> cached,
                                     GridCacheTxEntry<K,V> entry,
                                     long topVer)

Adds reader to cached entry.

Specified by:

addReader in class GridDhtTxLocalAdapter<K,V>

Parameters:

msgId - Message ID.

cached - Cached entry.

entry - Transaction entry.

Returns:

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

updateExplicitVersion

protected void updateExplicitVersion(GridCacheTxEntry<K,V> txEntry,
                         GridCacheEntryEx<K,V> entry)
                              throws GridCacheEntryRemovedException

Updates explicit version for tx entry based on current entry lock owner.

Overrides:

updateExplicitVersion in class GridCacheTxLocalAdapter<K,V>

Parameters:

txEntry - Tx entry to update.

entry - Entry.

Throws:

GridCacheEntryRemovedException - If entry was concurrently removed.

prepareAsync

public GridFuture<GridCacheTxEx<K,V>> prepareAsync()

Prepare stage.

Specified by:

prepareAsync in interface GridCacheTxEx<K,V>

Returns:

Future for prepare step.

prepareAsync

public GridFuture<GridCacheTxEx<K,V>> prepareAsync(@Nullable
                                          Iterable<GridCacheTxEntry<K,V>> reads,
                                          @Nullable
                                          Iterable<GridCacheTxEntry<K,V>> writes,
                                          Map<K,GridCacheVersion> verMap,
                                          long msgId,
                                          GridUuid nearMiniId,
                                          Map<UUID,Collection<UUID>> txNodes,
                                          boolean last,
                                          Collection<UUID> lastBackups)

Prepares next batch of entries in dht transaction.

Parameters:

reads - Read entries.

writes - Write entries.

verMap - Version map.

msgId - Message ID.

nearMiniId - Near mini future ID.

txNodes - Transaction nodes mapping.

last - True if this is last prepare request.

lastBackups - IDs of backup nodes receiving last prepare request.

Returns:

Future that will be completed when locks are acquired.

commitAsync

public GridFuture<GridCacheTx> commitAsync()

Asynchronously commits this transaction by initiating two-phase-commit process.

Specified by:

commitAsync in interface GridCacheTx

Returns:

Future for commit operation.

clearPrepareFuture

protected void clearPrepareFuture(GridDhtTxPrepareFuture<K,V> fut)

Removes previously created prepare future from atomic reference.

Specified by:

clearPrepareFuture in class GridDhtTxLocalAdapter<K,V>

Parameters:

fut - Expected future.

rollbackAsync

public GridFuture<GridCacheTx> rollbackAsync()

TODO-gg-4004 Put rollback async on public API? Asynchronously rollback this transaction.

Specified by:

rollbackAsync in interface GridCacheTxEx<K,V>

Returns:

Rollback future.

finish

public boolean finish(boolean commit)
               throws GridException

Finishes transaction (either commit or rollback).

Specified by:

finish in interface GridCacheTxLocalEx<K,V>

Overrides:

finish in class GridDhtTxLocalAdapter<K,V>

Parameters:

commit - True if commit, false if rollback.

Returns:

True if state has been changed.

Throws:

GridException - If finish failed.

sendFinishReply

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

Specified by:

sendFinishReply in class GridDhtTxLocalAdapter<K,V>

Parameters:

commit - Commit flag.

err - Error, if any.

toString

public String toString()

Overrides:

toString in class GridDhtTxLocalAdapter<K,V>