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.transactions
org.apache.ignite.internal.processors.datastructures

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	CacheProjection.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	GridCacheProjectionImpl.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	GridCacheProxyImpl.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
IgniteInternalTx	GridCacheAdapter.txStartEx(TransactionConcurrency concurrency, TransactionIsolation isolation)
static IgniteInternalTx	GridCacheUtils.txStartInternal(GridCacheContext ctx, CacheProjection 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, long 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, long 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, long 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, long topVer, CacheEntryPredicate[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
boolean	GridCacheStoreManager.loadAllFromStore(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, IgniteBiInClosure<KeyCacheObject,Object> vis) Loads data from persistent store.
Object	GridCacheStoreManager.loadFromStore(IgniteInternalTx tx, KeyCacheObject key) Loads data from persistent store.
void	GridCacheStoreManager.localStoreLoadAll(IgniteInternalTx tx, Collection<? extends KeyCacheObject> keys, GridInClosure3<KeyCacheObject,Object,GridCacheVersion> vis)
GridTuple<CacheObject>	GridCacheEntryEx.peek0(boolean failFast, GridCachePeekMode mode, CacheEntryPredicate[] filter, IgniteInternalTx tx)
GridTuple<CacheObject>	GridCacheMapEntry.peek0(boolean failFast, GridCachePeekMode mode, CacheEntryPredicate[] filter, IgniteInternalTx tx)
protected GridTuple<V>	GridCacheAdapter.peek0(boolean failFast, K key, Collection<GridCachePeekMode> modes, IgniteInternalTx tx)
protected V	GridCacheAdapter.peek0(K key, Collection<GridCachePeekMode> modes, IgniteInternalTx tx)
protected Map<K,V>	GridCacheAdapter.peekAll0(Collection<? extends K> keys, Collection<GridCachePeekMode> modes, IgniteInternalTx tx, Collection<K> skipped)
boolean	GridCacheStoreManager.putAllToStore(IgniteInternalTx tx, Map<Object,IgniteBiTuple<Object,GridCacheVersion>> map) Puts key-value pair into storage.
boolean	GridCacheStoreManager.putToStore(IgniteInternalTx tx, Object key, Object val, GridCacheVersion ver) Puts key-value pair into storage.
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)
boolean	GridCacheStoreManager.removeAllFromStore(IgniteInternalTx tx, Collection<Object> keys)
boolean	GridCacheStoreManager.removeFromStore(IgniteInternalTx tx, Object key)
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.
boolean	GridCacheSharedContext.txCompatible(IgniteInternalTx tx, Iterable<Integer> activeCacheIds, GridCacheContext<K,V> cacheCtx)
void	GridCacheStoreManager.txEnd(IgniteInternalTx tx, boolean commit)
static String	GridCacheUtils.txString(IgniteInternalTx tx)
void	GridCacheEntryEx.txUnlock(IgniteInternalTx tx) Unlocks acquired lock.

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)
GridCacheOptimisticCheckPreparedTxFuture(GridCacheSharedContext<K,V> cctx, IgniteInternalTx tx, UUID failedNodeId, Map<UUID,Collection<UUID>> txNodes)
GridCacheOptimisticCheckPreparedTxRequest(IgniteInternalTx tx, int txNum, IgniteUuid futId, IgniteUuid miniId)
GridDistributedTxPrepareRequest(IgniteInternalTx tx, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, IgniteTxKey grpLockKey, boolean partLock, 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.prepareAsync() Prepare stage.
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry> reads, Iterable<IgniteTxEntry> writes, Map<IgniteTxKey,GridCacheVersion> verMap, long msgId, IgniteUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse> completeCb) Prepares next batch of entries in dht transaction.
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	GridDhtTxPrepareFuture.onDone(IgniteInternalTx tx0, 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.prepareAsync() Prepare stage.
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse> completeCb) Prepares next batch of entries in dht 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	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, CacheObject val, GridCacheVersion ver, GridCacheVersion dhtVer, GridCacheVersion expVer, long ttl, long expireTime, boolean evt, long topVer, UUID subjId)
boolean	GridNearTxPrepareFuture.onDone(IgniteInternalTx t, Throwable err) Callback to notify that future is finished.
boolean	GridNearTxFinishFuture.onDone(IgniteInternalTx tx, 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, long topVer, IgniteInternalTx tx, Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, IgniteTxKey grpLockKey, boolean partLock, boolean near, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, boolean onePhaseCommit, boolean retVal, boolean implicitSingle, UUID subjId, int taskNameHash)

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.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.localTxForRecovery(GridCacheVersion nearXidVer, boolean markFinalizing) Gets local transaction for pessimistic tx recovery.
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.txx(GridCacheVersion txId)
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
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.prepareAsync() Prepare stage.
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.prepareTx(UUID nearNodeId, GridNearTxLocal locTx, GridNearTxPrepareRequest req, IgniteInClosure<GridNearTxPrepareResponse> completeCb)
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.processNearTxFinishRequest(UUID nodeId, GridNearTxFinishRequest req)
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.processNearTxPrepareRequest(UUID nearNodeId, GridNearTxPrepareRequest 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)
void	IgniteTxManager.commitTx(IgniteInternalTx tx) Commits a transaction.
void	IgniteTxManager.finishOptimisticTxOnRecovery(IgniteInternalTx tx, boolean commit) Commits or rolls back prepared transaction.
void	IgniteTxManager.finishPessimisticTxOnRecovery(IgniteInternalTx tx, GridCacheCommittedTxInfo commitInfo) Commits or rolls back pessimistic 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.onTxStateChange(TransactionState prevState, TransactionState newState, IgniteInternalTx tx)
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) This constructor is meant for local transactions.
IgniteTxEntry(GridCacheContext<?,?> ctx, IgniteInternalTx tx, GridCacheOperation op, CacheObject val, long ttl, long conflictExpireTime, GridCacheEntryEx entry, GridCacheVersion conflictVer) This constructor is meant for remote transactions.
TransactionProxyImpl(IgniteInternalTx tx, GridCacheSharedContext<K,V> cctx, boolean async)

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

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

Modifier and Type	Method and Description
<K,V> void	DataStructuresProcessor.onTxCommitted(IgniteInternalTx tx) Transaction committed callback for transaction manager.