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

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

All Implemented Interfaces:

Externalizable, Serializable, AutoCloseable, GridCacheTx, GridMetadataAware, GridCacheTxEx<K,V>, GridCacheTxRemoteEx<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.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
GridNearTxRemote() Empty constructor required for Externalizable.
GridNearTxRemote(ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean invalidate, long timeout, Collection<GridCacheTxEntry<K,V>> writeEntries, GridCacheContext<K,V> ctx, int txSize, Object grpLockKey, UUID subjId) This constructor is meant for optimistic transactions.
GridNearTxRemote(UUID nodeId, UUID nearNodeId, GridCacheVersion nearXidVer, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, GridCacheTxConcurrency concurrency, GridCacheTxIsolation isolation, boolean invalidate, long timeout, K key, byte[] keyBytes, V val, byte[] valBytes, GridCacheVersion drVer, GridCacheContext<K,V> ctx, int txSize, Object grpLockKey, UUID subjId) This constructor is meant for pessimistic transactions.

Method Summary

Methods

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

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

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

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

GridNearTxRemote

public GridNearTxRemote()

Empty constructor required for Externalizable.

GridNearTxRemote

public GridNearTxRemote(ClassLoader ldr,
                UUID nodeId,
                UUID nearNodeId,
                long rmtThreadId,
                GridCacheVersion xidVer,
                GridCacheVersion commitVer,
                GridCacheTxConcurrency concurrency,
                GridCacheTxIsolation isolation,
                boolean invalidate,
                long timeout,
                Collection<GridCacheTxEntry<K,V>> writeEntries,
                GridCacheContext<K,V> ctx,
                int txSize,
                @Nullable
                Object grpLockKey,
                @Nullable
                UUID subjId)
                 throws GridException

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.

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:

GridException - If unmarshalling failed.

GridNearTxRemote

public GridNearTxRemote(UUID nodeId,
                UUID nearNodeId,
                GridCacheVersion nearXidVer,
                long rmtThreadId,
                GridCacheVersion xidVer,
                GridCacheVersion commitVer,
                GridCacheTxConcurrency concurrency,
                GridCacheTxIsolation isolation,
                boolean invalidate,
                long timeout,
                K key,
                byte[] keyBytes,
                V val,
                byte[] valBytes,
                @Nullable
                GridCacheVersion drVer,
                GridCacheContext<K,V> ctx,
                int txSize,
                @Nullable
                Object grpLockKey,
                @Nullable
                UUID subjId)
                 throws GridException

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.

concurrency - Concurrency level (should be pessimistic).

isolation - Transaction isolation.

invalidate - Invalidate flag.

timeout - Timeout.

key - Key.

keyBytes - Key bytes.

val - Value.

valBytes - Value bytes.

drVer - DR version.

ctx - Cache registry.

txSize - Ecpected transaction size.

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

Throws:

GridException - If failed.

Method Detail

near

public boolean near()

Specified by:

near in interface GridCacheTxEx<K,V>

Overrides:

near in class GridCacheTxAdapter<K,V>

Returns:

True if near transaction.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface GridCacheTxEx<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 GridCacheTxEx<K,V>

Overrides:

enforceSerializable in class GridCacheTxAdapter<K,V>

Returns:

Enforce serializable flag.

ownedVersion

public GridCacheVersion ownedVersion(K key)

Gets owned version for near remote transaction.

Specified by:

ownedVersion in interface GridCacheTxEx<K,V>

Overrides:

ownedVersion in class GridCacheTxAdapter<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 GridCacheTxEx<K,V>

Overrides:

groupLock in class GridCacheTxAdapter<K,V>

Returns:

True if transaction group-locked.

nearXidVersion

public GridCacheVersion nearXidVersion()

Description copied from class: GridCacheTxAdapter

Specified by:

nearXidVersion in interface GridCacheTxEx<K,V>

Overrides:

nearXidVersion in class GridCacheTxAdapter<K,V>

Returns:

Near transaction ID.

ownedVersions

public void ownedVersions(Map<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 GridCacheTxEx<K,V>

Overrides:

masterNodeIds in class GridDistributedTxRemoteAdapter<K,V>

Returns:

Master node IDs.

evicted

public Collection<K> evicted()

Returns:

Evicted keys.

evictedBytes

public Collection<byte[]> evictedBytes()

Returns:

Evicted bytes.

addEvicted

public void addEvicted(K key,
              byte[] bytes)

Adds evicted key bytes to evicted collection.

Parameters:

key - Evicted key.

bytes - Bytes of evicted key.

hasEvictedBytes

public boolean hasEvictedBytes()

Returns:

True if transaction contains a valid list of evicted bytes.

addEntries

public void addEntries(ClassLoader ldr,
              Iterable<GridCacheTxEntry<K,V>> entries)
                throws GridException

Adds entries to started near remote tx.

Parameters:

ldr - Class loader.

entries - Entries to add.

Throws:

GridException - If failed.

toString

public String toString()

Overrides:

toString in class GridDistributedTxRemoteAdapter<K,V>