| Modifier and Type | Method and Description |
|---|---|
IgniteTxKey |
GridCacheMvccCandidate.key() |
IgniteTxKey |
GridCacheEntryEx.txKey() |
IgniteTxKey |
GridCacheMapEntry.txKey() |
IgniteTxKey |
GridCacheContext.txKey(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxKey> |
GridCacheMvccManager.lockedKeys() |
Collection<IgniteTxKey> |
GridCacheMvccManager.nearLockedKeys() |
Map<IgniteTxKey,Collection<GridCacheMvccCandidate>> |
GridCacheMvccManager.unfinishedLocks(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridCacheExplicitLockSpan.candidate(IgniteTxKey key,
GridCacheVersion ver)
Gets explicit lock candidate for given key.
|
GridCacheMvccCandidate |
GridCacheMvccManager.explicitLock(IgniteTxKey key,
GridCacheVersion ver)
Gets explicit lock candidate added by any thread by given key and lock version.
|
GridCacheMvccCandidate |
GridCacheMvccManager.explicitLock(long threadId,
IgniteTxKey key)
Gets last added explicit lock candidate by thread id and key.
|
boolean |
GridCacheMvccManager.isLockedByThread(IgniteTxKey key,
long threadId)
Checks if given key is locked by thread with given id or any thread.
|
void |
GridCacheMvccManager.markExplicitOwner(IgniteTxKey key,
long threadId)
Marks candidates for given thread and given key as owned.
|
void |
GridCacheExplicitLockSpan.markOwned(IgniteTxKey key)
Marks all candidates added for given key as owned.
|
GridCacheMvccCandidate |
GridCacheExplicitLockSpan.removeCandidate(IgniteTxKey key,
GridCacheVersion ver)
Removes lock by key and optional version.
|
GridCacheMvccCandidate |
GridCacheMvccManager.removeExplicitLock(long threadId,
IgniteTxKey key,
GridCacheVersion ver)
Removes explicit lock for given thread id, key and optional version.
|
| Modifier and Type | Method and Description |
|---|---|
Map<IgniteTxKey,GridCacheVersion> |
GridDistributedTxPrepareRequest.dhtVersions() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.readMap() |
Set<IgniteTxKey> |
GridDistributedTxRemoteAdapter.readSet() |
Map<IgniteTxKey,IgniteTxEntry> |
GridDistributedTxRemoteAdapter.writeMap() |
Set<IgniteTxKey> |
GridDistributedTxRemoteAdapter.writeSet() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxPrepareRequest.addDhtVersion(IgniteTxKey key,
GridCacheVersion dhtVer)
Adds version to be verified on remote node.
|
void |
GridDistributedTxRemoteAdapter.clearEntry(IgniteTxKey key)
Clears entry from transaction as it never happened.
|
IgniteTxEntry |
GridDistributedTxRemoteAdapter.entry(IgniteTxKey key) |
boolean |
GridDistributedTxRemoteAdapter.hasWriteKey(IgniteTxKey key) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDistributedTxMapping.evictReaders(Collection<IgniteTxKey> keys) |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxKey> |
GridDhtLockResponse.nearEvicted() |
Collection<IgniteTxKey> |
GridDhtTxPrepareResponse.nearEvicted() |
List<IgniteTxKey> |
GridDhtTxPrepareRequest.nearWritesCacheMissed() |
Map<IgniteTxKey,GridCacheVersion> |
GridDhtTxPrepareRequest.owned() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtTxRemote.addWrite(GridCacheContext cacheCtx,
GridCacheOperation op,
IgniteTxKey key,
CacheObject val,
Collection<T2<javax.cache.processor.EntryProcessor<Object,Object,Object>,Object[]>> entryProcessors,
long ttl,
boolean skipStore,
boolean keepBinary) |
void |
GridDhtTxPrepareRequest.owned(IgniteTxKey key,
GridCacheVersion ownerMapped)
Sets owner and its mapped version.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDhtLockResponse.nearEvicted(Collection<IgniteTxKey> nearEvicted) |
void |
GridDhtTxPrepareResponse.nearEvicted(Collection<IgniteTxKey> nearEvicted) |
IgniteInternalFuture<GridNearTxPrepareResponse> |
GridDhtTxLocal.prepareAsync(Collection<IgniteTxEntry> reads,
Collection<IgniteTxEntry> writes,
Map<IgniteTxKey,GridCacheVersion> verMap,
long msgId,
int nearMiniId,
Map<UUID,Collection<UUID>> txNodes,
boolean last)
Prepares next batch of entries in dht transaction.
|
| Constructor and Description |
|---|
GridDhtTxPrepareFuture(GridCacheSharedContext cctx,
GridDhtTxLocalAdapter tx,
long timeout,
int nearMiniId,
Map<IgniteTxKey,GridCacheVersion> dhtVerMap,
boolean last,
boolean retVal) |
| Modifier and Type | Method and Description |
|---|---|
Set<IgniteTxKey> |
GridDhtColocatedLockFuture.requestedKeys() |
| Modifier and Type | Field and Description |
|---|---|
protected Collection<IgniteTxKey> |
GridNearOptimisticTxPrepareFutureAdapter.KeyLockFuture.lockKeys |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteTxKey> |
GridNearTxRemote.evicted() |
Collection<IgniteTxKey> |
GridNearTxPrepareResponse.filterFailedKeys() |
Map<IgniteTxKey,CacheVersionedValue> |
GridNearTxPrepareResponse.ownedValues() |
Set<IgniteTxKey> |
GridNearLockFuture.requestedKeys() |
Set<IgniteTxKey> |
GridNearOptimisticTxPrepareFuture.requestedKeys() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
GridNearTxLocal.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
boolean |
GridNearTxRemote.addEntry(GridCacheContext cacheCtx,
IgniteTxKey key,
GridCacheOperation op,
CacheObject val,
GridCacheVersion drVer,
boolean skipStore,
boolean keepBinary) |
void |
GridNearTxLocal.addKeyMapping(IgniteTxKey key,
ClusterNode node)
Adds key mapping to dht mapping.
|
protected void |
GridNearOptimisticTxPrepareFutureAdapter.KeyLockFuture.addLockKey(IgniteTxKey key) |
void |
GridNearTxPrepareResponse.addOwnedValue(IgniteTxKey key,
GridCacheVersion ver,
CacheObject val)
Adds owned value.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
GridNearTxLocal.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
boolean |
GridNearTxPrepareResponse.hasOwnedValue(IgniteTxKey key) |
protected void |
GridNearOptimisticTxPrepareFutureAdapter.KeyLockFuture.onKeyLocked(IgniteTxKey key) |
GridCacheVersion |
GridNearTxRemote.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNearTxPrepareResponse.filterFailedKeys(Collection<IgniteTxKey> filterFailedKeys) |
void |
GridNearTxRemote.ownedVersions(Map<IgniteTxKey,GridCacheVersion> vers)
Adds owned versions to map.
|
| Modifier and Type | Field and Description |
|---|---|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.readMap
Read set.
|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxStateImpl.txMap
Per-transaction read map.
|
protected Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.writeMap
Write map.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteTxKey |
IgniteTxEntry.txKey() |
| Modifier and Type | Method and Description |
|---|---|
Set<Map.Entry<IgniteTxKey,IgniteTxEntry>> |
IgniteTxMap.entrySet() |
Set<IgniteTxKey> |
TxLocksResponse.keys() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxImplicitSingleStateImpl.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxState.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxStateImpl.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteSingleStateImpl.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteInternalTx.readMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxLocalAdapter.readMap() |
Set<IgniteTxKey> |
IgniteTxImplicitSingleStateImpl.readSet() |
Set<IgniteTxKey> |
IgniteTxState.readSet() |
Set<IgniteTxKey> |
IgniteTxRemoteStateImpl.readSet() |
Set<IgniteTxKey> |
IgniteTxStateImpl.readSet() |
Set<IgniteTxKey> |
IgniteTxRemoteSingleStateImpl.readSet() |
Set<IgniteTxKey> |
IgniteInternalTx.readSet() |
Set<IgniteTxKey> |
IgniteTxLocalAdapter.readSet() |
Collection<IgniteTxKey> |
TxLocksRequest.txKeys() |
Map<IgniteTxKey,TxLockList> |
TxLocksResponse.txLocks() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxImplicitSingleStateImpl.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxState.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteStateImpl.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxStateImpl.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxRemoteSingleStateImpl.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteInternalTx.writeMap() |
Map<IgniteTxKey,IgniteTxEntry> |
IgniteTxLocalAdapter.writeMap() |
Set<IgniteTxKey> |
IgniteTxImplicitSingleStateImpl.writeSet() |
Set<IgniteTxKey> |
IgniteTxState.writeSet() |
Set<IgniteTxKey> |
IgniteTxRemoteStateImpl.writeSet() |
Set<IgniteTxKey> |
IgniteTxStateImpl.writeSet() |
Set<IgniteTxKey> |
IgniteTxRemoteSingleStateImpl.writeSet() |
Set<IgniteTxKey> |
IgniteInternalTx.writeSet() |
Set<IgniteTxKey> |
IgniteTxLocalAdapter.writeSet() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteCacheExpiryPolicy |
IgniteTxLocalAdapter.accessPolicy(GridCacheContext ctx,
IgniteTxKey key,
javax.cache.expiry.ExpiryPolicy expiryPlc) |
void |
TxLocksResponse.addKey(IgniteTxKey key) |
void |
TxLocksResponse.addTxLock(IgniteTxKey txKey,
TxLock txLock) |
void |
IgniteTxRemoteState.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
void |
IgniteTxRemoteStateImpl.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
void |
IgniteTxRemoteSingleStateImpl.addWriteEntry(IgniteTxKey key,
IgniteTxEntry e) |
protected boolean |
IgniteTxAdapter.checkInternal(IgniteTxKey key) |
void |
IgniteTxRemoteState.clearEntry(IgniteTxKey key) |
void |
IgniteTxRemoteStateImpl.clearEntry(IgniteTxKey key) |
void |
IgniteTxRemoteSingleStateImpl.clearEntry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxImplicitSingleStateImpl.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxState.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxRemoteStateImpl.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxStateImpl.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxRemoteSingleStateImpl.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteInternalTx.entry(IgniteTxKey key) |
IgniteTxEntry |
IgniteTxLocalAdapter.entry(IgniteTxKey key) |
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key)
Gets cache entry for given key.
|
protected GridCacheEntryEx |
IgniteTxLocalAdapter.entryEx(GridCacheContext cacheCtx,
IgniteTxKey key,
AffinityTopologyVersion topVer)
Gets cache entry for given key and topology version.
|
long |
IgniteTxLocalAdapter.entryExpireTime(IgniteTxKey key) |
long |
IgniteTxLocalAdapter.entryTtl(IgniteTxKey key) |
boolean |
IgniteTxImplicitSingleStateImpl.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteTxState.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteTxRemoteStateImpl.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteTxStateImpl.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteTxRemoteSingleStateImpl.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteInternalTx.hasWriteKey(IgniteTxKey key) |
boolean |
IgniteTxLocalAdapter.hasWriteKey(IgniteTxKey key) |
GridCacheVersion |
IgniteTxAdapter.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
GridCacheVersion |
IgniteInternalTx.ownedVersion(IgniteTxKey key)
Gets owned version for near remote transaction.
|
TxLockList |
TxLocksResponse.txLocks(IgniteTxKey txKey) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<TxDeadlock> |
IgniteTxManager.detectDeadlock(IgniteInternalTx tx,
Set<IgniteTxKey> keys)
Performs deadlock detection for given keys.
|
| Constructor and Description |
|---|
IgniteTxMap(Map<IgniteTxKey,IgniteTxEntry> txMap,
IgnitePredicate<IgniteTxEntry> filter) |
IgniteTxRemoteStateImpl(Map<IgniteTxKey,IgniteTxEntry> readMap,
Map<IgniteTxKey,IgniteTxEntry> writeMap) |
IgniteTxRemoteStateImpl(Map<IgniteTxKey,IgniteTxEntry> readMap,
Map<IgniteTxKey,IgniteTxEntry> writeMap) |
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
TxDeadlock(List<GridCacheVersion> cycle,
Map<GridCacheVersion,T2<UUID,Long>> txs,
Map<GridCacheVersion,Set<IgniteTxKey>> txLockedKeys,
Map<IgniteTxKey,Set<GridCacheVersion>> txRequestedKeys) |
TxLocksRequest(long futId,
Set<IgniteTxKey> txKeys) |
Follow @ApacheIgnite
Ignite Fabric : ver. 2.2.0 Release Date : September 15 2017