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

Class GridDhtColocatedTxLocal<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.colocated.GridDhtColocatedTxLocal<K,V>

All Implemented Interfaces:

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

public class GridDhtColocatedTxLocal<K,V>
extends GridDhtTxLocalAdapter<K,V>

Colocated transaction. Embedded combination of near and dht local transactions when near cache is disabled.

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
GridDhtColocatedTxLocal() Empty constructor, required by Externalizable
GridDhtColocatedTxLocal(boolean implicit, boolean implicitSingle, GridCacheContext<K,V> cctx, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, long timeout, boolean invalidate, boolean syncCommit, boolean syncRollback, boolean swapEnabled, boolean storeEnabled, int txSize, Object grpLockKey, boolean partLock, UUID subjId)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addGroupTxMapping(Collection<K> keys) Adds key mapping to transaction.
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.
boolean	colocated()
GridFuture<GridCacheTx>	commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
protected GridCacheEntryEx<K,V>	entryEx(K key) Gets cache entry for given key.
protected GridCacheEntryEx<K,V>	entryEx(K key, long topVer) Gets cache entry for given key and topology version.
GridFuture<GridCacheTxEx<K,V>>	future()
GridFuture<Boolean>	loadMissing(boolean async, Collection<? extends K> keys, GridBiInClosure<K,V> c)
protected GridUuid	nearFutureId()
protected GridUuid	nearMiniId()
protected UUID	nearNodeId()
GridCacheVersion	nearXidVersion()
Collection<GridCacheTxEntry<K,V>>	optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
boolean	ownsLock(GridCacheEntryEx<K,V> entry)
boolean	ownsLockUnsafe(GridCacheEntryEx<K,V> entry)
GridFuture<GridCacheTxEx<K,V>>	prepareAsync() Prepare stage.
GridFuture<GridCacheTxEx<K,V>>	prepareAsyncLocal(Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
Collection<GridCacheTxEntry<K,V>>	recoveryWrites() Gets pessimistic recovery writes, i.e.
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()
protected void	updateExplicitVersion(GridCacheTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

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

addEntry, addInvalidPartition, addLocalCandidates, finish, 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, eventNodeId, getAllAsync, groupLockAsync, hasReadKey, hasWriteKey, init, isBatchUpdate, isSingleUpdate, isStarted, 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, userCommit, userPrepare, userRollback, writeEntries, writeMap, writeSet

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

applyTransformClosures, awaitCompletion, awaitSignal, awaitSignal, checkInternal, close, 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, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, otherNodeId, ownedVersion, pessimistic, readCommitted, readExternal, readResolve, 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

groupLockEntry

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

commitVersion, commitVersion, dht, done, endVersion, endVersion, enforceSerializable, finishFuture, groupLock, groupLockKey, implicitSingle, internal, invalidate, invalidPartitions, isSystemInvalidate, local, markFinalizing, markPreparing, near, onePhaseCommit, optimistic, otherNodeId, ownedVersion, pessimistic, readCommitted, remainingTime, repeatableRead, replicated, serializable, size, startVersion, state, subjectId, systemInvalidate, timedOut, topologyVersion, topologyVersion, transactionNodes, 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

GridDhtColocatedTxLocal

public GridDhtColocatedTxLocal()

Empty constructor, required by Externalizable

GridDhtColocatedTxLocal

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

Parameters:

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.

swapEnabled - Flag indicating whether swap is enabled or not.

storeEnabled - Flag indicating whether store is enabled or not.

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 should be locked.

Method Detail

colocated

public boolean colocated()

Specified by:

colocated in interface GridCacheTxEx<K,V>

Overrides:

colocated in class GridCacheTxAdapter<K,V>

Returns:

True if dht colocated transaction.

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.

recoveryWrites

public Collection<GridCacheTxEntry<K,V>> recoveryWrites()

Gets pessimistic recovery writes, i.e. values that have never been sent to remote nodes with lock requests.

Specified by:

recoveryWrites in interface GridCacheTxEx<K,V>

Overrides:

recoveryWrites in class GridCacheTxAdapter<K,V>

Returns:

Recover write entries.

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.

addReader

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.

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.

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.

future

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

Returns:

Future for this transaction.

ownsLockUnsafe

public boolean ownsLockUnsafe(GridCacheEntryEx<K,V> entry)

Specified by:

ownsLockUnsafe in interface GridCacheTxEx<K,V>

Overrides:

ownsLockUnsafe in class GridCacheTxAdapter<K,V>

Parameters:

entry - Entry to check.

Returns:

True if lock is owned.

ownsLock

public boolean ownsLock(GridCacheEntryEx<K,V> entry)
                 throws GridCacheEntryRemovedException

Specified by:

ownsLock in interface GridCacheTxEx<K,V>

Overrides:

ownsLock in class GridCacheTxAdapter<K,V>

Parameters:

entry - Entry to check.

Returns:

True if lock is owned.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

optimisticLockEntries

public Collection<GridCacheTxEntry<K,V>> optimisticLockEntries()

Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.

Specified by:

optimisticLockEntries in interface GridCacheTxEx<K,V>

Overrides:

optimisticLockEntries in class GridCacheTxAdapter<K,V>

Returns:

List of tx entries for optimistic locking.

loadMissing

public GridFuture<Boolean> loadMissing(boolean async,
                              Collection<? extends K> keys,
                              GridBiInClosure<K,V> c)

Specified by:

loadMissing in interface GridCacheTxLocalEx<K,V>

Overrides:

loadMissing in class GridCacheTxLocalAdapter<K,V>

Parameters:

async - if True, then loading will happen in a separate thread.

keys - Keys.

c - Closure.

Returns:

Future with True value if loading took place.

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.

Returns:

Future for prepare step.

commitAsync

public GridFuture<GridCacheTx> commitAsync()

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

Returns:

Future for commit operation.

rollbackAsync

public GridFuture<GridCacheTx> rollbackAsync()

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

Returns:

Rollback future.

prepareAsyncLocal

public GridFuture<GridCacheTxEx<K,V>> prepareAsyncLocal(@Nullable
                                               Collection<GridCacheTxEntry<K,V>> reads,
                                               @Nullable
                                               Collection<GridCacheTxEntry<K,V>> writes,
                                               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.

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.

addGroupTxMapping

protected void addGroupTxMapping(Collection<K> keys)

Adds key mapping to transaction.

Overrides:

addGroupTxMapping in class GridDhtTxLocalAdapter<K,V>

Parameters:

keys - Keys to add.

entryEx

protected GridCacheEntryEx<K,V> entryEx(K key)

Gets cache entry for given key.

Overrides:

entryEx in class GridCacheTxLocalAdapter<K,V>

Parameters:

key - Key.

Returns:

Cache entry.

entryEx

protected GridCacheEntryEx<K,V> entryEx(K key,
                            long topVer)

Gets cache entry for given key and topology version.

Overrides:

entryEx in class GridCacheTxLocalAdapter<K,V>

Parameters:

key - Key.

topVer - Topology version.

Returns:

Cache entry.

toString

public String toString()

Overrides:

toString in class GridDhtTxLocalAdapter<K,V>