| Modifier and Type | Field and Description |
|---|---|
static GridCacheTxIsolation |
GridCacheConfiguration.DFLT_TX_ISOLATION
Default transaction isolation level.
|
| Modifier and Type | Method and Description |
|---|---|
static GridCacheTxIsolation |
GridCacheTxIsolation.fromOrdinal(int ord)
Efficiently gets enumerated value from its ordinal.
|
GridCacheTxIsolation |
GridCacheConfiguration.getDefaultTxIsolation()
Default cache transaction isolation to use when one is not explicitly
specified.
|
GridCacheTxIsolation |
GridCacheTx.isolation()
Cache transaction isolation level.
|
static GridCacheTxIsolation |
GridCacheTxIsolation.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static GridCacheTxIsolation[] |
GridCacheTxIsolation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheConfiguration.setDefaultTxIsolation(GridCacheTxIsolation dfltIsolation)
Sets default transaction isolation.
|
GridCacheTx |
GridCacheProjection.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProjection.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProjection.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProjection.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheTxIsolation |
GridCacheTxAdapter.isolation
Isolation.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxIsolation |
GridCacheAttributes.defaultIsolation() |
GridCacheTxIsolation |
GridCacheTxAdapter.isolation()
Cache transaction isolation level.
|
GridCacheTxIsolation |
GridCacheTxProxyImpl.isolation()
Cache transaction isolation level.
|
| Modifier and Type | Method and Description |
|---|---|
static <K,V> void |
GridCacheUtils.inTx(GridCacheProjection<K,V> cache,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
GridInClosureX<GridCacheProjection<K,V>> clo)
Execute closure inside cache transaction.
|
abstract GridCacheTxLocalAdapter<K,V> |
GridCacheAdapter.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
abstract GridFuture<Boolean> |
GridCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheTx |
GridCacheProjectionImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheAdapter.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProxyImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation)
Starts new transaction with the specified concurrency and isolation.
|
GridCacheTx |
GridCacheProjectionImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheAdapter.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProxyImpl.txStart(GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts transaction with specified isolation, concurrency, timeout, invalidation flag,
and number of participating entries.
|
GridCacheTx |
GridCacheProjectionImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheAdapter.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
GridCacheTx |
GridCacheProxyImpl.txStartAffinity(Object affinityKey,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
affinity-group-locked transaction based on affinity key. |
static GridCacheTx |
GridCacheUtils.txStartInternal(GridCacheContext ctx,
GridCacheProjection prj,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation) |
GridCacheTx |
GridCacheProjectionImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheAdapter.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
GridCacheTx |
GridCacheProxyImpl.txStartPartition(int partId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
int txSize)
Starts
partition-group-locked transaction based on partition ID. |
| Constructor and Description |
|---|
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
boolean loc,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxAdapter(GridCacheContext<K,V> cctx,
UUID nodeId,
GridCacheVersion xidVer,
GridCacheVersion startVer,
long threadId,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
UUID subjId) |
GridCacheTxLocalAdapter(GridCacheContext<K,V> cctx,
GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxIsolation |
GridDistributedTxPrepareRequest.isolation() |
GridCacheTxIsolation |
GridDistributedLockRequest.isolation() |
| Modifier and Type | Method and Description |
|---|---|
protected abstract GridFuture<Boolean> |
GridDistributedCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridDistributedCacheAdapter.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean isInvalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Constructor and Description |
|---|
GridDistributedLockRequest(UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
GridUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
int keyCnt,
int txSize,
Object grpLockKey,
boolean partLock) |
GridDistributedTxRemoteAdapter(GridCacheContext<K,V> ctx,
UUID nodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
int txSize,
Object grpLockKey,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxIsolation |
GridDhtTxFinishRequest.isolation() |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridDhtFuture<Boolean> |
GridDhtTransactionalCacheAdapter.lockAllAsyncInternal(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> txx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Acquires locks in partitioned cache.
|
GridCacheTxLocalAdapter<K,V> |
GridDhtCacheAdapter.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
| Constructor and Description |
|---|
GridDhtLockRequest(UUID nodeId,
GridCacheVersion nearXidVer,
long threadId,
GridUuid futId,
GridUuid miniId,
GridCacheVersion lockVer,
long topVer,
boolean isInTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
int dhtCnt,
int nearCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtTxFinishRequest(UUID nearNodeId,
GridUuid futId,
GridUuid miniId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
long threadId,
GridCacheTxIsolation isolation,
boolean commit,
boolean invalidate,
boolean sysInvalidate,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
Collection<GridCacheVersion> pendingVers,
int txSize,
Collection<GridCacheTxEntry<K,V>> writes,
Collection<GridCacheTxEntry<K,V>> nearWrites,
Collection<GridCacheTxEntry<K,V>> recoverWrites,
boolean reply,
boolean onePhaseCommit,
Object grpLockKey,
UUID subjId) |
GridDhtTxLocalAdapter(GridCacheVersion xidVer,
boolean implicit,
boolean implicitSingle,
GridCacheContext<K,V> cctx,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean explicitLock,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
GridDhtTxRemote(UUID nearNodeId,
GridUuid rmtFutId,
UUID nodeId,
long rmtThreadId,
long topVer,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
GridCacheVersion nearXidVer,
Map<UUID,Collection<UUID>> txNodes,
UUID subjId)
This constructor is meant for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridFuture<Boolean> |
GridDhtAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheTxLocalAdapter<K,V> |
GridDhtAtomicCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Boolean> |
GridDhtColocatedCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This is an entry point to pessimistic locking within transaction.
|
GridCacheTxLocalAdapter<K,V> |
GridDhtColocatedCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
| Constructor and Description |
|---|
GridDhtColocatedTxLocal(boolean implicit,
boolean implicitSingle,
GridCacheContext<K,V> cctx,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
| Modifier and Type | Method and Description |
|---|---|
protected GridFuture<Boolean> |
GridNearTransactionalCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected GridFuture<Boolean> |
GridNearAtomicCache.lockAllAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isInvalidate,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridCacheTxLocalAdapter<K,V> |
GridNearTransactionalCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
GridCacheTxLocalAdapter<K,V> |
GridNearAtomicCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
| Constructor and Description |
|---|
GridNearLockRequest(long topVer,
UUID nodeId,
long threadId,
GridUuid futId,
GridCacheVersion lockVer,
boolean isInTx,
boolean implicitTx,
boolean implicitSingleTx,
boolean isRead,
GridCacheTxIsolation isolation,
boolean isInvalidate,
long timeout,
boolean syncCommit,
boolean syncRollback,
int keyCnt,
int txSize,
Object grpLockKey,
boolean partLock,
UUID subjId) |
GridNearTxRemote(ClassLoader ldr,
UUID nodeId,
UUID nearNodeId,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
Collection<GridCacheTxEntry<K,V>> writeEntries,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for optimistic transactions.
|
GridNearTxRemote(UUID nodeId,
UUID nearNodeId,
GridCacheVersion nearXidVer,
long rmtThreadId,
GridCacheVersion xidVer,
GridCacheVersion commitVer,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
boolean invalidate,
long timeout,
K key,
byte[] keyBytes,
V val,
byte[] valBytes,
GridCacheVersion drVer,
GridCacheContext<K,V> ctx,
int txSize,
Object grpLockKey,
UUID subjId)
This constructor is meant for pessimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxLocalAdapter<K,V> |
GridLocalCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
GridFuture<Boolean> |
GridLocalCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxLocalAdapter<K,V> |
GridLocalAtomicCache.newTx(boolean implicit,
boolean implicitSingle,
GridCacheTxConcurrency concurrency,
GridCacheTxIsolation isolation,
long timeout,
boolean invalidate,
boolean syncCommit,
boolean syncRollback,
boolean swapOrOffheapEnabled,
boolean storeEnabled,
int txSize,
Object grpLockKey,
boolean partLock) |
GridFuture<Boolean> |
GridLocalAtomicCache.txLockAsync(Collection<? extends K> keys,
long timeout,
GridCacheTxLocalEx<K,V> tx,
boolean isRead,
boolean retval,
GridCacheTxIsolation isolation,
boolean invalidate,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheTxIsolation |
VisorDefaultConfig.txIsolation() |
| Modifier and Type | Method and Description |
|---|---|
void |
VisorDefaultConfig.txIsolation(GridCacheTxIsolation txIsolation) |
Copyright © 2014. All rights reserved.