| Modifier and Type | Class and Description |
|---|---|
class |
GridCacheMapEntry<K,V>
Adapter for cache entry.
|
| Modifier and Type | Field and Description |
|---|---|
protected GridCacheEntryEx<K,V> |
EvictableEntryImpl.cached
Cached entry.
|
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key) |
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key,
boolean touch) |
GridCacheEntryEx<K,V> |
GridCacheAdapter.entryEx(K key,
long topVer) |
protected GridCacheEntryEx<K,V> |
GridCacheAdapter.entryExSafe(K key,
long topVer) |
<V> GridCacheEntryEx<K,V> |
GridCacheMvccCandidate.parent() |
GridCacheEntryEx<K,V> |
GridCacheAdapter.peekEx(K key) |
| 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> IgniteClosure<GridCacheEntryEx<K,V>,K> |
GridCacheUtils.entry2Key() |
Iterator<GridCacheEntryEx<K,V>> |
GridCacheConcurrentMap.stripedEntryIterator(int id,
int totalCnt)
Get striped entry iterator.
|
static <K,V> IgniteClosure<IgniteTxEntry<K,V>,GridCacheEntryEx<K,V>> |
GridCacheUtils.tx2entry() |
| Modifier and Type | Method and Description |
|---|---|
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).
|
protected void |
GridCacheClearAllRunnable.clearEntry(GridCacheEntryEx<K,V> e)
Clear entry from cache.
|
boolean |
GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry,
GridCacheVersion obsoleteVer,
boolean explicit,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
V |
GridCacheProjectionEx.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheProjectionImpl.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheProxyImpl.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
V |
GridCacheAdapter.get(K key,
GridCacheEntryEx<K,V> entry,
boolean deserializePortable,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) |
protected IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
GridCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean readThrough,
GridCacheEntryEx<K,V> cached,
boolean checkTx,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean forcePrimary,
IgniteCacheExpiryPolicy expiry,
boolean skipVals) |
<K1,V1> boolean |
GridCacheContext.isAll(GridCacheEntryEx<K1,V1> e,
IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p)
Same as
GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions. |
void |
GridCacheContext.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
abstract void |
GridCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridCacheMvccFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
void |
GridCacheMvccCallback.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> prev,
GridCacheMvccCandidate<K> owner)
Called when entry lock ownership changes.
|
void |
GridCacheMvccCandidate.parent(GridCacheEntryEx<K,?> parent) |
V |
GridCacheProjectionEx.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.put(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionEx.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionEx.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.putx(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionEx.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProjectionImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheProxyImpl.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridCacheAdapter.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionEx.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProjectionImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheProxyImpl.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridCacheAdapter.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheConcurrentMap.removeEntry(GridCacheEntryEx<K,V> e)
Removes passed in entry if it presents in the map.
|
void |
GridCacheAdapter.removeEntry(GridCacheEntryEx<K,V> entry) |
boolean |
GridCacheProjectionEx.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProjectionImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheProxyImpl.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridCacheAdapter.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionEx.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProjectionImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheProxyImpl.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridCacheAdapter.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
void |
GridCacheEvictionManager.touch(GridCacheEntryEx<K,V> e,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
protected Iterator<javax.cache.Cache.Entry<K,V>> |
GridCacheAdapter.iterator(Iterator<GridCacheEntryEx<K,V>> it,
boolean deserializePortable) |
| Constructor and Description |
|---|
EvictableEntryImpl(GridCacheEntryEx<K,V> cached) |
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) |
| Modifier and Type | Class and Description |
|---|---|
class |
GridDistributedCacheEntry<K,V>
Entry for distributed (replicated/partitioned) cache.
|
| 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.
|
| 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 |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtCacheAdapter.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
void |
GridDhtCacheAdapter.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
boolean |
GridDhtLockFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback for whenever entry lock ownership changes.
|
boolean |
GridDhtTxPrepareFuture.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner) |
boolean |
GridNoStorageCacheMap.removeEntry(GridCacheEntryEx<K,V> e)
Removes passed in entry if it presents in the map.
|
protected void |
GridDhtTxLocal.updateExplicitVersion(IgniteTxEntry<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 |
GridDhtAtomicCacheEntry<K,V>
DHT atomic cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
V |
GridDhtAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridDhtAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridDhtAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridDhtAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridDhtAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridDhtAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
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.
|
| Constructor and Description |
|---|
GridNearAtomicUpdateFuture(GridCacheContext<K,V> cctx,
GridDhtAtomicCache<K,V> cache,
CacheWriteSynchronizationMode syncMode,
GridCacheOperation op,
Collection<? extends K> keys,
Collection<?> vals,
Object[] invokeArgs,
Collection<GridCacheDrInfo<V>> drPutVals,
Collection<GridCacheVersion> drRmvVals,
boolean retval,
boolean rawRetval,
GridCacheEntryEx<K,V> cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
UUID subjId,
int taskNameHash) |
| 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> |
GridDhtColocatedCache.entryExSafe(K key,
long topVer) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridDhtColocatedCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals)
This method is used internally.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNearCacheEntry<K,V>
Near cache entry.
|
| Modifier and Type | Method and Description |
|---|---|
protected GridCacheEntryEx<K,V> |
GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key)
Gets cache entry for given key.
|
protected GridCacheEntryEx<K,V> |
GridNearTxLocal.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key,
long topVer)
Gets cache entry for given key and topology version.
|
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) |
IgniteInternalFuture<Map<K,V>> |
GridNearTransactionalCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
protected IgniteInternalFuture<Map<K,V>> |
GridNearAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
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 |
GridNearTxLocal.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 |
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) |
boolean |
GridNearTxLocal.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
GridNearTxLocal.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
V |
GridNearAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridNearAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridNearAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridNearAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridNearAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridNearAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
protected void |
GridNearTxLocal.updateExplicitVersion(IgniteTxEntry<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 |
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 |
|---|---|
IgniteInternalFuture<Map<K,V>> |
GridLocalAtomicCache.getAllAsync(Collection<? extends K> keys,
boolean forcePrimary,
boolean skipTx,
GridCacheEntryEx<K,V> entry,
UUID subjId,
String taskName,
boolean deserializePortable,
boolean skipVals) |
void |
GridLocalAtomicCache.onDeferredDelete(GridCacheEntryEx<K,V> entry,
GridCacheVersion ver) |
V |
GridLocalAtomicCache.put(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridLocalAtomicCache.putAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.putx(K key,
V val,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.putxAsync(K key,
V val,
GridCacheEntryEx<K,V> entry,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
V |
GridLocalAtomicCache.remove(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<V> |
GridLocalAtomicCache.removeAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
boolean |
GridLocalAtomicCache.removex(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
IgniteInternalFuture<Boolean> |
GridLocalAtomicCache.removexAsync(K key,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Internal method that is called from
GridCacheEntryImpl. |
| Modifier and Type | Method and Description |
|---|---|
void |
CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx<K,V> e,
K key,
V oldVal,
GridCacheValueBytes oldBytes) |
void |
CacheContinuousQueryManager.onEntryUpdated(GridCacheEntryEx<K,V> e,
K key,
V newVal,
GridCacheValueBytes newBytes,
V oldVal,
GridCacheValueBytes oldBytes,
boolean preload) |
| Modifier and Type | Method and Description |
|---|---|
GridCacheEntryEx<K,V> |
IgniteTxEntry.cached() |
protected GridCacheEntryEx<K,V> |
IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key)
Gets cache entry for given key.
|
protected GridCacheEntryEx<K,V> |
IgniteTxLocalAdapter.entryEx(GridCacheContext<K,V> cacheCtx,
IgniteTxKey<K> key,
long topVer)
Gets cache entry for given key and topology version.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteTxEntry<K,V> |
IgniteTxLocalAdapter.addEntry(GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor entryProcessor,
Object[] invokeArgs,
GridCacheEntryEx<K,V> entry,
javax.cache.expiry.ExpiryPolicy expiryPlc,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
boolean filtersSet,
long drTtl,
long drExpireTime,
GridCacheVersion drVer) |
void |
IgniteTxEntry.cached(GridCacheEntryEx<K,V> entry,
byte[] keyBytes) |
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext<K,V>> |
IgniteTxAdapter.conflictResolve(GridCacheOperation op,
K key,
V newVal,
byte[] newValBytes,
long newTtl,
long newDrExpireTime,
GridCacheVersion newVer,
GridCacheEntryEx<K,V> old)
Resolve DR conflict.
|
protected IgniteInternalFuture<Set<K>> |
IgniteTxLocalAdapter.enlistWrite(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
javax.cache.expiry.ExpiryPolicy expiryPlc,
boolean implicit,
Map<? extends K,? extends V> lookup,
Map<? extends K,javax.cache.processor.EntryProcessor<K,V,Object>> invokeMap,
Object[] invokeArgs,
boolean retval,
boolean lockOnly,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter,
GridCacheReturn<V> ret,
Collection<K> enlisted,
Map<? extends K,GridCacheDrInfo<V>> drPutMap,
Map<? extends K,GridCacheVersion> drRmvMap)
Internal routine for putAll(..)
|
IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalEx.getAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean deserializePortable,
boolean skipVals) |
IgniteInternalFuture<Map<K,V>> |
IgniteTxLocalAdapter.getAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean deserializePortable,
boolean skipVals) |
boolean |
IgniteTxManager.onOwnerChanged(GridCacheEntryEx<K,V> entry,
GridCacheMvccCandidate<K> owner)
Callback invoked whenever a member of a transaction acquires
lock ownership.
|
boolean |
IgniteInternalTx.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 |
IgniteTxLocalAdapter.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 |
IgniteTxAdapter.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
IgniteInternalTx.ownsLock(GridCacheEntryEx<K,V> entry) |
boolean |
IgniteTxAdapter.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
boolean |
IgniteInternalTx.ownsLockUnsafe(GridCacheEntryEx<K,V> entry) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.putAllAsync(GridCacheContext<K,V> cacheCtx,
Map<? extends K,? extends V> map,
boolean retval,
GridCacheEntryEx<K,V> cached,
long ttl,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalEx.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
IgniteInternalFuture<GridCacheReturn<V>> |
IgniteTxLocalAdapter.removeAllAsync(GridCacheContext<K,V> cacheCtx,
Collection<? extends K> keys,
GridCacheEntryEx<K,V> cached,
boolean retval,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) |
protected void |
IgniteTxLocalAdapter.updateExplicitVersion(IgniteTxEntry<K,V> txEntry,
GridCacheEntryEx<K,V> entry)
Updates explicit version for tx entry based on current entry lock owner.
|
| Constructor and Description |
|---|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
javax.cache.processor.EntryProcessor<K,V,?> entryProcessor,
Object[] invokeArgs,
long ttl,
GridCacheEntryEx<K,V> entry,
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters,
GridCacheVersion drVer)
This constructor is meant for local transactions.
|
IgniteTxEntry(GridCacheContext<K,V> ctx,
IgniteInternalTx<K,V> tx,
GridCacheOperation op,
V val,
long ttl,
long drExpireTime,
GridCacheEntryEx<K,V> entry,
GridCacheVersion drVer)
This constructor is meant for remote transactions.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 17 2015