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

Packages that use IgniteInternalTx

Package	Description
org.apache.ignite.internal	Contains main implementation.
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

Methods in org.apache.ignite.internal that return IgniteInternalTx

Modifier and Type	Method and Description
IgniteInternalTx	IgniteTransactionsEx.txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	IgniteTransactionsEx.txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)

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

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

Modifier and Type	Method and Description
IgniteInternalTx	GridCacheProxyImpl.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	GridCacheAdapter.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	IgniteInternalCache.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
static IgniteInternalTx	GridCacheUtils.txStartInternal(GridCacheContext ctx, IgniteInternalCache prj, TransactionConcurrency concurrency, TransactionIsolation isolation)

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(IgniteInternalTx tx)
IgniteInternalFuture<IgniteInternalTx>	GridCacheAdapter.commitTxAsync(IgniteInternalTx tx) Asynchronously commits transaction after all previous asynchronous operations are completed.
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)
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)
void	GridCacheMultiTxFuture.addTx(IgniteInternalTx tx)
IgniteInternalFuture<IgniteInternalTx>	GridCacheSharedContext.commitTxAsync(IgniteInternalTx tx)
IgniteInternalFuture<IgniteInternalTx>	GridCacheAdapter.commitTxAsync(IgniteInternalTx tx) Asynchronously commits transaction after all previous asynchronous operations are completed.
void	GridCacheSharedContext.endTx(IgniteInternalTx tx)
CacheObject	GridCacheEntryEx.innerGet(IgniteInternalTx tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, boolean tmp, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expiryPlc)
CacheObject	GridCacheMapEntry.innerGet(IgniteInternalTx tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, boolean tmp, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expirePlc)
GridCacheUpdateTxResult	GridCacheEntryEx.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerRemove(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheEntryEx.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult	GridCacheMapEntry.innerSet(IgniteInternalTx tx, UUID evtNodeId, UUID affNodeId, CacheObject val, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, AffinityTopologyVersion topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
protected Object	GridCacheMapEntry.readThrough(IgniteInternalTx tx, KeyCacheObject key, boolean reload, UUID subjId, String taskName)
IgniteInternalFuture<Object>	GridCacheAdapter.readThroughAllAsync(Collection<KeyCacheObject> keys, boolean reload, boolean skipVals, IgniteInternalTx tx, UUID subjId, String taskName, IgniteBiInClosure<KeyCacheObject,Object> vis)
IgniteInternalFuture	GridCacheSharedContext.rollbackTxAsync(IgniteInternalTx tx)
static <K,V> UUID	GridCacheUtils.subjectId(IgniteInternalTx tx, GridCacheSharedContext<K,V> ctx) Gets subject ID by transaction.
boolean	GridCacheEntryEx.tmLock(IgniteInternalTx tx, long timeout) 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, Iterable<Integer> 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 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.prepareAsync() Prepare stage.
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) 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
GridCacheCommittedTxInfo(IgniteInternalTx tx)
GridCacheTxRecoveryFuture(GridCacheSharedContext<?,?> cctx, IgniteInternalTx tx, UUID failedNodeId, Map<UUID,Collection<UUID>> txNodes)
GridCacheTxRecoveryRequest(IgniteInternalTx tx, int txNum, boolean nearTxCheck, IgniteUuid futId, IgniteUuid miniId)
GridDistributedTxPrepareRequest(IgniteInternalTx tx, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, Map<UUID,Collection<UUID>> txNodes, boolean onePhaseCommit)

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.rollbackAsync() Asynchronously rollback this transaction.

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) 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 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.rollbackAsync() Asynchronously rollback this transaction.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.rollbackAsyncLocal() Rolls back local part of colocated transaction.

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 reload, boolean forcePrimary, UUID subjId, String taskName, boolean deserializePortable, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean skipVal, boolean skipStore, boolean canRemap)
boolean	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, GridCacheVersion expVer, long ttl, long expireTime, boolean evt, AffinityTopologyVersion topVer, UUID subjId)
boolean	GridNearTxFinishFuture.onDone(IgniteInternalTx tx0, Throwable err) Callback to notify that future is finished.
boolean	GridNearPessimisticTxPrepareFuture.onDone(IgniteInternalTx res, Throwable err) Callback to notify that future is finished.
boolean	GridNearOptimisticTxPrepareFuture.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)
IgniteInternalFuture<Object>	GridNearCacheAdapter.readThroughAllAsync(Collection<KeyCacheObject> keys, boolean reload, boolean skipVals, IgniteInternalTx tx, UUID subjId, String taskName, IgniteBiInClosure<KeyCacheObject,Object> vis)

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

Constructor and Description
GridNearTxPrepareRequest(IgniteUuid futId, AffinityTopologyVersion topVer, IgniteInternalTx tx, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, boolean explicitLock, UUID subjId, int taskNameHash, boolean firstClientReq)

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) 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	GridCacheStoreManagerAdapter.load(IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
Object	CacheStoreManager.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	GridCacheStoreManagerAdapter.put(IgniteInternalTx tx, Object key, Object val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	CacheStoreManager.put(IgniteInternalTx tx, Object key, Object val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.putAll(IgniteInternalTx tx, Map map) Puts key-value pair into storage.
boolean	CacheStoreManager.putAll(IgniteInternalTx tx, Map<Object,IgniteBiTuple<Object,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	GridCacheStoreManagerAdapter.remove(IgniteInternalTx tx, Object key)
boolean	CacheStoreManager.remove(IgniteInternalTx tx, Object key)
boolean	GridCacheStoreManagerAdapter.removeAll(IgniteInternalTx tx, Collection keys)
boolean	CacheStoreManager.removeAll(IgniteInternalTx tx, Collection<Object> keys)
void	GridCacheStoreManagerAdapter.sessionEnd(IgniteInternalTx tx, boolean commit, boolean last)
void	CacheStoreManager.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.anyActiveThreadTx(IgniteInternalTx ignore)
IgniteInternalTx	IgniteTxManager.localTxx()
IgniteInternalTx	TransactionProxyImpl.tx()
IgniteInternalTx	IgniteTransactionsImpl.txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	IgniteTransactionsImpl.txStartEx(GridCacheContext ctx, TransactionConcurrency concurrency, TransactionIsolation isolation, long timeout, int txSize)
IgniteInternalTx	IgniteTxManager.txx()
IgniteInternalTx	IgniteTxManager.userTx()
IgniteInternalTx	IgniteTxManager.userTx(GridCacheContext cctx)

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>	IgniteTxHandler.processNearTxFinishRequest(UUID nodeId, GridNearTxFinishRequest req)
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)
boolean	IgniteTxManager.addCommittedTx(IgniteInternalTx tx)
boolean	IgniteTxManager.addRolledbackTx(IgniteInternalTx tx)
IgniteInternalTx	IgniteTxManager.anyActiveThreadTx(IgniteInternalTx ignore)
void	IgniteTxManager.commitIfPrepared(IgniteInternalTx tx) 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.
void	IgniteTxManager.finishTxOnRecovery(IgniteInternalTx tx, boolean commit) Commits or rolls back prepared transaction.
boolean	IgniteTxManager.isCompleted(IgniteInternalTx tx)
boolean	IgniteTxManager.onStarted(IgniteInternalTx tx) Transaction start callback (has to do with when any operation was performed on this transaction).
void	IgniteTxManager.prepareTx(IgniteInternalTx tx) Handles prepare stage of 2PC.
void	IgniteTxManager.removeCommittedTx(IgniteInternalTx tx)
void	IgniteTxManager.rollbackTx(IgniteInternalTx tx) Rolls back a transaction.
boolean	IgniteTxManager.salvageTx(IgniteInternalTx tx) Invalidates transaction.
void	IgniteTxManager.txContext(IgniteInternalTx tx)
void	IgniteTxManager.uncommitTx(IgniteInternalTx tx) Tries to minimize damage from partially-committed transaction.

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) 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) This constructor is meant for remote transactions.
TransactionProxyImpl(IgniteInternalTx tx, GridCacheSharedContext<K,V> cctx, boolean async)