Package org.apache.ignite.internal.processors.cache

Class GridCacheContext<K,V>

java.lang.Object

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

All Implemented Interfaces:

Externalizable, Serializable

@GridToStringExclude
public class GridCacheContext<K,V>
extends Object
implements Externalizable

Cache context.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	DFLT_READ_LOAD_BALANCING

Constructor Summary

Constructors

Constructor	Description
GridCacheContext()	Empty constructor required for Externalizable.
GridCacheContext(GridKernalContext ctx, GridCacheSharedContext sharedCtx, CacheConfiguration cacheCfg, CacheGroupContext grp, CacheType cacheType, AffinityTopologyVersion locStartTopVer, IgniteUuid deploymentId, boolean affNode, boolean updatesAllowed, boolean statisticsEnabled, boolean recoveryMode, GridCacheEventManager evtMgr, CacheStoreManager storeMgr, CacheEvictionManager evictMgr, GridCacheQueryManager<K,V> qryMgr, CacheContinuousQueryManager contQryMgr, CacheDataStructuresManager dataStructuresMgr, GridCacheTtlManager ttlMgr, GridCacheDrManager drMgr, CacheConflictResolutionManager<K,V> rslvrMgr, CachePluginManager pluginMgr, GridCacheAffinityManager affMgr, PlatformCacheManager platformMgr)

Method Summary

Modifier and Type	Method	Description
<K1,V1> void	addResult(Map<K1,V1> map, KeyCacheObject key, CacheObject val, boolean skipVals, boolean keepCacheObjects, boolean deserializeBinary, boolean cpy, @Nullable EntryGetResult getRes, GridCacheVersion ver, long expireTime, long ttl, boolean needVer, @Nullable ClassLoader ldr)
<K1,V1> void	addResult(Map<K1,V1> map, KeyCacheObject key, CacheObject val, boolean skipVals, boolean keepCacheObjects, boolean deserializeBinary, boolean cpy, GridCacheVersion ver, long expireTime, long ttl, @Nullable ClassLoader ldr)
<K1,V1> void	addResult(Map<K1,V1> map, KeyCacheObject key, EntryGetResult getRes, boolean skipVals, boolean keepCacheObjects, boolean deserializeBinary, boolean cpy, boolean needVer)
GridCacheAffinityManager	affinity()
boolean	affinityNode()
boolean	atomic()
void	awaitStarted()
boolean	binaryMarshaller()
GridCacheAdapter<K,V>	cache()
void	cache(GridCacheAdapter<K,V> cache)
int	cacheId()
Integer	cacheIdBoxed()
Collection<KeyCacheObject>	cacheKeysView(Collection<?> keys)
CacheObjectContext	cacheObjectContext()
void	cacheObjectContext(CacheObjectContext cacheObjCtx)	Sets cache object context.
IgniteCacheObjectProcessor	cacheObjects()
boolean	cancelRemove(@Nullable IgniteBiTuple<Boolean,?> interceptorRes)
void	checkSecurity(SecurityPermission op)
void	cleanup()	Nulling references to potentially leak-prone objects.
GridClosureProcessor	closures()
GridDhtColocatedCache<K,V>	colocated()
CacheConfiguration	config()
boolean	conflictNeedResolve()	Check whether conflict resolution is required.
GridCacheVersionConflictContext<K,V>	conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComp)	Resolve DR conflict.
CacheVersionConflictResolver	conflictResolver()
CacheContinuousQueryManager	continuousQueries()
byte	dataCenterId()
DataRegion	dataRegion()
CacheDataStructuresManager	dataStructures()
boolean	dataStructuresCache()
void	decrementPublicSize(GridCacheMapEntry e)
boolean	deferredDelete()
GridCacheDeploymentManager<K,V>	deploy()
boolean	deploymentEnabled()
GridDhtCacheAdapter<K,V>	dht()
GridDhtCacheAdapter	dhtCache()
void	dhtMap(UUID nearNodeId, AffinityTopologyVersion topVer, GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, @Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
void	dhtMap(GridDhtCacheEntry entry, GridCacheVersion explicitLockVer, IgniteLogger log, Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap, Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
GridDhtTransactionalCacheAdapter<K,V>	dhtTx()
boolean	disableTriggeringCacheInterceptorOnConflict()
GridDiscoveryManager	discovery()
GridCacheDrManager	dr()
DumpEntryChangeListener	dumpListener()
void	dumpListener(DumpEntryChangeListener dumpEntryChangeLsnr)
IgniteUuid	dynamicDeploymentId()
GridCacheVersion[]	emptyVersion()
CacheEntryPredicate	equalsVal(V val)
GridCacheEventManager	events()
CacheEvictionManager	evicts()
@Nullable javax.cache.expiry.ExpiryPolicy	expiry()
@Nullable javax.cache.expiry.ExpiryPolicy	expiryForTxEntry(IgniteTxEntry txEntry)
void	finishRecovery(AffinityTopologyVersion topVer, DynamicCacheDescriptor clusterWideDesc)	Called when cache was restored during recovery and node has joined to topology.
GridCacheGateway<K,V>	gate()
IgniteEx	grid()
IgniteConfiguration	gridConfig()
GridDeploymentManager	gridDeploy()
GridEventStorageManager	gridEvents()
GridIoManager	gridIO()
CacheGroupContext	group()
int	groupId()
CacheEntryPredicate	hasVal()
String	igniteInstanceName()
void	incrementPublicSize(GridCacheMapEntry e)
GridCacheIoManager	io()
byte	ioPolicy()
<E> boolean	isAll(E e, @Nullable IgnitePredicate<? super E>[] p)	Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
boolean	isAll(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	isAllLocked(GridCacheEntryEx e, CacheEntryPredicate[] p)
boolean	isColocated()
boolean	isDht()
boolean	isDhtAtomic()
boolean	isDrEnabled()
boolean	isInvalidate()
boolean	isLocalNode(UUID id)
boolean	isLocalNode(ClusterNode n)
boolean	isNear()
boolean	isPartitioned()
boolean	isQueryEnabled()
boolean	isRecoveryMode()
boolean	isReplicated()
boolean	isReplicatedAffinityNode()
CacheWeakQueryIteratorsHolder<Map.Entry<K,V>>	itHolder()
CacheJtaManagerAdapter	jta()
boolean	keepBinary()
GridKernalContext	kernalContext()
AtomicReference<IgniteInternalFuture<Boolean>>	lastRemoveAllJobFut()	Returns future that assigned to last performing GridDistributedCacheAdapter.GlobalRemoveAllJob.
boolean	loadPreviousValue()
ClusterNode	localNode()
UUID	localNodeId()
IgniteLogger	logger(Class<?> cls)
IgniteLogger	logger(String ctgr)
List<GridCacheManager<K,V>>	managers()
Marshaller	marshaller()
GridCacheMvccManager	mvcc()
String	name()
GridNearCacheAdapter<K,V>	near()
GridNearTransactionalCache<K,V>	nearTx()
boolean	needValueCopy()
@Nullable ClusterNode	node(UUID nodeId)
UUID	nodeId()
CacheEntryPredicate	noVal()
IgniteCacheOffheapManager	offheap()
void	onDeferredDelete(GridCacheEntryEx entry, GridCacheVersion ver)
void	onSchemaAddQueryEntity(Collection<QueryEntity> entities, String sqlSchema, boolean isSqlEscape, int qryParallelism)	Apply changes on enable indexing.
void	onSchemaAddQueryEntity(SchemaAddQueryEntityOperation op)	Apply changes from SchemaAddQueryEntityOperation.
void	onStarted()
CacheOperationContext	operationContextPerCall()	Gets thread local cache operation context.
void	operationContextPerCall(@Nullable CacheOperationContext opCtx)	Sets thread local cache operation context.
CachePluginManager	plugin()
GridCachePreloader	preloader()
void	prepareAffinityField(BinaryObjectBuilder builder)	Prepare affinity field for builder (if possible).
void	printMemoryStats()	Print memory statistics of all cache managers.
Runnable	projectSafe(Runnable r)	Creates Runnable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread.
<T> Callable<T>	projectSafe(Callable<T> r)	Creates callable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread.
boolean	putIfAbsentFilter(@Nullable CacheEntryPredicate[] p)
GridCacheQueryManager<K,V>	queries()
void	readExternal(ObjectInput in)
boolean	readNoEntry(@Nullable IgniteCacheExpiryPolicy expiryPlc, boolean readers)	Checks if it is possible to directly read data memory without entry creation (this is optimization to avoid unnecessary blocking synchronization on cache entry).
protected Object	readResolve()	Reconstructs object on unmarshalling.
boolean	readThrough()
boolean	readThroughConfigured()
boolean	rebalanceEnabled()
boolean	recordEvent(int type)
void	releaseForFastLocalGet(int part, AffinityTopologyVersion topVer)	Releases the partition that was reserved by a call to reserveForFastLocalGet(int, AffinityTopologyVersion).
boolean	reserveForFastLocalGet(int part, AffinityTopologyVersion topVer)	Checks if local reads are allowed for the given partition and reserves the partition when needed.
@Nullable ClusterNode	selectAffinityNodeBalanced(List<ClusterNode> affNodes, Set<ClusterNode> invalidNodes, int partId, boolean canRemap, boolean forcePrimary)	Determines an affinity node to send get request to.
GridCacheSharedContext<K,V>	shared()
boolean	skipStore()
boolean	started()
AffinityTopologyVersion	startTopologyVersion()
boolean	statisticsEnabled()
void	statisticsEnabled(boolean statisticsEnabled)
CacheStoreManager	store()
boolean	syncCommit()
boolean	syncPrimary()
boolean	syncRollback()
boolean	systemTx()
GridTimeoutProcessor	time()
IgniteTxManager	tm()
KeyCacheObject	toCacheKeyObject(byte[] bytes)
KeyCacheObject	toCacheKeyObject(Object obj)
@Nullable CacheObject	toCacheObject(@Nullable Object obj)
GridDhtPartitionTopology	topology()
GridDhtTopologyFuture	topologyVersionFuture()
String	toString()
boolean	transactional()
TransactionChanges<Object>	transactionChanges(Integer part)
GridCacheTtlManager	ttl()
IgniteTxKey	txKey(KeyCacheObject key)
Collection<Object>	unwrapBinariesIfNeeded(Collection<?> col, boolean keepBinary)	Unwraps collection.
Object	unwrapBinaryIfNeeded(Object o, boolean keepBinary, boolean cpy, @Nullable ClassLoader ldr)	Unwraps object for binary.
Object	unwrapBinaryIfNeeded(Object o, boolean keepBinary, @Nullable ClassLoader ldr)	Unwraps object for binary.
Map	unwrapInvokeResult(@Nullable Map<Object,javax.cache.processor.EntryProcessorResult> resMap, boolean keepBinary)
<T> T	unwrapTemporary(@Nullable Object obj)	Converts temporary offheap object to heap-based.
boolean	updatesAllowed()
boolean	userCache()
void	validateKeyAndValue(KeyCacheObject key, CacheObject val)	Performs validation of provided key and value against configured constraints.
IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]	vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)
GridCacheVersionManager	versions()
void	writeExternal(ObjectOutput out)
boolean	writeThrough()
boolean	writeToStoreFromDht()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

DFLT_READ_LOAD_BALANCING

public static final boolean DFLT_READ_LOAD_BALANCING

See Also:

IgniteSystemProperties.IGNITE_READ_LOAD_BALANCING, Constant Field Values

Constructor Detail

GridCacheContext

public GridCacheContext()

Empty constructor required for Externalizable.

GridCacheContext

public GridCacheContext(GridKernalContext ctx,
                        GridCacheSharedContext sharedCtx,
                        CacheConfiguration cacheCfg,
                        CacheGroupContext grp,
                        CacheType cacheType,
                        AffinityTopologyVersion locStartTopVer,
                        IgniteUuid deploymentId,
                        boolean affNode,
                        boolean updatesAllowed,
                        boolean statisticsEnabled,
                        boolean recoveryMode,
                        GridCacheEventManager evtMgr,
                        CacheStoreManager storeMgr,
                        CacheEvictionManager evictMgr,
                        GridCacheQueryManager<K,V> qryMgr,
                        CacheContinuousQueryManager contQryMgr,
                        CacheDataStructuresManager dataStructuresMgr,
                        GridCacheTtlManager ttlMgr,
                        GridCacheDrManager drMgr,
                        CacheConflictResolutionManager<K,V> rslvrMgr,
                        CachePluginManager pluginMgr,
                        GridCacheAffinityManager affMgr,
                        PlatformCacheManager platformMgr)

Parameters:

ctx - Kernal context.

sharedCtx - Cache shared context.

cacheCfg - Cache configuration.

grp - Cache group.

cacheType - Cache type.

locStartTopVer - Topology version when cache was started on local node.

affNode - True if local node is affinity node.

updatesAllowed - Updates allowed flag.

evtMgr - Cache event manager.

storeMgr - Store manager.

evictMgr - Cache eviction manager.

qryMgr - Cache query manager.

contQryMgr - Continuous query manager.

affMgr - Affinity manager.

dataStructuresMgr - Cache dataStructures manager.

ttlMgr - TTL manager.

drMgr - Data center replication manager.

rslvrMgr - Conflict resolution manager.

pluginMgr - Cache plugin manager.

Method Detail

finishRecovery

public void finishRecovery(AffinityTopologyVersion topVer,
                           DynamicCacheDescriptor clusterWideDesc)

Called when cache was restored during recovery and node has joined to topology.

Parameters:

topVer - Cache topology join version.

clusterWideDesc - Cluster-wide cache descriptor received during exchange.

isRecoveryMode

public boolean isRecoveryMode()

Returns:

True if cache is in recovery mode.

groupId

public int groupId()

Returns:

Cache group ID.

group

public CacheGroupContext group()

Returns:

Cache group.

dynamicDeploymentId

public IgniteUuid dynamicDeploymentId()

Returns:

Dynamic deployment ID.

affinityNode

public boolean affinityNode()

Returns:

True if local node is affinity node.

isReplicatedAffinityNode

public boolean isReplicatedAffinityNode()

Returns:

true If this is a replicated cache and we are on a data node.

awaitStarted

public void awaitStarted()
                  throws IgniteCheckedException

Throws:

IgniteCheckedException - If failed to wait.

started

public boolean started()

Returns:

Started flag.

onStarted

public void onStarted()

startTopologyVersion

public AffinityTopologyVersion startTopologyVersion()

Returns:

Topology version when cache was started on local node.

expiry

@Nullable
public @Nullable javax.cache.expiry.ExpiryPolicy expiry()

Returns:

Cache default ExpiryPolicy.

expiryForTxEntry

@Nullable
public @Nullable javax.cache.expiry.ExpiryPolicy expiryForTxEntry(IgniteTxEntry txEntry)

Parameters:

txEntry - TX entry.

Returns:

Expiry policy for the given TX entry.

managers

public List<GridCacheManager<K,V>> managers()

Returns:

Cache managers.

shared

public GridCacheSharedContext<K,V> shared()

Returns:

Shared cache context.

cacheId

public int cacheId()

Returns:

Cache ID.

cacheIdBoxed

public Integer cacheIdBoxed()

Returns:

Cache ID.

systemTx

public boolean systemTx()

Returns:

True if should use system transactions which are isolated from user transactions.

userCache

public boolean userCache()

Returns:

True if cache created by user.

dataStructuresCache

public boolean dataStructuresCache()

Returns:

True if cache created to store data structures.

ioPolicy

public byte ioPolicy()

Returns:

IO policy for the given cache.

cache

public void cache(GridCacheAdapter<K,V> cache)

Parameters:

cache - Cache.

isDht

public boolean isDht()

Returns:

True if cache is DHT.

isDhtAtomic

public boolean isDhtAtomic()

Returns:

True if cache is DHT atomic.

isColocated

public boolean isColocated()

Returns:

True if cache is colocated (dht with near disabled).

isNear

public boolean isNear()

Returns:

True if cache is near cache.

isReplicated

public boolean isReplicated()

Returns:

True if cache is replicated cache.

isPartitioned

public boolean isPartitioned()

Returns:

True if cache is partitioned cache.

isDrEnabled

public boolean isDrEnabled()

Returns:

True in case replication is enabled.

isQueryEnabled

public boolean isQueryEnabled()

Returns:

True in case cache supports query.

deferredDelete

public boolean deferredDelete()

Returns:

True if entries should not be deleted from cache immediately.

incrementPublicSize

public void incrementPublicSize(GridCacheMapEntry e)

Parameters:

e - Entry.

decrementPublicSize

public void decrementPublicSize(GridCacheMapEntry e)

Parameters:

e - Entry.

dht

public GridDhtCacheAdapter<K,V> dht()

Returns:

DHT cache.

dhtTx

public GridDhtTransactionalCacheAdapter<K,V> dhtTx()

Returns:

Transactional DHT cache.

colocated

public GridDhtColocatedCache<K,V> colocated()

Returns:

Colocated cache.

near

public GridNearCacheAdapter<K,V> near()

Returns:

Near cache.

nearTx

public GridNearTransactionalCache<K,V> nearTx()

Returns:

Near cache for transactional mode.

gate

public GridCacheGateway<K,V> gate()

Returns:

Cache gateway.

kernalContext

public GridKernalContext kernalContext()

Returns:

Kernal context.

grid

public IgniteEx grid()

Returns:

Grid instance.

igniteInstanceName

public String igniteInstanceName()

Returns:

Ignite instance name.

name

public String name()

Returns:

Cache name.

dataRegion

public DataRegion dataRegion()

Returns:

Data region.

txKey

public IgniteTxKey txKey(KeyCacheObject key)

Parameters:

key - Key to construct tx key for.

Returns:

Transaction key.

checkSecurity

public void checkSecurity(SecurityPermission op)
                   throws SecurityException

Parameters:

op - Operation to check.

Throws:

SecurityException - If security check failed.

preloader

public GridCachePreloader preloader()

Returns:

Preloader.

nodeId

public UUID nodeId()

Returns:

Local node ID.

rebalanceEnabled

public boolean rebalanceEnabled()

Returns:

True if rebalance is enabled.

atomic

public boolean atomic()

Returns:

True if atomic.

transactional

public boolean transactional()

Returns:

True if transactional.

disableTriggeringCacheInterceptorOnConflict

public boolean disableTriggeringCacheInterceptorOnConflict()

Returns:

True if cache interceptor should be skipped in case of conflicts.

localNode

public ClusterNode localNode()

Returns:

Local node.

localNodeId

public UUID localNodeId()

Returns:

Local node ID.

isLocalNode

public boolean isLocalNode(ClusterNode n)

Parameters:

n - Node to check.

Returns:

True if node is local.

isLocalNode

public boolean isLocalNode(UUID id)

Parameters:

id - Node ID to check.

Returns:

True if node ID is local.

node

@Nullable
public @Nullable ClusterNode node(UUID nodeId)

Parameters:

nodeId - Node id.

Returns:

Node.

topology

public GridDhtPartitionTopology topology()

Returns:

Partition topology.

dhtCache

public GridDhtCacheAdapter dhtCache()

Returns:

DHT cache.

topologyVersionFuture

public GridDhtTopologyFuture topologyVersionFuture()

Returns:

Topology version future.

marshaller

public Marshaller marshaller()

Returns:

Marshaller.

logger

public IgniteLogger logger(String ctgr)

Parameters:

ctgr - Category to log.

Returns:

Logger.

logger

public IgniteLogger logger(Class<?> cls)

Parameters:

cls - Class to log.

Returns:

Logger.

gridConfig

public IgniteConfiguration gridConfig()

Returns:

Grid configuration.

gridIO

public GridIoManager gridIO()

Returns:

Grid communication manager.

time

public GridTimeoutProcessor time()

Returns:

Grid timeout processor.

gridDeploy

public GridDeploymentManager gridDeploy()

Returns:

Grid deployment manager.

gridEvents

public GridEventStorageManager gridEvents()

Returns:

Grid event storage manager.

closures

public GridClosureProcessor closures()

Returns:

Closures processor.

discovery

public GridDiscoveryManager discovery()

Returns:

Grid discovery manager.

cache

public GridCacheAdapter<K,V> cache()

Returns:

Cache instance.

config

public CacheConfiguration config()

Returns:

Cache configuration for given cache instance.

Throws:

IllegalStateException - If this cache context was cleaned up.

writeToStoreFromDht

public boolean writeToStoreFromDht()

Returns:

True If store writes should be performed from dht transactions. This happens if both writeBehindEnabled and writeBehindPreferPrimary cache configuration properties are set to true or the store is local.

tm

public IgniteTxManager tm()

Returns:

Cache transaction manager.

versions

public GridCacheVersionManager versions()

Returns:

Lock order manager.

mvcc

public GridCacheMvccManager mvcc()

Returns:

Lock manager.

events

public GridCacheEventManager events()

Returns:

Event manager.

affinity

public GridCacheAffinityManager affinity()

Returns:

Cache affinity manager.

queries

public GridCacheQueryManager<K,V> queries()

Returns:

Query manager, null if disabled.

continuousQueries

public CacheContinuousQueryManager continuousQueries()

Returns:

Continuous query manager, null if disabled.

itHolder

public CacheWeakQueryIteratorsHolder<Map.Entry<K,V>> itHolder()

Returns:

Iterators Holder.

store

public CacheStoreManager store()

Returns:

Store manager.

deploy

public GridCacheDeploymentManager<K,V> deploy()

Returns:

Cache deployment manager.

io

public GridCacheIoManager io()

Returns:

Cache communication manager.

evicts

public CacheEvictionManager evicts()

Returns:

Eviction manager.

dataStructures

public CacheDataStructuresManager dataStructures()

Returns:

Data structures manager.

dr

public GridCacheDrManager dr()

Returns:

DR manager.

offheap

public IgniteCacheOffheapManager offheap()

Returns:

Offheap manager.

ttl

public GridCacheTtlManager ttl()

Returns:

TTL manager.

jta

public CacheJtaManagerAdapter jta()

Returns:

JTA manager.

plugin

public CachePluginManager plugin()

Returns:

Cache plugin manager.

putIfAbsentFilter

public boolean putIfAbsentFilter(@Nullable
                                 @Nullable CacheEntryPredicate[] p)

Parameters:

p - Predicate.

Returns:

True if given predicate is filter for putIfAbsent operation.

noVal

public CacheEntryPredicate noVal()

Returns:

No value filter.

hasVal

public CacheEntryPredicate hasVal()

Returns:

Has value filter.

equalsVal

public CacheEntryPredicate equalsVal(V val)

Parameters:

val - Value to check.

Returns:

Predicate that checks for value.

emptyVersion

public GridCacheVersion[] emptyVersion()

Returns:

Empty cache version array.

cacheObjectContext

public void cacheObjectContext(CacheObjectContext cacheObjCtx)

Sets cache object context.

Parameters:

cacheObjCtx - Cache object context.

vararg

public IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] vararg(IgnitePredicate<javax.cache.Cache.Entry<K,V>> p)

Parameters:

p - Single predicate.

Returns:

Array containing single predicate.

isAll

public <E> boolean isAll(E e,
                         @Nullable
                         @Nullable IgnitePredicate<? super E>[] p)
                  throws IgniteCheckedException

Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.

Type Parameters:

E - Element type.

Parameters:

e - Element.

p - Predicates.

Returns:

True if predicates passed.

Throws:

IgniteCheckedException - If failed.

isAll

public boolean isAll(GridCacheEntryEx e,
                     CacheEntryPredicate[] p)
              throws IgniteCheckedException

Parameters:

e - Entry.

p - Predicates.

Returns:

True if predicates passed.

Throws:

IgniteCheckedException - If failed.

isAllLocked

public boolean isAllLocked(GridCacheEntryEx e,
                           CacheEntryPredicate[] p)
                    throws IgniteCheckedException

Parameters:

e - Entry.

p - Predicates.

Returns:

True if predicates passed.

Throws:

IgniteCheckedException - If failed.

operationContextPerCall

public void operationContextPerCall(@Nullable
                                    @Nullable CacheOperationContext opCtx)

Sets thread local cache operation context.

Parameters:

opCtx - Operation context.

operationContextPerCall

public CacheOperationContext operationContextPerCall()

Gets thread local cache operation context.

Returns:

Operation context per call.

skipStore

public boolean skipStore()

Returns:

true if the skip store flag is set.

projectSafe

public Runnable projectSafe(Runnable r)

Creates Runnable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread. If no projection is set for current thread then there's no need to create new object and method simply returns given Runnable.

Parameters:

r - Runnable.

Returns:

Runnable that can be executed in a different thread with the same projection as for current thread.

projectSafe

public <T> Callable<T> projectSafe(Callable<T> r)

Creates callable that can be executed safely in a different thread inheriting the same thread local projection as for the current thread. If no projection is set for current thread then there's no need to create new object and method simply returns given callable.

Parameters:

r - Callable.

Returns:

Callable that can be executed in a different thread with the same projection as for current thread.

deploymentEnabled

public boolean deploymentEnabled()

Returns:

True if deployment is enabled.

readThrough

public boolean readThrough()

Returns:

True if store read-through mode is enabled.

readThroughConfigured

public boolean readThroughConfigured()

Returns:

True if store and read-through mode are enabled in configuration.

loadPreviousValue

public boolean loadPreviousValue()

Returns:

True if CacheConfiguration.isLoadPreviousValue() flag is set.

writeThrough

public boolean writeThrough()

Returns:

True if store write-through is enabled.

isInvalidate

public boolean isInvalidate()

Returns:

True if invalidation is enabled.

syncCommit

public boolean syncCommit()

Returns:

True if synchronous commit is enabled.

syncRollback

public boolean syncRollback()

Returns:

True if synchronous rollback is enabled.

syncPrimary

public boolean syncPrimary()

Returns:

True if only primary node should be updated synchronously.

dhtMap

public void dhtMap(UUID nearNodeId,
                   AffinityTopologyVersion topVer,
                   GridDhtCacheEntry entry,
                   GridCacheVersion explicitLockVer,
                   IgniteLogger log,
                   Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
                   @Nullable
                   @Nullable Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
            throws GridCacheEntryRemovedException

Parameters:

nearNodeId - Near node ID.

topVer - Topology version.

entry - Entry.

log - Log.

dhtMap - Dht mappings.

nearMap - Near mappings.

Throws:

GridCacheEntryRemovedException - If reader for entry is removed.

dhtMap

public void dhtMap(GridDhtCacheEntry entry,
                   GridCacheVersion explicitLockVer,
                   IgniteLogger log,
                   Map<ClusterNode,List<GridDhtCacheEntry>> dhtMap,
                   Map<ClusterNode,List<GridDhtCacheEntry>> nearMap)
            throws GridCacheEntryRemovedException

Parameters:

entry - Entry.

log - Log.

dhtMap - Dht mappings.

nearMap - Near mappings.

Throws:

GridCacheEntryRemovedException - If reader for entry is removed.

conflictNeedResolve

public boolean conflictNeedResolve()

Check whether conflict resolution is required.

Returns:

True in case DR is required.

conflictResolver

public CacheVersionConflictResolver conflictResolver()

Returns:

Conflict resolver.

conflictResolve

public GridCacheVersionConflictContext<K,V> conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry,
                                                                  GridCacheVersionedEntryEx<K,V> newEntry,
                                                                  boolean atomicVerComp)
                                                           throws IgniteCheckedException

Resolve DR conflict.

Parameters:

oldEntry - Old entry.

newEntry - New entry.

atomicVerComp - Whether to use atomic version comparator.

Returns:

Conflict resolution result.

Throws:

IgniteCheckedException - In case of exception.

dataCenterId

public byte dataCenterId()

Returns:

Data center ID.

onDeferredDelete

public void onDeferredDelete(GridCacheEntryEx entry,
                             GridCacheVersion ver)

Parameters:

entry - Entry.

ver - Version.

cancelRemove

public boolean cancelRemove(@Nullable
                            @Nullable IgniteBiTuple<Boolean,?> interceptorRes)

Parameters:

interceptorRes - Result of CacheInterceptor.onBeforeRemove(javax.cache.Cache.Entry<K, V>) callback.

Returns:

True if interceptor cancels remove.

cacheObjects

public IgniteCacheObjectProcessor cacheObjects()

Returns:

Binary processor.

binaryMarshaller

public boolean binaryMarshaller()

Returns:

True if is configured.

keepBinary

public boolean keepBinary()

Returns:

Keep binary flag.

needValueCopy

public boolean needValueCopy()

Returns:

True if the value for the cache object has to be copied because of CacheConfiguration.isCopyOnRead().

unwrapTemporary

@Nullable
public <T> T unwrapTemporary(@Nullable
                             @Nullable Object obj)

Converts temporary offheap object to heap-based.

Parameters:

obj - Object.

Returns:

Heap-based object.

unwrapBinariesIfNeeded

public Collection<Object> unwrapBinariesIfNeeded(Collection<?> col,
                                                 boolean keepBinary)

Unwraps collection.

Parameters:

col - Collection to unwrap.

keepBinary - Keep binary flag.

Returns:

Unwrapped collection.

unwrapBinaryIfNeeded

public Object unwrapBinaryIfNeeded(Object o,
                                   boolean keepBinary,
                                   @Nullable
                                   @Nullable ClassLoader ldr)

Unwraps object for binary.

Parameters:

o - Object to unwrap.

keepBinary - Keep binary flag.

ldr - Class loader, used for deserialization from binary representation.

Returns:

Unwrapped object.

unwrapBinaryIfNeeded

public Object unwrapBinaryIfNeeded(Object o,
                                   boolean keepBinary,
                                   boolean cpy,
                                   @Nullable
                                   @Nullable ClassLoader ldr)

Unwraps object for binary.

Parameters:

o - Object to unwrap.

keepBinary - Keep binary flag.

cpy - Copy value flag.

ldr - Class loader, used for deserialization from binary representation.

Returns:

Unwrapped object.

unwrapInvokeResult

public Map unwrapInvokeResult(@Nullable
                              @Nullable Map<Object,javax.cache.processor.EntryProcessorResult> resMap,
                              boolean keepBinary)

Parameters:

resMap - Invoke results map.

keepBinary - Keep binary flag.

Returns:

Unwrapped results.

cacheObjectContext

public CacheObjectContext cacheObjectContext()

Returns:

Cache object context.

toCacheObject

@Nullable
public @Nullable CacheObject toCacheObject(@Nullable
                                           @Nullable Object obj)

Parameters:

obj - Object.

Returns:

Cache object.

toCacheKeyObject

public KeyCacheObject toCacheKeyObject(Object obj)

Parameters:

obj - Object.

Returns:

Cache key object.

toCacheKeyObject

public KeyCacheObject toCacheKeyObject(byte[] bytes)
                                throws IgniteCheckedException

Parameters:

bytes - Bytes.

Returns:

Cache key object.

Throws:

IgniteCheckedException - If failed.

validateKeyAndValue

public void validateKeyAndValue(KeyCacheObject key,
                                CacheObject val)
                         throws IgniteCheckedException

Performs validation of provided key and value against configured constraints.

Parameters:

key - Key.

val - Value.

Throws:

IgniteCheckedException

addResult

public <K1,V1> void addResult(Map<K1,V1> map,
                                    KeyCacheObject key,
                                    CacheObject val,
                                    boolean skipVals,
                                    boolean keepCacheObjects,
                                    boolean deserializeBinary,
                                    boolean cpy,
                                    GridCacheVersion ver,
                                    long expireTime,
                                    long ttl,
                                    @Nullable
                                    @Nullable ClassLoader ldr)

Parameters:

map - Map.

key - Key.

val - Value.

skipVals - Skip values flag.

keepCacheObjects - Keep cache objects flag.

deserializeBinary - Deserialize binary flag.

cpy - Copy flag.

ver - GridCacheVersion.

ldr - Class loader, used for deserialization from binary representation.

addResult

public <K1,V1> void addResult(Map<K1,V1> map,
                                    KeyCacheObject key,
                                    EntryGetResult getRes,
                                    boolean skipVals,
                                    boolean keepCacheObjects,
                                    boolean deserializeBinary,
                                    boolean cpy,
                                    boolean needVer)

Parameters:

map - Map.

key - Key.

getRes - EntryGetResult.

skipVals - Skip values.

keepCacheObjects - Keep CacheObject.

deserializeBinary - Deserialize binary flag.

cpy - Copy flag.

needVer - Need version flag.

addResult

public <K1,V1> void addResult(Map<K1,V1> map,
                                    KeyCacheObject key,
                                    CacheObject val,
                                    boolean skipVals,
                                    boolean keepCacheObjects,
                                    boolean deserializeBinary,
                                    boolean cpy,
                                    @Nullable
                                    @Nullable EntryGetResult getRes,
                                    GridCacheVersion ver,
                                    long expireTime,
                                    long ttl,
                                    boolean needVer,
                                    @Nullable
                                    @Nullable ClassLoader ldr)

Parameters:

map - Map.

key - Key.

val - Value.

skipVals - Skip values.

keepCacheObjects - Keep CacheObject.

deserializeBinary - Deserialize binary.

cpy - Copy flag.

getRes - EntryGetResult.

ver - Version.

expireTime - Entry expire time.

ttl - Entry TTL.

needVer - Need version flag.

ldr - Class loader, used for deserialization from binary representation.

updatesAllowed

public boolean updatesAllowed()

Returns:

Updates allowed.

cleanup

public void cleanup()

Nulling references to potentially leak-prone objects.

printMemoryStats

public void printMemoryStats()

Print memory statistics of all cache managers. NOTE: this method is for testing and profiling purposes only.

cacheKeysView

public Collection<KeyCacheObject> cacheKeysView(Collection<?> keys)

Parameters:

keys - Keys.

Returns:

Read-only collection of KeyCacheObject instances.

reserveForFastLocalGet

public boolean reserveForFastLocalGet(int part,
                                      AffinityTopologyVersion topVer)

Checks if local reads are allowed for the given partition and reserves the partition when needed. If this method returns true, then releaseForFastLocalGet(int, AffinityTopologyVersion) method must be called after the read is completed.

Parameters:

part - Partition.

topVer - Topology version.

Returns:

True if cache 'get' operation is allowed to get entry locally.

releaseForFastLocalGet

public void releaseForFastLocalGet(int part,
                                   AffinityTopologyVersion topVer)

Releases the partition that was reserved by a call to reserveForFastLocalGet(int, AffinityTopologyVersion).

Parameters:

part - Partition to release.

topVer - Topology version.

readNoEntry

public boolean readNoEntry(@Nullable
                           @Nullable IgniteCacheExpiryPolicy expiryPlc,
                           boolean readers)

Checks if it is possible to directly read data memory without entry creation (this is optimization to avoid unnecessary blocking synchronization on cache entry).

Parameters:

expiryPlc - Optional expiry policy for read operation.

readers - True if need update near cache readers.

Returns:

True if it is possible to directly read offheap instead of using GridCacheEntryEx.innerGet(org.apache.ignite.internal.processors.cache.version.GridCacheVersion, org.apache.ignite.internal.processors.cache.transactions.IgniteInternalTx, boolean, boolean, boolean, java.lang.Object, java.lang.String, org.apache.ignite.internal.processors.cache.IgniteCacheExpiryPolicy, boolean).

recordEvent

public boolean recordEvent(int type)

Parameters:

type - Event type.

Returns:

True if event should be recorded.

selectAffinityNodeBalanced

@Nullable
public @Nullable ClusterNode selectAffinityNodeBalanced(List<ClusterNode> affNodes,
                                                        Set<ClusterNode> invalidNodes,
                                                        int partId,
                                                        boolean canRemap,
                                                        boolean forcePrimary)

Determines an affinity node to send get request to.

Parameters:

affNodes - All affinity nodes.

canRemap - Flag indicating that 'get' should be done on a locked topology version.

partId - Partition ID.

forcePrimary - Force primary flag.

Returns:

Affinity node to get key from or null if there is no suitable alive node.

prepareAffinityField

public void prepareAffinityField(BinaryObjectBuilder builder)

Prepare affinity field for builder (if possible).

Parameters:

builder - Builder.

statisticsEnabled

public boolean statisticsEnabled()

Returns:

Statistics enabled flag.

statisticsEnabled

public void statisticsEnabled(boolean statisticsEnabled)

Parameters:

statisticsEnabled - Statistics enabled flag.

onSchemaAddQueryEntity

public void onSchemaAddQueryEntity(SchemaAddQueryEntityOperation op)

Apply changes from SchemaAddQueryEntityOperation.

Parameters:

op - Add query entity schema operation.

onSchemaAddQueryEntity

public void onSchemaAddQueryEntity(Collection<QueryEntity> entities,
                                   String sqlSchema,
                                   boolean isSqlEscape,
                                   int qryParallelism)

Apply changes on enable indexing.

Parameters:

entities - New query entities.

sqlSchema - Sql schema name.

isSqlEscape - Sql escape flag.

qryParallelism - Query parallelism parameter.

lastRemoveAllJobFut

public AtomicReference<IgniteInternalFuture<Boolean>> lastRemoveAllJobFut()

Returns future that assigned to last performing GridDistributedCacheAdapter.GlobalRemoveAllJob.

dumpListener

public DumpEntryChangeListener dumpListener()

dumpListener

public void dumpListener(DumpEntryChangeListener dumpEntryChangeLsnr)

transactionChanges

public TransactionChanges<Object> transactionChanges(Integer part)

Parameters:

part - Partition.

Returns:

First, set of object changed in transaction, second, list of transaction data in required format.

See Also:

ExecutionContext#transactionChanges(int, int[], Function)

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
                         ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

readResolve

protected Object readResolve()
                      throws ObjectStreamException

Reconstructs object on unmarshalling.

Returns:

Reconstructed object.

Throws:

ObjectStreamException - Thrown in case of unmarshalling error.

toString

public String toString()

Overrides:

toString in class Object