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

Class GridDhtTxRemote<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.distributed.GridDistributedTxRemoteAdapter<K,V>

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

All Implemented Interfaces:

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

public class GridDhtTxRemote<K,V>
extends GridDistributedTxRemoteAdapter<K,V>

Transaction created by system implicitly on remote nodes.

See Also:

Serialized Form

Nested Class Summary

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.GridDistributedTxRemoteAdapter

readMap, writeMap

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
GridDhtTxRemote() Empty constructor required for Externalizable.
GridDhtTxRemote(UUID nearNodeId, GridUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean invalidate, long timeout, GridCacheContext<K,V> ctx, int txSize, Object grpLockKey, UUID subjId) This constructor is meant for pessimistic transactions.
GridDhtTxRemote(UUID nearNodeId, GridUuid rmtFutId, UUID nodeId, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean invalidate, long timeout, GridCacheContext<K,V> ctx, int txSize, Object grpLockKey, GridCacheVersion nearXidVer, Map<UUID,Collection<UUID>> txNodes, UUID subjId) This constructor is meant for optimistic transactions.

Method Summary

Methods

Modifier and Type	Method and Description
void	addInvalidPartition(int part)
boolean	dht()
boolean	enforceSerializable() For Partitioned caches, this flag is false for remote DHT and remote NEAR transactions because serializability of transaction is enforced on primary node.
UUID	eventNodeId()
Collection<UUID>	masterNodeIds()
GridCacheVersion	nearXidVersion()
UUID	otherNodeId() Gets ID of additional node involved.
String	toString()
Map<UUID,Collection<UUID>>	transactionNodes()
protected boolean	updateNearCache() Checks whether near cache should be updated.

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

addExplicit, addLocalCandidates, addRead, addRemoteCandidates, addWrite, allEntries, alternateVersions, clearEntry, commit, commitAsync, doneRemote, empty, entry, forceCommit, groupLockKey, hasReadKey, hasWriteKey, invalidate, isStarted, localCandidates, onOwnerChanged, originatingNodeId, peek, prepare, prepareAsync, readEntries, readMap, readSet, remoteThreadId, removed, rollback, rollbackAsync, seal, setWriteValue, writeEntries, writeMap, writeSet

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

applyTransformClosures, awaitCompletion, awaitSignal, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, completedVersions, concurrency, done, drResolveConflict, endTime, endVersion, endVersion, equals, evictNearEntry, finalizationStatus, finishFuture, groupLock, groupLockEntry, groupLockKey, hashCode, implicit, implicitSingle, initCommitVersion, internal, invalidPartitions, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, near, needsCompletedVersions, 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, syncCommit, syncRollback, 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.GridCacheTxEx

colocated, commitVersion, commitVersion, completedVersions, done, endVersion, endVersion, finishFuture, groupLock, groupLockKey, implicitSingle, internal, invalidPartitions, isSystemInvalidate, local, markFinalizing, markPreparing, near, needsCompletedVersions, onePhaseCommit, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, recoveryWrites, remainingTime, repeatableRead, replicated, serializable, size, startVersion, state, subjectId, syncCommit, syncRollback, 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

GridDhtTxRemote

public GridDhtTxRemote()

Empty constructor required for Externalizable.

GridDhtTxRemote

public GridDhtTxRemote(UUID nearNodeId,
               GridUuid rmtFutId,
               UUID nodeId,
               long rmtThreadId,
               long topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               GridCacheTxConcurrency concurrency,
               GridCacheTxIsolation isolation,
               boolean invalidate,
               long timeout,
               GridCacheContext<K,V> ctx,
               int txSize,
               @Nullable
               Object grpLockKey,
               GridCacheVersion nearXidVer,
               Map<UUID,Collection<UUID>> txNodes,
               @Nullable
               UUID subjId)

This constructor is meant for optimistic transactions.

Parameters:

nearNodeId - Near node ID.

rmtFutId - Remote future ID.

nodeId - Node ID.

rmtThreadId - Remote thread ID.

topVer - Topology version.

xidVer - XID version.

commitVer - Commit version.

concurrency - Concurrency level (should be pessimistic).

isolation - Transaction isolation.

invalidate - Invalidate flag.

timeout - Timeout.

ctx - Cache context.

txSize - Expected transaction size.

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

nearXidVer - Near transaction ID.

txNodes - Transaction nodes mapping.

GridDhtTxRemote

public GridDhtTxRemote(UUID nearNodeId,
               GridUuid rmtFutId,
               UUID nodeId,
               GridCacheVersion nearXidVer,
               long rmtThreadId,
               long topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               GridCacheTxConcurrency concurrency,
               GridCacheTxIsolation isolation,
               boolean invalidate,
               long timeout,
               GridCacheContext<K,V> ctx,
               int txSize,
               @Nullable
               Object grpLockKey,
               @Nullable
               UUID subjId)

This constructor is meant for pessimistic transactions.

Parameters:

nearNodeId - Near node ID.

rmtFutId - Remote future ID.

nodeId - Node ID.

nearXidVer - Near transaction ID.

rmtThreadId - Remote thread ID.

topVer - Topology version.

xidVer - XID version.

commitVer - Commit version.

concurrency - Concurrency level (should be pessimistic).

isolation - Transaction isolation.

invalidate - Invalidate flag.

timeout - Timeout.

ctx - Cache context.

txSize - Expected transaction size.

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

Method Detail

dht

public boolean dht()

Specified by:

dht in interface GridCacheTxEx<K,V>

Overrides:

dht in class GridCacheTxAdapter<K,V>

Returns:

True if DHT transaction.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface GridCacheTxEx<K,V>

Overrides:

eventNodeId in class GridDistributedTxRemoteAdapter<K,V>

Returns:

Event node ID.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface GridCacheTxEx<K,V>

Overrides:

masterNodeIds in class GridDistributedTxRemoteAdapter<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.

enforceSerializable

public boolean enforceSerializable()

For Partitioned caches, this flag is false for remote DHT and remote NEAR transactions because serializability of transaction is enforced on primary node. All other transaction types must enforce it.

Specified by:

enforceSerializable in interface GridCacheTxEx<K,V>

Overrides:

enforceSerializable in class GridCacheTxAdapter<K,V>

Returns:

Enforce serializable flag.

nearXidVersion

public GridCacheVersion nearXidVersion()

Specified by:

nearXidVersion in interface GridCacheTxEx<K,V>

Overrides:

nearXidVersion in class GridCacheTxAdapter<K,V>

Returns:

Near transaction ID.

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).

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.

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.

toString

public String toString()

Overrides:

toString in class GridDistributedTxRemoteAdapter<K,V>