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

Class GridNearTxLocal<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.transactions.IgniteTxLocalAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter<K,V>

org.apache.ignite.internal.processors.cache.distributed.near.GridNearTxLocal<K,V>

All Implemented Interfaces:

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

public class GridNearTxLocal<K,V>
extends GridDhtTxLocalAdapter<K,V>

Replicated user transaction.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.transactions.IgniteTxLocalAdapter

IgniteTxLocalAdapter.FinishClosure<T>, IgniteTxLocalAdapter.PLC1<T>, IgniteTxLocalAdapter.PLC2<T>, IgniteTxLocalAdapter.PMC<T>, IgniteTxLocalAdapter.PostLockClosure1<T>, IgniteTxLocalAdapter.PostLockClosure2<T>, IgniteTxLocalAdapter.PostMissClosure<T>

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.dht.GridDhtTxLocalAdapter

dhtMap, nearMap

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

activeCacheIds, commitErr, doneFlag, implicitRes, minVer, needRetVal, readView, txMap, writeView

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
GridNearTxLocal() Empty constructor required for Externalizable.
GridNearTxLocal(GridCacheSharedContext<K,V> ctx, boolean implicit, boolean implicitSingle, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, boolean invalidate, boolean storeEnabled, int txSize, IgniteTxKey grpLockKey, boolean partLock, UUID subjId, int taskNameHash)

Method Summary

Methods

Modifier and Type	Method and Description
protected IgniteCacheExpiryPolicy	accessPolicy(GridCacheContext ctx, IgniteTxKey<K> key, javax.cache.expiry.ExpiryPolicy expiryPlc)
protected void	addGroupTxMapping(Collection<IgniteTxKey<K>> keys) Adds key mapping to transaction.
void	addKeyMapping(IgniteTxKey<K> key, ClusterNode node) Adds key mapping to dht mapping.
protected IgniteInternalFuture<Boolean>	addReader(long msgId, GridDhtCacheEntry<K,V> cached, IgniteTxEntry<K,V> entry, long topVer) Adds reader to cached entry.
protected void	clearPrepareFuture(GridDhtTxPrepareFuture<K,V> fut) Removes previously created prepare future from atomic reference.
void	close() Ends the transaction.
boolean	colocated()
boolean	colocatedLocallyMapped()
void	colocatedLocallyMapped(boolean colocatedLocallyMapped)
IgniteInternalFuture<IgniteInternalTx>	commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	commitAsyncLocal() Commits local part of colocated transaction.
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.
protected GridCacheEntryEx<K,V>	entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key) Gets cache entry for given key.
protected GridCacheEntryEx<K,V>	entryEx(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, long topVer) Gets cache entry for given key and topology version.
boolean	finish(boolean commit) Finishes transaction (either commit or rollback).
IgniteInternalFuture<Boolean>	loadMissing(GridCacheContext<K,V> cacheCtx, boolean readThrough, boolean async, Collection<? extends K> keys, boolean deserializePortable, boolean skipVals, IgniteBiInClosure<K,V> c)
IgniteInternalFuture<GridCacheReturn<V>>	lockAllAsync(GridCacheContext<K,V> cacheCtx, Collection<? extends K> keys, boolean implicit, boolean read, long accessTtl)
boolean	markExplicit(UUID nodeId)
boolean	near()
protected IgniteUuid	nearFutureId()
boolean	nearLocallyMapped()
void	nearLocallyMapped(boolean nearLocallyMapped)
protected IgniteUuid	nearMiniId()
protected UUID	nearNodeId()
GridCacheVersion	nearXidVersion()
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.
Collection<IgniteTxEntry<K,V>>	optimisticLockEntries() Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.
void	optimisticLockEntries(Collection<IgniteTxEntry<K,V>> optimisticLockEntries)
boolean	ownsLock(GridCacheEntryEx<K,V> entry)
boolean	ownsLockUnsafe(GridCacheEntryEx<K,V> entry)
IgniteInternalFuture<IgniteInternalTx<K,V>>	prepareAsync() Prepare stage.
IgniteInternalFuture<IgniteInternalTx<K,V>>	prepareAsyncLocal(Collection<IgniteTxEntry<K,V>> reads, Collection<IgniteTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb) Prepares next batch of entries in dht transaction.
boolean	removeMapping(UUID nodeId)
IgniteInternalFuture<IgniteInternalTx>	rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	rollbackAsyncLocal() Rolls back local part of colocated transaction.
protected void	sendFinishReply(boolean commit, Throwable err)
boolean	syncCommit()
boolean	syncRollback()
GridDiscoveryTopologySnapshot	topologySnapshot()
boolean	topologySnapshot(GridDiscoveryTopologySnapshot topSnapshot) Sets topology snapshot on which this tx was started.
String	toString()
protected void	updateExplicitVersion(IgniteTxEntry<K,V> txEntry, GridCacheEntryEx<K,V> entry) Updates explicit version for tx entry based on current entry lock owner.

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtTxLocalAdapter

addDhtMapping, addEntry, addInvalidPartition, addNearMapping, mapExplicitLocks, needsCompletedVersions, needsCompletedVersions, pendingVersions, pendingVersions, rollback

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

activeCacheIds, addActiveCache, addEntry, allEntries, alternateVersions, batchStoreCommit, checkValid, commit, commitAfterLock, commitError, commitError, committedVersions, completedBase, completedVersions, empty, enlistWrite, entry, entryExpireTime, entryTtl, entryTtl, eventNodeId, getAllAsync, groupLockAsync, hasWriteKey, implicitSingleResult, implicitSingleResult, init, invokeAsync, isStarted, masterNodeIds, minVersion, needReturnValue, needReturnValue, originatingNodeId, partitionLock, peek, postLockWrite, prepare, putAllAsync, putAllDrAsync, readEntries, readMap, readSet, removeAllAsync, removeAllDrAsync, removed, rolledbackVersions, seal, sendTransformedValues, tmCommit, userCommit, userPrepare, userRollback, writeEntries, writeMap, writeSet

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

applyTransformClosures, awaitCompletion, awaitSignal, checkInternal, commitVersion, commitVersion, concurrency, conflictResolve, dht, done, endTime, endVersion, endVersion, equals, evictNearEntry, finalizationStatus, finishFuture, groupLock, groupLockEntry, groupLockKey, hashCode, hasTransforms, implicit, implicitSingle, initCommitVersion, internal, invalidate, invalidPartitions, ioPolicy, isInvalidate, isNearLocallyMapped, isolation, isRollbackOnly, isSystemInvalidate, local, lock, lockTimeout, log, markFinalizing, markPreparing, nodeId, onePhaseCommit, onePhaseCommit, onTimeout, optimistic, otherNodeId, ownedVersion, pessimistic, proxy, readCommitted, readExternal, readResolve, remainingTime, repeatableRead, replicated, resolveTaskName, serializable, setRollbackOnly, signalAll, size, startTime, startVersion, state, state, store, storeEnabled, storeEnabled, storeUsed, subjectId, syncCommit, 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.IgniteTxLocalEx

groupLockEntry

Methods inherited from interface org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

addMeta, commitVersion, commitVersion, concurrency, dht, done, endVersion, endVersion, finishFuture, groupLock, groupLockKey, hasTransforms, implicit, implicitSingle, internal, invalidate, invalidPartitions, ioPolicy, isInvalidate, isolation, isRollbackOnly, isSystemInvalidate, local, markFinalizing, markPreparing, meta, nodeId, onePhaseCommit, optimistic, otherNodeId, ownedVersion, pessimistic, proxy, readCommitted, remainingTime, removeMeta, repeatableRead, replicated, serializable, setRollbackOnly, size, startTime, startVersion, state, state, storeEnabled, storeUsed, subjectId, 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

GridNearTxLocal

public GridNearTxLocal()

Empty constructor required for Externalizable.

GridNearTxLocal

public GridNearTxLocal(GridCacheSharedContext<K,V> ctx,
               boolean implicit,
               boolean implicitSingle,
               boolean sys,
               TransactionConcurrency concurrency,
               TransactionIsolation isolation,
               long timeout,
               boolean invalidate,
               boolean storeEnabled,
               int txSize,
               @Nullable
               IgniteTxKey grpLockKey,
               boolean partLock,
               @Nullable
               UUID subjId,
               int taskNameHash)

Parameters:

ctx - Cache registry.

implicit - Implicit flag.

implicitSingle - Implicit with one key flag.

sys - System flag.

concurrency - Concurrency.

isolation - Isolation.

timeout - Timeout.

invalidate - Invalidate flag.

storeEnabled - Store enabled flag.

txSize - Transaction size.

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

partLock - True if this is a group-lock transaction and the whole partition should be locked.

subjId - Subject ID.

taskNameHash - Task name hash code.

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.

colocated

public boolean colocated()

Specified by:

colocated in interface IgniteInternalTx<K,V>

Overrides:

colocated in class IgniteTxAdapter<K,V>

Returns:

True if dht colocated transaction.

nearXidVersion

@Nullable
public GridCacheVersion nearXidVersion()

Specified by:

nearXidVersion in interface IgniteInternalTx<K,V>

Overrides:

nearXidVersion in class IgniteTxAdapter<K,V>

Returns:

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

nearNodeId

protected UUID nearNodeId()

Specified by:

nearNodeId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near node id.

nearFutureId

protected IgniteUuid nearFutureId()

Specified by:

nearFutureId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near future ID.

nearMiniId

protected IgniteUuid nearMiniId()

Specified by:

nearMiniId in class GridDhtTxLocalAdapter<K,V>

Returns:

Near future mini ID.

addReader

protected IgniteInternalFuture<Boolean> addReader(long msgId,
                                      GridDhtCacheEntry<K,V> cached,
                                      IgniteTxEntry<K,V> entry,
                                      long topVer)

Adds reader to cached entry.

Specified by:

addReader in class GridDhtTxLocalAdapter<K,V>

Parameters:

msgId - Message ID.

cached - Cached entry.

entry - Transaction entry.

topVer - Topology version.

Returns:

True if reader was added as a result of this call.

sendFinishReply

protected void sendFinishReply(boolean commit,
                   @Nullable
                   Throwable err)

Specified by:

sendFinishReply in class GridDhtTxLocalAdapter<K,V>

Parameters:

commit - Commit flag.

err - Error, if any.

clearPrepareFuture

protected void clearPrepareFuture(GridDhtTxPrepareFuture<K,V> fut)

Removes previously created prepare future from atomic reference.

Specified by:

clearPrepareFuture in class GridDhtTxLocalAdapter<K,V>

Parameters:

fut - Expected future.

syncCommit

public boolean syncCommit()

Specified by:

syncCommit in interface IgniteInternalTx<K,V>

Overrides:

syncCommit in class IgniteTxAdapter<K,V>

Returns:

True if transaction is configured with synchronous commit flag.

syncRollback

public boolean syncRollback()

Specified by:

syncRollback in interface IgniteInternalTx<K,V>

Overrides:

syncRollback in class IgniteTxAdapter<K,V>

Returns:

True if transaction is configured with synchronous rollback flag.

nearLocallyMapped

public boolean nearLocallyMapped()

Returns:

True if transaction contains at least one near cache key mapped to the local node.

nearLocallyMapped

public void nearLocallyMapped(boolean nearLocallyMapped)

Parameters:

nearLocallyMapped - True if transaction contains near key mapped to the local node.

colocatedLocallyMapped

public boolean colocatedLocallyMapped()

Returns:

True if transaction contains colocated key mapped to the local node.

colocatedLocallyMapped

public void colocatedLocallyMapped(boolean colocatedLocallyMapped)

Parameters:

colocatedLocallyMapped - True if transaction contains colocated key mapped to the local node.

ownsLockUnsafe

public boolean ownsLockUnsafe(GridCacheEntryEx<K,V> entry)

Specified by:

ownsLockUnsafe in interface IgniteInternalTx<K,V>

Overrides:

ownsLockUnsafe in class IgniteTxAdapter<K,V>

Parameters:

entry - Entry to check.

Returns:

True if lock is owned.

ownsLock

public boolean ownsLock(GridCacheEntryEx<K,V> entry)
                 throws GridCacheEntryRemovedException

Specified by:

ownsLock in interface IgniteInternalTx<K,V>

Overrides:

ownsLock in class IgniteTxAdapter<K,V>

Parameters:

entry - Entry to check.

Returns:

True if lock is owned.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

optimisticLockEntries

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

Gets a list of entries that needs to be locked on the next step of prepare stage of optimistic transaction.

Specified by:

optimisticLockEntries in interface IgniteInternalTx<K,V>

Overrides:

optimisticLockEntries in class IgniteTxAdapter<K,V>

Returns:

List of tx entries for optimistic locking.

optimisticLockEntries

public void optimisticLockEntries(Collection<IgniteTxEntry<K,V>> optimisticLockEntries)

Parameters:

optimisticLockEntries - Optimistic lock entries.

loadMissing

public IgniteInternalFuture<Boolean> loadMissing(GridCacheContext<K,V> cacheCtx,
                                        boolean readThrough,
                                        boolean async,
                                        Collection<? extends K> keys,
                                        boolean deserializePortable,
                                        boolean skipVals,
                                        IgniteBiInClosure<K,V> c)

Specified by:

loadMissing in interface IgniteTxLocalEx<K,V>

Overrides:

loadMissing in class IgniteTxLocalAdapter<K,V>

Parameters:

cacheCtx - Cache context.

readThrough - Read through flag.

async - if True, then loading will happen in a separate thread.

keys - Keys.

deserializePortable - Deserialize portable flag.

skipVals - Skip values flag.

c - Closure.

Returns:

Future with True value if loading took place.

updateExplicitVersion

protected void updateExplicitVersion(IgniteTxEntry<K,V> txEntry,
                         GridCacheEntryEx<K,V> entry)
                              throws GridCacheEntryRemovedException

Updates explicit version for tx entry based on current entry lock owner.

Overrides:

updateExplicitVersion in class IgniteTxLocalAdapter<K,V>

Parameters:

txEntry - Tx entry to update.

entry - Entry.

Throws:

GridCacheEntryRemovedException - If entry was concurrently removed.

removeMapping

public boolean removeMapping(UUID nodeId)

Overrides:

removeMapping in class GridDhtTxLocalAdapter<K,V>

Parameters:

nodeId - Undo mapping.

Returns:

True if mapping was removed.

addGroupTxMapping

protected void addGroupTxMapping(Collection<IgniteTxKey<K>> keys)

Adds key mapping to transaction.

Overrides:

addGroupTxMapping in class GridDhtTxLocalAdapter<K,V>

Parameters:

keys - Keys to add.

addKeyMapping

public void addKeyMapping(IgniteTxKey<K> key,
                 ClusterNode node)

Adds key mapping to dht mapping.

Parameters:

key - Key to add.

node - Node this key mapped to.

markExplicit

public boolean markExplicit(UUID nodeId)

Parameters:

nodeId - Node ID to mark with explicit lock.

Returns:

True if mapping was found.

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>

Overrides:

onOwnerChanged in class IgniteTxLocalAdapter<K,V>

Parameters:

entry - Cache entry.

owner - Lock candidate that won ownership of the lock.

Returns:

True if transaction cared about notification.

topologySnapshot

public GridDiscoveryTopologySnapshot topologySnapshot()

Returns:

Topology snapshot on which this tx was started.

topologySnapshot

public boolean topologySnapshot(GridDiscoveryTopologySnapshot topSnapshot)

Sets topology snapshot on which this tx was started.

Parameters:

topSnapshot - Topology snapshot.

Returns:

True if topology snapshot was set by this call.

finish

public boolean finish(boolean commit)
               throws IgniteCheckedException

Finishes transaction (either commit or rollback).

Specified by:

finish in interface IgniteTxLocalEx<K,V>

Overrides:

finish in class GridDhtTxLocalAdapter<K,V>

Parameters:

commit - True if commit, false if rollback.

Returns:

True if state has been changed.

Throws:

IgniteCheckedException - If finish failed.

prepareAsync

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

Prepare stage.

Returns:

Future for prepare step.

commitAsync

public IgniteInternalFuture<IgniteInternalTx> commitAsync()

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

Returns:

Future for commit operation.

rollbackAsync

public IgniteInternalFuture<IgniteInternalTx> rollbackAsync()

Asynchronously rollback this transaction.

Returns:

Rollback future.

prepareAsyncLocal

public IgniteInternalFuture<IgniteInternalTx<K,V>> prepareAsyncLocal(@Nullable
                                                            Collection<IgniteTxEntry<K,V>> reads,
                                                            @Nullable
                                                            Collection<IgniteTxEntry<K,V>> writes,
                                                            Map<UUID,Collection<UUID>> txNodes,
                                                            boolean last,
                                                            Collection<UUID> lastBackups,
                                                            IgniteInClosure<GridNearTxPrepareResponse<K,V>> completeCb)

Prepares next batch of entries in dht transaction.

Parameters:

reads - Read entries.

writes - Write entries.

txNodes - Transaction nodes mapping.

last - True if this is last prepare request.

lastBackups - IDs of backup nodes receiving last prepare request.

Returns:

Future that will be completed when locks are acquired.

commitAsyncLocal

public IgniteInternalFuture<IgniteInternalTx> commitAsyncLocal()

Commits local part of colocated transaction.

Returns:

Commit future.

rollbackAsyncLocal

public IgniteInternalFuture<IgniteInternalTx> rollbackAsyncLocal()

Rolls back local part of colocated transaction.

Returns:

Commit future.

lockAllAsync

public IgniteInternalFuture<GridCacheReturn<V>> lockAllAsync(GridCacheContext<K,V> cacheCtx,
                                                    Collection<? extends K> keys,
                                                    boolean implicit,
                                                    boolean read,
                                                    long accessTtl)

entryEx

protected GridCacheEntryEx<K,V> entryEx(GridCacheContext<K,V> cacheCtx,
                            IgniteTxKey<K> key)

Gets cache entry for given key.

Overrides:

entryEx in class IgniteTxLocalAdapter<K,V>

Parameters:

cacheCtx - Cache context.

key - Key.

Returns:

Cache entry.

entryEx

protected GridCacheEntryEx<K,V> entryEx(GridCacheContext<K,V> cacheCtx,
                            IgniteTxKey<K> key,
                            long topVer)

Gets cache entry for given key and topology version.

Overrides:

entryEx in class IgniteTxLocalAdapter<K,V>

Parameters:

cacheCtx - Cache context.

key - Key.

topVer - Topology version.

Returns:

Cache entry.

accessPolicy

protected IgniteCacheExpiryPolicy accessPolicy(GridCacheContext ctx,
                                   IgniteTxKey<K> key,
                                   @Nullable
                                   javax.cache.expiry.ExpiryPolicy expiryPlc)

Overrides:

accessPolicy in class IgniteTxLocalAdapter<K,V>

Parameters:

ctx - Cache context.

key - Key.

expiryPlc - Expiry policy.

Returns:

Expiry policy wrapper for entries accessed locally in optimistic transaction.

close

public void close()
           throws IgniteCheckedException

Ends the transaction. Transaction will be rolled back if it has not been committed.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface IgniteInternalTx<K,V>

Overrides:

close in class IgniteTxAdapter<K,V>

Throws:

IgniteCheckedException - If transaction could not be gracefully ended.

toString

public String toString()

Overrides:

toString in class GridDhtTxLocalAdapter<K,V>