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

Class GridDhtDetachedCacheEntry

java.lang.Object

org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

org.apache.ignite.internal.processors.cache.GridCacheMapEntry

org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheEntry

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

All Implemented Interfaces:

GridCacheEntryEx

public class GridDhtDetachedCacheEntry
extends GridDistributedCacheEntry

Detached cache entry.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

GridMetadataAwareAdapter.EntryKey

Field Summary

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

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

Constructor Summary

Constructors

Constructor and Description
GridDhtDetachedCacheEntry(GridCacheContext ctx, KeyCacheObject key, int hash, CacheObject val, GridCacheMapEntry next, int hdrId)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addRemoved(GridCacheVersion ver)
protected void	clearIndex(CacheObject val) Clears index.
boolean	detached()
int	partition()
void	resetFromPrimary(CacheObject val, GridCacheVersion ver) Sets value to detached entry so it can be retrieved in transactional gets.
String	toString()
CacheObject	unswap(boolean needVal, boolean checkExpire) Unswaps an entry.
protected void	updateIndex(CacheObject val, long expireTime, GridCacheVersion ver, CacheObject old) Updates cache index.
protected void	value(CacheObject val) Sets entry value.
protected CacheObject	valueBytesUnlocked()

Methods inherited from class org.apache.ignite.internal.processors.cache.distributed.GridDistributedCacheEntry

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

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

candidate, candidate, checkObsolete, checkOwnerChanged, checkSerializableReadVersion, clear, clearReader, clearReaders, clearReserveForLoad, context, decrementMapPublicSize, deleted, deletedUnlocked, deletedUnlocked, equals, evictInBatchInternal, evictInternal, evictionDisabled, expireTime, expireTimeExtras, expireTimeUnlocked, hashCode, hasLockCandidate, hasLockCandidate, hasLockCandidateUnsafe, hasOffHeapPointer, hasReaders, hasValue, hasValueUnlocked, incrementMapPublicSize, info, initialValue, initialValue, innerGet, innerGetAndReserveForLoad, innerGetVersioned, innerReload, innerRemove, innerSet, innerUpdate, innerUpdateLocal, invalidate, invalidate, isDht, isInternal, isLocal, isNear, isNew, isNewLocked, isOffHeapValuesOnly, isReplicated, isStartVersion, key, keyValue, localCandidate, localCandidates, localOwner, lockedBy, lockedByAny, lockedByThread, lockedByThread, lockedByThread, lockedByThreadUnsafe, lockedByUnsafe, lockedLocally, lockedLocallyByIdOrThread, lockedLocallyUnsafe, markObsolete, markObsolete0, markObsoleteIfEmpty, markObsoleteVersion, memorySize, mvccAllLocal, mvccExtras, mvccExtras, obsolete, obsolete, obsoleteOrDeleted, obsoleteVersion, obsoleteVersionExtras, offHeapPointer, offHeapPointer, onInvalidate, onMarkedObsolete, onOffheapEvict, onTtlExpired, onUnlock, partitionValid, peek, peek, peekVisibleValue, rawExpireTime, rawGet, rawGetOrUnmarshal, rawGetOrUnmarshalUnlocked, rawPut, rawTtl, readThrough, recordNodeId, releaseSwap, saveValueForIndexUnlocked, startVersion, ttl, ttlAndExpireTimeExtras, ttlExtras, txKey, unswap, unswap, update, updateTtl, updateTtl, valid, valueBytes, valueBytes, valueBytes0, version, versionedEntry, versionedValue, visitable, wrap, wrapEviction, wrapLazyValue, wrapVersioned

Methods inherited from class org.apache.ignite.internal.util.lang.GridMetadataAwareAdapter

addMeta, addMetaIfAbsent, addMetaIfAbsent, allMeta, clone, copyMeta, copyMeta, hasMeta, hasMeta, meta, putMetaIfAbsent, readExternalMeta, removeAllMeta, removeMeta, removeMeta, replaceMeta, writeExternalMeta

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheEntryEx

addMeta, hasMeta, meta, putMetaIfAbsent, removeMeta, removeMeta, replaceMeta

Constructor Detail

GridDhtDetachedCacheEntry

public GridDhtDetachedCacheEntry(GridCacheContext ctx,
                         KeyCacheObject key,
                         int hash,
                         CacheObject val,
                         GridCacheMapEntry next,
                         int hdrId)

Parameters:

ctx - Cache context.

key - Cache key.

hash - Key hash value.

val - Entry value.

next - Next entry in the linked list.

hdrId - Header ID.

Method Detail

resetFromPrimary

public void resetFromPrimary(CacheObject val,
                    GridCacheVersion ver)

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

Parameters:

val - Value.

ver - Version.

unswap

@Nullable
public CacheObject unswap(boolean needVal,
                          boolean checkExpire)
                   throws IgniteCheckedException

Unswaps an entry.

Overrides:

unswap in class GridCacheMapEntry

Parameters:

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

checkExpire - If true checks for expiration, as result entry can be obsoleted or marked deleted.

Returns:

Value.

Throws:

IgniteCheckedException - If failed.

value

protected void value(@Nullable
         CacheObject val)

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

Overrides:

value in class GridCacheMapEntry

Parameters:

val - Value to store.

valueBytesUnlocked

protected CacheObject valueBytesUnlocked()

Overrides:

valueBytesUnlocked in class GridCacheMapEntry

Returns:

Value bytes.

updateIndex

protected void updateIndex(CacheObject val,
               long expireTime,
               GridCacheVersion ver,
               CacheObject old)
                    throws IgniteCheckedException

Updates cache index.

Overrides:

updateIndex in class GridCacheMapEntry

Parameters:

val - Value.

expireTime - Expire time.

ver - New entry version.

old - Previous value.

Throws:

IgniteCheckedException - If update failed.

clearIndex

protected void clearIndex(CacheObject val)
                   throws IgniteCheckedException

Clears index.

Overrides:

clearIndex in class GridCacheMapEntry

Parameters:

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

Throws:

IgniteCheckedException - If failed.

detached

public boolean detached()

Specified by:

detached in interface GridCacheEntryEx

Overrides:

detached in class GridCacheMapEntry

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

addRemoved

public boolean addRemoved(GridCacheVersion ver)

Overrides:

addRemoved in class GridDistributedCacheEntry

Parameters:

ver - Lock version.

Returns:

True if removed.

partition

public int partition()

Specified by:

partition in interface GridCacheEntryEx

Overrides:

partition in class GridCacheMapEntry

Returns:

Partition ID.