Uses of Interface
org.gridgain.grid.kernal.processors.cache.GridCacheTxEx

Packages that use GridCacheTxEx

Package	Description
org.gridgain.grid.kernal.processors.cache
org.gridgain.grid.kernal.processors.cache.datastructures
org.gridgain.grid.kernal.processors.cache.distributed
org.gridgain.grid.kernal.processors.cache.distributed.dht
org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated
org.gridgain.grid.kernal.processors.cache.distributed.near
org.gridgain.grid.kernal.processors.cache.local

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache

Subinterfaces of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache

Modifier and Type	Interface and Description
interface	GridCacheTxLocalEx<K,V> Local transaction API.
interface	GridCacheTxRemoteEx<K,V> Local transaction API.

Classes in org.gridgain.grid.kernal.processors.cache that implement GridCacheTxEx

Modifier and Type	Class and Description
class	GridCacheTxAdapter<K,V> Managed transaction adapter.
class	GridCacheTxLocalAdapter<K,V> Transaction adapter for cache transactions.

Methods in org.gridgain.grid.kernal.processors.cache with type parameters of type GridCacheTxEx

Modifier and Type	Method and Description
<T extends GridCacheTxEx<K,V>> T	GridCacheTxManager.onCreated(T tx)
<T extends GridCacheTxEx<K,V>> T	GridCacheTxManager.tx(GridCacheVersion txId)

Methods in org.gridgain.grid.kernal.processors.cache that return GridCacheTxEx

Modifier and Type	Method and Description
GridCacheTxEx<K,V>	GridCacheTxManager.localTxForRecovery(GridCacheVersion nearXidVer) Gets local transaction for pessimistic tx recovery.
GridCacheTxEx<K,V>	GridCacheTxManager.localTxx()
GridCacheTxEx<K,V>	GridCacheTxManager.txx()
GridCacheTxEx<K,V>	GridCacheTxManager.txx(GridCacheVersion txId)

Methods in org.gridgain.grid.kernal.processors.cache that return types with arguments of type GridCacheTxEx

Modifier and Type	Method and Description
GridFuture<GridCacheTxEx<K,V>>	GridCacheTxLocalEx.future()
GridFuture<GridCacheTxEx<K,V>>	GridCacheTxEx.prepareAsync() Prepare stage.
Set<GridCacheTxEx<K,V>>	GridCacheMultiTxFuture.remainingTxs()
static <K,V> GridClosure<GridCacheTxEx<K,V>,GridCacheVersion>	GridCacheUtils.tx2xidVersion()
Set<GridCacheTxEx<K,V>>	GridCacheMultiTxFuture.txs()
Collection<GridCacheTxEx<K,V>>	GridCacheTxManager.txs()

Methods in org.gridgain.grid.kernal.processors.cache with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
void	GridCacheTxManager.addAlternateVersion(GridCacheVersion ver, GridCacheTxEx<K,V> tx)
boolean	GridCacheTxManager.addCommittedTx(GridCacheTxEx<K,V> tx)
boolean	GridCacheTxManager.addRolledbackTx(GridCacheTxEx<K,V> tx)
void	GridCacheMultiTxFuture.addTx(GridCacheTxEx<K,V> tx)
void	GridCacheTxManager.commitTx(GridCacheTxEx<K,V> tx) Commits a transaction.
void	GridCacheTxManager.finishOptimisticTxOnRecovery(GridCacheTxEx<K,V> tx, boolean commit) Commits or rolls back prepared transaction.
void	GridCacheTxManager.finishPessimisticTxOnRecovery(GridCacheTxEx<K,V> tx, GridCacheCommittedTxInfo<K,V> commitInfo) Commits or rolls back pessimistic transaction.
V	GridCacheMapEntry.innerGet(GridCacheTxEx<K,V> tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, UUID subjId, GridPredicate<GridCacheEntry<K,V>>[] filter)
V	GridCacheEntryEx.innerGet(GridCacheTxEx<K,V> tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, UUID subjId, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheUpdateTxResult<V>	GridCacheMapEntry.innerRemove(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId)
GridCacheUpdateTxResult<V>	GridCacheEntryEx.innerRemove(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId)
GridCacheUpdateTxResult<V>	GridCacheMapEntry.innerSet(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, V val, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId)
GridCacheUpdateTxResult<V>	GridCacheEntryEx.innerSet(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, V val, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId)
boolean	GridCacheTxManager.isCompleted(GridCacheTxEx<K,V> tx)
boolean	GridCacheTxManager.onStarted(GridCacheTxEx<K,V> tx) Transaction start callback (has to do with when any operation was performed on this transaction).
GridTuple<V>	GridCacheMapEntry.peek0(boolean failFast, GridCachePeekMode mode, GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheTxEx<K,V> tx)
GridTuple<V>	GridCacheEntryEx.peek0(boolean failFast, GridCachePeekMode mode, GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheTxEx<K,V> tx)
protected GridTuple<V>	GridCacheAdapter.peek0(boolean failFast, K key, Collection<GridCachePeekMode> modes, GridCacheTxEx<K,V> tx)
protected V	GridCacheAdapter.peek0(K key, Collection<GridCachePeekMode> modes, GridCacheTxEx<K,V> tx)
protected Map<K,V>	GridCacheAdapter.peekAll0(Collection<? extends K> keys, Collection<GridCachePeekMode> modes, GridCacheTxEx<K,V> tx, Collection<K> skipped)
void	GridCacheTxManager.prepareTx(GridCacheTxEx<K,V> tx) Handles prepare stage of 2PC.
protected V	GridCacheMapEntry.readThrough(GridCacheTxEx<K,V> tx, K key, boolean reload, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId)
GridFuture<Object>	GridCacheAdapter.readThroughAllAsync(Collection<? extends K> keys, boolean reload, GridCacheTxEx<K,V> tx, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId, GridBiInClosure<K,V> vis)
void	GridCacheTxManager.removeCommittedTx(GridCacheTxEx<K,V> tx)
void	GridCacheTxManager.rollbackTx(GridCacheTxEx<K,V> tx) Rolls back a transaction.
boolean	GridCacheTxManager.salvageTx(GridCacheTxEx<K,V> tx) Invalidates transaction.
static <K,V> UUID	GridCacheUtils.subjectId(GridCacheTxEx<K,V> tx, GridCacheContext<K,V> ctx) Gets subject ID by transaction.
boolean	GridCacheEntryEx.tmLock(GridCacheTxEx<K,V> tx, long timeout) This locks is called by transaction manager during prepare step for optimistic transactions.
void	GridCacheEvictionManager.touch(GridCacheTxEx<K,V> tx)
void	GridCacheTxManager.txContext(GridCacheTxEx tx)
void	GridCacheEntryEx.txUnlock(GridCacheTxEx<K,V> tx) Unlocks acquired lock.
void	GridCacheTxManager.uncommitTx(GridCacheTxEx<K,V> tx) Tries to minimize damage from partially-committed transaction.

Constructors in org.gridgain.grid.kernal.processors.cache with parameters of type GridCacheTxEx

Constructor and Description
GridCacheTxEntry(GridCacheContext<K,V> ctx, GridCacheTxEx<K,V> tx, GridCacheOperation op, V val, GridClosure<V,V> transformClos, long ttl, GridCacheEntryEx<K,V> entry, GridPredicate<GridCacheEntry<K,V>>[] filters, GridCacheVersion drVer) This constructor is meant for local transactions.
GridCacheTxEntry(GridCacheContext<K,V> ctx, GridCacheTxEx<K,V> tx, GridCacheOperation op, V val, long ttl, long drExpireTime, GridCacheEntryEx<K,V> entry, GridCacheVersion drVer) This constructor is meant for remote transactions.

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.datastructures

Methods in org.gridgain.grid.kernal.processors.cache.datastructures with parameters of type GridCacheTxEx

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

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.distributed

Classes in org.gridgain.grid.kernal.processors.cache.distributed that implement GridCacheTxEx

Modifier and Type	Class and Description
class	GridDistributedTxRemoteAdapter<K,V> Transaction created by system implicitly on remote nodes.

Methods in org.gridgain.grid.kernal.processors.cache.distributed that return types with arguments of type GridCacheTxEx

Modifier and Type	Method and Description
GridFuture<GridCacheTxEx<K,V>>	GridDistributedTxRemoteAdapter.prepareAsync() Prepare stage.

Methods in org.gridgain.grid.kernal.processors.cache.distributed with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
void	GridCacheTxCommitBuffer.addCommittedTx(GridCacheTxEx<K,V> tx) Adds committed transaction to commit buffer.
void	GridCachePerThreadTxCommitBuffer.addCommittedTx(GridCacheTxEx<K,V> tx) Adds committed transaction to commit buffer.
boolean	GridDistributedCacheEntry.tmLock(GridCacheTxEx<K,V> tx, long timeout) This locks is called by transaction manager during prepare step for optimistic transactions.
void	GridDistributedCacheEntry.txUnlock(GridCacheTxEx<K,V> tx) Unlocks acquired lock.

Constructors in org.gridgain.grid.kernal.processors.cache.distributed with parameters of type GridCacheTxEx

Constructor and Description
GridCacheCommittedTxInfo(GridCacheTxEx<K,V> tx)
GridCacheOptimisticCheckPreparedTxFuture(GridCacheContext<K,V> cctx, GridCacheTxEx<K,V> tx, UUID failedNodeId, Map<UUID,Collection<UUID>> txNodes)
GridCacheOptimisticCheckPreparedTxRequest(GridCacheTxEx<K,V> tx, int txNum, GridUuid futId, GridUuid miniId)
GridCachePessimisticCheckCommittedTxFuture(GridCacheContext<K,V> cctx, GridCacheTxEx<K,V> tx, UUID failedNodeId)
GridCachePessimisticCheckCommittedTxRequest(GridCacheTxEx<K,V> tx, long originatingThreadId, GridUuid futId, GridUuid miniId)
GridDistributedTxPrepareRequest(GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, Map<UUID,Collection<UUID>> txNodes)

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.distributed.dht

Classes in org.gridgain.grid.kernal.processors.cache.distributed.dht that implement GridCacheTxEx

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

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht that return types with arguments of type GridCacheTxEx

Modifier and Type	Method and Description
GridFuture<GridCacheTxEx<K,V>>	GridDhtTxLocal.future()
GridFuture<GridCacheTxEx<K,V>>	GridDhtTxLocal.prepareAsync() Prepare stage.
GridFuture<GridCacheTxEx<K,V>>	GridDhtTxLocal.prepareAsync(Iterable<GridCacheTxEntry<K,V>> reads, Iterable<GridCacheTxEntry<K,V>> writes, Map<K,GridCacheVersion> verMap, long msgId, GridUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTxEx<K,V>>	GridDhtTransactionalCacheAdapter.prepareTx(GridNode nearNode, GridNearTxPrepareRequest<K,V> req)

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
boolean	GridDhtTxPrepareFuture.onDone(GridCacheTxEx<K,V> tx0, Throwable err) Callback to notify that future is finished.
boolean	GridDhtCacheEntry.tmLock(GridCacheTxEx<K,V> tx, long timeout) This locks is called by transaction manager during prepare step for optimistic transactions.

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated

Classes in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated that implement GridCacheTxEx

Modifier and Type	Class and Description
class	GridDhtColocatedTxLocal<K,V> Colocated transaction.

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated that return types with arguments of type GridCacheTxEx

Modifier and Type	Method and Description
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedTxLocal.future()
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedTxLocal.prepareAsync() Prepare stage.
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedTxLocal.prepareAsyncLocal(Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups) Prepares next batch of entries in dht transaction.
GridFuture<GridCacheTxEx<K,V>>	GridDhtColocatedCache.prepareTxLocally(GridDhtColocatedTxLocal<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups)

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
boolean	GridDhtColocatedTxPrepareFuture.onDone(GridCacheTxEx<K,V> t, Throwable err) Callback to notify that future is finished.

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.distributed.near

Classes in org.gridgain.grid.kernal.processors.cache.distributed.near that implement GridCacheTxEx

Modifier and Type	Class and Description
class	GridNearTxRemote<K,V> Transaction created by system implicitly on remote nodes.

Methods in org.gridgain.grid.kernal.processors.cache.distributed.near with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
GridFuture<Map<K,V>>	GridNearCacheAdapter.loadAsync(GridCacheTxEx tx, Collection<? extends K> keys, boolean reload, boolean forcePrimary, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId)
boolean	GridNearCacheEntry.loadedValue(GridCacheTxEx tx, UUID primaryNodeId, V val, byte[] valBytes, GridCacheVersion ver, GridCacheVersion dhtVer, GridCacheVersion expVer, long ttl, long expireTime, boolean evt, long topVer, UUID subjId)
boolean	GridNearTxPrepareFuture.onDone(GridCacheTxEx<K,V> t, Throwable err) Callback to notify that future is finished.
protected V	GridNearCacheEntry.readThrough(GridCacheTxEx<K,V> tx, K key, boolean reload, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId)
GridFuture<Object>	GridNearCacheAdapter.readThroughAllAsync(Collection<? extends K> keys, boolean reload, GridCacheTxEx<K,V> tx, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId, GridBiInClosure<K,V> vis)

Constructors in org.gridgain.grid.kernal.processors.cache.distributed.near with parameters of type GridCacheTxEx

Constructor and Description
GridNearTxPrepareRequest(GridUuid futId, long topVer, GridCacheTxEx<K,V> tx, Collection<GridCacheTxEntry<K,V>> reads, Collection<GridCacheTxEntry<K,V>> writes, Object grpLockKey, boolean partLock, boolean syncCommit, boolean syncRollback, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, UUID subjId)

Uses of GridCacheTxEx in org.gridgain.grid.kernal.processors.cache.local

Methods in org.gridgain.grid.kernal.processors.cache.local with parameters of type GridCacheTxEx

Modifier and Type	Method and Description
boolean	GridLocalCacheEntry.tmLock(GridCacheTxEx<K,V> tx, long timeout) This locks is called by transaction manager during prepare step for optimistic transactions.
void	GridLocalCacheEntry.txUnlock(GridCacheTxEx<K,V> tx) Unlocks lock if it is currently owned.