| 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() |
protected void |
GridCacheMapEntry.clearReader(UUID nodeId) |
boolean |
GridCacheContext.dhtMap(UUID nearNodeId,
AffinityTopologyVersion topVer,
GridDhtCacheEntry entry,
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)
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)
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(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expiryPlc) |
CacheObject |
GridCacheMapEntry.innerGet(IgniteInternalTx tx,
boolean readSwap,
boolean readThrough,
boolean failFast,
boolean unmarshal,
boolean updateMetrics,
boolean evt,
boolean tmp,
UUID subjId,
Object transformClo,
String taskName,
IgniteCacheExpiryPolicy expirePlc) |
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 writeThrough,
boolean retval,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerRemove(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
boolean writeThrough,
boolean retval,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheEntryEx.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateTxResult |
GridCacheMapEntry.innerSet(IgniteInternalTx tx,
UUID evtNodeId,
UUID affNodeId,
CacheObject val,
boolean writeThrough,
boolean retval,
long ttl,
boolean evt,
boolean metrics,
AffinityTopologyVersion topVer,
CacheEntryPredicate[] filter,
GridDrType drType,
long drExpireTime,
GridCacheVersion explicitVer,
UUID subjId,
String taskName) |
GridCacheUpdateAtomicResult |
GridCacheEntryEx.innerUpdate(GridCacheVersion ver,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object val,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
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) |
GridCacheUpdateAtomicResult |
GridCacheMapEntry.innerUpdate(GridCacheVersion newVer,
UUID evtNodeId,
UUID affNodeId,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
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) |
GridTuple3<Boolean,Object,javax.cache.processor.EntryProcessorResult<Object>> |
GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver,
GridCacheOperation op,
Object writeObj,
Object[] invokeArgs,
boolean writeThrough,
boolean retval,
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 retval,
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) |
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(Collection<GridCachePeekMode> modes,
CacheEntryPredicate... filter)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(Collection<GridCachePeekMode> modes,
CacheEntryPredicate[] filter)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheEntryEx.peek(GridCachePeekMode mode,
CacheEntryPredicate... filter)
Peeks into entry without loading value or updating statistics.
|
CacheObject |
GridCacheMapEntry.peek(GridCachePeekMode mode,
CacheEntryPredicate[] filter)
Peeks into entry without loading value or updating statistics.
|
GridTuple<CacheObject> |
GridCacheEntryEx.peek0(boolean failFast,
GridCachePeekMode mode,
CacheEntryPredicate[] filter,
IgniteInternalTx tx) |
GridTuple<CacheObject> |
GridCacheMapEntry.peek0(boolean failFast,
GridCachePeekMode mode,
CacheEntryPredicate[] filter,
IgniteInternalTx tx) |
CacheObject |
GridCacheEntryEx.poke(CacheObject val)
This method overwrites current in-memory value with new value.
|
CacheObject |
GridCacheMapEntry.poke(CacheObject val)
This method overwrites current in-memory value with new value.
|
boolean |
GridCacheEntryEx.removeLock(GridCacheVersion ver) |
boolean |
GridCacheEntryEx.tmLock(IgniteInternalTx tx,
long timeout)
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.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() |
boolean |
GridCacheEntryEx.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
Sets new value if passed in version matches the current version
(used for read-through only).
|
boolean |
GridCacheMapEntry.versionedValue(CacheObject val,
GridCacheVersion curVer,
GridCacheVersion newVer)
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,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
void |
GridDistributedCacheEntry.addRemote(GridCacheMvccCandidate cand)
Adds new lock candidate.
|
void |
GridDistributedCacheEntry.addRemote(UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle,
GridCacheVersion owned)
Adds new lock candidate.
|
GridCacheMvccCandidate |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
GridCacheMvccCandidate |
GridDistributedCacheEntry.doneRemote(GridCacheVersion lockVer,
GridCacheVersion baseVer,
Collection<GridCacheVersion> pendingVers,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers,
boolean sysInvalidate) |
void |
GridDistributedCacheEntry.orderCompleted(GridCacheVersion baseVer,
Collection<GridCacheVersion> committedVers,
Collection<GridCacheVersion> rolledbackVers)
Reorders completed versions.
|
GridCacheMvccCandidate |
GridDistributedCacheEntry.readyLock(GridCacheVersion ver) |
GridCacheMvccCandidate |
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)
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 |
GridDhtCacheEntry.addDhtLocal(UUID nearNodeId,
GridCacheVersion nearVer,
AffinityTopologyVersion topVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
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.localCandidateByNearVersion(GridCacheVersion nearVer,
boolean rmv) |
GridCacheMvccCandidate |
GridDhtCacheEntry.mappings(GridCacheVersion ver)
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)
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,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
GridCacheMvccCandidate |
GridNearCacheEntry.addNearLocal(UUID dhtNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add near local candidate.
|
GridCacheMvccCandidate |
GridNearCacheEntry.dhtNodeId(GridCacheVersion ver,
UUID dhtNodeId) |
GridCacheVersion |
GridNearCacheEntry.dhtVersion() |
boolean |
GridNearCacheEntry.initializeFromDht(AffinityTopologyVersion topVer) |
boolean |
GridNearCacheEntry.loadedValue(IgniteInternalTx tx,
UUID primaryNodeId,
CacheObject val,
GridCacheVersion ver,
GridCacheVersion dhtVer,
GridCacheVersion expVer,
long ttl,
long expireTime,
boolean evt,
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 |
|---|---|
GridCacheMvccCandidate |
GridLocalCacheEntry.addLocal(long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle)
Add local candidate.
|
boolean |
GridLocalCacheEntry.removeLock(GridCacheVersion ver) |
boolean |
GridLocalCacheEntry.tmLock(IgniteInternalTx tx,
long timeout)
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) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
IgniteTxEntry txEntry,
CacheObject newVal,
GridCacheVersion newVer,
GridCacheEntryEx old)
Resolve DR conflict.
|
boolean |
IgniteInternalTx.ownsLock(GridCacheEntryEx entry) |
boolean |
IgniteTxAdapter.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.0.0 Release Date : March 31 2015