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

Class GridDhtTxRemote

java.lang.Object

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

org.apache.ignite.internal.processors.cache.transactions.IgniteTxAdapter

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

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

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, IgniteInternalTx, IgniteTxRemoteEx, GridTimeoutObject

public class GridDhtTxRemote
extends GridDistributedTxRemoteAdapter

Transaction created by system implicitly on remote nodes.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

GridMetadataAwareAdapter.EntryKey

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, implicit, implicitSingle, internal, invalidate, isDone, isolation, loc, log, nodeId, onePhaseCommit, startTime, startVer, storeEnabled, subjId, syncCommit, syncRollback, taskName, taskNameHash, threadId, timeout, topVer, transform, txNodes, txSize, writeVer, xidVer

Constructor Summary

Constructors

Constructor and Description
GridDhtTxRemote() Empty constructor required for Externalizable.
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, GridCacheVersion nearXidVer, long rmtThreadId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, UUID subjId, int taskNameHash) This constructor is meant for pessimistic transactions.
GridDhtTxRemote(GridCacheSharedContext ctx, UUID nearNodeId, IgniteUuid rmtFutId, UUID nodeId, long rmtThreadId, AffinityTopologyVersion topVer, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, 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 cacheCtx, int part)
void	addWrite(GridCacheContext cacheCtx, GridCacheOperation op, IgniteTxKey key, CacheObject val, Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors, long ttl, boolean skipStore)
void	addWrite(IgniteTxEntry 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()
UUID	nearNodeId()
GridCacheVersion	nearXidVersion()
UUID	otherNodeId() Gets ID of additional node involved.
String	toString()
void	transactionNodes(Map<UUID,Collection<UUID>> txNodes)
protected boolean	updateNearCache(GridCacheContext cacheCtx, KeyCacheObject key, AffinityTopologyVersion 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, 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, currentPrepareFuture, done, endTime, endVersion, endVersion, equals, evictNearEntry, finalizationStatus, finishFuture, hashCode, hasTransforms, implicit, implicitSingle, initCommitVersion, internal, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, localResult, lock, lockTimeout, log, markFinalizing, markPreparing, near, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, onRemap, onTimeout, optimistic, optimisticLockEntries, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, proxy, readCommitted, readExternal, readResolve, remainingTime, repeatableRead, replicated, resolveTaskName, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, storeEnabled, storeEnabled, stores, storeUsed, subjectId, syncCommit, syncCommit, syncRollback, syncRollback, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, timeoutId, topologyVersion, topologyVersion, topologyVersionSnapshot, 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, readExternalMeta, removeAllMeta, 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, currentPrepareFuture, done, endVersion, endVersion, finishFuture, hasTransforms, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, localResult, markFinalizing, markPreparing, meta, near, needsCompletedVersions, nodeId, onePhaseCommit, onRemap, 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, topologyVersionSnapshot, 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 ctx,
               UUID nearNodeId,
               IgniteUuid rmtFutId,
               UUID nodeId,
               long rmtThreadId,
               AffinityTopologyVersion topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               boolean sys,
               byte plc,
               TransactionConcurrency concurrency,
               TransactionIsolation isolation,
               boolean invalidate,
               long timeout,
               int txSize,
               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.

nearXidVer - Near transaction ID.

txNodes - Transaction nodes mapping.

GridDhtTxRemote

public GridDhtTxRemote(GridCacheSharedContext ctx,
               UUID nearNodeId,
               IgniteUuid rmtFutId,
               UUID nodeId,
               GridCacheVersion nearXidVer,
               long rmtThreadId,
               AffinityTopologyVersion topVer,
               GridCacheVersion xidVer,
               GridCacheVersion commitVer,
               boolean sys,
               byte plc,
               TransactionConcurrency concurrency,
               TransactionIsolation isolation,
               boolean invalidate,
               long timeout,
               int txSize,
               @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.

Method Detail

transactionNodes

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

Overrides:

transactionNodes in class IgniteTxAdapter

Parameters:

txNodes - Transaction nodes.

dht

public boolean dht()

Specified by:

dht in interface IgniteInternalTx

Overrides:

dht in class IgniteTxAdapter

Returns:

True if DHT transaction.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface IgniteInternalTx

Overrides:

eventNodeId in class GridDistributedTxRemoteAdapter

Returns:

Event node ID.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface IgniteInternalTx

Overrides:

masterNodeIds in class GridDistributedTxRemoteAdapter

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

Overrides:

otherNodeId in class IgniteTxAdapter

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

Overrides:

enforceSerializable in class IgniteTxAdapter

Returns:

Enforce serializable flag.

nearXidVersion

public GridCacheVersion nearXidVersion()

Specified by:

nearXidVersion in interface IgniteInternalTx

Overrides:

nearXidVersion in class IgniteTxAdapter

Returns:

Near transaction ID.

nearNodeId

public UUID nearNodeId()

Returns:

Near node ID.

updateNearCache

protected boolean updateNearCache(GridCacheContext cacheCtx,
                      KeyCacheObject key,
                      AffinityTopologyVersion topVer)

Checks whether near cache should be updated.

Overrides:

updateNearCache in class IgniteTxAdapter

Returns:

Flag indicating whether near cache should be updated.

addInvalidPartition

public void addInvalidPartition(GridCacheContext cacheCtx,
                       int part)

Specified by:

addInvalidPartition in interface IgniteInternalTx

Overrides:

addInvalidPartition in class IgniteTxAdapter

Parameters:

cacheCtx - Cache context.

part - Invalid partition.

addWrite

public void addWrite(IgniteTxEntry entry,
            ClassLoader ldr)
              throws IgniteCheckedException

Parameters:

entry - Write entry.

ldr - Class loader.

Throws:

IgniteCheckedException - If failed.

addWrite

public void addWrite(GridCacheContext cacheCtx,
            GridCacheOperation op,
            IgniteTxKey key,
            @Nullable
            CacheObject val,
            @Nullable
            Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
            long ttl,
            boolean skipStore)

Parameters:

cacheCtx - Cache context.

op - Write operation.

key - Key to add to write set.

val - Value.

entryProcessors - Entry processors.

ttl - TTL.

skipStore - Skip store flag.

toString

public String toString()

Overrides:

toString in class GridDistributedTxRemoteAdapter