| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheMapEntry<K,V>
Adapter for cache entry.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheEntryEx<K,V> |
GridCacheEvictionEntry.cached
Cached entry.
|
protected GridCacheEntryEx<K,V> |
GridCacheEntryImpl.cached
Cached entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx<K,V> |
GridCacheTxEntry.cached() |
protected GridCacheEntryEx<K,V> |
GridCacheEntryImpl.entryEx(boolean touch,
long topVer) |
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key) |
protected GridCacheEntryEx<K,V> |
GridCacheTxLocalAdapter.entryEx(K key)
Gets cache entry for given key.
|
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key,
boolean touch) |
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key,
long topVer) |
protected GridCacheEntryEx<K,V> |
GridCacheTxLocalAdapter.entryEx(K key,
long topVer)
Gets cache entry for given key and topology version.
|
protected GridCacheEntryEx<K,V> |
GridCacheAdapter.entryExSafe(K key,
long topVer) |
<V> GridCacheEntryEx<K,V> |
GridCacheMvccCandidate.parent() |
GridCacheEntryEx<K,V> |
GridCacheAdapter.peekEx(K key) |
protected GridCacheEntryEx<K,V> |
GridCacheEntryImpl.peekEx(long topVer) |
GridCacheEntryEx<K,V> |
GridCacheEntryImpl.unwrapNoCreate() |
| Modifier and Type | Method and Description |
|---|---|
Set<GridCacheEntryEx<K,V>> |
GridCacheAdapter.allEntries() |
Set<GridCacheEntryEx<K,V>> |
GridCacheConcurrentMap.allEntries0()
Gets all internal entry set, including
GridCacheInternal entries. |
Set<GridCacheEntryEx<K,V>> |
GridCacheAdapter.entries() |
Set<GridCacheEntryEx<K,V>> |
GridCacheConcurrentMap.entries0()
Internal entry set, excluding
GridCacheInternal entries. |
static <K,V> GridClosure<GridCacheEntryEx<K,V>,K> |
GridCacheUtils.entry2Key() |
Iterator<GridCacheEntryEx<K,V>> |
GridCacheConcurrentMap.stripedEntryIterator(int id,
int totalCnt)
Get striped entry iterator.
|
static <K,V> GridClosure<GridCacheTxEntry<K,V>,GridCacheEntryEx<K,V>> |
GridCacheUtils.tx2entry() |
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheTxEntry<K,V> |
GridCacheTxLocalAdapter.addEntry(GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addLocal(GridCacheEntryEx<K,?> parent,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addLocal(GridCacheEntryEx<K,?> parent,
UUID nearNodeId,
GridCacheVersion nearVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean reenter,
boolean tx,
boolean implicitSingle,
boolean dhtLoc) |
GridCacheMvccCandidate<K> |
GridCacheMvcc.addNearLocal(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle)
Adds new near local lock candidate.
|
GridCacheMvccCandidate<K> |
GridCacheMvcc.addRemote(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
long threadId,
GridCacheVersion ver,
long timeout,
boolean tx,
boolean implicitSingle,
boolean nearLoc)
Adds new remote lock candidate (either near remote or dht remote).
|
void |
GridCacheTxEntry.cached(GridCacheEntryEx<K,V> entry,
byte[] keyBytes) |
protected void |
GridCacheClearAllRunnable.clearEntry(GridCacheEntryEx<K,V> e)
Clear entry from cache.
|
protected GridBiTuple<GridCacheOperation,GridDrReceiverConflictContextImpl<K,V>> |
GridCacheTxAdapter.drResolveConflict(GridCacheOperation op,
K key,
V newVal,
byte[] newValBytes,
long newTtl,
long newDrExpireTime,
GridCacheVersion newVer,
GridCacheEntryEx<K,V> old)
Resolve DR conflict.
|
protected GridFuture<Set<K>> |
GridCacheTxLocalAdapter.enlistWrite(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
long ttl,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,? extends GridClosure<V,V>> transformMap,
boolean retval,
boolean lockOnly,
GridPredicate<GridCacheEntry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter) |
protected GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean checkTx,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalAdapter.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Map<K,V>> |
GridCacheTxLocalEx.getAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
<K,V> boolean |
GridCacheContext.isAll(GridCacheEntryEx<K,V> e,
GridPredicate<GridCacheEntry<K,V>>[] p)
Same as
GridFunc.isAll(Object, GridPredicate[]), but safely unwraps
exceptions. |
abstract void |
GridCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridCacheContext.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridCacheMvccFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
boolean |
GridCacheTxEx.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
boolean |
GridCacheTxManager.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback invoked whenever a member of a transaction acquires
lock ownership.
|
boolean |
GridCacheTxLocalAdapter.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
void |
GridCacheMvccCallback.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> prev,
GridCacheMvccCandidate<K> owner)
Called when entry lock ownership changes.
|
boolean |
GridCacheTxAdapter.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
GridCacheTxEx.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
GridCacheTxAdapter.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
boolean |
GridCacheTxEx.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
void |
GridCacheMvccCandidate.parent(GridCacheEntryEx<K,?> parent) |
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putAllAsync(Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheTxLocalEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheTxLocalEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.putxAsync0(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheTxLocalAdapter.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
V |
GridCacheTxLocalEx.remove(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removeAllAsync(Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean implicit,
boolean retval,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridCacheTxLocalAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<V> |
GridCacheTxLocalEx.removeAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
boolean |
GridCacheConcurrentMap.removeEntry(GridCacheEntryEx<K,V> e)
Removes passed in entry if it presents in the map.
|
protected void |
GridCacheAdapter.removeEntry(GridCacheEntryEx<K,V> entry) |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheTxLocalAdapter.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
boolean |
GridCacheTxLocalEx.removex(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
GridFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<Boolean> |
GridCacheTxLocalEx.removexAsync(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalAdapter.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
GridFuture<GridCacheReturn<V>> |
GridCacheTxLocalEx.removexAsync0(K key,
GridCacheEntryEx<K,V> cached,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Asynchronous remove.
|
void |
GridCacheEvictionManager.touch(GridCacheEntryEx<K,V> e,
long topVer) |
GridFuture<?> |
GridCacheProjectionEx.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheProjectionImpl.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheAdapter.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridCacheProxyImpl.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridCacheTxLocalAdapter.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> cached,
long ttl) |
GridFuture<Boolean> |
GridCacheTxLocalEx.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> cached,
long ttl) |
protected void |
GridCacheTxLocalAdapter.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry,
GridCacheEntryEx<K,V> entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Constructor and Description |
|---|
GridCacheEntryImpl(GridCacheProjectionImpl<K,V> prj,
GridCacheContext<K,V> ctx,
K key,
GridCacheEntryEx<K,V> cached) |
GridCacheEvictionEntry(GridCacheEntryEx<K,V> cached) |
GridCacheFilterEvaluationEntry(K key,
V val,
GridCacheEntryEx<K,V> impl) |
GridCacheFilterEvaluationEntry(K key,
V val,
GridCacheEntryEx<K,V> impl,
boolean allowTx) |
GridCacheMvccCandidate(GridCacheEntryEx<K,?> parent,
UUID nodeId,
UUID otherNodeId,
GridCacheVersion otherVer,
long threadId,
GridCacheVersion ver,
long timeout,
boolean loc,
boolean reentry,
boolean tx,
boolean singleImplicit,
boolean nearLoc,
boolean dhtLoc) |
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
GridClosure<V,V> transformClos,
long ttl,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
GridCacheTxEntry(GridCacheContext<K,V> ctx,
GridCacheTxEx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedCacheEntry<K,V>
Entry for distributed (replicated/partitioned) cache.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx<K,V> |
GridPartitionedCacheEntryImpl.entryEx(boolean touch,
long topVer) |
protected GridCacheEntryEx<K,V> |
GridPartitionedCacheEntryImpl.peekEx(long topVer) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDistributedTxRemoteAdapter.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback invoked whenever there is a lock that has been acquired
by this transaction for any of the participating entries.
|
| Constructor and Description |
|---|
GridPartitionedCacheEntryImpl(GridCacheProjectionImpl<K,V> nearPrj,
GridCacheContext<K,V> ctx,
K key,
GridCacheEntryEx<K,V> cached) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtCacheEntry<K,V>
Replicated cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx<K,V> |
GridDhtCacheAdapter.entryEx(K key,
boolean touch) |
GridCacheEntryEx<K,V> |
GridDhtCacheAdapter.entryEx(K key,
long topVer) |
GridCacheEntryEx<K,V> |
GridDhtCacheAdapter.entryExx(K key,
long topVer,
boolean allowDetached,
boolean touch)
Gets or creates entry for given key.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridDhtTxPrepareFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
boolean |
GridDhtLockFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback for whenever entry lock ownership changes.
|
boolean |
GridNoStorageCacheMap.removeEntry(GridCacheEntryEx<K,V> e)
Removes passed in entry if it presents in the map.
|
protected void |
GridDhtTxLocal.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry,
GridCacheEntryEx<K,V> entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Constructor and Description |
|---|
GridDhtCacheEntryImpl(GridCacheProjectionImpl<K,V> nearPrj,
GridCacheContext<K,V> ctx,
K key,
GridCacheEntryEx<K,V> cached) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtAtomicCacheEntry<K,V>
DHT atomic cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridDhtAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridDhtAtomicCache.updateAllAsyncInternal(UUID nodeId,
GridNearAtomicUpdateRequest<K,V> req,
GridCacheEntryEx<K,V> cached,
CI2<GridNearAtomicUpdateRequest<K,V>,GridNearAtomicUpdateResponse<K,V>> completionCb)
Executes local update.
|
void |
GridDhtAtomicCache.updateAllAsyncInternal0(UUID nodeId,
GridNearAtomicUpdateRequest<K,V> req,
GridCacheEntryEx<K,V> cached,
CI2<GridNearAtomicUpdateRequest<K,V>,GridNearAtomicUpdateResponse<K,V>> completionCb)
Executes local update after preloader fetched values.
|
| Constructor and Description |
|---|
GridNearAtomicUpdateFuture(GridCacheContext<K,V> cctx,
GridDhtAtomicCache<K,V> cache,
GridCacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<? extends K> keys,
Collection<?> vals,
Collection<GridCacheDrInfo<V>> drPutVals,
Collection<GridCacheVersion> drRmvVals,
boolean retval,
boolean rawRetval,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter,
UUID subjId) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDhtColocatedCacheEntry<K,V>
Cache entry for colocated cache.
|
class |
GridDhtDetachedCacheEntry<K,V>
Detached cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx<K,V> |
GridDhtColocatedTxLocal.entryEx(K key)
Gets cache entry for given key.
|
protected GridCacheEntryEx<K,V> |
GridDhtColocatedTxLocal.entryEx(K key,
long topVer)
Gets cache entry for given key and topology version.
|
protected GridCacheEntryEx<K,V> |
GridDhtColocatedCache.entryExSafe(K key,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter)
This method is used internally.
|
boolean |
GridDhtColocatedTxLocal.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
GridDhtColocatedTxLocal.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
protected void |
GridDhtColocatedTxLocal.updateExplicitVersion(GridCacheTxEntry<K,V> txEntry,
GridCacheEntryEx<K,V> entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearCacheEntry<K,V>
Near cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx<K,V> |
GridNearCacheAdapter.entryEx(K key,
boolean touch) |
GridCacheEntryEx<K,V> |
GridNearCacheAdapter.entryEx(K key,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
protected boolean |
GridNearTransactionalCache.evictNearEntry(GridCacheEntryEx<K,V> e,
GridCacheVersion obsoleteVer,
long topVer) |
protected GridFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>... filter) |
GridFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
protected boolean |
GridNearTransactionalCache.isNearLocallyMapped(GridCacheEntryEx<K,V> e,
long topVer) |
void |
GridNearTransactionalCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
void |
GridNearAtomicCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridNearLockFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback for whenever entry lock ownership changes.
|
boolean |
GridNearTxPrepareFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridNearAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridLocalCacheEntry<K,V>
Cache entry for local caches.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridLocalCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridLocalLockFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
| Modifier and Type | Method and Description |
|---|---|
GridFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
GridPredicate<GridCacheEntry<K,V>>[] filter) |
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
GridPredicate<GridCacheEntry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
GridFuture<?> |
GridLocalAtomicCache.transformAsync(K key,
GridClosure<V,V> transformer,
GridCacheEntryEx<K,V> entry,
long ttl)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheContinuousQueryManager.onEntryUpdate(GridCacheEntryEx<K,V> e,
K key,
V val,
GridCacheValueBytes valBytes,
boolean unwind) |
Copyright © 2014. All rights reserved.