org.gridgain.grid.kernal.processors.cache

Class GridCacheMapEntry<K,V>

java.lang.Object

org.gridgain.grid.kernal.processors.cache.GridCacheMapEntry<K,V>

All Implemented Interfaces:

Serializable, GridMetadataAware, GridCacheEntryEx<K,V>

Direct Known Subclasses:

GridDistributedCacheEntry, GridLocalCacheEntry

public abstract class GridCacheMapEntry<K,V>
extends Object
implements GridCacheEntryEx<K,V>

Adapter for cache entry.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected GridCacheContext<K,V>	cctx Cache registry.
protected byte	flags Flags: Refreshing flag - mask IS_REFRESHING_MASK Deleted flag - mask IS_DELETED_MASK
protected K	key Key.
protected static GridLogger	log Logger.
protected static AtomicReference<GridLogger>	logRef Static logger to avoid re-creation.
protected long	startVer Start version.
protected V	val Value.
protected byte[]	valBytes Value bytes.
protected GridCacheVersion	ver Version.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	GridCacheMapEntry(GridCacheContext<K,V> cctx, K key, int hash, V val, GridCacheMapEntry<K,V> next, long ttl, int hdrId)

Method Summary

Methods

Modifier and Type	Method and Description
<V> V	addMeta(String name, V val) Adds a new metadata.
<V> V	addMetaIfAbsent(String name, Callable<V> c) Adds given metadata value only if it was absent.
<V> V	addMetaIfAbsent(String name, V val) Adds given metadata value only if it was absent.
<V> Map<String,V>	allMeta() Gets all metadata in this entry.
GridCacheMvccCandidate<K>	candidate(GridCacheVersion ver) Gets lock candidate for given lock ID.
GridCacheMvccCandidate<K>	candidate(UUID nodeId, long threadId)
protected void	checkObsolete()
boolean	clear(GridCacheVersion ver, boolean readers, GridPredicate<GridCacheEntry<K,V>>[] filter) Marks entry as obsolete and, if possible or required, removes it from swap storage.
protected void	clearIndex(V prevVal) Clears index.
protected void	clearReaders()
boolean	compact(GridPredicate<GridCacheEntry<K,V>>[] filter) Optimizes the size of this entry.
GridCacheContext<K,V>	context()
void	copyMeta(GridMetadataAware from) Copies all metadata from another instance.
void	copyMeta(Map<String,?> attrData) Copies all metadata from given map.
protected GridCacheValueBytes	createValueBytes(V val) Create value bytes wrapper from the given object.
boolean	deleted() Note: this method works only for cache configured in ATOMIC mode or for cache that is data center replication target.
protected boolean	deletedUnlocked()
protected void	deletedUnlocked(boolean deleted)
boolean	detached()
GridDrEntry<K,V>	drEntry() Create DR entry for that cache entry.
boolean	equals(Object o)
GridCacheBatchSwapEntry<K,V>	evictInBatchInternal(GridCacheVersion obsoleteVer) Evicts entry when batch evict is performed.
boolean	evictInternal(boolean swap, GridCacheVersion obsoleteVer, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheEntry<K,V>	evictWrap()
long	expireTime()
protected long	expireTimeExtras()
long	expireTimeUnlocked()
byte[]	getOrMarshalKeyBytes()
int	hashCode()
boolean	hasLockCandidate(GridCacheVersion ver) Checks if the candidate is either owner or pending.
boolean	hasLockCandidate(long threadId) Checks if the candidate is either owner or pending.
boolean	hasLockCandidateUnsafe(GridCacheVersion ver)
boolean	hasMeta(String name) Tests whether or not given metadata is set.
<V> boolean	hasMeta(String name, V val) Tests whether or not metadata with given name and value is set.
protected boolean	hasReaders()
boolean	hasValue()
protected boolean	hasValueUnlocked()
GridCacheEntryInfo<K,V>	info()
boolean	initialValue(K key, GridCacheSwapEntry<V> unswapped) Sets new value if current version is 0 using swap entry data.
boolean	initialValue(V val, byte[] valBytes, GridCacheVersion ver, long ttl, long expireTime, boolean preload, long topVer, GridDrType drType) Sets new value if current version is 0
V	innerGet(GridCacheTxEx<K,V> tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, UUID subjId, GridPredicate<GridCacheEntry<K,V>>[] filter)
V	innerReload(GridPredicate<GridCacheEntry<K,V>>[] filter) Reloads entry from underlying storage.
GridCacheUpdateTxResult<V>	innerRemove(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId)
GridCacheUpdateTxResult<V>	innerSet(GridCacheTxEx<K,V> tx, UUID evtNodeId, UUID affNodeId, V val, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, long topVer, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId)
GridCacheUpdateAtomicResult<K,V>	innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object writeObj, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, boolean primary, boolean verCheck, GridPredicate<GridCacheEntry<K,V>>[] filter, GridDrType drType, long drTtl, long drExpireTime, GridCacheVersion drVer, boolean drResolve, boolean intercept, UUID subjId)
GridBiTuple<Boolean,V>	innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, Object writeObj, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, GridPredicate<GridCacheEntry<K,V>>[] filter, boolean intercept, UUID subjId) Update method for local cache in atomic mode.
boolean	invalidate(GridCacheVersion curVer, GridCacheVersion newVer) Invalidates this entry.
boolean	invalidate(GridPredicate<GridCacheEntry<K,V>>[] filter) Invalidates this entry if it passes given filter.
boolean	isDht()
boolean	isInternal()
boolean	isLocal()
boolean	isNear()
boolean	isNew() Checks if entry is new assuming lock is held externally.
boolean	isNewLocked() Checks if entry is new while holding lock.
protected boolean	isOffHeapValuesOnly()
boolean	isReplicated()
protected boolean	isStartVersion()
protected boolean	isStoreValueBytes()
K	key()
byte[]	keyBytes()
void	keyBytes(byte[] keyBytes)
GridCacheMvccCandidate<K>	localCandidate(long threadId)
Collection<GridCacheMvccCandidate<K>>	localCandidates(GridCacheVersion... exclude) Gets all local candidates.
GridCacheMvccCandidate<K>	localOwner()
boolean	lockedBy(GridCacheVersion ver)
boolean	lockedByAny(GridCacheVersion... exclude)
boolean	lockedByThread()
boolean	lockedByThread(long threadId)
boolean	lockedByThread(long threadId, GridCacheVersion exclude)
boolean	lockedByThreadUnsafe(long threadId) Will not fail for removed entries.
boolean	lockedByUnsafe(GridCacheVersion ver)
boolean	lockedLocally(GridCacheVersion lockVer)
boolean	lockedLocallyByIdOrThread(GridCacheVersion lockVer, long threadId)
boolean	lockedLocallyUnsafe(GridCacheVersion lockVer)
boolean	markObsolete(GridCacheVersion ver) Sets obsolete flag if possible.
protected boolean	markObsolete0(GridCacheVersion ver, boolean clear) Note that onMarkedObsolete() should always be called after this method returns true.
boolean	markObsoleteIfEmpty(GridCacheVersion ver) Sets obsolete flag if entry value is null or entry is expired and no locks are held.
boolean	markObsoleteVersion(GridCacheVersion ver) Sets obsolete flag if entry version equals to ver.
int	memorySize()
<V> V	meta(String name) Gets metadata by name.
protected GridCacheMvcc<K>	mvccExtras()
protected void	mvccExtras(GridCacheMvcc<K> mvcc)
boolean	obsolete()
boolean	obsolete(GridCacheVersion exclude)
boolean	obsoleteOrDeleted()
GridCacheVersion	obsoleteVersion()
protected GridCacheVersion	obsoleteVersionExtras()
protected void	obsoleteVersionExtras(GridCacheVersion obsoleteVer)
protected void	onInvalidate() Called when entry invalidated.
void	onMarkedObsolete() This method should be called each time entry is marked obsolete other than by calling GridCacheEntryEx.markObsolete(GridCacheVersion).
boolean	onTtlExpired(GridCacheVersion obsoleteVer) Callback from ttl processor to cache entry indicating that entry is expired.
int	partition()
boolean	partitionValid()
V	peek(Collection<GridCachePeekMode> modes, GridPredicate<GridCacheEntry<K,V>>[] filter) Peeks into entry without loading value or updating statistics.
V	peek(GridCachePeekMode mode, GridPredicate<GridCacheEntry<K,V>>[] filter) Peeks into entry without loading value or updating statistics.
GridTuple<V>	peek0(boolean failFast, GridCachePeekMode mode, GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheTxEx<K,V> tx)
V	peekFailFast(GridCachePeekMode mode, GridPredicate<GridCacheEntry<K,V>>[] filter) Peeks into entry without loading value or updating statistics.
V	poke(V val) This method overwrites current in-memory value with new value.
<V> V	putMetaIfAbsent(String name, Callable<V> c) Adds given metadata value only if it was absent.
<V> V	putMetaIfAbsent(String name, V val) Adds given metadata value only if it was absent.
long	rawExpireTime()
V	rawGet()
V	rawGetOrUnmarshal()
protected V	rawGetOrUnmarshalUnlocked()
V	rawPut(V val, long ttl)
long	rawTtl()
protected void	readExternalMeta(ObjectInput in) Convenience way for super-classes which implement Externalizable to serialize metadata.
protected V	readThrough(GridCacheTxEx<K,V> tx, K key, boolean reload, GridPredicate<GridCacheEntry<K,V>>[] filter, UUID subjId)
protected void	recordNodeId(UUID nodeId)
protected void	refreshAhead(K key, GridCacheVersion matchVer)
protected void	refreshingLocked(boolean refreshing)
protected boolean	refreshingUnlocked()
protected void	releaseSwap()
Collection<GridCacheMvccCandidate<K>>	remoteMvccSnapshot(GridCacheVersion... exclude) Gets all remote versions.
<V> V	removeMeta(String name) Removes metadata by name.
<V> boolean	removeMeta(String name, V val) Removes metadata only if its current value is equal to val passed in.
<V> boolean	replaceMeta(String name, V curVal, V newVal) Replaces given metadata with new newVal value only if its current value is equal to curVal.
protected V	saveValueForIndexUnlocked() This method will return current value only if clearIndex(V) will require previous value (this is the case for Mongo caches).
long	startVersion()
protected long	toExpireTime(long ttl)
String	toString()
long	ttl()
protected void	ttlAndExpireTimeExtras(long ttl, long expireTime)
protected long	ttlExtras()
V	unswap() Unswaps an entry.
V	unswap(boolean ignoreFlags) Unswaps an entry.
protected void	update(V val, byte[] valBytes, long expireTime, long ttl, GridCacheVersion ver)
protected void	updateIndex(V val, byte[] valBytes, long expireTime, GridCacheVersion ver, V prevVal) Updates cache index.
boolean	valid(long topVer)
protected void	value(V val, byte[] valBytes) Sets entry value.
GridCacheValueBytes	valueBytes()
GridCacheValueBytes	valueBytes(GridCacheVersion ver) Gets cached serialized value bytes.
protected GridCacheValueBytes	valueBytesUnlocked()
GridCacheVersion	version()
boolean	versionedValue(V val, GridCacheVersion curVer, GridCacheVersion newVer) Sets new value if passed in version matches the current version (used for read-through only).
boolean	visitable(GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheEntry<K,V>	wrap(boolean prjAware) Wraps this map entry into cache entry.
GridCacheEntry<K,V>	wrapFilterLocked() Wraps this map entry into cache entry for filter evaluation inside entry lock.
protected void	writeExternalMeta(ObjectOutput out) Convenience way for super-classes which implement Externalizable to serialize metadata.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.gridgain.grid.kernal.processors.cache.GridCacheEntryEx

removeLock, tmLock, txUnlock

Field Detail

logRef

protected static final AtomicReference<GridLogger> logRef

Static logger to avoid re-creation. Made static for test purpose.

log

protected static volatile GridLogger log

Logger.

cctx

@GridToStringExclude
protected final GridCacheContext<K,V> cctx

Cache registry.

key

@GridToStringInclude
protected final K key

Key.

val

@GridToStringInclude
protected V val

Value.

startVer

@GridToStringInclude
protected final long startVer

Start version.

ver

@GridToStringInclude
protected GridCacheVersion ver

Version.

valBytes

@GridToStringExclude
protected byte[] valBytes

Value bytes.

flags

@GridToStringInclude
protected byte flags

Flags:

• Refreshing flag - mask IS_REFRESHING_MASK
• Deleted flag - mask IS_DELETED_MASK

Constructor Detail

GridCacheMapEntry

protected GridCacheMapEntry(GridCacheContext<K,V> cctx,
                 K key,
                 int hash,
                 V val,
                 GridCacheMapEntry<K,V> next,
                 long ttl,
                 int hdrId)

Parameters:

cctx - Cache context.

key - Cache key.

hash - Key hash value.

val - Entry value.

next - Next entry in the linked list.

ttl - Time to live.

hdrId - Header id.

Method Detail

startVersion

public long startVersion()

Specified by:

startVersion in interface GridCacheEntryEx<K,V>

Returns:

Start version.

value

protected void value(@Nullable
         V val,
         @Nullable
         byte[] valBytes)

Sets entry value. If off-heap value storage is enabled, will serialize value to off-heap.

Parameters:

val - Value to store.

valBytes - Value bytes to store.

valueBytesUnlocked

protected GridCacheValueBytes valueBytesUnlocked()

Returns:

Value bytes.

memorySize

public int memorySize()
               throws GridException

Specified by:

memorySize in interface GridCacheEntryEx<K,V>

Returns:

Memory size.

Throws:

GridException - If failed.

isInternal

public boolean isInternal()

Specified by:

isInternal in interface GridCacheEntryEx<K,V>

Returns:

True if entry is internal cache entry.

isDht

public boolean isDht()

Specified by:

isDht in interface GridCacheEntryEx<K,V>

Returns:

True if DHT.

isLocal

public boolean isLocal()

Specified by:

isLocal in interface GridCacheEntryEx<K,V>

Returns:

True if local.

isNear

public boolean isNear()

Specified by:

isNear in interface GridCacheEntryEx<K,V>

Returns:

True if near.

isReplicated

public boolean isReplicated()

Specified by:

isReplicated in interface GridCacheEntryEx<K,V>

Returns:

True if replicated.

detached

public boolean detached()

Specified by:

detached in interface GridCacheEntryEx<K,V>

Returns:

False if entry belongs to cache map, true if this entry was created in colocated cache and node is not primary for this key.

context

public GridCacheContext<K,V> context()

Specified by:

context in interface GridCacheEntryEx<K,V>

Returns:

Context.

isNew

public boolean isNew()
              throws GridCacheEntryRemovedException

Checks if entry is new assuming lock is held externally.

Specified by:

isNew in interface GridCacheEntryEx<K,V>

Returns:

True if entry is new.

Throws:

GridCacheEntryRemovedException - If entry was removed.

isNewLocked

public boolean isNewLocked()
                    throws GridCacheEntryRemovedException

Checks if entry is new while holding lock.

Specified by:

isNewLocked in interface GridCacheEntryEx<K,V>

Returns:

True if entry is new.

Throws:

GridCacheEntryRemovedException - If entry was removed.

isStartVersion

protected boolean isStartVersion()

Returns:

True if start version.

valid

public boolean valid(long topVer)

Specified by:

valid in interface GridCacheEntryEx<K,V>

Parameters:

topVer - Topology version where validation should be performed. When negative the latest available topology should be used.

Returns:

Checks if value is valid.

partition

public int partition()

Specified by:

partition in interface GridCacheEntryEx<K,V>

Returns:

Partition ID.

partitionValid

public boolean partitionValid()

Specified by:

partitionValid in interface GridCacheEntryEx<K,V>

Returns:

True if partition is in valid.

info

@Nullable
public GridCacheEntryInfo<K,V> info()

Specified by:

info in interface GridCacheEntryEx<K,V>

Returns:

Entry info.

unswap

public V unswap()
         throws GridException

Unswaps an entry.

Specified by:

unswap in interface GridCacheEntryEx<K,V>

Returns:

Value.

Throws:

GridException - If failed.

unswap

public V unswap(boolean ignoreFlags)
         throws GridException

Unswaps an entry.

Specified by:

unswap in interface GridCacheEntryEx<K,V>

Parameters:

ignoreFlags - Whether to ignore swap flags.

Returns:

Value.

Throws:

GridException - If failed.

releaseSwap

protected final void releaseSwap()
                          throws GridException

Throws:

GridException - If failed.

refreshAhead

protected void refreshAhead(K key,
                GridCacheVersion matchVer)

Parameters:

key - Key.

matchVer - Version to match.

readThrough

@Nullable
protected V readThrough(@Nullable
                     GridCacheTxEx<K,V> tx,
                     K key,
                     boolean reload,
                     GridPredicate<GridCacheEntry<K,V>>[] filter,
                     UUID subjId)
                 throws GridException

Parameters:

tx - Transaction.

key - Key.

reload - flag.

filter - Filter.

Returns:

Read value.

Throws:

GridException - If failed.

innerGet

@Nullable
public final V innerGet(@Nullable
                  GridCacheTxEx<K,V> tx,
                  boolean readSwap,
                  boolean readThrough,
                  boolean failFast,
                  boolean unmarshal,
                  boolean updateMetrics,
                  boolean evt,
                  UUID subjId,
                  GridPredicate<GridCacheEntry<K,V>>[] filter)
                 throws GridException,
                        GridCacheEntryRemovedException,
                        GridCacheFilterFailedException

Specified by:

innerGet in interface GridCacheEntryEx<K,V>

Parameters:

tx - Ongoing transaction (possibly null).

readSwap - Flag indicating whether to check swap memory.

readThrough - Flag indicating whether to read through.

failFast - If true, then throw GridCacheFilterFailedException if filter didn't pass.

unmarshal - Unmarshal flag.

updateMetrics - If true then metrics should be updated.

evt - Flag to signal event notification.

subjId - Subject ID initiated this read.

filter - Filter to check prior to getting the value. Note that filter check together with getting the value is an atomic operation.

Returns:

Cached value.

Throws:

GridException - If loading value failed.

GridCacheEntryRemovedException - If entry was removed.

GridCacheFilterFailedException - If filter failed.

innerReload

@Nullable
public final V innerReload(GridPredicate<GridCacheEntry<K,V>>[] filter)
                    throws GridException,
                           GridCacheEntryRemovedException

Reloads entry from underlying storage.

Specified by:

innerReload in interface GridCacheEntryEx<K,V>

Parameters:

filter - Filter for entries.

Returns:

Reloaded value.

Throws:

GridException - If reload failed.

GridCacheEntryRemovedException - If entry has been removed.

recordNodeId

protected void recordNodeId(UUID nodeId)

Parameters:

nodeId - Node ID.

innerSet

public final GridCacheUpdateTxResult<V> innerSet(@Nullable
                                  GridCacheTxEx<K,V> tx,
                                  UUID evtNodeId,
                                  UUID affNodeId,
                                  V val,
                                  @Nullable
                                  byte[] valBytes,
                                  boolean writeThrough,
                                  boolean retval,
                                  long ttl,
                                  boolean evt,
                                  boolean metrics,
                                  long topVer,
                                  GridPredicate<GridCacheEntry<K,V>>[] filter,
                                  GridDrType drType,
                                  long drExpireTime,
                                  @Nullable
                                  GridCacheVersion explicitVer,
                                  @Nullable
                                  UUID subjId)
                                          throws GridException,
                                                 GridCacheEntryRemovedException

Specified by:

innerSet in interface GridCacheEntryEx<K,V>

Parameters:

tx - Cache transaction.

evtNodeId - ID of node responsible for this change.

affNodeId - Partitioned node iD.

val - Value to set.

valBytes - Value bytes to set.

writeThrough - If true then persist to storage.

retval - True if value should be returned (and unmarshalled if needed).

ttl - Time to live.

evt - Flag to signal event notification.

metrics - Flag to signal metrics update.

filter - Filter.

drType - DR type.

drExpireTime - DR expire time (if any).

explicitVer - Explicit version (if any).

Returns:

Tuple containing success flag and old value. If success is false, then value is null.

Throws:

GridException - If storing value failed.

GridCacheEntryRemovedException - If entry has been removed.

innerRemove

public final GridCacheUpdateTxResult<V> innerRemove(@Nullable
                                     GridCacheTxEx<K,V> tx,
                                     UUID evtNodeId,
                                     UUID affNodeId,
                                     boolean writeThrough,
                                     boolean retval,
                                     boolean evt,
                                     boolean metrics,
                                     long topVer,
                                     GridPredicate<GridCacheEntry<K,V>>[] filter,
                                     GridDrType drType,
                                     @Nullable
                                     GridCacheVersion explicitVer,
                                     @Nullable
                                     UUID subjId)
                                             throws GridException,
                                                    GridCacheEntryRemovedException

Specified by:

innerRemove in interface GridCacheEntryEx<K,V>

Parameters:

tx - Cache transaction.

evtNodeId - ID of node responsible for this change.

affNodeId - Partitioned node iD.

writeThrough - If true, persist to the storage.

retval - True if value should be returned (and unmarshalled if needed).

evt - Flag to signal event notification.

metrics - Flag to signal metrics notification.

filter - Filter.

drType - DR type.

explicitVer - Explicit version (if any).

Returns:

Tuple containing success flag and old value. If success is false, then value is null.

Throws:

GridException - If remove failed.

GridCacheEntryRemovedException - If entry has been removed.

innerUpdateLocal

public GridBiTuple<Boolean,V> innerUpdateLocal(GridCacheVersion ver,
                                      GridCacheOperation op,
                                      @Nullable
                                      Object writeObj,
                                      boolean writeThrough,
                                      boolean retval,
                                      long ttl,
                                      boolean evt,
                                      boolean metrics,
                                      @Nullable
                                      GridPredicate<GridCacheEntry<K,V>>[] filter,
                                      boolean intercept,
                                      @Nullable
                                      UUID subjId)
                                        throws GridException,
                                               GridCacheEntryRemovedException

Update method for local cache in atomic mode.

Specified by:

innerUpdateLocal in interface GridCacheEntryEx<K,V>

Parameters:

ver - Cache version.

op - Operation.

writeObj - Value. Type depends on operation.

writeThrough - Write through flag.

retval - Return value flag.

ttl - Time to live.

evt - Event flag.

metrics - Metrics update flag.

filter - Optional filter to check.

intercept - If true then calls cache interceptor.

Returns:

Tuple containing success flag and old value.

Throws:

GridException - If update failed.

GridCacheEntryRemovedException - If entry is obsolete.

innerUpdate

public GridCacheUpdateAtomicResult<K,V> innerUpdate(GridCacheVersion newVer,
                                           UUID evtNodeId,
                                           UUID affNodeId,
                                           GridCacheOperation op,
                                           @Nullable
                                           Object writeObj,
                                           @Nullable
                                           byte[] valBytes,
                                           boolean writeThrough,
                                           boolean retval,
                                           long ttl,
                                           boolean evt,
                                           boolean metrics,
                                           boolean primary,
                                           boolean verCheck,
                                           @Nullable
                                           GridPredicate<GridCacheEntry<K,V>>[] filter,
                                           GridDrType drType,
                                           long drTtl,
                                           long drExpireTime,
                                           @Nullable
                                           GridCacheVersion drVer,
                                           boolean drResolve,
                                           boolean intercept,
                                           @Nullable
                                           UUID subjId)
                                             throws GridException,
                                                    GridCacheEntryRemovedException,
                                                    GridClosureException

Specified by:

innerUpdate in interface GridCacheEntryEx<K,V>

Parameters:

newVer - Cache version to set. Entry will be updated only if current version is less then passed version.

evtNodeId - Event node ID.

affNodeId - Affinity node ID.

op - Update operation.

writeObj - Value. Type depends on operation.

valBytes - Value bytes. Can be non-null only if operation is UPDATE.

writeThrough - Write through flag.

retval - Return value flag.

ttl - Time to live.

evt - Event flag.

metrics - Metrics update flag.

primary - If update is performed on primary node (the one which assigns version).

verCheck - Whether update should check current version and ignore update if current version is greater than passed in.

filter - Optional filter to check.

drType - DR type.

drTtl - DR TTL (if any).

drExpireTime - DR expire time (if any).

drVer - DR version (if any).

drResolve - If true then performs DR conflicts resolution.

intercept - If true then calls cache interceptor.

Returns:

Tuple where first value is flag showing whether operation succeeded, second value is old entry value if return value is requested, third is updated entry value, fourth is the version to enqueue for deferred delete the fifth is DR conflict context or null if conflict resolution was not performed, the last boolean - whether update should be propagated to backups or not.

Throws:

GridException - If update failed.

GridCacheEntryRemovedException - If entry is obsolete.

GridClosureException

hasReaders

protected boolean hasReaders()
                      throws GridCacheEntryRemovedException

Returns:

true if entry has readers. It makes sense only for dht entry.

Throws:

GridCacheEntryRemovedException - If removed.

clearReaders

protected void clearReaders()

clear

public boolean clear(GridCacheVersion ver,
            boolean readers,
            @Nullable
            GridPredicate<GridCacheEntry<K,V>>[] filter)
              throws GridException

Marks entry as obsolete and, if possible or required, removes it from swap storage.

Specified by:

clear in interface GridCacheEntryEx<K,V>

Parameters:

ver - Obsolete version.

readers - Flag to clear readers as well.

filter - Optional entry filter.

Returns:

True if entry was not being used, passed the filter and could be removed.

Throws:

GridException - If failed to remove from swap.

obsoleteVersion

public GridCacheVersion obsoleteVersion()

Specified by:

obsoleteVersion in interface GridCacheEntryEx<K,V>

Returns:

Not-null version if entry is obsolete.

markObsolete

public boolean markObsolete(GridCacheVersion ver)

Sets obsolete flag if possible.

Specified by:

markObsolete in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version to set as obsolete.

Returns:

True if entry is obsolete, false if entry is still used by other threads or nodes.

markObsoleteIfEmpty

public boolean markObsoleteIfEmpty(@Nullable
                          GridCacheVersion ver)
                            throws GridException

Sets obsolete flag if entry value is null or entry is expired and no locks are held.

Specified by:

markObsoleteIfEmpty in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version to set as obsolete.

Returns:

True if entry was marked obsolete.

Throws:

GridException - If failed.

markObsoleteVersion

public boolean markObsoleteVersion(GridCacheVersion ver)

Sets obsolete flag if entry version equals to ver.

Specified by:

markObsoleteVersion in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version to compare with.

Returns:

True if marked obsolete.

markObsolete0

protected final boolean markObsolete0(GridCacheVersion ver,
                    boolean clear)

Note that onMarkedObsolete() should always be called after this method returns true.

Parameters:

ver - Version.

clear - True to clear.

Returns:

True if entry is obsolete, false if entry is still used by other threads or nodes.

onMarkedObsolete

public void onMarkedObsolete()

This method should be called each time entry is marked obsolete other than by calling GridCacheEntryEx.markObsolete(GridCacheVersion).

Specified by:

onMarkedObsolete in interface GridCacheEntryEx<K,V>

obsolete

public final boolean obsolete()

Specified by:

obsolete in interface GridCacheEntryEx<K,V>

Returns:

True if entry is obsolete.

obsolete

public final boolean obsolete(GridCacheVersion exclude)

Specified by:

obsolete in interface GridCacheEntryEx<K,V>

Parameters:

exclude - Obsolete version to ignore.

Returns:

True if obsolete version is not null and is not the passed in version.

invalidate

public boolean invalidate(@Nullable
                 GridCacheVersion curVer,
                 GridCacheVersion newVer)
                   throws GridException

Invalidates this entry.

Specified by:

invalidate in interface GridCacheEntryEx<K,V>

Parameters:

curVer - Current version to match (null means always match).

newVer - New version to set.

Returns:

true if entry is obsolete.

Throws:

GridException - If swap could not be released.

onInvalidate

protected void onInvalidate()

Called when entry invalidated.

invalidate

public boolean invalidate(@Nullable
                 GridPredicate<GridCacheEntry<K,V>>[] filter)
                   throws GridCacheEntryRemovedException,
                          GridException

Invalidates this entry if it passes given filter.

Specified by:

invalidate in interface GridCacheEntryEx<K,V>

Parameters:

filter - Optional filter that entry should pass before invalidation.

Returns:

true if entry was actually invalidated.

Throws:

GridCacheEntryRemovedException - If entry was removed.

GridException - If swap could not be released.

compact

public boolean compact(@Nullable
              GridPredicate<GridCacheEntry<K,V>>[] filter)
                throws GridCacheEntryRemovedException,
                       GridException

Optimizes the size of this entry.

Specified by:

compact in interface GridCacheEntryEx<K,V>

Parameters:

filter - Optional filter that entry should pass before invalidation.

Returns:

true if entry was not being used and could be removed.

Throws:

GridCacheEntryRemovedException - If entry was removed.

GridException - If operation failed.

update

protected final void update(@Nullable
          V val,
          @Nullable
          byte[] valBytes,
          long expireTime,
          long ttl,
          GridCacheVersion ver)

Parameters:

val - New value.

valBytes - New value bytes.

expireTime - Expiration time.

ttl - Time to live.

ver - Update version.

isStoreValueBytes

protected boolean isStoreValueBytes()

Returns:

true If value bytes should be stored.

isOffHeapValuesOnly

protected boolean isOffHeapValuesOnly()

Returns:

True if values should be stored off-heap.

toExpireTime

protected long toExpireTime(long ttl)

Parameters:

ttl - Time to live.

Returns:

Expiration time.

checkObsolete

protected void checkObsolete()
                      throws GridCacheEntryRemovedException

Throws:

GridCacheEntryRemovedException - If entry is obsolete.

key

public K key()

Specified by:

key in interface GridCacheEntryEx<K,V>

Returns:

Key.

version

public GridCacheVersion version()
                         throws GridCacheEntryRemovedException

Specified by:

version in interface GridCacheEntryEx<K,V>

Returns:

Version.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

peek

@Nullable
public V peek(GridCachePeekMode mode,
              GridPredicate<GridCacheEntry<K,V>>[] filter)
       throws GridCacheEntryRemovedException

Peeks into entry without loading value or updating statistics.

Specified by:

peek in interface GridCacheEntryEx<K,V>

Parameters:

mode - Peek mode.

filter - Optional filter.

Returns:

Value.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

peek

public V peek(Collection<GridCachePeekMode> modes,
     GridPredicate<GridCacheEntry<K,V>>[] filter)
       throws GridCacheEntryRemovedException

Peeks into entry without loading value or updating statistics.

Specified by:

peek in interface GridCacheEntryEx<K,V>

Parameters:

modes - Peek modes.

filter - Optional filter.

Returns:

Value.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

peekFailFast

@Nullable
public V peekFailFast(GridCachePeekMode mode,
                      GridPredicate<GridCacheEntry<K,V>>[] filter)
               throws GridCacheEntryRemovedException,
                      GridCacheFilterFailedException

Peeks into entry without loading value or updating statistics.

Specified by:

peekFailFast in interface GridCacheEntryEx<K,V>

Parameters:

mode - Peek mode.

filter - Optional filter.

Returns:

Value.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

GridCacheFilterFailedException - If failFast is true and filter didn't pass.

peek0

@Nullable
public GridTuple<V> peek0(boolean failFast,
                          GridCachePeekMode mode,
                          GridPredicate<GridCacheEntry<K,V>>[] filter,
                          @Nullable
                          GridCacheTxEx<K,V> tx)
                   throws GridCacheEntryRemovedException,
                          GridCacheFilterFailedException,
                          GridException

Specified by:

peek0 in interface GridCacheEntryEx<K,V>

Parameters:

failFast - Fail-fast flag.

mode - Peek mode.

filter - Filter.

tx - Transaction to peek value at (if mode is TX value).

Returns:

Peeked value.

Throws:

GridException - In case of error.

GridCacheEntryRemovedException - If removed.

GridCacheFilterFailedException - If filter failed.

poke

public V poke(V val)
       throws GridCacheEntryRemovedException,
              GridException

This method overwrites current in-memory value with new value.

Note that this method is non-transactional and non-distributed and should almost never be used. It is meant to be used when fixing some heurisitic error state.

Specified by:

poke in interface GridCacheEntryEx<K,V>

Parameters:

val - Value to set.

Returns:

Previous value.

Throws:

GridCacheEntryRemovedException - if entry was unexpectedly removed.

GridException - If poke operation failed.

rawGet

public V rawGet()

Specified by:

rawGet in interface GridCacheEntryEx<K,V>

Returns:

Value.

rawGetOrUnmarshal

public V rawGetOrUnmarshal()
                    throws GridException

Specified by:

rawGetOrUnmarshal in interface GridCacheEntryEx<K,V>

Returns:

Value (unmarshalled if needed).

Throws:

GridException - If failed.

rawGetOrUnmarshalUnlocked

protected V rawGetOrUnmarshalUnlocked()
                               throws GridException

Returns:

Value (unmarshalled if needed).

Throws:

GridException - If failed.

hasValue

public boolean hasValue()

Specified by:

hasValue in interface GridCacheEntryEx<K,V>

Returns:

True if has value or value bytes.

hasValueUnlocked

protected boolean hasValueUnlocked()

Returns:

True if this entry has value.

drEntry

public GridDrEntry<K,V> drEntry()
                         throws GridException

Create DR entry for that cache entry.

Specified by:

drEntry in interface GridCacheEntryEx<K,V>

Returns:

DR entry.

Throws:

GridException - If failed.

rawPut

public V rawPut(V val,
       long ttl)

Specified by:

rawPut in interface GridCacheEntryEx<K,V>

Parameters:

val - New value.

ttl - Time to live.

Returns:

Old value.

initialValue

public boolean initialValue(V val,
                   byte[] valBytes,
                   GridCacheVersion ver,
                   long ttl,
                   long expireTime,
                   boolean preload,
                   long topVer,
                   GridDrType drType)
                     throws GridException,
                            GridCacheEntryRemovedException

Sets new value if current version is 0

Specified by:

initialValue in interface GridCacheEntryEx<K,V>

Parameters:

val - New value.

valBytes - Value bytes.

ver - Version to use.

ttl - Time to live.

expireTime - Expiration time.

preload - Flag indicating whether entry is being preloaded.

drType - DR type.

Returns:

True if initial value was set.

Throws:

GridException - In case of error.

GridCacheEntryRemovedException - If entry was removed.

initialValue

public boolean initialValue(K key,
                   GridCacheSwapEntry<V> unswapped)
                     throws GridException,
                            GridCacheEntryRemovedException

Sets new value if current version is 0 using swap entry data. Note that this method does not update cache index.

Specified by:

initialValue in interface GridCacheEntryEx<K,V>

Parameters:

key - Key.

unswapped - Swap entry to set entry state from.

Returns:

True if initial value was set.

Throws:

GridException - In case of error.

GridCacheEntryRemovedException - If entry was removed.

versionedValue

public boolean versionedValue(V val,
                     GridCacheVersion curVer,
                     GridCacheVersion newVer)
                       throws GridException,
                              GridCacheEntryRemovedException

Sets new value if passed in version matches the current version (used for read-through only).

Specified by:

versionedValue in interface GridCacheEntryEx<K,V>

Parameters:

val - New value.

curVer - Version to match or null if match is not required.

newVer - Version to set.

Returns:

True if versioned matched.

Throws:

GridException - If index could not be updated.

GridCacheEntryRemovedException - If entry was removed.

hasLockCandidate

public boolean hasLockCandidate(GridCacheVersion ver)
                         throws GridCacheEntryRemovedException

Checks if the candidate is either owner or pending.

Specified by:

hasLockCandidate in interface GridCacheEntryEx<K,V>

Parameters:

ver - Candidate version to check.

Returns:

True if the candidate is either owner or pending.

Throws:

GridCacheEntryRemovedException - If entry was removed.

hasLockCandidate

public boolean hasLockCandidate(long threadId)
                         throws GridCacheEntryRemovedException

Checks if the candidate is either owner or pending.

Specified by:

hasLockCandidate in interface GridCacheEntryEx<K,V>

Parameters:

threadId - ThreadId.

Returns:

True if the candidate is either owner or pending.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedByAny

public boolean lockedByAny(GridCacheVersion... exclude)
                    throws GridCacheEntryRemovedException

Specified by:

lockedByAny in interface GridCacheEntryEx<K,V>

Parameters:

exclude - Exclude versions.

Returns:

True if lock is owned by any thread or node.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedByThread

public boolean lockedByThread()
                       throws GridCacheEntryRemovedException

Specified by:

lockedByThread in interface GridCacheEntryEx<K,V>

Returns:

True if lock is owned by current thread.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedLocally

public boolean lockedLocally(GridCacheVersion lockVer)
                      throws GridCacheEntryRemovedException

Specified by:

lockedLocally in interface GridCacheEntryEx<K,V>

Parameters:

lockVer - Lock ID to check.

Returns:

True if lock is owned by candidate.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedByThread

public boolean lockedByThread(long threadId,
                     GridCacheVersion exclude)
                       throws GridCacheEntryRemovedException

Specified by:

lockedByThread in interface GridCacheEntryEx<K,V>

Parameters:

threadId - Thread ID to check.

exclude - Version to exclude from check.

Returns:

True if lock is owned by given thread.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedLocallyByIdOrThread

public boolean lockedLocallyByIdOrThread(GridCacheVersion lockVer,
                                long threadId)
                                  throws GridCacheEntryRemovedException

Specified by:

lockedLocallyByIdOrThread in interface GridCacheEntryEx<K,V>

Parameters:

lockVer - Lock ID.

threadId - Thread ID.

Returns:

True if locked either locally or by thread.

Throws:

GridCacheEntryRemovedException - If removed.

lockedByThread

public boolean lockedByThread(long threadId)
                       throws GridCacheEntryRemovedException

Specified by:

lockedByThread in interface GridCacheEntryEx<K,V>

Parameters:

threadId - Thread ID to check.

Returns:

True if lock is owned by given thread.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedBy

public boolean lockedBy(GridCacheVersion ver)
                 throws GridCacheEntryRemovedException

Specified by:

lockedBy in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version to check for ownership.

Returns:

True if owner has the specified version.

Throws:

GridCacheEntryRemovedException - If entry was removed.

lockedByThreadUnsafe

public boolean lockedByThreadUnsafe(long threadId)

Will not fail for removed entries.

Specified by:

lockedByThreadUnsafe in interface GridCacheEntryEx<K,V>

Parameters:

threadId - Thread ID to check.

Returns:

True if lock is owned by given thread.

lockedByUnsafe

public boolean lockedByUnsafe(GridCacheVersion ver)

Specified by:

lockedByUnsafe in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version to check for ownership.

Returns:

True if owner has the specified version.

lockedLocallyUnsafe

public boolean lockedLocallyUnsafe(GridCacheVersion lockVer)

Specified by:

lockedLocallyUnsafe in interface GridCacheEntryEx<K,V>

Parameters:

lockVer - Lock ID to check.

Returns:

True if lock is owned by candidate.

hasLockCandidateUnsafe

public boolean hasLockCandidateUnsafe(GridCacheVersion ver)

Specified by:

hasLockCandidateUnsafe in interface GridCacheEntryEx<K,V>

Parameters:

ver - Lock version to check.

Returns:

True if has candidate with given lock ID.

localCandidates

public Collection<GridCacheMvccCandidate<K>> localCandidates(GridCacheVersion... exclude)
                                                      throws GridCacheEntryRemovedException

Gets all local candidates.

Specified by:

localCandidates in interface GridCacheEntryEx<K,V>

Parameters:

exclude - Versions to exclude from check.

Returns:

All local candidates.

Throws:

GridCacheEntryRemovedException - If entry was removed.

remoteMvccSnapshot

public Collection<GridCacheMvccCandidate<K>> remoteMvccSnapshot(GridCacheVersion... exclude)

Gets all remote versions.

Specified by:

remoteMvccSnapshot in interface GridCacheEntryEx<K,V>

Parameters:

exclude - Exclude version.

Returns:

All remote versions minus the excluded ones, if any.

candidate

@Nullable
public GridCacheMvccCandidate<K> candidate(GridCacheVersion ver)
                                    throws GridCacheEntryRemovedException

Gets lock candidate for given lock ID.

Specified by:

candidate in interface GridCacheEntryEx<K,V>

Parameters:

ver - Lock version.

Returns:

Lock candidate for given ID.

Throws:

GridCacheEntryRemovedException - If entry was removed.

localCandidate

public GridCacheMvccCandidate<K> localCandidate(long threadId)
                                         throws GridCacheEntryRemovedException

Specified by:

localCandidate in interface GridCacheEntryEx<K,V>

Parameters:

threadId - Thread ID.

Returns:

Local candidate.

Throws:

GridCacheEntryRemovedException - If entry was removed.

candidate

public GridCacheMvccCandidate<K> candidate(UUID nodeId,
                                  long threadId)
                                    throws GridCacheEntryRemovedException

Specified by:

candidate in interface GridCacheEntryEx<K,V>

Parameters:

nodeId - Node ID.

threadId - Thread ID.

Returns:

Candidate.

Throws:

GridCacheEntryRemovedException - If entry was removed.

localOwner

public GridCacheMvccCandidate<K> localOwner()
                                     throws GridCacheEntryRemovedException

Specified by:

localOwner in interface GridCacheEntryEx<K,V>

Returns:

Local owner.

Throws:

GridCacheEntryRemovedException - If entry was removed.

rawExpireTime

public long rawExpireTime()

Specified by:

rawExpireTime in interface GridCacheEntryEx<K,V>

Returns:

Expire time, without accounting for transactions or removals.

expireTime

public long expireTime()
                throws GridCacheEntryRemovedException

Specified by:

expireTime in interface GridCacheEntryEx<K,V>

Returns:

Expiration time.

Throws:

GridCacheEntryRemovedException - If entry was removed.

expireTimeUnlocked

public long expireTimeUnlocked()

Specified by:

expireTimeUnlocked in interface GridCacheEntryEx<K,V>

Returns:

Expiration time. Does not check for entry obsolete flag.

onTtlExpired

public boolean onTtlExpired(GridCacheVersion obsoleteVer)

Callback from ttl processor to cache entry indicating that entry is expired.

Specified by:

onTtlExpired in interface GridCacheEntryEx<K,V>

Parameters:

obsoleteVer - Version to set obsolete if entry is expired.

Returns:

True if this entry was obsolete or became obsolete as a result of this call.

rawTtl

public long rawTtl()

Specified by:

rawTtl in interface GridCacheEntryEx<K,V>

Returns:

Time to live, without accounting for transactions or removals.

ttl

public long ttl()
         throws GridCacheEntryRemovedException

Specified by:

ttl in interface GridCacheEntryEx<K,V>

Returns:

Time to live.

Throws:

GridCacheEntryRemovedException - If entry was removed.

keyBytes

public void keyBytes(byte[] keyBytes)
              throws GridCacheEntryRemovedException

Specified by:

keyBytes in interface GridCacheEntryEx<K,V>

Parameters:

keyBytes - Key bytes.

Throws:

GridCacheEntryRemovedException - If entry was removed.

keyBytes

public byte[] keyBytes()

Specified by:

keyBytes in interface GridCacheEntryEx<K,V>

Returns:

Key bytes.

getOrMarshalKeyBytes

public byte[] getOrMarshalKeyBytes()
                            throws GridException

Specified by:

getOrMarshalKeyBytes in interface GridCacheEntryEx<K,V>

Returns:

Key bytes.

Throws:

GridException - If marshalling failed.

valueBytes

public GridCacheValueBytes valueBytes()
                               throws GridCacheEntryRemovedException

Specified by:

valueBytes in interface GridCacheEntryEx<K,V>

Returns:

Value bytes.

Throws:

GridCacheEntryRemovedException - If entry was removed.

valueBytes

@Nullable
public GridCacheValueBytes valueBytes(@Nullable
                                      GridCacheVersion ver)
                               throws GridException,
                                      GridCacheEntryRemovedException

Gets cached serialized value bytes.

Specified by:

valueBytes in interface GridCacheEntryEx<K,V>

Parameters:

ver - Version for which to get value bytes.

Returns:

Serialized value bytes.

Throws:

GridException - If serialization failed.

GridCacheEntryRemovedException - If entry was removed.

updateIndex

protected void updateIndex(@Nullable
               V val,
               @Nullable
               byte[] valBytes,
               long expireTime,
               GridCacheVersion ver,
               @Nullable
               V prevVal)
                    throws GridException

Updates cache index.

Parameters:

val - Value.

valBytes - Value bytes.

expireTime - Expire time.

ver - New entry version.

prevVal - Previous value.

Throws:

GridException - If update failed.

clearIndex

protected void clearIndex(@Nullable
              V prevVal)
                   throws GridException

Clears index.

Parameters:

prevVal - Previous value (if needed for index update).

Throws:

GridException - If failed.

saveValueForIndexUnlocked

protected V saveValueForIndexUnlocked()
                               throws GridException

This method will return current value only if clearIndex(V) will require previous value (this is the case for Mongo caches). If previous value is not required, this method will return null.

Returns:

Previous value or null.

Throws:

GridException - If failed to retrieve previous value.

wrap

public GridCacheEntry<K,V> wrap(boolean prjAware)

Wraps this map entry into cache entry.

Specified by:

wrap in interface GridCacheEntryEx<K,V>

Parameters:

prjAware - true if entry should inherit projection properties.

Returns:

Wrapped entry.

wrapFilterLocked

public GridCacheEntry<K,V> wrapFilterLocked()
                                     throws GridException

Wraps this map entry into cache entry for filter evaluation inside entry lock.

Specified by:

wrapFilterLocked in interface GridCacheEntryEx<K,V>

Returns:

Wrapped entry.

Throws:

GridException - If failed.

evictWrap

public GridCacheEntry<K,V> evictWrap()

Specified by:

evictWrap in interface GridCacheEntryEx<K,V>

Returns:

Entry which is safe to pass into eviction policy.

evictInternal

public boolean evictInternal(boolean swap,
                    GridCacheVersion obsoleteVer,
                    @Nullable
                    GridPredicate<GridCacheEntry<K,V>>[] filter)
                      throws GridException

Specified by:

evictInternal in interface GridCacheEntryEx<K,V>

Parameters:

swap - Swap flag.

obsoleteVer - Version for eviction.

filter - Optional filter.

Returns:

True if entry could be evicted.

Throws:

GridException - In case of error.

evictInBatchInternal

public GridCacheBatchSwapEntry<K,V> evictInBatchInternal(GridCacheVersion obsoleteVer)
                                                  throws GridException

Evicts entry when batch evict is performed. When called, does not write entry data to swap, but instead returns batch swap entry if entry was marked obsolete.

Specified by:

evictInBatchInternal in interface GridCacheEntryEx<K,V>

Parameters:

obsoleteVer - Version to mark obsolete with.

Returns:

Swap entry if this entry was marked obsolete, null if entry was not evicted.

Throws:

GridException - If failed.

createValueBytes

protected GridCacheValueBytes createValueBytes(@Nullable
                                   V val)
                                        throws GridException

Create value bytes wrapper from the given object.

Parameters:

val - Value.

Returns:

Value bytes wrapper.

Throws:

GridException - If failed.

visitable

public boolean visitable(GridPredicate<GridCacheEntry<K,V>>[] filter)

Parameters:

filter - Entry filter.

Returns:

True if entry is visitable.

copyMeta

public void copyMeta(GridMetadataAware from)

Copies all metadata from another instance.

Specified by:

copyMeta in interface GridMetadataAware

Parameters:

from - Metadata aware instance to copy metadata from.

copyMeta

public void copyMeta(Map<String,?> attrData)

Copies all metadata from given map.

Specified by:

copyMeta in interface GridMetadataAware

Parameters:

attrData - Map to copy metadata from.

addMeta

@Nullable
public <V> V addMeta(String name,
                     V val)

Adds a new metadata.

Specified by:

addMeta in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

val - Metadata value.

Returns:

Metadata previously associated with given name, or null if there was none.

meta

@Nullable
public <V> V meta(String name)

Gets metadata by name.

Specified by:

meta in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

Returns:

Metadata value or null.

removeMeta

@Nullable
public <V> V removeMeta(String name)

Removes metadata by name.

Specified by:

removeMeta in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Name of the metadata to remove.

Returns:

Value of removed metadata or null.

removeMeta

public <V> boolean removeMeta(String name,
                     V val)

Removes metadata only if its current value is equal to val passed in.

Specified by:

removeMeta in interface GridMetadataAware

Type Parameters:

V - Value type.

Parameters:

name - Name of metadata attribute.

val - Value to compare.

Returns:

True if value was removed, false otherwise.

allMeta

public <V> Map<String,V> allMeta()

Gets all metadata in this entry.

Specified by:

allMeta in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Returns:

All metadata in this entry.

hasMeta

public boolean hasMeta(String name)

Tests whether or not given metadata is set.

Specified by:

hasMeta in interface GridMetadataAware

Parameters:

name - Name of the metadata to test.

Returns:

Whether or not given metadata is set.

hasMeta

public <V> boolean hasMeta(String name,
                  V val)

Tests whether or not metadata with given name and value is set. Returns true if attachment with given name it set and its value is equals to provided value. Otherwise returns false.

Specified by:

hasMeta in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Name of the metadata.

val - Value to compare. Cannot be null.

Returns:

true if metadata with given name is set and its value is equals to provided value - otherwise returns false.

putMetaIfAbsent

@Nullable
public <V> V putMetaIfAbsent(String name,
                             V val)

Adds given metadata value only if it was absent.

Specified by:

putMetaIfAbsent in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

val - Value to add if it's not attached already.

Returns:

null if new value was put, or current value if put didn't happen.

putMetaIfAbsent

@Nullable
public <V> V putMetaIfAbsent(String name,
                             Callable<V> c)

Adds given metadata value only if it was absent.

Specified by:

putMetaIfAbsent in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

c - Factory closure to produce value to add if it's not attached already. Not that unlike GridMetadataAware.addMeta(String, Object) method the factory closure will not be called unless the value is required and therefore value will only be created when it is actually needed.

Returns:

null if new value was put, or current value if put didn't happen.

addMetaIfAbsent

public <V> V addMetaIfAbsent(String name,
                    V val)

Adds given metadata value only if it was absent. Unlike GridMetadataAware.putMetaIfAbsent(String, Callable), this method always returns the latest value and never previous one.

Specified by:

addMetaIfAbsent in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

val - Value to add if it's not attached already.

Returns:

The value of the metadata after execution of this method.

addMetaIfAbsent

@Nullable
public <V> V addMetaIfAbsent(String name,
                             @Nullable
                             Callable<V> c)

Adds given metadata value only if it was absent.

Specified by:

addMetaIfAbsent in interface GridMetadataAware

Type Parameters:

V - Type of the value.

Parameters:

name - Metadata name.

c - Factory closure to produce value to add if it's not attached already. Not that unlike GridMetadataAware.addMeta(String, Object) method the factory closure will not be called unless the value is required and therefore value will only be created when it is actually needed. If null and metadata value is missing - null will be returned from this method.

Returns:

The value of the metadata after execution of this method.

replaceMeta

public <V> boolean replaceMeta(String name,
                      V curVal,
                      V newVal)

Replaces given metadata with new newVal value only if its current value is equal to curVal. Otherwise, it is no-op.

Specified by:

replaceMeta in interface GridMetadataAware

Parameters:

name - Name of the metadata.

curVal - Current value to check.

newVal - New value.

Returns:

true if replacement occurred, false otherwise.

writeExternalMeta

protected void writeExternalMeta(ObjectOutput out)
                          throws IOException

Convenience way for super-classes which implement Externalizable to serialize metadata. Super-classes must call this method explicitly from within Externalizable.writeExternal(ObjectOutput) methods implementation.

Parameters:

out - Output to write to.

Throws:

IOException - If I/O error occurred.

readExternalMeta

protected void readExternalMeta(ObjectInput in)
                         throws IOException,
                                ClassNotFoundException

Convenience way for super-classes which implement Externalizable to serialize metadata. Super-classes must call this method explicitly from within Externalizable.readExternal(ObjectInput) methods implementation.

Parameters:

in - Input to read from.

Throws:

IOException - If I/O error occurred.

ClassNotFoundException - If some class could not be found.

deleted

public boolean deleted()

Note: this method works only for cache configured in ATOMIC mode or for cache that is data center replication target.

Specified by:

deleted in interface GridCacheEntryEx<K,V>

Returns:

True if entry has been already deleted.

obsoleteOrDeleted

public boolean obsoleteOrDeleted()

Specified by:

obsoleteOrDeleted in interface GridCacheEntryEx<K,V>

Returns:

True if entry is obsolete or deleted.

See Also:

GridCacheEntryEx.deleted()

deletedUnlocked

protected boolean deletedUnlocked()

Returns:

True if deleted.

deletedUnlocked

protected void deletedUnlocked(boolean deleted)

Parameters:

deleted - True if deleted.

refreshingUnlocked

protected boolean refreshingUnlocked()

Returns:

True if refreshing.

refreshingLocked

protected void refreshingLocked(boolean refreshing)

Parameters:

refreshing - True if refreshing.

mvccExtras

@Nullable
protected GridCacheMvcc<K> mvccExtras()

Returns:

MVCC.

mvccExtras

protected void mvccExtras(@Nullable
              GridCacheMvcc<K> mvcc)

Parameters:

mvcc - MVCC.

obsoleteVersionExtras

@Nullable
protected GridCacheVersion obsoleteVersionExtras()

Returns:

Obsolete version.

obsoleteVersionExtras

protected void obsoleteVersionExtras(@Nullable
                         GridCacheVersion obsoleteVer)

Parameters:

obsoleteVer - Obsolete version.

ttlExtras

protected long ttlExtras()

Returns:

TTL.

expireTimeExtras

protected long expireTimeExtras()

Returns:

Expire time.

ttlAndExpireTimeExtras

protected void ttlAndExpireTimeExtras(long ttl,
                          long expireTime)

Parameters:

ttl - TTL.

expireTime - Expire time.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object