| Package | Description |
|---|---|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed | |
| org.apache.ignite.internal.processors.cache.distributed.dht | |
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.transactions |
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheMvccCandidate |
GridCacheEntryEx.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
@Nullable GridCacheMvccCandidate |
GridCacheMapEntry.candidate(GridCacheVersion ver)
Gets lock candidate for given lock ID.
|
@Nullable 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,
@Nullable 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,
boolean primary)
Sets new value if current version is 0
|
default boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
boolean primary)
Sets new value if current version is 0
|
boolean |
GridCacheEntryEx.initialValue(CacheObject val,
GridCacheVersion ver,
@Nullable MvccVersion mvccVer,
@Nullable MvccVersion newMvccVer,
byte mvccTxState,
byte newMvccTxState,
long ttl,
long expireTime,
boolean preload,
AffinityTopologyVersion topVer,
GridDrType drType,
boolean fromStore,
boolean primary,
@Nullable CacheDataRow row)
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,
boolean primary,
CacheDataRow row)
Sets new value if current version is 0
|
CacheObject |
GridCacheEntryEx.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary) |
CacheObject |
GridCacheMapEntry.innerGet(@Nullable GridCacheVersion ver,
@Nullable IgniteInternalTx tx,
boolean readThrough,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expirePlc,
boolean keepBinary) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean updateMetrics,
boolean evt,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(@Nullable GridCacheVersion ver,
IgniteInternalTx tx,
boolean updateMetrics,
boolean evt,
Object transformClo,
String taskName,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
@Nullable ReaderArguments readerArgs) |
@Nullable CacheObject |
GridCacheEntryEx.innerReload()
Reloads entry from underlying storage.
|
@Nullable CacheObject |
GridCacheMapEntry.innerReload()
Reloads entry from underlying storage.
|
GridCacheUpdateTxResult |
GridCacheEntryEx.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean retval,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
@Nullable CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(@Nullable IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
boolean keepBinary,
boolean oldValPresent,
@Nullable CacheObject oldVal,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
@Nullable GridCacheVersion explicitVer,
String taskName,
@Nullable GridCacheVersion dhtVer,
@Nullable Long updateCntr) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object val,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean checkVer,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long conflictTtl,
long conflictExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
@Nullable Object writeObj,
@Nullable Object[] invokeArgs,
boolean writeThrough,
boolean readThrough,
boolean retval,
boolean keepBinary,
@Nullable IgniteCacheExpiryPolicy expiryPlc,
boolean evt,
boolean metrics,
boolean primary,
boolean verCheck,
boolean readRepairRecovery,
AffinityTopologyVersion topVer,
@Nullable CacheEntryPredicate[] filter,
GridDrType drType,
long explicitTtl,
long explicitExpireTime,
@Nullable GridCacheVersion conflictVer,
boolean conflictResolve,
boolean intercept,
String taskName,
@Nullable CacheObject prevVal,
@Nullable Long updateCntr,
@Nullable GridDhtAtomicAbstractUpdateFuture fut,
boolean transformOp) |
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.
|
@Nullable 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.
|
@Nullable 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) |
@Nullable CacheObject |
GridCacheEntryEx.mvccPeek(boolean onheapOnly)
Retrieves the last committed MVCC entry version.
|
@Nullable CacheObject |
GridCacheMapEntry.mvccPeek(boolean onheapOnly)
Retrieves the last committed MVCC entry version.
|
boolean |
GridCacheEntryEx.mvccPreloadEntry(List<GridCacheMvccEntryInfo> entries)
Apply entry history if not exists.
|
boolean |
GridCacheMapEntry.mvccPreloadEntry(List<GridCacheMvccEntryInfo> entryHist)
Apply entry history if not exists.
|
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccRemove(@Nullable IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHist,
boolean needOldValue,
@Nullable CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheMapEntry.mvccRemove(IgniteInternalTx tx,
UUID affNodeId,
AffinityTopologyVersion topVer,
MvccSnapshot mvccVer,
boolean needHistory,
boolean needOldVal,
@Nullable CacheEntryPredicate filter,
boolean retVal) |
GridCacheUpdateTxResult |
GridCacheEntryEx.mvccSet(@Nullable 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,
@Nullable CacheEntryPredicate filter,
boolean retVal,
boolean keepBinary) |
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,
boolean keepBinary) |
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.
|
@Nullable CacheObject |
GridCacheEntryEx.peek()
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheMapEntry.peek()
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
@Nullable CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
AffinityTopologyVersion topVer,
@Nullable IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout,
@Nullable GridCacheVersion serOrder,
@Nullable 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.
|
void |
GridCacheMapEntry.txUnlock(IgniteInternalTx tx)
Unlocks acquired lock.
|
@Nullable CacheObject |
GridCacheEntryEx.unswap() |
CacheObject |
GridCacheMapEntry.unswap() |
@Nullable CacheObject |
GridCacheEntryEx.unswap(boolean needVal)
Unswap ignoring flags.
|
@Nullable CacheObject |
GridCacheMapEntry.unswap(boolean needVal)
Unswap ignoring flags.
|
@Nullable CacheObject |
GridCacheEntryEx.unswap(CacheDataRow row) |
CacheObject |
GridCacheMapEntry.unswap(CacheDataRow row) |
protected @Nullable CacheDataRow |
GridCacheMapEntry.unswap(@Nullable CacheDataRow row,
boolean checkExpire)
Unswaps an entry.
|
void |
GridCacheEntryEx.updateIndex(SchemaIndexCacheVisitorClosure clo)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheMapEntry.updateIndex(SchemaIndexCacheVisitorClosure clo)
Update index from within entry lock, passing key, value, and expiration time to provided closure.
|
void |
GridCacheEntryEx.updateTtl(GridCacheVersion ver,
IgniteCacheExpiryPolicy expiryPlc) |
void |
GridCacheMapEntry.updateTtl(GridCacheVersion ver,
IgniteCacheExpiryPolicy expiryPlc) |
void |
GridCacheEntryEx.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
void |
GridCacheMapEntry.updateTtl(@Nullable GridCacheVersion ver,
long ttl) |
CacheObject |
GridCacheEntryEx.valueBytes() |
CacheObject |
GridCacheMapEntry.valueBytes() |
@Nullable CacheObject |
GridCacheEntryEx.valueBytes(@Nullable GridCacheVersion ver)
Gets cached serialized value bytes.
|
@Nullable CacheObject |
GridCacheMapEntry.valueBytes(@Nullable 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,
@Nullable GridCacheVersion curVer,
@Nullable GridCacheVersion newVer,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable 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,
@Nullable IgniteCacheExpiryPolicy loadExpiryPlc,
@Nullable ReaderArguments readerArgs)
Sets new value if passed in version matches the current version
(used for read-through only).
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable 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,
@Nullable UUID otherNodeId,
long threadId,
GridCacheVersion ver,
boolean tx,
boolean implicitSingle,
@Nullable GridCacheVersion owned)
Adds new lock candidate.
|
void |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
@Nullable Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
@Nullable 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,
@Nullable GridCacheVersion serOrder,
GridCacheVersion serReadVer,
boolean read)
This locks is called by transaction manager during prepare step
for optimistic transactions.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable GridCacheMvccCandidate |
GridDhtLockFuture.addEntry(GridDhtCacheEntry entry)
Adds entry to future.
|
@Nullable 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() |
@Nullable 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,
@Nullable 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.
|
@Nullable 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.
|
@Nullable GridCacheMvccCandidate |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
@Nullable GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
void |
GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer) |
boolean |
GridNearCacheEntry.loadedValue(@Nullable IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
long ttl,
long expireTime,
boolean evt,
boolean keepBinary,
AffinityTopologyVersion topVer) |
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.
|
@Nullable IgniteBiTuple<GridCacheVersion,CacheObject> |
GridNearCacheEntry.versionedValue() |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteBiTuple<GridCacheOperation,CacheObject> |
IgniteTxAdapter.applyTransformClosures(IgniteTxEntry txEntry,
boolean metrics,
@Nullable 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.15.0 Release Date : April 25 2023