| 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() |
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 |
GridCacheMapEntry.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(KeyCacheObject key,
GridCacheSwapEntry unswapped)
Sets new value if current version is 0 using swap entry data.
|
boolean |
GridCacheMapEntry.initialValue(KeyCacheObject key,
GridCacheSwapEntry unswapped)
Sets new value if current version is 0 using swap entry data.
|
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) |
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) |
EntryGetResult |
GridCacheEntryEx.innerGetAndReserveForLoad(boolean readSwap,
boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetAndReserveForLoad(boolean readSwap,
boolean updateMetrics,
boolean evt,
UUID subjId,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheEntryEx.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
ReaderArguments readerArgs) |
EntryGetResult |
GridCacheMapEntry.innerGetVersioned(GridCacheVersion ver,
IgniteInternalTx tx,
boolean readSwap,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc,
boolean keepBinary,
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) |
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.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 |
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) |
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) |
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) |
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)
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)
Update method for local cache in atomic mode.
|
boolean |
GridCacheEntryEx.invalidate(CacheEntryPredicate[] filter)
Invalidates this entry if it passes given filter.
|
boolean |
GridCacheMapEntry.invalidate(CacheEntryPredicate[] filter)
Invalidates this entry if it passes given filter.
|
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) |
boolean |
GridCacheEntryEx.onOffheapEvict(byte[] entry,
GridCacheVersion evictVer,
GridCacheVersion obsoleteVer)
Called when entry should be evicted from offheap.
|
boolean |
GridCacheMapEntry.onOffheapEvict(byte[] entry,
GridCacheVersion evictVer,
GridCacheVersion obsoleteVer)
Called when entry should be evicted from offheap.
|
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,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
boolean swap,
AffinityTopologyVersion topVer,
IgniteCacheExpiryPolicy expiryPlc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(boolean heap,
boolean offheap,
boolean swap,
IgniteCacheExpiryPolicy plc)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(boolean heap,
boolean offheap,
boolean swap,
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.
|
protected CacheObject |
GridCacheMapEntry.unswap(boolean needVal,
boolean checkExpire)
Unswaps an entry.
|
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<org.apache.ignite.internal.processors.cache.distributed.dht.GridDhtCacheEntry.ReaderId> |
GridDhtCacheEntry.checkReaders() |
protected Collection<org.apache.ignite.internal.processors.cache.distributed.dht.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 Fabric : ver. 1.9.0 Release Date : March 2 2017