org.apache.ignite.internal.processors.cache.local

Class GridLocalCacheEntry

java.lang.Object

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

org.apache.ignite.internal.processors.cache.local.GridLocalCacheEntry

All Implemented Interfaces:

GridCacheEntryEx

public class GridLocalCacheEntry
extends GridCacheMapEntry

Cache entry for local caches.

Field Summary

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

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

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
GridCacheMvccCandidate	addLocal(long threadId, GridCacheVersion ver, long timeout, boolean reenter, boolean tx, boolean implicitSingle) Add local candidate.
boolean	isLocal()
GridCacheMvccCandidate	readyLocal(GridCacheMvccCandidate cand)
GridCacheMvccCandidate	readyLocal(GridCacheVersion ver)
GridCacheMvccCandidate	recheck() Rechecks if lock should be reassigned.
boolean	removeLock(GridCacheVersion ver)
boolean	tmLock(IgniteInternalTx tx, long timeout) This locks is called by transaction manager during prepare step for optimistic transactions.
void	txUnlock(IgniteInternalTx tx) Unlocks lock if it is currently owned.

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

addMeta, candidate, candidate, checkObsolete, clear, clearIndex, clearReader, clearReaders, context, deleted, deletedUnlocked, deletedUnlocked, detached, equals, evictInBatchInternal, evictInternal, expireTime, expireTimeExtras, expireTimeUnlocked, hashCode, hasLockCandidate, hasLockCandidate, hasLockCandidateUnsafe, hasMeta, hasReaders, hasValue, hasValueUnlocked, info, initialValue, initialValue, innerGet, innerReload, innerRemove, innerSet, innerUpdate, innerUpdateLocal, invalidate, invalidate, isDht, isInternal, 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, meta, mvccExtras, mvccExtras, obsolete, obsolete, obsoleteOrDeleted, obsoleteVersion, obsoleteVersionExtras, obsoleteVersionExtras, onInvalidate, onMarkedObsolete, onTtlExpired, partition, partitionValid, peek, peek, peek, peek0, peekVisibleValue, poke, putMetaIfAbsent, rawExpireTime, rawGet, rawGetOrUnmarshal, rawGetOrUnmarshalUnlocked, rawPut, rawTtl, readExternalMeta, readThrough, recordNodeId, releaseSwap, remoteMvccSnapshot, removeMeta, removeMeta, replaceMeta, saveValueForIndexUnlocked, startVersion, toString, ttl, ttlAndExpireTimeExtras, ttlExtras, txKey, unswap, unswap, update, updateIndex, updateTtl, valid, value, valueBytes, valueBytes, valueBytes0, valueBytesUnlocked, version, versionedEntry, versionedValue, visitable, wrap, wrapEviction, wrapLazyValue, wrapVersioned, writeExternalMeta

Methods inherited from class java.lang.Object

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

Constructor Detail

GridLocalCacheEntry

public GridLocalCacheEntry(GridCacheContext ctx,
                   KeyCacheObject key,
                   int hash,
                   CacheObject val,
                   GridCacheMapEntry next,
                   long ttl,
                   int hdrId)

Parameters:

ctx - Cache registry.

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

isLocal

public boolean isLocal()

Specified by:

isLocal in interface GridCacheEntryEx

Overrides:

isLocal in class GridCacheMapEntry

Returns:

True if local.

addLocal

@Nullable
public GridCacheMvccCandidate addLocal(long threadId,
                                       GridCacheVersion ver,
                                       long timeout,
                                       boolean reenter,
                                       boolean tx,
                                       boolean implicitSingle)
                                throws GridCacheEntryRemovedException

Add local candidate.

Parameters:

threadId - Owning thread ID.

ver - Lock version.

timeout - Timeout to acquire lock.

reenter - Reentry flag.

tx - Transaction flag.

implicitSingle - Implicit transaction flag.

Returns:

New candidate.

Throws:

GridCacheEntryRemovedException - If entry has been removed.

readyLocal

@Nullable
public GridCacheMvccCandidate readyLocal(GridCacheMvccCandidate cand)

Parameters:

cand - Candidate.

Returns:

Current owner.

readyLocal

@Nullable
public GridCacheMvccCandidate readyLocal(GridCacheVersion ver)

Parameters:

ver - Candidate version.

Returns:

Current owner.

tmLock

public boolean tmLock(IgniteInternalTx tx,
             long timeout)
               throws GridCacheEntryRemovedException

This locks is called by transaction manager during prepare step for optimistic transactions.

Parameters:

tx - Cache transaction.

timeout - Timeout for lock acquisition.

Returns:

True if lock was acquired, false otherwise.

Throws:

GridCacheEntryRemovedException - If this entry is obsolete.

recheck

@Nullable
public GridCacheMvccCandidate recheck()

Rechecks if lock should be reassigned.

Returns:

Current owner.

txUnlock

public void txUnlock(IgniteInternalTx tx)
              throws GridCacheEntryRemovedException

Unlocks lock if it is currently owned.

Parameters:

tx - Transaction to unlock.

Throws:

GridCacheEntryRemovedException - If this entry has been removed from cache.

removeLock

public boolean removeLock(GridCacheVersion ver)
                   throws GridCacheEntryRemovedException

Parameters:

ver - Removes lock.

Returns:

True If lock has been removed.

Throws:

GridCacheEntryRemovedException - If this entry has been removed from cache.