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:

Externalizable, Serializable, IgniteInternalTx, IgniteTxRemoteEx

Direct Known Subclasses:

GridDhtTxRemote, GridNearTxRemote

public abstract class GridDistributedTxRemoteAdapter
extends IgniteTxAdapter
implements IgniteTxRemoteEx

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

Modifier and Type	Field and Description
protected IgniteTxRemoteState	txState

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

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

Constructor Summary

Constructors

Constructor and Description
GridDistributedTxRemoteAdapter() Empty constructor required for Externalizable.
GridDistributedTxRemoteAdapter(GridCacheSharedContext<?,?> ctx, UUID nodeId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, byte plc, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, int txSize, UUID subjId, int taskNameHash)

Method Summary

Modifier and Type	Method and Description
boolean	activeCachesDeploymentEnabled()
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()
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)
boolean	skipCompletedVersions()
void	skipCompletedVersions(boolean skipCompletedVers)
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, batchStoreCommit, checkInternal, colocated, commitVersion, commitVersion, completedVersions, concurrency, conflictResolve, context, currentPrepareFuture, dht, done, endVersion, equals, errorWhenCommitting, evictNearEntry, finalizationStatus, finishFuture, hashCode, implicit, implicitSingle, internal, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, isWriteToStoreFromDhtValid, local, localResult, log, markFinalizing, near, nearXidVersion, needReturnValue, needReturnValue, needsCompletedVersions, nodeId, onePhaseCommit, onePhaseCommit, optimistic, optimisticLockEntries, otherNodeId, ownedVersion, ownsLock, ownsLockUnsafe, pessimistic, readCommitted, readExternal, readResolve, remainingTime, remote, repeatableRead, resolveTaskName, rollbackException, serializable, sessionEnd, setRollbackOnly, size, startTime, state, state, state, storeEnabled, storeEnabled, storeWriteThrough, subjectId, system, systemInvalidate, taskNameHash, threadId, timedOut, timeout, timeout, timeoutException, topologyVersion, topologyVersion, topologyVersionSnapshot, transactionNodes, transactionNodes, uncommit, 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, 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

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

Field Detail

txState

@GridToStringInclude
protected IgniteTxRemoteState txState

Constructor Detail

GridDistributedTxRemoteAdapter

public GridDistributedTxRemoteAdapter()

Empty constructor required for Externalizable.

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
                                      UUID subjId,
                                      int taskNameHash)

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.

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.

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)

Specified by:

doneRemote in interface IgniteTxRemoteEx

Parameters:

baseVer - Base version.

committedVers - Committed versions.

rolledbackVers - Rolled back versions.

pendingVers - Pending versions.

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.

skipCompletedVersions

public boolean skipCompletedVersions()

Returns:

True if tx should skip adding itself to completed version map on finish.

skipCompletedVersions

public void skipCompletedVersions(boolean skipCompletedVers)

Parameters:

skipCompletedVers - True if tx should skip adding itself to completed version map on finish.

addExplicit

protected void addExplicit(IgniteTxEntry e)

Adds explicit version if there is one.

Parameters:

e - Transaction entry.

toString

public String toString()

Overrides:

toString in class IgniteTxAdapter