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

Class GridDhtTxRemote<K,V>

java.lang.Object

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

org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxRemoteAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxRemote<K,V>

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, IgniteInternalTx<K,V>, IgniteTxRemoteEx<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.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

IgniteInternalTx.FinalizationStatus

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxRemoteAdapter

readMap, writeMap

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

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

Constructor Summary

Constructors

Constructor and Description
GridDhtTxRemote() Empty constructor required for Externalizable.
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for pessimistic transactions.
GridDhtTxRemote(GridCacheSharedContext<K,V> ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, long rmtThreadId, long topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, GridCacheVersion nearXidVer, Map<UUID,Collection<UUID>> txNodes, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.

Method Summary

Methods

Modifier and Type	Method and Description
void	addInvalidPartition(GridCacheContext<K,V> cacheCtx, int part)
void	addWrite(GridCacheContext<K,V> cacheCtx, GridCacheOperation op, IgniteTxKey<K> key, byte[] keyBytes, V val, byte[] valBytes, Collection<T2<javax.cache.processor.EntryProcessor<K,V,?>,Object[]>> entryProcessors, long ttl)
void	addWrite(IgniteTxEntry<K,V> entry, ClassLoader ldr)
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()
protected boolean	updateNearCache(GridCacheContext<K,V> cacheCtx, K key, long topVer) Checks whether near cache should be updated.

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.GridDistributedTxRemoteAdapter

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

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

applyTransformClosures, awaitCompletion, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, completedVersions, concurrency, conflictResolve, done, endTime, endVersion, endVersion, equals, evictNearEntry, finalizationStatus, finishFuture, groupLock, groupLockEntry, groupLockKey, hashCode, hasTransforms, implicit, implicitSingle, initCommitVersion, internal, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, near, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, proxy, readCommitted, readExternal, readResolve, remainingTime, repeatableRead, replicated, resolveTaskName, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, store, storeEnabled, storeEnabled, storeUsed, subjectId, syncCommit, syncCommit, syncRollback, syncRollback, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, timeoutId, topologyVersion, topologyVersion, transactionNodes, transactionNodes, uncommit, unlock, 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, 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, commitVersion, commitVersion, completedVersions, concurrency, done, endVersion, endVersion, finishFuture, groupLock, groupLockKey, hasTransforms, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, markFinalizing, markPreparing, meta, near, needsCompletedVersions, nodeId, onePhaseCommit, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, proxy, readCommitted, remainingTime, removeMeta, repeatableRead, replicated, serializable, setRollbackOnly, size, startTime, startVersion, state, state, storeEnabled, storeUsed, subjectId, syncCommit, syncRollback, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, topologyVersion, topologyVersion, transactionNodes, user, writeVersion, writeVersion, xid, xidVersion

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

endTime, onTimeout, timeoutId

Constructor Detail

GridDhtTxRemote

public GridDhtTxRemote()

Empty constructor required for Externalizable.

GridDhtTxRemote

public GridDhtTxRemote(GridCacheSharedContext<K,V> ctx,
               UUID nearNodeId,
               IgniteUuid rmtFutId,
               UUID nodeId,
               long rmtThreadId,
               long topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               boolean sys,
               TransactionConcurrency concurrency,
               TransactionIsolation isolation,
               boolean invalidate,
               long timeout,
               int txSize,
               @Nullable
               IgniteTxKey grpLockKey,
               GridCacheVersion nearXidVer,
               Map<UUID,Collection<UUID>> txNodes,
               @Nullable
               UUID subjId,
               int taskNameHash)

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.

sys - System flag.

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(GridCacheSharedContext<K,V> ctx,
               UUID nearNodeId,
               IgniteUuid rmtFutId,
               UUID nodeId,
               GridCacheVersion nearXidVer,
               long rmtThreadId,
               long topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               boolean sys,
               TransactionConcurrency concurrency,
               TransactionIsolation isolation,
               boolean invalidate,
               long timeout,
               int txSize,
               @Nullable
               IgniteTxKey grpLockKey,
               @Nullable
               UUID subjId,
               int taskNameHash)

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.

sys - System flag.

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

Overrides:

dht in class IgniteTxAdapter<K,V>

Returns:

True if DHT transaction.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface IgniteInternalTx<K,V>

Overrides:

eventNodeId in class GridDistributedTxRemoteAdapter<K,V>

Returns:

Event node ID.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface IgniteInternalTx<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 IgniteInternalTx<K,V>

Overrides:

otherNodeId in class IgniteTxAdapter<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 IgniteInternalTx<K,V>

Overrides:

enforceSerializable in class IgniteTxAdapter<K,V>

Returns:

Enforce serializable flag.

nearXidVersion

public GridCacheVersion nearXidVersion()

Specified by:

nearXidVersion in interface IgniteInternalTx<K,V>

Overrides:

nearXidVersion in class IgniteTxAdapter<K,V>

Returns:

Near transaction ID.

updateNearCache

protected boolean updateNearCache(GridCacheContext<K,V> cacheCtx,
                      K key,
                      long topVer)

Checks whether near cache should be updated.

Overrides:

updateNearCache in class IgniteTxAdapter<K,V>

Returns:

Flag indicating whether near cache should be updated.

addInvalidPartition

public void addInvalidPartition(GridCacheContext<K,V> cacheCtx,
                       int part)

Specified by:

addInvalidPartition in interface IgniteInternalTx<K,V>

Overrides:

addInvalidPartition in class IgniteTxAdapter<K,V>

Parameters:

cacheCtx - Cache context.

part - Invalid partition.

addWrite

public void addWrite(IgniteTxEntry<K,V> entry,
            ClassLoader ldr)
              throws IgniteCheckedException

Parameters:

entry - Write entry.

ldr - Class loader.

Throws:

IgniteCheckedException - If failed.

addWrite

public void addWrite(GridCacheContext<K,V> cacheCtx,
            GridCacheOperation op,
            IgniteTxKey<K> key,
            byte[] keyBytes,
            @Nullable
            V val,
            @Nullable
            byte[] valBytes,
            @Nullable
            Collection<T2<javax.cache.processor.EntryProcessor<K,V,?>,Object[]>> entryProcessors,
            long ttl)

Parameters:

cacheCtx - Cache context.

op - Write operation.

key - Key to add to write set.

keyBytes - Key bytes.

val - Value.

valBytes - Value bytes.

entryProcessors - Entry processors.

ttl - TTL.

toString

public String toString()

Overrides:

toString in class GridDistributedTxRemoteAdapter<K,V>