org.apache.ignite.internal.processors.cache.distributed.dht.colocated

Class GridDhtDetachedCacheEntry<K,V>

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheMapEntry<K,V>

org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheEntry<K,V>

org.apache.ignite.internal.processors.cache.distributed.dht.colocated.GridDhtDetachedCacheEntry<K,V>

All Implemented Interfaces:

GridCacheEntryEx<K,V>

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

Detached cache entry.

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.GridCacheMapEntry

ATOMIC_VER_COMPARATOR, 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()
V	unswap(boolean ignoreFlags, boolean needVal) Unswaps an entry.
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.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheEntry

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

Methods inherited from class org.apache.ignite.internal.processors.cache.GridCacheMapEntry

addMeta, candidate, candidate, checkObsolete, clear, clearReader, clearReaders, compact, context, deleted, deletedUnlocked, deletedUnlocked, equals, evictInBatchInternal, evictInternal, expireTime, expireTimeExtras, expireTimeUnlocked, getOrMarshalKeyBytes, hashCode, hasLockCandidate, hasLockCandidate, hasLockCandidateUnsafe, 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, peek, peek0, peekFailFast, poke, putMetaIfAbsent, putMetaIfAbsent, rawExpireTime, rawGet, rawGetOrUnmarshal, rawGetOrUnmarshalUnlocked, rawPut, rawTtl, readExternalMeta, readThrough, recordNodeId, releaseSwap, removeMeta, removeMeta, replaceMeta, saveValueForIndexUnlocked, startVersion, toExpireTime, ttl, ttlAndExpireTimeExtras, ttlExtras, txKey, unswap, update, updateTtl, valid, valueBytes, valueBytes, version, versionedEntry, versionedValue, visitable, wrap, wrapEviction, wrapFilterLocked, wrapLazyValue, wrapVersioned, 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 IgniteCheckedException

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

Parameters:

val - Value.

valBytes - Value bytes.

ver - Version.

Throws:

IgniteCheckedException - If value unmarshalling failed.

unswap

@Nullable
public V unswap(boolean ignoreFlags,
                boolean needVal)
         throws IgniteCheckedException

Unswaps an entry.

Specified by:

unswap in interface GridCacheEntryEx<K,V>

Overrides:

unswap in class GridCacheMapEntry<K,V>

Parameters:

ignoreFlags - Whether to ignore swap flags.

needVal - If false then do not to deserialize value during unswap.

Returns:

Value.

Throws:

IgniteCheckedException - If 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 IgniteCheckedException

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:

IgniteCheckedException - If update failed.

clearIndex

protected void clearIndex(V val)
                   throws IgniteCheckedException

Clears index.

Overrides:

clearIndex in class GridCacheMapEntry<K,V>

Parameters:

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

Throws:

IgniteCheckedException - 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.