org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated

Class GridDhtDetachedCacheEntry<K,V>

java.lang.Object

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

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

org.gridgain.grid.kernal.processors.cache.distributed.dht.colocated.GridDhtDetachedCacheEntry<K,V>

All Implemented Interfaces:

Serializable, GridMetadataAware, GridCacheEntryEx<K,V>

public class GridDhtDetachedCacheEntry<K,V>
extends GridDistributedCacheEntry<K,V>

Detached cache entry.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheMapEntry

cctx, flags, key, log, logRef, startVer, val, valBytes, ver

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addRemoved(GridCacheVersion ver)
protected void	clearIndex(V val) Clears index.
boolean	detached()
void	resetFromPrimary(V val, byte[] valBytes, GridCacheVersion ver) Sets value to detached entry so it can be retrieved in transactional gets.
String	toString()
protected void	updateIndex(V val, byte[] valBytes, long expireTime, GridCacheVersion ver, V old) Updates cache index.
protected void	value(V val, byte[] valBytes) Sets entry value.
protected GridCacheValueBytes	valueBytesUnlocked()

Methods inherited from class org.gridgain.grid.kernal.processors.cache.distributed.GridDistributedCacheEntry

addLocal, addRemote, addRemote, addRemoteCandidates, checkCallbacks, checkOwnerChanged, checkRemoved, checkThreadChain, doneRemote, doneRemote, orderCompleted, readyLock, readyLock, readyNearLock, recheck, refreshRemotes, remoteMvccSnapshot, removeExplicitNodeLocks, removeLock, removeLock, tmLock, txUnlock

Methods inherited from class org.gridgain.grid.kernal.processors.cache.GridCacheMapEntry

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, candidate, candidate, checkObsolete, clear, clearReaders, compact, context, copyMeta, copyMeta, createValueBytes, deleted, deletedUnlocked, deletedUnlocked, drEntry, equals, evictInBatchInternal, evictInternal, evictWrap, expireTime, expireTimeExtras, expireTimeUnlocked, getOrMarshalKeyBytes, hashCode, hasLockCandidate, hasLockCandidate, hasLockCandidateUnsafe, hasMeta, hasMeta, hasReaders, hasValue, hasValueUnlocked, info, initialValue, initialValue, innerGet, innerReload, innerRemove, innerSet, innerUpdate, innerUpdateLocal, invalidate, invalidate, isDht, isInternal, isLocal, isNear, isNew, isNewLocked, isOffHeapValuesOnly, isReplicated, isStartVersion, isStoreValueBytes, key, keyBytes, keyBytes, localCandidate, localCandidates, localOwner, lockedBy, lockedByAny, lockedByThread, lockedByThread, lockedByThread, lockedByThreadUnsafe, lockedByUnsafe, lockedLocally, lockedLocallyByIdOrThread, lockedLocallyUnsafe, markObsolete, markObsolete0, markObsoleteIfEmpty, markObsoleteVersion, memorySize, meta, mvccExtras, mvccExtras, obsolete, obsolete, obsoleteOrDeleted, obsoleteVersion, obsoleteVersionExtras, obsoleteVersionExtras, onInvalidate, onMarkedObsolete, onTtlExpired, partition, partitionValid, peek, peek, peek0, peekFailFast, poke, putMetaIfAbsent, putMetaIfAbsent, rawExpireTime, rawGet, rawGetOrUnmarshal, rawGetOrUnmarshalUnlocked, rawPut, rawTtl, readExternalMeta, readThrough, recordNodeId, refreshAhead, refreshingLocked, refreshingUnlocked, releaseSwap, removeMeta, removeMeta, replaceMeta, saveValueForIndexUnlocked, startVersion, toExpireTime, ttl, ttlAndExpireTimeExtras, ttlExtras, unswap, unswap, update, valid, valueBytes, valueBytes, version, versionedValue, visitable, wrap, wrapFilterLocked, writeExternalMeta

Methods inherited from class java.lang.Object

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

Constructor Detail

GridDhtDetachedCacheEntry

public GridDhtDetachedCacheEntry(GridCacheContext<K,V> ctx,
                         K key,
                         int hash,
                         V val,
                         GridCacheMapEntry<K,V> next,
                         long ttl,
                         int hdrId)

Parameters:

ctx - 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

resetFromPrimary

public void resetFromPrimary(V val,
                    byte[] valBytes,
                    GridCacheVersion ver)
                      throws GridException

Sets value to detached entry so it can be retrieved in transactional gets.

Parameters:

val - Value.

valBytes - Value bytes.

ver - Version.

Throws:

GridException - If value unmarshalling failed.

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.

Overrides:

value in class GridCacheMapEntry<K,V>

Parameters:

val - Value to store.

valBytes - Value bytes to store.

valueBytesUnlocked

protected GridCacheValueBytes valueBytesUnlocked()

Overrides:

valueBytesUnlocked in class GridCacheMapEntry<K,V>

Returns:

Value bytes.

updateIndex

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

Updates cache index.

Overrides:

updateIndex in class GridCacheMapEntry<K,V>

Parameters:

val - Value.

valBytes - Value bytes.

expireTime - Expire time.

ver - New entry version.

old - Previous value.

Throws:

GridException - If update failed.

clearIndex

protected void clearIndex(V val)
                   throws GridException

Clears index.

Overrides:

clearIndex in class GridCacheMapEntry<K,V>

Parameters:

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

Throws:

GridException - If failed.

detached

public boolean detached()

Specified by:

detached in interface GridCacheEntryEx<K,V>

Overrides:

detached in class GridCacheMapEntry<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.

toString

public String toString()

Overrides:

toString in class GridDistributedCacheEntry<K,V>

addRemoved

public boolean addRemoved(GridCacheVersion ver)

Overrides:

addRemoved in class GridDistributedCacheEntry<K,V>

Parameters:

ver - Lock version.

Returns:

True if removed.