| 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) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
GridCacheAdapter.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
IgniteInternalCache.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
IgniteInternalTx |
GridCacheProxyImpl.txStartEx(TransactionConcurrency concurrency,
TransactionIsolation isolation) |
static IgniteInternalTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
IgniteInternalCache prj,
TransactionConcurrency concurrency,
TransactionIsolation isolation) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheAdapter.commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(IgniteInternalTx tx) |
static <K,V> IgniteClosure<IgniteInternalTx,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
| 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) |
IgniteInternalFuture<IgniteInternalTx> |
GridCacheAdapter.commitTxAsync(IgniteInternalTx tx)
Asynchronously commits transaction after all previous asynchronous operations are completed.
|
IgniteInternalFuture<IgniteInternalTx> |
GridCacheSharedContext.commitTxAsync(IgniteInternalTx tx) |
void |
GridCacheSharedContext.endTx(IgniteInternalTx tx) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
T2<CacheObject,GridCacheVersion> |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
T2<CacheObject,GridCacheVersion> |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
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.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.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 |
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) |
AffinityTopologyVersion |
GridCacheSharedContext.lockedTopologyVersion(IgniteInternalTx ignore) |
protected Object |
GridCacheMapEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
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,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean keepBinary)
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,
GridLongList activeCacheIds,
GridCacheContext<K,V> cacheCtx) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedTxRemoteAdapter
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
GridCacheTxRecoveryFuture.tx() |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDistributedCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean keepBinary)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridDistributedCacheEntry.txUnlock(IgniteInternalTx tx)
Unlocks acquired lock.
|
| Constructor and Description |
|---|
GridCacheCommittedTxInfo(IgniteInternalTx tx)
Deprecated.
|
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 onePhaseCommit,
boolean addDepInfo) |
| 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.
|
| 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.
|
| 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 keepBinary)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearTxLocal
Replicated user transaction.
|
class |
GridNearTxRemote
Transaction created by system implicitly on remote nodes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalTx |
GridNearTxPrepareFutureAdapter.tx() |
| 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.
|
| 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,
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 |
GridNearPessimisticTxPrepareFuture.onDone(IgniteInternalTx res,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridNearOptimisticSerializableTxPrepareFuture.onDone(IgniteInternalTx t,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridNearOptimisticTxPrepareFuture.onDone(IgniteInternalTx t,
Throwable err)
Callback to notify that future is finished.
|
boolean |
GridNearTxFinishFuture.onDone(IgniteInternalTx tx0,
Throwable err)
Callback to notify that future is finished.
|
protected Object |
GridNearCacheEntry.readThrough(IgniteInternalTx tx,
KeyCacheObject key,
boolean reload,
UUID subjId,
String taskName) |
| Constructor and Description |
|---|
GridNearTxPrepareRequest(IgniteUuid futId,
AffinityTopologyVersion topVer,
IgniteInternalTx tx,
long timeout,
Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
boolean near,
Map<UUID,Collection<UUID>> txNodes,
boolean last,
boolean onePhaseCommit,
boolean retVal,
boolean implicitSingle,
boolean explicitLock,
UUID subjId,
int taskNameHash,
boolean firstClientReq,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean keepBinary)
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.
|
| 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) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteTxLocalEx
Local transaction API.
|
interface |
IgniteTxRemoteEx
Local transaction API.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteTxAdapter
Managed transaction adapter.
|
class |
IgniteTxLocalAdapter
Transaction adapter for cache transactions.
|
| Modifier and Type | Method and Description |
|---|---|
<T extends IgniteInternalTx> |
IgniteTxManager.nearTx(GridCacheVersion txId) |
<T extends IgniteInternalTx> |
IgniteTxManager.onCreated(GridCacheContext cacheCtx,
T tx) |
<T extends IgniteInternalTx> |
IgniteTxManager.tx(GridCacheVersion txId) |
| Modifier and Type | Method and Description |
|---|---|
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) |
| 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.
|
boolean |
IgniteTxManager.isCompleted(IgniteInternalTx tx) |
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 |
IgniteTxStateImpl.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxState.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxRemoteStateAdapter.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
void |
IgniteTxImplicitSingleStateImpl.onTxEnd(GridCacheSharedContext cctx,
IgniteInternalTx tx,
boolean commit) |
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.
|
| 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.
|
TransactionProxyImpl(IgniteInternalTx tx,
GridCacheSharedContext<K,V> cctx,
boolean async) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.8.0 Release Date : December 5 2016