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

Class GridNearTxRemote<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.near.GridNearTxRemote<K,V>

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, IgniteInternalTx<K,V>, IgniteTxRemoteEx<K,V>, GridTimeoutObject

public class GridNearTxRemote<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
GridNearTxRemote() Empty constructor required for Externalizable.
GridNearTxRemote(GridCacheSharedContext<K,V> ctx, ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, Collection<IgniteTxEntry<K,V>> writeEntries, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.
GridNearTxRemote(GridCacheSharedContext<K,V> ctx, UUID nodeId, UUID nearNodeId, GridCacheVersion nearXidVer, long rmtThreadId, 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.

Method Summary

Methods

Modifier and Type	Method and Description
void	addEntries(ClassLoader ldr, Iterable<IgniteTxEntry<K,V>> entries) Adds entries to started near remote tx.
boolean	addEntry(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, byte[] keyBytes, GridCacheOperation op, V val, byte[] valBytes, GridCacheVersion drVer)
void	addEvicted(IgniteTxKey<K> key) Adds evicted key bytes to evicted collection.
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<IgniteTxKey<K>>	evicted()
boolean	groupLock()
void	markGroupLock() Marks near local transaction as group lock.
Collection<UUID>	masterNodeIds()
boolean	near()
UUID	nearNodeId()
GridCacheVersion	nearXidVersion()
GridCacheVersion	ownedVersion(IgniteTxKey<K> key) Gets owned version for near remote transaction.
void	ownedVersions(Map<IgniteTxKey<K>,GridCacheVersion> vers) Adds owned versions to map.
String	toString()

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

addInvalidPartition, applyTransformClosures, awaitCompletion, awaitSignal, checkInternal, close, colocated, commitVersion, commitVersion, completedVersions, concurrency, conflictResolve, dht, done, endTime, endVersion, endVersion, equals, evictNearEntry, finalizationStatus, finishFuture, groupLockEntry, groupLockKey, hashCode, hasTransforms, implicit, implicitSingle, initCommitVersion, internal, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, otherNodeId, 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, updateNearCache, 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

addInvalidPartition, addMeta, close, colocated, commitVersion, commitVersion, completedVersions, concurrency, dht, done, endVersion, endVersion, finishFuture, groupLockKey, hasTransforms, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, markFinalizing, markPreparing, meta, needsCompletedVersions, nodeId, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, 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

GridNearTxRemote

public GridNearTxRemote()

Empty constructor required for Externalizable.

GridNearTxRemote

public GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
                ClassLoader ldr,
                UUID nodeId,
                UUID nearNodeId,
                long rmtThreadId,
                GridCacheVersion xidVer,
                GridCacheVersion commitVer,
                boolean sys,
                TransactionConcurrency concurrency,
                TransactionIsolation isolation,
                boolean invalidate,
                long timeout,
                Collection<IgniteTxEntry<K,V>> writeEntries,
                int txSize,
                @Nullable
                IgniteTxKey grpLockKey,
                @Nullable
                UUID subjId,
                int taskNameHash)
                 throws IgniteCheckedException

This constructor is meant for optimistic transactions.

Parameters:

ldr - Class loader.

nodeId - Node ID.

nearNodeId - Near node ID.

rmtThreadId - Remote thread ID.

xidVer - XID version.

commitVer - Commit version.

sys - System flag.

concurrency - Concurrency level (should be pessimistic).

isolation - Transaction isolation.

invalidate - Invalidate flag.

timeout - Timeout.

writeEntries - Write entries.

ctx - Cache registry.

txSize - Expected transaction size.

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

Throws:

IgniteCheckedException - If unmarshalling failed.

GridNearTxRemote

public GridNearTxRemote(GridCacheSharedContext<K,V> ctx,
                UUID nodeId,
                UUID nearNodeId,
                GridCacheVersion nearXidVer,
                long rmtThreadId,
                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:

nodeId - Node ID.

nearNodeId - Near node ID.

nearXidVer - Near transaction ID.

rmtThreadId - Remote thread ID.

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

txSize - Expected transaction size.

grpLockKey - Collection of group lock keys if this is a group-lock transaction.

Method Detail

near

public boolean near()

Specified by:

near in interface IgniteInternalTx<K,V>

Overrides:

near in class IgniteTxAdapter<K,V>

Returns:

True if near transaction.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface IgniteInternalTx<K,V>

Overrides:

eventNodeId in class GridDistributedTxRemoteAdapter<K,V>

Returns:

Event node ID.

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.

ownedVersion

public GridCacheVersion ownedVersion(IgniteTxKey<K> key)

Gets owned version for near remote transaction.

Specified by:

ownedVersion in interface IgniteInternalTx<K,V>

Overrides:

ownedVersion in class IgniteTxAdapter<K,V>

Parameters:

key - Key to get version for.

Returns:

Owned version, if any.

markGroupLock

public void markGroupLock()

Marks near local transaction as group lock. Note that near remote transaction may be marked as group lock even if it does not contain any locked key.

groupLock

public boolean groupLock()

Specified by:

groupLock in interface IgniteInternalTx<K,V>

Overrides:

groupLock in class IgniteTxAdapter<K,V>

Returns:

True if transaction group-locked.

nearXidVersion

public GridCacheVersion nearXidVersion()

Description copied from class: IgniteTxAdapter

Specified by:

nearXidVersion in interface IgniteInternalTx<K,V>

Overrides:

nearXidVersion in class IgniteTxAdapter<K,V>

Returns:

Near transaction ID.

ownedVersions

public void ownedVersions(Map<IgniteTxKey<K>,GridCacheVersion> vers)

Adds owned versions to map.

Parameters:

vers - Map of owned versions.

nearNodeId

public UUID nearNodeId()

Returns:

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

evicted

public Collection<IgniteTxKey<K>> evicted()

Returns:

Evicted keys.

addEvicted

public void addEvicted(IgniteTxKey<K> key)

Adds evicted key bytes to evicted collection.

Parameters:

key - Evicted key.

addEntries

public void addEntries(ClassLoader ldr,
              Iterable<IgniteTxEntry<K,V>> entries)
                throws IgniteCheckedException

Adds entries to started near remote tx.

Parameters:

ldr - Class loader.

entries - Entries to add.

Throws:

IgniteCheckedException - If failed.

addEntry

public boolean addEntry(GridCacheContext<K,V> cacheCtx,
               IgniteTxKey<K> key,
               byte[] keyBytes,
               GridCacheOperation op,
               V val,
               byte[] valBytes,
               @Nullable
               GridCacheVersion drVer)
                 throws IgniteCheckedException

Parameters:

key - Key to add to read set.

keyBytes - Key bytes.

val - Value.

valBytes - Value bytes.

drVer - Data center replication version.

Returns:

True if entry has been enlisted.

Throws:

IgniteCheckedException - If failed.

toString

public String toString()

Overrides:

toString in class GridDistributedTxRemoteAdapter<K,V>