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

Class GridDistributedTxRemoteAdapter

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

All Implemented Interfaces:

IgniteInternalTx, IgniteTxRemoteEx

Direct Known Subclasses:

GridDhtTxRemote, GridNearTxRemote

public abstract class GridDistributedTxRemoteAdapter
extends IgniteTxAdapter
implements IgniteTxRemoteEx

Transaction created by system implicitly on remote nodes.

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

Modifier and Type	Field and Description
protected IgniteTxRemoteState	txState

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

cctx, concurrency, consistentIdMapper, deploymentLdrId, implicit, internal, invalidate, isDone, isolation, loc, log, mvccSnapshot, needRetVal, nodeId, onePhaseCommit, startTime, startTimeNanos, storeEnabled, subjId, taskName, taskNameHash, threadId, timeout, topVer, txNodes, txSize, writeVer, xidVer

Constructor Summary

Constructors

Constructor and Description
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx, UUID nodeId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, @Nullable UUID subjId, int taskNameHash, String txLbl)

Method Summary

Modifier and Type	Method and Description
boolean	activeCachesDeploymentEnabled()
void	activeCachesDeploymentEnabled(boolean depEnabled)
void	addActiveCache(GridCacheContext cacheCtx, boolean recovery) Adds cache to the list of active caches in transaction.
protected void	addExplicit(IgniteTxEntry e) Adds explicit version if there is one.
Collection<IgniteTxEntry>	allEntries()
Collection<GridCacheVersion>	alternateVersions()
void	clearEntry(IgniteTxKey key) Clears entry from transaction as it never happened.
IgniteInternalFuture<IgniteInternalTx>	commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
void	commitError(Throwable e)
void	commitRemoteTx()
void	doneRemote(GridCacheVersion baseVer, Collection<GridCacheVersion> committedVers, Collection<GridCacheVersion> rolledbackVers, Collection<GridCacheVersion> pendingVers)
boolean	empty()
IgniteTxEntry	entry(IgniteTxKey key)
UUID	eventNodeId()
void	forceCommit() Forces commit for this tx.
boolean	hasWriteKey(IgniteTxKey key)
void	invalidate(boolean invalidate)
boolean	isStarted()
String	label() Returns label of transactions.
boolean	onOwnerChanged(GridCacheEntryEx entry, GridCacheMvccCandidate 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<CacheObject>	peek(GridCacheContext cacheCtx, boolean failFast, KeyCacheObject key)
void	prepareRemoteTx()
Collection<IgniteTxEntry>	readEntries()
Map<IgniteTxKey,IgniteTxEntry>	readMap()
Set<IgniteTxKey>	readSet()
IgniteInternalFuture<IgniteInternalTx>	rollbackAsync() Asynchronously rollback this transaction.
void	rollbackRemoteTx()
IgniteInternalFuture<?>	salvageTx()
void	seal() Seals transaction for updates.
void	setPartitionUpdateCounters(long[] cntrs)
String	toString()
IgniteTxState	txState()
Collection<IgniteTxEntry>	writeEntries()
Map<IgniteTxKey,IgniteTxEntry>	writeMap()
Set<IgniteTxKey>	writeSet()

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

addInvalidPartition, applyTransformClosures, applyTxSizes, batchStoreCommit, chainState, checkInternal, colocated, commitVersion, commitVersion, completedVersions, concurrency, conflictResolve, context, currentPrepareFuture, dht, done, equals, errorWhenCommitting, evictNearEntry, finalizationStatus, finishFuture, hashCode, heuristicException, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, isWriteToStoreFromDhtValid, local, localResult, log, logTxFinishErrorSafe, markFinalizing, mvccSnapshot, mvccSnapshot, near, nearXidVersion, needReturnValue, needReturnValue, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, recordStateChangedEvent, remainingTime, remote, repeatableRead, resolveTaskName, rollbackException, rollbackFuture, rollbackFuture, serializable, sessionEnd, setParentTx, setRollbackOnly, size, skipCompletedVersions, skipCompletedVersions, startTime, startTimeNanos, state, state, state, storeEnabled, storeEnabled, storeWriteThrough, subjectId, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, timeoutException, topologyVersion, topologyVersion, topologyVersionSnapshot, transactionNodes, transactionNodes, txCounters, uncommit, updateNearCache, user, 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, removeAllMeta, removeMeta, removeMeta, replaceMeta

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, colocated, commitVersion, commitVersion, completedVersions, concurrency, currentPrepareFuture, dht, done, errorWhenCommitting, finalizationStatus, finishFuture, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, localResult, markFinalizing, masterNodeIds, meta, mvccSnapshot, mvccSnapshot, near, nearXidVersion, needsCompletedVersions, nodeId, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, remainingTime, removeMeta, repeatableRead, serializable, setRollbackOnly, size, startTime, startTimeNanos, state, state, storeEnabled, storeWriteThrough, subjectId, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, topologyVersion, topologyVersion, topologyVersionSnapshot, transactionNodes, txCounters, user, writeVersion, writeVersion, xid, xidVersion

Field Detail

txState

@GridToStringInclude
protected IgniteTxRemoteState txState

Constructor Detail

GridDistributedTxRemoteAdapter

public GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx,
                                      UUID nodeId,
                                      GridCacheVersion xidVer,
                                      GridCacheVersion commitVer,
                                      boolean sys,
                                      byte plc,
                                      TransactionConcurrency concurrency,
                                      TransactionIsolation isolation,
                                      boolean invalidate,
                                      long timeout,
                                      int txSize,
                                      @Nullable
                                      @Nullable UUID subjId,
                                      int taskNameHash,
                                      String txLbl)

Parameters:

ctx - Cache registry.

nodeId - Node ID.

xidVer - XID version.

commitVer - Commit version.

sys - System flag.

plc - IO policy.

concurrency - Concurrency level (should be pessimistic).

isolation - Transaction isolation.

invalidate - Invalidate flag.

timeout - Timeout.

txSize - Expected transaction size.

subjId - Subject ID.

taskNameHash - Task name hash code.

txLbl - Transaction label.

Method Detail

txState

public IgniteTxState txState()

Specified by:

txState in interface IgniteInternalTx

Returns:

Transaction state.

eventNodeId

public UUID eventNodeId()

Specified by:

eventNodeId in interface IgniteInternalTx

Returns:

Event node ID.

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.

Specified by:

originatingNodeId in interface IgniteInternalTx

Returns:

Originating node ID.

activeCachesDeploymentEnabled

public boolean activeCachesDeploymentEnabled()

Specified by:

activeCachesDeploymentEnabled in interface IgniteInternalTx

Returns:

true or false if the deployment is enabled or disabled for all active caches involved in this transaction.

activeCachesDeploymentEnabled

public void activeCachesDeploymentEnabled(boolean depEnabled)

Specified by:

activeCachesDeploymentEnabled in interface IgniteInternalTx

Parameters:

depEnabled - Flag indicating whether deployment is enabled for caches from this transaction or not.

addActiveCache

public void addActiveCache(GridCacheContext cacheCtx,
                           boolean recovery)
                    throws IgniteCheckedException

Adds cache to the list of active caches in transaction.

Specified by:

addActiveCache in class IgniteTxAdapter

Parameters:

cacheCtx - Cache context to add.

recovery - Recovery flag. See CacheOperationContext.setRecovery(boolean).

Throws:

IgniteCheckedException - If caches already enlisted in this transaction are not compatible with given cache (e.g. they have different stores).

empty

public boolean empty()

Specified by:

empty in interface IgniteInternalTx

Returns:

Checks if transaction has no entries.

invalidate

public void invalidate(boolean invalidate)

Specified by:

invalidate in interface IgniteInternalTx

Overrides:

invalidate in class IgniteTxAdapter

Parameters:

invalidate - Invalidate flag.

writeMap

public Map<IgniteTxKey,IgniteTxEntry> writeMap()

Specified by:

writeMap in interface IgniteInternalTx

Returns:

Transaction write map.

readMap

public Map<IgniteTxKey,IgniteTxEntry> readMap()

Specified by:

readMap in interface IgniteInternalTx

Returns:

Transaction read map.

seal

public void seal()

Seals transaction for updates.

Specified by:

seal in interface IgniteInternalTx

peek

public GridTuple<CacheObject> peek(GridCacheContext cacheCtx,
                                   boolean failFast,
                                   KeyCacheObject key)
                            throws GridCacheFilterFailedException

Specified by:

peek in interface IgniteInternalTx

Parameters:

cacheCtx - Cache context.

failFast - Fail-fast flag.

key - Key to look up.

Returns:

Current value for the key within transaction.

Throws:

GridCacheFilterFailedException - If filter failed and failFast is true.

entry

public IgniteTxEntry entry(IgniteTxKey key)

Specified by:

entry in interface IgniteInternalTx

Parameters:

key - Key for the entry.

Returns:

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

clearEntry

public void clearEntry(IgniteTxKey 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)
                throws GridDhtInvalidPartitionException

Specified by:

doneRemote in interface IgniteTxRemoteEx

Parameters:

baseVer - Base version.

committedVers - Committed versions.

rolledbackVers - Rolled back versions.

pendingVers - Pending versions.

Throws:

GridDhtInvalidPartitionException - If partition was invalidated.

setPartitionUpdateCounters

public void setPartitionUpdateCounters(long[] cntrs)

Specified by:

setPartitionUpdateCounters in interface IgniteTxRemoteEx

Parameters:

cntrs - Partition update indexes.

onOwnerChanged

public boolean onOwnerChanged(GridCacheEntryEx entry,
                              GridCacheMvccCandidate 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

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

Returns:

True if transaction has at least one key enlisted.

hasWriteKey

public boolean hasWriteKey(IgniteTxKey key)

Specified by:

hasWriteKey in interface IgniteInternalTx

Parameters:

key - Key to check.

Returns:

True if key is present.

readSet

public Set<IgniteTxKey> readSet()

Specified by:

readSet in interface IgniteInternalTx

Returns:

Read set.

writeSet

public Set<IgniteTxKey> writeSet()

Specified by:

writeSet in interface IgniteInternalTx

Returns:

Write set.

allEntries

public Collection<IgniteTxEntry> allEntries()

Specified by:

allEntries in interface IgniteInternalTx

Returns:

All transaction entries.

writeEntries

public Collection<IgniteTxEntry> writeEntries()

Specified by:

writeEntries in interface IgniteInternalTx

Returns:

Write entries.

readEntries

public Collection<IgniteTxEntry> readEntries()

Specified by:

readEntries in interface IgniteInternalTx

Returns:

Read entries.

prepareRemoteTx

public final void prepareRemoteTx()
                           throws IgniteCheckedException

Throws:

IgniteCheckedException - If failed.

commitRemoteTx

public final void commitRemoteTx()
                          throws IgniteCheckedException

Specified by:

commitRemoteTx in interface IgniteTxRemoteEx

Throws:

IgniteCheckedException - If 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

Returns:

Future for commit operation.

salvageTx

public final IgniteInternalFuture<?> salvageTx()

Specified by:

salvageTx in interface IgniteInternalTx

Returns:

Future.

rollbackRemoteTx

public final void rollbackRemoteTx()

Specified by:

rollbackRemoteTx in interface IgniteTxRemoteEx

rollbackAsync

public IgniteInternalFuture<IgniteInternalTx> rollbackAsync()

Asynchronously rollback this transaction.

Specified by:

rollbackAsync in interface IgniteInternalTx

Returns:

Rollback future.

alternateVersions

public Collection<GridCacheVersion> alternateVersions()

Specified by:

alternateVersions in interface IgniteInternalTx

Returns:

Alternate transaction versions.

commitError

public void commitError(Throwable e)

Specified by:

commitError in interface IgniteInternalTx

Parameters:

e - Commit error.

addExplicit

protected void addExplicit(IgniteTxEntry e)

Adds explicit version if there is one.

Parameters:

e - Transaction entry.

label

public String label()

Returns label of transactions.

Specified by:

label in interface IgniteInternalTx

Returns:

Label of transaction or null if there was not set.

toString

public String toString()

Overrides:

toString in class IgniteTxAdapter