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

Class GridDhtTxLocalAdapter<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>

All Implemented Interfaces:

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

Direct Known Subclasses:

GridDhtColocatedTxLocal, GridDhtTxLocal

public abstract class GridDhtTxLocalAdapter<K,V>
extends GridCacheTxLocalAdapter<K,V>

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

Modifier and Type	Field and Description
protected Map<UUID,GridDistributedTxMapping<K,V>>	dhtMap DHT mappings.
protected Map<UUID,GridDistributedTxMapping<K,V>>	nearMap Near mappings.

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

Modifier	Constructor and Description
protected	GridDhtTxLocalAdapter() Empty constructor required for Externalizable.
protected	GridDhtTxLocalAdapter(GridCacheVersion xidVer, boolean implicit, boolean implicitSingle, GridCacheContext<K,V> cctx, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, boolean invalidate, boolean syncCommit, boolean syncRollback, boolean explicitLock, boolean swapEnabled, boolean storeEnabled, int txSize, Object grpLockKey, boolean partLock, UUID subjId)

Method Summary

Methods

Modifier and Type	Method and Description
GridFuture<Boolean>	addEntry(long msgId, GridCacheTxEntry<K,V> e)
protected void	addGroupTxMapping(Collection<K> keys) Adds key mapping to transaction.
void	addInvalidPartition(int part)
void	addLocalCandidates(K key, Collection<GridCacheMvccCandidate<K>> cands)
protected abstract GridFuture<Boolean>	addReader(long msgId, GridDhtCacheEntry<K,V> cached, GridCacheTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected abstract void	clearPrepareFuture(GridDhtTxPrepareFuture<K,V> fut) Removes previously created prepare future from atomic reference.
boolean	finish(boolean commit) Finishes transaction (either commit or rollback).
Map<K,Collection<GridCacheMvccCandidate<K>>>	localCandidates()
protected void	mapExplicitLocks() Map explicit locks.
protected abstract GridUuid	nearFutureId()
protected abstract GridUuid	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)
boolean	syncCommit()
boolean	syncRollback()
String	toString()

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, eventNodeId, getAllAsync, groupLockAsync, hasReadKey, hasWriteKey, init, isBatchUpdate, isSingleUpdate, isStarted, loadMissing, masterNodeIds, minVersion, onOwnerChanged, originatingNodeId, 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, updateExplicitVersion, 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, dht, 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, nearXidVersion, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, otherNodeId, 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, transactionNodes, unlock, updateNearCache, 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

future, groupLockEntry

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

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

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

close, commitAsync, 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

Field Detail

nearMap

protected Map<UUID,GridDistributedTxMapping<K,V>> nearMap

Near mappings.

dhtMap

protected Map<UUID,GridDistributedTxMapping<K,V>> dhtMap

DHT mappings.

Constructor Detail

GridDhtTxLocalAdapter

protected GridDhtTxLocalAdapter()

Empty constructor required for Externalizable.

GridDhtTxLocalAdapter

protected GridDhtTxLocalAdapter(GridCacheVersion xidVer,
                     boolean implicit,
                     boolean implicitSingle,
                     GridCacheContext<K,V> cctx,
                     GridCacheTxConcurrency concurrency,
                     GridCacheTxIsolation isolation,
                     long timeout,
                     boolean invalidate,
                     boolean syncCommit,
                     boolean syncRollback,
                     boolean explicitLock,
                     boolean swapEnabled,
                     boolean storeEnabled,
                     int txSize,
                     @Nullable
                     Object grpLockKey,
                     boolean partLock,
                     @Nullable
                     UUID subjId)

Parameters:

xidVer - Transaction version.

implicit - Implicit flag.

implicitSingle - Implicit-with-single-key flag.

cctx - Cache context.

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

invalidate - Invalidation policy.

syncCommit - Synchronous commit flag.

syncRollback - Synchronous rollback flag.

explicitLock - Explicit lock flag.

swapEnabled - Swap enabled.

storeEnabled - Store enabled flag.

txSize - Expected transaction size.

grpLockKey - Group lock key if this is a group-lock transaction.

partLock - True if this is a group lock transaction and whole partition is locked.

Method Detail

nearNodeId

protected abstract UUID nearNodeId()

Returns:

Near node id.

nearFutureId

protected abstract GridUuid nearFutureId()

Returns:

Near future ID.

nearMiniId

protected abstract GridUuid nearMiniId()

Returns:

Near future mini ID.

addReader

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

Adds reader to cached entry.

Parameters:

msgId - Message ID.

cached - Cached entry.

entry - Transaction entry.

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 GridCacheTxEx<K,V>

Overrides:

needsCompletedVersions in class GridCacheTxAdapter<K,V>

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.

syncCommit

public boolean syncCommit()

Specified by:

syncCommit in interface GridCacheTxEx<K,V>

Overrides:

syncCommit in class GridCacheTxAdapter<K,V>

Returns:

True if transaction is configured with synchronous commit flag.

syncRollback

public boolean syncRollback()

Specified by:

syncRollback in interface GridCacheTxEx<K,V>

Overrides:

syncRollback in class GridCacheTxAdapter<K,V>

Returns:

True if transaction is configured with synchronous rollback flag.

mapExplicitLocks

protected void mapExplicitLocks()

Map explicit locks.

removeMapping

public boolean removeMapping(UUID nodeId)

Parameters:

nodeId - Node ID.

Returns:

True if mapping was removed.

addInvalidPartition

public void addInvalidPartition(int part)

Specified by:

addInvalidPartition in interface GridCacheTxEx<K,V>

Overrides:

addInvalidPartition in class GridCacheTxAdapter<K,V>

Parameters:

part - Invalid partition.

addEntry

@Nullable
public GridFuture<Boolean> addEntry(long msgId,
                                    GridCacheTxEntry<K,V> e)
                             throws GridException

Parameters:

msgId - Message ID.

e - Entry to add.

Returns:

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

Throws:

GridException - If failed.

addGroupTxMapping

protected void addGroupTxMapping(Collection<K> keys)

Adds key mapping to transaction.

Overrides:

addGroupTxMapping in class GridCacheTxLocalAdapter<K,V>

Parameters:

keys - Keys to add.

finish

public boolean finish(boolean commit)
               throws GridException

Finishes transaction (either commit or rollback).

Parameters:

commit - True if commit, false if rollback.

Returns:

True if state has been changed.

Throws:

GridException - If finish failed.

clearPrepareFuture

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

Removes previously created prepare future from atomic reference.

Parameters:

fut - Expected future.

rollback

public void rollback()
              throws GridException

Rolls back this transaction.

Throws:

GridException - If rollback failed.

addLocalCandidates

public void addLocalCandidates(K key,
                      Collection<GridCacheMvccCandidate<K>> cands)

Parameters:

key - Cache key.

cands - Collection of lock candidates for that key.

localCandidates

public Map<K,Collection<GridCacheMvccCandidate<K>>> localCandidates()

Returns:

All lock candidates.

toString

public String toString()

Overrides:

toString in class GridCacheTxLocalAdapter<K,V>