Uses of Interface
org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx

Packages that use IgniteInternalTx

Package	Description
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.local
org.apache.ignite.internal.processors.cache.store
org.apache.ignite.internal.processors.cache.transactions

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache

Methods in org.apache.ignite.internal.processors.cache that return types with arguments of type IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridCacheSharedContext.commitTxAsync(GridNearTxLocal tx)
static <K,V> IgniteClosure<IgniteInternalTx,GridCacheVersion>	GridCacheUtils.tx2xidVersion()

Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
void	GridCacheEventManager.addEvent(int part, KeyCacheObject key, IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName, boolean keepBinary)
void	GridCacheEventManager.addEvent(int part, KeyCacheObject key, UUID nodeId, IgniteInternalTx tx, GridCacheMvccCandidate owner, int type, CacheObject newVal, boolean hasNewVal, CacheObject oldVal, boolean hasOldVal, UUID subjId, String cloClsName, String taskName, boolean keepBinary)
void	GridCacheMultiTxFuture.addTx(IgniteInternalTx tx)
CacheObject	GridCacheEntryEx.innerGet(GridCacheVersion ver, IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary)
CacheObject	GridCacheMapEntry.innerGet(GridCacheVersion ver, IgniteInternalTx tx, boolean readThrough, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expirePlc, boolean keepBinary)
EntryGetResult	GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, ReaderArguments readerArgs)
EntryGetResult	GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver, IgniteInternalTx tx, boolean updateMetrics, boolean evt, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expiryPlc, boolean keepBinary, ReaderArguments readerArgs)
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean retval, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean keepBinary, boolean oldValPresent, CacheObject oldVal, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName, GridCacheVersion dhtVer, Long updateCntr)
AffinityTopologyVersion	GridCacheSharedContext.lockedTopologyVersion(IgniteInternalTx ignore)
protected Object	GridCacheMapEntry.readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName)
static <K,V> UUID	GridCacheUtils.subjectId(IgniteInternalTx tx, GridCacheSharedContext<K,V> ctx) Gets subject ID by transaction.
boolean	GridCacheEntryEx.tmLock(IgniteInternalTx tx, long timeout, GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.
static String	GridCacheUtils.txString(IgniteInternalTx tx)
void	GridCacheEntryEx.txUnlock(IgniteInternalTx tx) Unlocks acquired lock.
String	GridCacheSharedContext.verifyTxCompatibility(IgniteInternalTx tx, GridIntList activeCacheIds, GridCacheContext<K,V> cacheCtx)

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.distributed

Classes in org.apache.ignite.internal.processors.cache.distributed that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridDistributedTxRemoteAdapter Transaction created by system implicitly on remote nodes.

Methods in org.apache.ignite.internal.processors.cache.distributed that return IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalTx	GridCacheTxRecoveryFuture.tx()

Methods in org.apache.ignite.internal.processors.cache.distributed that return types with arguments of type IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridDistributedTxRemoteAdapter.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridDistributedTxRemoteAdapter.rollbackAsync() Asynchronously rollback this transaction.

Methods in org.apache.ignite.internal.processors.cache.distributed with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
boolean	GridDistributedCacheEntry.tmLock(IgniteInternalTx tx, long timeout, GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.
void	GridDistributedCacheEntry.txUnlock(IgniteInternalTx tx) Unlocks acquired lock.

Constructors in org.apache.ignite.internal.processors.cache.distributed with parameters of type IgniteInternalTx

Constructor and Description
GridCacheTxRecoveryFuture(GridCacheSharedContext<?,?> cctx, IgniteInternalTx tx, Set<UUID> failedNodeIds, Map<UUID,Collection<UUID>> txNodes)
GridCacheTxRecoveryRequest(IgniteInternalTx tx, int txNum, boolean nearTxCheck, IgniteUuid futId, IgniteUuid miniId, boolean addDepInfo)
GridDistributedTxPrepareRequest(IgniteInternalTx tx, long timeout, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, Map<UUID,Collection<UUID>> txNodes, boolean retVal, boolean last, boolean onePhaseCommit, boolean addDepInfo)

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.distributed.dht

Classes in org.apache.ignite.internal.processors.cache.distributed.dht that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridDhtTxLocal Replicated user transaction.
class	GridDhtTxLocalAdapter Replicated user transaction.
class	GridDhtTxRemote Transaction created by system implicitly on remote nodes.

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that return types with arguments of type IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.commitDhtLocalAsync()
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.rollbackDhtLocalAsync()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
boolean	GridDhtTxFinishFuture.onDone(IgniteInternalTx tx, Throwable err) Callback to notify that future is finished.
boolean	GridDhtCacheEntry.tmLock(IgniteInternalTx tx, long timeout, GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.distributed.near

Classes in org.apache.ignite.internal.processors.cache.distributed.near that implement IgniteInternalTx

Modifier and Type	Class and Description
class	GridNearTxLocal Replicated user transaction.
class	GridNearTxRemote Transaction created by system implicitly on remote nodes.

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalTx	GridNearTxPrepareFutureAdapter.tx()

Methods in org.apache.ignite.internal.processors.cache.distributed.near that return types with arguments of type IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitAsyncLocal() Commits local part of colocated transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.commitNearTxLocalAsync()
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackAsyncLocal() Rolls back local part of colocated transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackNearTxLocalAsync()

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalFuture<Map<K,V>>	GridNearCacheAdapter.loadAsync(IgniteInternalTx tx, Collection<KeyCacheObject> keys, boolean forcePrimary, UUID subjId, String taskName, boolean deserializeBinary, boolean recovery, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean skipVal, boolean skipStore, boolean canRemap, boolean needVer)
boolean	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, long ttl, long expireTime, boolean evt, boolean keepBinary, AffinityTopologyVersion topVer, UUID subjId)
boolean	GridNearOptimisticTxPrepareFuture.onDone(IgniteInternalTx t, Throwable err) Callback to notify that future is finished.
boolean	GridNearPessimisticTxPrepareFuture.onDone(IgniteInternalTx res, Throwable err) Callback to notify that future is finished.
boolean	GridNearTxFinishFuture.onDone(IgniteInternalTx tx0, Throwable err) Callback to notify that future is finished.
boolean	GridNearOptimisticSerializableTxPrepareFuture.onDone(IgniteInternalTx t, Throwable err) Callback to notify that future is finished.
protected Object	GridNearCacheEntry.readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName)

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.local

Methods in org.apache.ignite.internal.processors.cache.local with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
boolean	GridLocalCacheEntry.tmLock(IgniteInternalTx tx, long timeout, GridCacheVersion serOrder, GridCacheVersion serReadVer, boolean read) This locks is called by transaction manager during prepare step for optimistic transactions.
void	GridLocalCacheEntry.txUnlock(IgniteInternalTx tx) Unlocks lock if it is currently owned.

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.store

Methods in org.apache.ignite.internal.processors.cache.store with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
Object	CacheStoreManager.load(IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
Object	GridCacheStoreManagerAdapter.load(IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
boolean	CacheStoreManager.loadAll(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis) Loads data from persistent store.
boolean	GridCacheStoreManagerAdapter.loadAll(IgniteInternalTx tx, Collection keys, IgniteBiInClosure vis) Loads data from persistent store.
void	CacheStoreManager.localStoreLoadAll(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)
void	GridCacheStoreManagerAdapter.localStoreLoadAll(IgniteInternalTx tx, Collection keys, GridInClosure3 vis)
boolean	CacheStoreManager.put(IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.put(IgniteInternalTx tx, KeyCacheObject key, CacheObject val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	CacheStoreManager.putAll(IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.putAll(IgniteInternalTx tx, Map<? extends KeyCacheObject,IgniteBiTuple<? extends CacheObject,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	CacheStoreManager.remove(IgniteInternalTx tx, KeyCacheObject key)
boolean	GridCacheStoreManagerAdapter.remove(IgniteInternalTx tx, KeyCacheObject key)
boolean	CacheStoreManager.removeAll(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)
boolean	GridCacheStoreManagerAdapter.removeAll(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys)
void	CacheStoreManager.sessionEnd(IgniteInternalTx tx, boolean commit, boolean last)
void	GridCacheStoreManagerAdapter.sessionEnd(IgniteInternalTx tx, boolean commit, boolean last)

Uses of IgniteInternalTx in org.apache.ignite.internal.processors.cache.transactions

Subinterfaces of IgniteInternalTx in org.apache.ignite.internal.processors.cache.transactions

Modifier and Type	Interface and Description
interface	IgniteTxLocalEx Local transaction API.
interface	IgniteTxRemoteEx Local transaction API.

Classes in org.apache.ignite.internal.processors.cache.transactions that implement IgniteInternalTx

Modifier and Type	Class and Description
class	IgniteTxAdapter Managed transaction adapter.
class	IgniteTxLocalAdapter Transaction adapter for cache transactions.

Methods in org.apache.ignite.internal.processors.cache.transactions with type parameters of type IgniteInternalTx

Modifier and Type	Method and Description
<T extends IgniteInternalTx> T	IgniteTxManager.nearTx(GridCacheVersion txId)
<T extends IgniteInternalTx> T	IgniteTxManager.onCreated(GridCacheContext cacheCtx, T tx)
<T extends IgniteInternalTx> T	IgniteTxManager.tx(GridCacheVersion txId)

Methods in org.apache.ignite.internal.processors.cache.transactions that return IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalTx	IgniteTxManager.localTxx()

Methods in org.apache.ignite.internal.processors.cache.transactions that return types with arguments of type IgniteInternalTx

Modifier and Type	Method and Description
Collection<IgniteInternalTx>	IgniteTxManager.activeTransactions()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.commitAsync() Asynchronously commits this transaction by initiating two-phase-commit process.
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.finish(UUID nodeId, GridNearTxLocal locTx, GridNearTxFinishRequest req)
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.finishColocatedLocal(boolean commit, GridNearTxLocal tx)
IgniteInternalFuture<IgniteInternalTx>	IgniteTxAdapter.finishFuture()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.finishFuture()
IgniteInternalFuture<IgniteInternalTx>	IgniteInternalTx.rollbackAsync() Asynchronously rollback this transaction.
Collection<IgniteInternalTx>	IgniteTxManager.txs()

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteInternalTx

Modifier and Type	Method and Description
void	IgniteTxManager.addAlternateVersion(GridCacheVersion ver, IgniteInternalTx tx)
void	IgniteTxManager.addCommittedTx(IgniteInternalTx tx)
boolean	IgniteTxManager.addCommittedTx(IgniteInternalTx tx, GridCacheVersion xidVer, GridCacheVersion nearXidVer)
void	IgniteTxManager.addCommittedTxReturn(IgniteInternalTx tx, GridCacheReturnCompletableWrapper ret)
boolean	IgniteTxManager.addRolledbackTx(IgniteInternalTx tx)
boolean	IgniteTxManager.addRolledbackTx(IgniteInternalTx tx, GridCacheVersion xidVer)
void	IgniteTxManager.commitIfPrepared(IgniteInternalTx tx, Set<UUID> failedNodeIds) Commits transaction in case when node started transaction failed, but all related transactions were prepared (invalidates transaction if it is not fully prepared).
void	IgniteTxManager.commitTx(IgniteInternalTx tx) Commits a transaction.
IgniteInternalFuture<TxDeadlock>	IgniteTxManager.detectDeadlock(IgniteInternalTx tx, Set<IgniteTxKey> keys) Performs deadlock detection for given keys.
void	IgniteTxManager.finishTxOnRecovery(IgniteInternalTx tx, boolean commit) Commits or rolls back prepared transaction.
AffinityTopologyVersion	IgniteTxManager.lockedTopologyVersion(long threadId, IgniteInternalTx ignore)
boolean	IgniteTxManager.needWaitTransaction(IgniteInternalTx tx, AffinityTopologyVersion topVer)
boolean	IgniteTxManager.onStarted(IgniteInternalTx tx) Transaction start callback (has to do with when any operation was performed on this transaction).
protected void	IgniteTxLocalStateAdapter.onTxEnd(GridCacheContext cacheCtx, IgniteInternalTx tx, boolean commit)
void	IgniteTxImplicitSingleStateImpl.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxStateImpl.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxRemoteStateAdapter.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxState.onTxEnd(GridCacheSharedContext cctx, IgniteInternalTx tx, boolean commit)
void	IgniteTxManager.prepareTx(IgniteInternalTx tx, Collection<IgniteTxEntry> entries) Handles prepare stage.
void	IgniteTxManager.removeCommittedTx(IgniteInternalTx tx)
void	IgniteTxManager.rollbackTx(IgniteInternalTx tx) Rolls back a transaction.
void	IgniteTxManager.salvageTx(IgniteInternalTx tx) Invalidates transaction.
void	IgniteTxManager.txContext(IgniteInternalTx tx)

Constructors in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteInternalTx

Constructor and Description
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, javax.cache.processor.EntryProcessor<Object,Object,Object> entryProcessor, Object[] invokeArgs, long ttl, GridCacheEntryEx entry, CacheEntryPredicate[] filters, GridCacheVersion conflictVer, boolean skipStore, boolean keepBinary) This constructor is meant for local transactions.
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, long ttl, long conflictExpireTime, GridCacheEntryEx entry, GridCacheVersion conflictVer, boolean skipStore, boolean keepBinary) This constructor is meant for remote transactions.