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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

GridDhtTxRemote, GridNearTxRemote

public class GridDistributedTxRemoteAdapter<K,V>
extends IgniteTxAdapter<K,V>
implements IgniteTxRemoteEx<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

Modifier and Type	Field and Description
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	readMap Read set.
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	writeMap Write map.

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
GridDistributedTxRemoteAdapter() Empty constructor required for Externalizable.
GridDistributedTxRemoteAdapter(GridCacheSharedContext<K,V> ctx, UUID nodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash)

Method Summary

Methods

Modifier and Type	Method and Description
Collection<Integer>	activeCacheIds()
protected void	addExplicit(IgniteTxEntry<K,V> e) Adds explicit version if there is one.
Collection<IgniteTxEntry<K,V>>	allEntries()
Collection<GridCacheVersion>	alternateVersions()
void	clearEntry(IgniteTxKey<K> key) Clears entry from transaction as it never happened.
void	commit() Commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
void	doneRemote(GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers)
boolean	empty()
IgniteTxEntry<K,V>	entry(IgniteTxKey<K> key)
UUID	eventNodeId()
void	forceCommit() Forces commit for this tx.
void	groupLockKey(IgniteTxKey key) Adds group lock key to remote transaction.
boolean	hasWriteKey(IgniteTxKey<K> key)
void	invalidate(boolean invalidate)
boolean	isStarted()
Collection<UUID>	masterNodeIds()
boolean	onOwnerChanged(GridCacheEntryEx<K,V> entry, GridCacheMvccCandidate<K> owner) Callback invoked whenever there is a lock that has been acquired by this transaction for any of the participating entries.
UUID	originatingNodeId() Gets node ID which directly started this transaction.
GridTuple<V>	peek(GridCacheContext<K,V> cacheCtx, boolean failFast, K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
void	prepare() Prepare phase.
IgniteInternalFuture<IgniteInternalTx<K,V>>	prepareAsync() Prepare stage.
Collection<IgniteTxEntry<K,V>>	readEntries()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	readMap()
Set<IgniteTxKey<K>>	readSet()
long	remoteThreadId()
boolean	removed(IgniteTxKey<K> key) Checks whether given key has been removed within transaction.
void	rollback() Rolls back this transaction.
IgniteInternalFuture<IgniteInternalTx>	rollbackAsync() Asynchronously rollback this transaction.
void	seal() Seals transaction for updates.
boolean	setWriteValue(IgniteTxEntry<K,V> e)
String	toString()
Collection<IgniteTxEntry<K,V>>	writeEntries()
Map<IgniteTxKey<K>,IgniteTxEntry<K,V>>	writeMap()
Set<IgniteTxKey<K>>	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, enforceSerializable, 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, nearXidVersion, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, optimisticLockEntries, otherNodeId, 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, 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, enforceSerializable, finishFuture, groupLock, groupLockKey, hasTransforms, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, markFinalizing, markPreparing, meta, near, nearXidVersion, needsCompletedVersions, nodeId, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, 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

Field Detail

readMap

@GridToStringInclude
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> readMap

Read set.

writeMap

@GridToStringInclude
protected Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> writeMap

Write map.

Constructor Detail

GridDistributedTxRemoteAdapter

public GridDistributedTxRemoteAdapter()

Empty constructor required for Externalizable.

GridDistributedTxRemoteAdapter

public GridDistributedTxRemoteAdapter(GridCacheSharedContext<K,V> ctx,
                              UUID nodeId,
                              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)

Parameters:

ctx - Cache registry.

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

txSize - Expected transaction size.

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

subjId - Subject ID.

taskNameHash - Task name hash code.

Method Detail

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface IgniteInternalTx<K,V>

Returns:

Event node ID.

masterNodeIds

public Collection<UUID> masterNodeIds()

Specified by:

masterNodeIds in interface IgniteInternalTx<K,V>

Returns:

Master node IDs.

originatingNodeId

public UUID originatingNodeId()

Gets node ID which directly started this transaction. In case of DHT local transaction it will be near node ID, in case of DHT remote transaction it will be primary node ID, in case of replicated remote transaction it will be starter node ID.

Specified by:

originatingNodeId in interface IgniteInternalTx<K,V>

Returns:

Originating node ID.

activeCacheIds

public Collection<Integer> activeCacheIds()

Specified by:

activeCacheIds in interface IgniteInternalTx<K,V>

Returns:

Collection of cache IDs involved in this transaction.

empty

public boolean empty()

Specified by:

empty in interface IgniteInternalTx<K,V>

Returns:

Checks if transaction has no entries.

removed

public boolean removed(IgniteTxKey<K> key)

Checks whether given key has been removed within transaction.

Specified by:

removed in interface IgniteInternalTx<K,V>

Parameters:

key - Key to check.

Returns:

True if key has been removed.

invalidate

public void invalidate(boolean invalidate)

Specified by:

invalidate in interface IgniteInternalTx<K,V>

Overrides:

invalidate in class IgniteTxAdapter<K,V>

Parameters:

invalidate - Invalidate flag.

writeMap

public Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> writeMap()

Specified by:

writeMap in interface IgniteInternalTx<K,V>

Returns:

Transaction write map.

readMap

public Map<IgniteTxKey<K>,IgniteTxEntry<K,V>> readMap()

Specified by:

readMap in interface IgniteInternalTx<K,V>

Returns:

Transaction read map.

seal

public void seal()

Seals transaction for updates.

Specified by:

seal in interface IgniteInternalTx<K,V>

groupLockKey

public void groupLockKey(IgniteTxKey key)

Adds group lock key to remote transaction.

Parameters:

key - Key.

peek

public GridTuple<V> peek(GridCacheContext<K,V> cacheCtx,
                boolean failFast,
                K key,
                IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
                  throws GridCacheFilterFailedException

Specified by:

peek in interface IgniteInternalTx<K,V>

Parameters:

cacheCtx - Cache context.

failFast - Fail-fast flag.

key - Key to look up.

filter - Filter to check.

Returns:

Current value for the key within transaction.

Throws:

GridCacheFilterFailedException - If filter failed and failFast is true.

entry

public IgniteTxEntry<K,V> entry(IgniteTxKey<K> key)

Specified by:

entry in interface IgniteInternalTx<K,V>

Parameters:

key - Key for the entry.

Returns:

Entry for the key (either from write set or read set).

clearEntry

public void clearEntry(IgniteTxKey<K> key)

Clears entry from transaction as it never happened.

Parameters:

key - key to be removed.

doneRemote

public void doneRemote(GridCacheVersion baseVer,
              Collection<GridCacheVersion> committedVers,
              Collection<GridCacheVersion> rolledbackVers,
              Collection<GridCacheVersion> pendingVers)

Specified by:

doneRemote in interface IgniteTxRemoteEx<K,V>

Parameters:

baseVer - Base version.

committedVers - Committed versions.

rolledbackVers - Rolled back versions.

pendingVers - Pending versions.

onOwnerChanged

public boolean onOwnerChanged(GridCacheEntryEx<K,V> entry,
                     GridCacheMvccCandidate<K> owner)

Callback invoked whenever there is a lock that has been acquired by this transaction for any of the participating entries.

Specified by:

onOwnerChanged in interface IgniteInternalTx<K,V>

Parameters:

entry - Cache entry.

owner - Lock candidate that won ownership of the lock.

Returns:

True if transaction cared about notification.

isStarted

public boolean isStarted()

Specified by:

isStarted in class IgniteTxAdapter<K,V>

Returns:

True if transaction has at least one key enlisted.

remoteThreadId

public long remoteThreadId()

Specified by:

remoteThreadId in interface IgniteTxRemoteEx<K,V>

Returns:

Remote node thread ID.

setWriteValue

public boolean setWriteValue(IgniteTxEntry<K,V> e)

Specified by:

setWriteValue in interface IgniteTxRemoteEx<K,V>

Parameters:

e - Transaction entry to set.

Returns:

True if value was set.

hasWriteKey

public boolean hasWriteKey(IgniteTxKey<K> key)

Specified by:

hasWriteKey in interface IgniteInternalTx<K,V>

Parameters:

key - Key to check.

Returns:

True if key is present.

prepareAsync

public IgniteInternalFuture<IgniteInternalTx<K,V>> prepareAsync()

Prepare stage.

Specified by:

prepareAsync in interface IgniteInternalTx<K,V>

Returns:

Future for prepare step.

readSet

public Set<IgniteTxKey<K>> readSet()

Specified by:

readSet in interface IgniteInternalTx<K,V>

Returns:

Read set.

writeSet

public Set<IgniteTxKey<K>> writeSet()

Specified by:

writeSet in interface IgniteInternalTx<K,V>

Returns:

Write set.

allEntries

public Collection<IgniteTxEntry<K,V>> allEntries()

Specified by:

allEntries in interface IgniteInternalTx<K,V>

Returns:

All transaction entries.

writeEntries

public Collection<IgniteTxEntry<K,V>> writeEntries()

Specified by:

writeEntries in interface IgniteInternalTx<K,V>

Returns:

Write entries.

readEntries

public Collection<IgniteTxEntry<K,V>> readEntries()

Specified by:

readEntries in interface IgniteInternalTx<K,V>

Returns:

Read entries.

prepare

public void prepare()
             throws IgniteCheckedException

Prepare phase.

Specified by:

prepare in interface IgniteInternalTx<K,V>

Throws:

IgniteCheckedException - If prepare failed.

commit

public void commit()
            throws IgniteCheckedException

Commits this transaction by initiating two-phase-commit process.

Specified by:

commit in interface IgniteInternalTx<K,V>

Throws:

IgniteCheckedException - If commit failed.

forceCommit

public void forceCommit()
                 throws IgniteCheckedException

Forces commit for this tx.

Throws:

IgniteCheckedException - If commit failed.

commitAsync

public IgniteInternalFuture<IgniteInternalTx> commitAsync()

Asynchronously commits this transaction by initiating two-phase-commit process.

Specified by:

commitAsync in interface IgniteInternalTx<K,V>

Returns:

Future for commit operation.

rollback

public void rollback()

Rolls back this transaction.

Specified by:

rollback in interface IgniteInternalTx<K,V>

rollbackAsync

public IgniteInternalFuture<IgniteInternalTx> rollbackAsync()

Asynchronously rollback this transaction.

Specified by:

rollbackAsync in interface IgniteInternalTx<K,V>

Returns:

Rollback future.

alternateVersions

public Collection<GridCacheVersion> alternateVersions()

Specified by:

alternateVersions in interface IgniteInternalTx<K,V>

Returns:

Alternate transaction versions.

addExplicit

protected void addExplicit(IgniteTxEntry<K,V> e)

Adds explicit version if there is one.

Parameters:

e - Transaction entry.

toString

public String toString()

Overrides:

toString in class IgniteTxAdapter<K,V>