| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridCacheEntryEx.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate |
GridCacheMapEntry.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
GridCacheMvccCandidate |
GridCacheEntryEx.candidate(UUID nodeId,
long threadId) |
GridCacheMvccCandidate |
GridCacheMapEntry.candidate(UUID nodeId,
long threadId) |
protected void |
GridCacheMapEntry.checkObsolete() |
boolean |
GridCacheEntryEx.checkSerializableReadVersion(GridCacheVersion serReadVer)
Checks if there was read/write conflict in serializable transaction.
|
boolean |
GridCacheMapEntry.checkSerializableReadVersion(GridCacheVersion serReadVer)
Checks if there was read/write conflict in serializable transaction.
|
protected void |
GridCacheMapEntry.clearReader(UUID nodeId) |
void |
GridCacheContext.dhtMap(GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
void |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
GridCacheVersion explicitLockVer,
IgniteLogger log,
Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
Map<ClusterNode,List<GridDhtCacheEntry>> nearMap) |
long |
GridCacheEntryEx.expireTime() |
long |
GridCacheMapEntry.expireTime() |
boolean |
GridCacheEntryEx.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidate(GridCacheVersion ver)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheEntryEx.hasLockCandidate(long threadId)
Checks if the candidate is either owner or pending.
|
boolean |
GridCacheMapEntry.hasLockCandidate(long threadId)
Checks if the candidate is either owner or pending.
|
protected boolean |
GridCacheMapEntry.hasReaders() |
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
boolean |
GridCacheMapEntry.initialValue(CacheObject val,
GridCacheVersion ver,
MvccVersion mvccVer,
MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore)
Sets new value if current version is 0
|
CacheObject |
GridCacheEntryEx.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
CacheObject |
GridCacheMapEntry.innerGet(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary,
MvccSnapshot mvccVer) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
MvccSnapshot mvccVer,
ReaderArguments readerArgs) |
CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
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,
MvccSnapshot mvccVer) |
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,
MvccSnapshot mvccVer) |
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,
MvccSnapshot mvccVer) |
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,
MvccSnapshot mvccVer) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
UUID subjId,
String taskName,
CacheObject prevVal,
Long updateCntr,
GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName,
boolean transformOp)
Update method for local cache in atomic mode.
|
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
CacheEntryPredicate[] filter,
boolean intercept,
UUID subjId,
String taskName,
boolean transformOp)
Update method for local cache in atomic mode.
|
boolean |
GridCacheEntryEx.isNew()
Checks if entry is new assuming lock is held externally.
|
boolean |
GridCacheMapEntry.isNew()
Checks if entry is new assuming lock is held externally.
|
boolean |
GridCacheEntryEx.isNewLocked()
Checks if entry is new while holding lock.
|
boolean |
GridCacheMapEntry.isNewLocked()
Checks if entry is new while holding lock.
|
GridCacheMvccCandidate |
GridCacheEntryEx.localCandidate(long threadId) |
GridCacheMvccCandidate |
GridCacheMapEntry.localCandidate(long threadId) |
Collection<GridCacheMvccCandidate> |
GridCacheEntryEx.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
Collection<GridCacheMvccCandidate> |
GridCacheMapEntry.localCandidates(GridCacheVersion... exclude)
Gets all local candidates.
|
GridCacheMvccCandidate |
GridCacheEntryEx.localOwner() |
GridCacheMvccCandidate |
GridCacheMapEntry.localOwner() |
boolean |
GridCacheEntryEx.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheMapEntry.lockedBy(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheMapEntry.lockedByAny(GridCacheVersion... exclude) |
boolean |
GridCacheEntryEx.lockedByThread() |
boolean |
GridCacheMapEntry.lockedByThread() |
boolean |
GridCacheEntryEx.lockedByThread(long threadId) |
boolean |
GridCacheMapEntry.lockedByThread(long threadId) |
boolean |
GridCacheEntryEx.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheMapEntry.lockedByThread(long threadId,
GridCacheVersion exclude) |
boolean |
GridCacheEntryEx.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheMapEntry.lockedLocally(GridCacheVersion lockVer) |
boolean |
GridCacheEntryEx.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
boolean |
GridCacheMapEntry.lockedLocallyByIdOrThread(GridCacheVersion lockVer,
long threadId) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccLock(GridDhtTxLocalAdapter tx,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccLock(GridDhtTxLocalAdapter tx,
MvccSnapshot mvccVer) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHist,
boolean needOldValue,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHistory,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHist,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccSet(IgniteInternalTx tx,
UUID affNodeId,
CacheObject val,
javax.cache.processor.EntryProcessor entryProc,
Object[] invokeArgs,
long ttl0,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
GridCacheOperation op,
boolean needHistory,
boolean noCreate,
boolean needOldVal,
CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccUpdateRowsWithPreloadInfo(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
List<GridCacheEntryInfo> entries,
GridCacheOperation op,
MvccSnapshot mvccVer,
IgniteUuid futId,
int batchNum) |
boolean |
GridCacheEntryEx.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
boolean |
GridCacheMapEntry.onTtlExpired(GridCacheVersion obsoleteVer)
Callback from ttl processor to cache entry indicating that entry is expired.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
long |
GridCacheEntryEx.ttl() |
long |
GridCacheMapEntry.ttl() |
void |
GridCacheEntryEx.txUnlock(IgniteInternalTx tx)
Unlocks acquired lock.
|
CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswap ignoring flags.
|
CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
protected CacheDataRow |
GridCacheMapEntry.unswap(CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
void |
GridCacheEntryEx.updateIndex(SchemaIndexCacheFilter filter,
SchemaIndexCacheVisitorClosure clo)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheMapEntry.updateIndex(SchemaIndexCacheFilter filter,
SchemaIndexCacheVisitorClosure clo)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheEntryEx.updateTtl(GridCacheVersion ver,
long ttl) |
void |
GridCacheMapEntry.updateTtl(GridCacheVersion ver,
long ttl) |
CacheObject |
GridCacheEntryEx.valueBytes() |
CacheObject |
GridCacheMapEntry.valueBytes() |
CacheObject |
GridCacheEntryEx.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
CacheObject |
GridCacheMapEntry.valueBytes(GridCacheVersion ver)
Gets cached serialized value bytes.
|
GridCacheVersion |
GridCacheEntryEx.version() |
GridCacheVersion |
GridCacheMapEntry.version() |
GridCacheVersionedEntryEx |
GridCacheMapEntry.versionedEntry(boolean keepBinary)
Create versioned entry for this cache entry.
|
<K,V> GridCacheVersionedEntryEx<K,V> |
GridCacheEntryEx.versionedEntry(boolean keepBinary)
Create versioned entry for this cache entry.
|
EntryGetResult |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
EntryGetResult |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer,
IgniteCacheExpiryPolicy loadExpiryPlc,
ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridDistributedCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
void |
GridDistributedCacheEntry.addRemote(UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
GridCacheVersion owned)
Adds new lock candidate.
|
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
CacheLockCandidates |
GridDistributedCacheEntry.readyLock(GridCacheVersion ver) |
void |
GridDistributedCacheEntry.readyNearLock(GridCacheVersion ver,
GridCacheVersion mapped,
Collection<GridCacheVersion> committed,
Collection<GridCacheVersion> rolledBack,
Collection<GridCacheVersion> pending)
Notifies mvcc that near local lock is ready to be acquired.
|
void |
GridDistributedCacheEntry.removeExplicitNodeLocks(UUID nodeId)
Removes all lock candidates for node.
|
boolean |
GridDistributedCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridDistributedCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
void |
GridDistributedCacheEntry.txUnlock(IgniteInternalTx tx)
Unlocks acquired lock.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridDhtLockFuture.addEntry(GridDhtCacheEntry entry)
Adds entry to future.
|
IgniteInternalFuture<Boolean> |
GridDhtCacheEntry.addReader(UUID nodeId,
long msgId,
AffinityTopologyVersion topVer) |
Collection<GridDhtCacheEntry.ReaderId> |
GridDhtCacheEntry.checkReaders() |
protected Collection<GridDhtCacheEntry.ReaderId> |
GridDhtCacheEntry.checkReadersLocked() |
void |
GridDhtCacheEntry.clearReader(UUID nodeId) |
protected boolean |
GridDhtCacheEntry.hasReaders() |
GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver,
Collection<ClusterNode> dhtNodeIds,
Collection<ClusterNode> nearNodeIds)
Sets mappings into entry.
|
Collection<UUID> |
GridDhtCacheEntry.readers() |
boolean |
GridDhtCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridDhtCacheEntry.removeReader(UUID nodeId,
long msgId) |
boolean |
GridDhtCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
protected void |
GridDhtTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridDhtCacheEntry.versionedValue(AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheMvccCandidate |
GridNearCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
AffinityTopologyVersion topVer,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean read)
Add local candidate.
|
GridCacheMvccCandidate |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
void |
GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer) |
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 |
GridNearTxLocal.ownsLock(GridCacheEntryEx entry) |
boolean |
GridNearCacheEntry.resetFromPrimary(CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
UUID primaryNodeId,
AffinityTopologyVersion topVer)
This method should be called only when lock is owned on this entry.
|
protected void |
GridNearTxLocal.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
IgniteBiTuple<GridCacheVersion,CacheObject> |
GridNearCacheEntry.versionedValue() |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridLocalCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout,
GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
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 |
|---|---|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
GridCacheReturn ret) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
boolean |
IgniteTxAdapter.ownsLock(GridCacheEntryEx entry) |
boolean |
IgniteInternalTx.ownsLock(GridCacheEntryEx entry) |
protected void |
IgniteTxLocalAdapter.updateExplicitVersion(IgniteTxEntry txEntry,
GridCacheEntryEx entry)
Updates explicit version for tx entry based on current entry lock owner.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.5 Release Date : June 4 2019