CacheManager (GigaSpaces 15.8.0 API)

java.lang.Object
- com.j_spaces.core.cache.AbstractCacheManager
- - com.j_spaces.core.cache.CacheManager

All Implemented Interfaces:

SpaceEvictionManager
```
public class CacheManager
extends AbstractCacheManager
implements SpaceEvictionManager
```
The Cache Manager acts as a fast intermediate storage for objects in Virtual Memory.
The maximum number of objects cached in memory is determined by a space property (cache-size).
However, according to this implementation, the following objects are always in the cache:
- Templates of any kind
- Active Transactions
- Entries locked under Active Transactions
- Entries waiting for templates
The objects in the cache are indexed.
Templates are cached in memory and are not written to the underlying SA.

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`CacheManager.InitialLoadOrigin` INITIALLOAD INFO.
`static class`	`CacheManager.RecentDeleteCodes` usage of recent deletes.

Field Summary

Fields
Modifier and Type	Field and Description
`TerminatingFifoXtnsInfo`	`_terminatingXtnsInfo`
`static boolean`	`GS_13953_ENABLED`
`static int`	`MIN_SIZE_TO_CONSIDER_COMPOUND_INDICES`
`static int`	`MIN_SIZE_TO_PERFORM_EXPLICIT_PROPERTIES_INDEX_SCAN_`

Fields inherited from class com.j_spaces.core.cache.AbstractCacheManager
_evictionQuota, m_CacheSize

Constructor Summary

Constructors
Constructor and Description
`CacheManager(SpaceConfigReader configReader, ClusterPolicy clusterPolicy, SpaceTypeManager typeManager, IReplicationNode replicationNode, IStorageAdapter sa, SpaceEngine engine, Properties customProperties)`

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addToEvictionStrategy(EvictableServerEntry entry, boolean isNew)`
`IEntryHolder`	`associateEntryWithXtn(Context context, IEntryHolder entryHolder, ITemplateHolder template, XtnEntry xtnEntry, IEntryHolder new_content)` tie an entry with a transaction.
`void`	`closeQueryExtensionManagers()`
`void`	`commit(Context context, XtnEntry xtnEntry, boolean singleParticipant, boolean anyUpdates, boolean supportsTwoPhaseReplication)`
`int`	`count(Context context, ITemplateHolder template, XtnEntry xtnFilter)`
`void`	`disconnectEntryFromXtn(Context context, IEntryHolder entryHolder, XtnEntry xtnEntry, boolean xtnEnd)` disconnect an entry from xtn
`int`	`evictBatch(int evictionQuota)` evict a quota of entries from cache.
`void`	`extendLeasePeriod(Context context, long time, long original_time, String uid, String classname, int objectType, boolean shouldReplicate, boolean origin)`
`Object`	`findTemplatesByIndex(Context context, IServerTypeDesc typeDesc, IEntryHolder entry, MatchTarget matchTarget)` given a class name return the SL of matching templates.
`boolean`	`forceSpaceIdIndexIfEqual()`
`Context`	`freeCacheContext(Context context)`
`IBlobStoreCacheHandler`	`getBlobStoreInternalCache()`
`BlobStoreMemoryMonitor`	`getBlobStoreMemoryMonitor()`
`IStorageConsistency`	`getBlobStoreRecoveryHelper()`
`BlobStoreStatistics`	`getBlobStoreStatistics()`
`BlobStoreExtendedStorageHandler`	`getBlobStoreStorageHandler()`
`Context`	`getCacheContext()`
`static org.slf4j.Logger`	`getCacheLogger()`
`String`	`getConfigInfo()`
`SpaceEngine`	`getEngine()`
`int`	`getEnriesSize()`
`IEntryCacheInfo[]`	`getEntriesByUniqueIds(IServerTypeDesc currServerTypeDesc, Object[] ids, ITemplateHolder template)`
`IStoredList<IEntryCacheInfo>`	`getEntriesMinIndex(Context context, TypeData typeData, int numOfFields, ITemplateHolder template)` Computes the best way to reach a list of potential match of entries of the specified type.
`Object`	`getEntriesMinIndexExtended(Context context, TypeData entryType, int numOfFields, ITemplateHolder template)` Using extended match-
`IEntryHolder`	`getEntry(Context context, IEntryHolder entryHolder, boolean tryInsertToCache, boolean lockedEntry)`
`IEntryHolder`	`getEntry(Context context, IEntryHolder entryHolder, boolean tryInsertToCache, boolean lockedEntry, boolean useOnlyCache)`
`IEntryHolder`	`getEntry(Context context, String uid, String inputClassName, IEntryHolder template, boolean tryInsertToCache, boolean lockedEntry, boolean useOnlyCache)` get entry by its uid, and, optionally, by its template className is passed if known, can be null template is not null if isCacheExternalDB is true: external DB, the template must contain the PK fields insertToCache- true if entry shouldbe inserted to cache
`IEntryHolder`	`getEntryByIdFromPureCache(Object id, IServerTypeDesc typeDesc)`
`IEntryHolder`	`getEntryByUidFromPureCache(String uid)`
`IEntryCacheInfo`	`getEntryByUniqueId(IServerTypeDesc currServerTypeDesc, Object templateValue, ITemplateHolder template)`
`IEntryCacheInfo`	`getEntryCacheInfo(IEntryHolder eh)` get PEntry for entry.
`IEntryHolder`	`getEntryFromCacheHolder(IEntryCacheInfo pt)` given a PEntry, return the entry.
`String`	`getEvictionPolicyReplicationMembersGroupName()`
`IEvictionReplicationsMarkersRepository`	`getEvictionReplicationsMarkersRepository()`
`FifoBackgroundDispatcher`	`getFifoBackgroundDispatcher()`
`TerminatingFifoXtnsInfo.FifoXtnEntryInfo`	`getFifoEntryXtnInfo(IEntryHolder eh)`
`FifoGroupCacheImpl`	`getFifoGroupCacheImpl()`
`long`	`getFifoXtnNumber(XtnEntry xtnEntry)` get the fifo xtn number of a xtn
`long`	`getLatestTTransactionTerminationNum()` get the Terminating fifo transaction
`LeaseManager`	`getLeaseManager()`
`Map<String,LocalCacheDetails>`	`getLocalCaches()`
`IBasicLockManager<IEntryHolder>`	`getLockManager()` get the lock manager
`static org.slf4j.Logger`	`getLogger()`
`IScanListIterator<IEntryCacheInfo>`	`getMatchingMemoryEntriesForScanning(Context context, IServerTypeDesc currServerTypeDesc, ITemplateHolder template, IServerTypeDesc serverTypeDesc)`
`int`	`getMinExtendedIndexActivationSize()`
`int`	`getNumberOfEntries()`
`int`	`getNumberOfEntries(String typeName, boolean includeSubtypes)`
`int`	`getNumberOfLockedObjectsUnderTxn(XtnEntry xtnEntry)` used by getTransactionsInfo to retrieve number of Locked Objects
`int`	`getNumberOfNotifyTemplates()`
`int`	`getNumberOfNotifyTemplates(String typeName, boolean includeSubtypes)`
`int`	`getNumOfRecentDeletes()`
`int`	`getNumOfRecentUpdates()`
`IEntryCacheInfo`	`getPEntryByUid(String uid)`
`QueryExtensionIndexManagerWrapper`	`getQueryExtensionManager(String namespace)`
`RecentDeletesRepository.RecentDeleteInfo`	`getRecentDeleteInfo(String uid)`
`Iterator<RecentDeletesRepository.RecentDeleteInfo>`	`getRecentDeletesIterator()`
`RecentUpdatesRepository.RecentUpdateInfo`	`getRecentUpdateInfo(String uid)`
`Iterator<RecentUpdatesRepository.RecentUpdateInfo>`	`getRecentUpdatesIterator()`
`IReplicationOutContext`	`getReplicationContext(Context context)`
`SpaceRuntimeInfo`	`getRuntimeInfo(String typeName)`
`SQLFunctions`	`getSqlFunctions()`
`IStorageAdapter`	`getStorageAdapter()`
`ITemplateHolder`	`getTemplate(String uid)`
`TemplateCacheInfo`	`getTemplateCacheInfo(ITemplateHolder th)` get PEntry for entry.
`TemplateExpirationManager`	`getTemplateExpirationManager()`
`List<TemplateInfo>`	`getTemplatesInfo(String className)` returns a list of all the pending templates for the given class
`TemplatesManager`	`getTemplatesManager()`
`ConcurrentHashMap<TerminatingFifoXtnsInfo.FifoXtnEntryInfo,TerminatingFifoXtnsInfo.FifoXtnEntryInfo>`	`getTerminatingXtnsEntries()`
`TypeData`	`getTypeData(IServerTypeDesc typeDesc)`
`TypeDataFactory`	`getTypeDataFactory()`
`SpaceTypeManager`	`getTypeManager()`
`void`	`handleFifoGroupsCacheOnXtnEnd(Context context, XtnEntry xtnEntry)`
`void`	`handleInsertEntryReplication(Context context, IEntryHolder entryHolder)`
`void`	`handleInsertEntryReplication(Context context, IEntryHolder entryHolder, int blobstoreBulkId)`
`void`	`handleRemoveEntryReplication(Context context, IEntryHolder entryHolder, SpaceEngine.EntryRemoveReasonCodes removeReason)`
`void`	`handleRemoveEntryReplication(Context context, IEntryHolder entryHolder, SpaceEngine.EntryRemoveReasonCodes removeReason, int blobstoreBulkId)`
`void`	`handleUnderXtnUpdate(Context context, ServerTransaction xtn, IEntryHolder eh, boolean isCommitting, XtnData pXtn)` xtn terminating-handle under xtn updates.
`void`	`handleUpdateEntryReplication(Context context, IEntryHolder new_eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators)`
`void`	`handleUpdateEntryReplication(Context context, IEntryHolder new_eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators, int blobstoreBulkId)`
`boolean`	`hasBlobStoreOffHeapCache()`
`boolean`	`hasBlobStoreOffHeapStore()`
`void`	`init(Properties properties)`
`void`	`initCache(boolean loadDataFromDB, Properties properties)` Init.
`boolean`	`initiatedEviction(Context context, IEntryHolder entry, boolean shouldReplicate)`
`void`	`insertEntry(Context context, IEntryHolder entryHolder, boolean shouldReplicate, boolean origin, boolean suppliedUid)` insert an entry to the space.
`void`	`insertEntryReferences(Context context, IEntryCacheInfo pEntry, TypeData pType, boolean applySequenceNumber)` Inserts the refs to cache.
`void`	`insertTemplate(Context context, ITemplateHolder templateHolder, boolean shouldReplicate)` insert a template to the cache and DB.
`void`	`insertToRecentDeletes(IEntryHolder entry, long duration, ServerTransaction committingXtn)`
`void`	`insertToRecentUpdates(IEntryHolder entry, long duration, ServerTransaction committingXtn)`
`void`	`insertToRecentUpdatesIfNeeded(IEntryHolder entry, long duration, ServerTransaction committingXtn)`
`boolean`	`isblobStoreDataSpace()`
`boolean`	`isCacheExternalDB()` Returns an indication if Storage Adapter acts as an external data-source.
`boolean`	`isCentralDB()` returns an indication if the underlying DB is a central DB common to several cluster members
`boolean`	`isClusteredExternalDBEnabled()` Returns an indication if Storage Adapter acts as an external clustered data-source.
`boolean`	`isDirectPersistencyEmbeddedtHandlerUsed()`
`boolean`	`isDummyEntry(IEntryHolder eh)`
`boolean`	`isEmptyAfterInitialLoadStage()`
`boolean`	`isEntryInPureCache(String uid)`
`boolean`	`isEntryInRecentUpdates(IEntryHolder entry)`
`boolean`	`isFromFifoClass(IServerTypeDesc typeDesc)`
`boolean`	`isMemorySpace()` is this space a memory space ?
`boolean`	`isPersistentBlobStore()`
`boolean`	`isResidentCacheEntry(EvictableServerEntry entry)`
`boolean`	`isSyncHybrid()`
`boolean`	`isTimeBasedEvictionStrategy()`
`boolean`	`isVersionedExternalDB()` returns an indication if the underlying data-source supports versioning.
`void`	`lockEntry(XtnData xtn, IEntryCacheInfo pEntry, OperationID operationID)`
`IEntryHolder`	`makeChangeOpEntry(Context context, ITemplateHolder template, IEntryHolder currentEntry)`
`ISAdapterIterator<IEntryHolder>`	`makeEntriesIter(Context context, ITemplateHolder template, IServerTypeDesc serverTypeDesc, long SCNFilter, long leaseFilter, boolean memoryOnly)`
`ISAdapterIterator<IEntryHolder>`	`makeEntriesIter(Context context, ITemplateHolder template, IServerTypeDesc serverTypeDesc, long SCNFilter, long leaseFilter, boolean memoryOnly, boolean transientOnly)`
`IScanListIterator`	`makeScanableEntriesIter(Context context, ITemplateHolder template, IServerTypeDesc serverTypeDesc, long SCNFilter, long leaseFilter, boolean memoryOnly)`
`ISAdapterIterator`	`makeUnderXtnEntriesIter(Context context, XtnEntry xtnEntry, int selectType)`
`ISAdapterIterator`	`makeUnderXtnEntriesIter(Context context, XtnEntry xtnEntry, int selectType, boolean returnPentries)`
`ISAdapterIterator<ITemplateHolder>`	`makeUnderXtnTemplatesIter(Context context, XtnEntry xtnEntry)`
`void`	`makeWaitForInfo(Context context, IEntryHolder entryHolder, ITemplateHolder templateHolder)`
`boolean`	`mayNeedEntriesUnpinning()`
`boolean`	`needReReadAfterEntryLock()`
`boolean`	`optimizedBlobStoreClear()`
`void`	`preCommit(Context context, XtnEntry xtnEntry, boolean supportsTwoPhaseReplication)`
`void`	`prepare(Context context, XtnEntry xtnEntry, boolean supportsTwoPhaseReplication, boolean handleReplication, boolean handleSA)`
`void`	`prePrepare(XtnEntry xtnEntry)` this method is called by the engine in order to make a "snapshot" of entries needed for notify.
`int`	`removeEntry(Context context, IEntryHolder entryHolder, IEntryCacheInfo pEntry, boolean shouldReplicate, boolean origin, SpaceEngine.EntryRemoveReasonCodes removeReason, boolean disableSAcall)` remove entry from cache & SA
`boolean`	`removeEntryFromCache(IEntryHolder entryHolder)` Removes the specified entry from cache.
`boolean`	`removeEntryFromCache(IEntryHolder entryHolder, boolean initiatedByEvictionStrategy, boolean locked, IEntryCacheInfo pEntry, CacheManager.RecentDeleteCodes recentDeleteUsage)` Removes the specified entry from cache.
`void`	`removeEntryReferences(IEntryCacheInfo pEntry, TypeData pType, int numOfIndexesInsertedOnError)` Removes entry refs from cache.
`void`	`removeFifoXtnInfoForEntry(IEntryHolder eh)` remove fifo xtn info for entry MUST be called when entry is locked
`void`	`removeFromEvictionStrategy(EvictableServerEntry entry)`
`boolean`	`removeFromRecentDeletes(IEntryHolder entry)`
`boolean`	`removeFromRecentUpdatesIfNeeded(IEntryHolder entry)`
`void`	`removeLockedEntry(XtnData xtn, IEntryCacheInfo pEntry)`
`void`	`removeTemplate(Context context, ITemplateHolder template, boolean fromReplication, boolean origin, boolean dontReplicate)` Marks template as DELETED and send a BUS Packet to the GC.
`void`	`removeTemplate(Context context, ITemplateHolder template, boolean fromReplication, boolean origin, boolean dontReplicate, SpaceEngine.TemplateRemoveReasonCodes removeReason)` Marks template as DELETED and send a BUS Packet to the GC.
`void`	`removeWaitingForInfo(Context context, IEntryHolder entryHolder, ITemplateHolder templateHolder, boolean unpinIfPossible)`
`boolean`	`requiresEvictionReplicationProtection()`
`void`	`rollback(Context context, XtnEntry xtnEntry, boolean alreadyPrepared, boolean anyUpdates, boolean supportsTwoPhaseReplication)`
`IEntryCacheInfo`	`safeInsertEntryToCache(Context context, IEntryHolder entryHolder, boolean newEntry, TypeData pType, boolean pin, CacheManager.InitialLoadOrigin fromInitialLoad)` Inserts the specified entry to cache, perform memory manager check.
`void`	`setFifoCreationXtnInfoForEntry(IEntryHolder eh, long xtnNumber)` create fifo xtn info for entry MUST be called when entry is locked
`void`	`setFifoXtnNumber(XtnEntry xtnEntry, long fifoXtnNumber)` set the fifo xtn number of a xtn
`void`	`setLatestTransactionTerminationNum(long xtnTerminationNum)` get the Terminating fifo transaction //NOTE- must be called when xtns are locked !!!!!!!!
`void`	`setLeaseManager(LeaseManager leaseManager)`
`void`	`shutDown()` shut down cache manager.
`void`	`startTemplateExpirationManager()`
`boolean`	`testAndSetFGCacheForEntry(Context context, IEntryHolder entry, ITemplateHolder template, boolean testOnly, IServerTypeDesc tte)`
`void`	`touchByEntry(Context context, IEntryHolder entry, boolean modifyOp, ITemplateHolder template, CacheOperationReason cacheOperationReason)`
`boolean`	`tryEvict(EvictableServerEntry entry)` get permission to evict an entry, and if granted remove the entry from cache.
`boolean`	`unpinIfNeeded(Context context, IEntryHolder entry, ITemplateHolder template, IEntryCacheInfo pEntry)` if relevant-unpin the entry method is called after each operation or xtn termination entry should be locked when method is called
`IEntryHolder`	`updateEntry(Context context, IEntryHolder entry, ITemplateHolder template, boolean shouldReplicate, boolean origin)` update entry- if the entry should be updated under a xtn - insert to xtn lists.
`void`	`updateFifoXtnInfoForEntry(IEntryHolder eh, long xtnNumber, boolean writeLock, boolean entryWritingXtn)` update fifo xtn info for entry MUST be called when entry is locked update write lock if writeLock is true, else update read lock entryWritingXtn = true if this is the commit of the entry write
`void`	`updateLock(XtnData xtn, IEntryCacheInfo pEntry, OperationID operationID, int templateOperation)`
`boolean`	`useBlobStoreBulks()`
`boolean`	`useBlobStorePreFetch()`
`boolean`	`useBlobStoreReplicationBackupBulks()`
`boolean`	`useRecentDeletes()` returns true if recentDeletes hash in engine need to be used.
`boolean`	`useRecentUpdatesForPinning()` returns true if recentUpdates hash in engine need to be used.
`Context`	`viewCacheContext()`

Methods inherited from class com.j_spaces.core.cache.AbstractCacheManager
getCachePolicy, getMaxCacheSize, isAllInCachePolicy, isBlobStoreCachePolicy, isEvictableCachePolicy, isPluggedEvictionPolicy, isResidentEntriesCachePolicy, setCachePolicy, setEvictionQuota

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_terminatingXtnsInfo

public final TerminatingFifoXtnsInfo _terminatingXtnsInfo

MIN_SIZE_TO_PERFORM_EXPLICIT_PROPERTIES_INDEX_SCAN_
```
public static final int MIN_SIZE_TO_PERFORM_EXPLICIT_PROPERTIES_INDEX_SCAN_
```
See Also:

Constant Field Values

GS_13953_ENABLED

public static final boolean GS_13953_ENABLED

MIN_SIZE_TO_CONSIDER_COMPOUND_INDICES
```
public static final int MIN_SIZE_TO_CONSIDER_COMPOUND_INDICES
```
See Also:

Constant Field Values

Constructor Detail

CacheManager

public CacheManager(SpaceConfigReader configReader,
                    ClusterPolicy clusterPolicy,
                    SpaceTypeManager typeManager,
                    IReplicationNode replicationNode,
                    IStorageAdapter sa,
                    SpaceEngine engine,
                    Properties customProperties)
             throws CreateException

Throws:: CreateException

Method Detail

isSyncHybrid
```
public boolean isSyncHybrid()
```

getLogger

public static org.slf4j.Logger getLogger()

setLeaseManager

public void setLeaseManager(LeaseManager leaseManager)

init

public void init(Properties properties)
          throws SAException,
                 CreateException

Throws:: SAException; CreateException

isTimeBasedEvictionStrategy

public boolean isTimeBasedEvictionStrategy()

requiresEvictionReplicationProtection

public boolean requiresEvictionReplicationProtection()

getEvictionReplicationsMarkersRepository

public IEvictionReplicationsMarkersRepository getEvictionReplicationsMarkersRepository()

initCache
```
public void initCache(boolean loadDataFromDB,
                      Properties properties)
               throws SAException
```
Init. the cache.
This method is called after init(), and after the engine Xtn table and Directory are completely built, but before any other SA method is called.
This implementation preloads all active transactions and entries locked under these transactions into cache.
In addition, all class info is preloaded into cache.

Throws:

SAException

isCacheExternalDB
```
public boolean isCacheExternalDB()
```
Returns an indication if Storage Adapter acts as an external data-source.

Returns:

true if Storage Adapter is an external data-source; false otherwise.

getEngine
```
public SpaceEngine getEngine()
```

getTypeManager

public SpaceTypeManager getTypeManager()

getLeaseManager
```
public LeaseManager getLeaseManager()
```

isblobStoreDataSpace
```
public boolean isblobStoreDataSpace()
```

getBlobStoreStorageHandler

public BlobStoreExtendedStorageHandler getBlobStoreStorageHandler()

getBlobStoreMemoryMonitor

public BlobStoreMemoryMonitor getBlobStoreMemoryMonitor()

getBlobStoreRecoveryHelper

public IStorageConsistency getBlobStoreRecoveryHelper()

useBlobStoreBulks
```
public boolean useBlobStoreBulks()
```

useBlobStoreReplicationBackupBulks

public boolean useBlobStoreReplicationBackupBulks()

useBlobStorePreFetch
```
public boolean useBlobStorePreFetch()
```

isPersistentBlobStore

public boolean isPersistentBlobStore()

optimizedBlobStoreClear

public boolean optimizedBlobStoreClear()

needReReadAfterEntryLock

public boolean needReReadAfterEntryLock()

mayNeedEntriesUnpinning

public boolean mayNeedEntriesUnpinning()

isClusteredExternalDBEnabled
```
public boolean isClusteredExternalDBEnabled()
```
Returns an indication if Storage Adapter acts as an external clustered data-source. true if either indicated by a cluster-wide property or by enabling the mirror service in the cluster.

Returns:

true if Storage Adapter is an external clustered data-source; false otherwise.

isCentralDB
```
public boolean isCentralDB()
```
returns an indication if the underlying DB is a central DB common to several cluster members

Returns:

true if the underlying DB is cental; false otherwise.

isVersionedExternalDB
```
public boolean isVersionedExternalDB()
```
returns an indication if the underlying data-source supports versioning.

Returns:

true if the underlying DB supports versioning; false otherwise.

isEmptyAfterInitialLoadStage

public boolean isEmptyAfterInitialLoadStage()

isDirectPersistencyEmbeddedtHandlerUsed

public boolean isDirectPersistencyEmbeddedtHandlerUsed()

getLockManager

public IBasicLockManager<IEntryHolder> getLockManager()

get the lock manager

touchByEntry

public void touchByEntry(Context context,
                         IEntryHolder entry,
                         boolean modifyOp,
                         ITemplateHolder template,
                         CacheOperationReason cacheOperationReason)

getBlobStoreInternalCache

public IBlobStoreCacheHandler getBlobStoreInternalCache()

hasBlobStoreOffHeapCache

public boolean hasBlobStoreOffHeapCache()

hasBlobStoreOffHeapStore

public boolean hasBlobStoreOffHeapStore()

getConfigInfo
```
public String getConfigInfo()
```

shutDown
```
public void shutDown()
```
shut down cache manager. does not throw any exception- unusable.

useRecentDeletes
```
public boolean useRecentDeletes()
```
returns true if recentDeletes hash in engine need to be used.

insertToRecentDeletes

public void insertToRecentDeletes(IEntryHolder entry,
                                  long duration,
                                  ServerTransaction committingXtn)

removeFromRecentDeletes

public boolean removeFromRecentDeletes(IEntryHolder entry)

getRecentDeletesIterator

public Iterator<RecentDeletesRepository.RecentDeleteInfo> getRecentDeletesIterator()

getRecentDeleteInfo

public RecentDeletesRepository.RecentDeleteInfo getRecentDeleteInfo(String uid)

getNumOfRecentDeletes
```
public int getNumOfRecentDeletes()
```

useRecentUpdatesForPinning
```
public boolean useRecentUpdatesForPinning()
```
returns true if recentUpdates hash in engine need to be used.

insertToRecentUpdates

public void insertToRecentUpdates(IEntryHolder entry,
                                  long duration,
                                  ServerTransaction committingXtn)

insertToRecentUpdatesIfNeeded

public void insertToRecentUpdatesIfNeeded(IEntryHolder entry,
                                          long duration,
                                          ServerTransaction committingXtn)

removeFromRecentUpdatesIfNeeded

public boolean removeFromRecentUpdatesIfNeeded(IEntryHolder entry)

getRecentUpdatesIterator

public Iterator<RecentUpdatesRepository.RecentUpdateInfo> getRecentUpdatesIterator()

getRecentUpdateInfo

public RecentUpdatesRepository.RecentUpdateInfo getRecentUpdateInfo(String uid)

getNumOfRecentUpdates
```
public int getNumOfRecentUpdates()
```

isEntryInRecentUpdates

public boolean isEntryInRecentUpdates(IEntryHolder entry)

isDummyEntry

public boolean isDummyEntry(IEntryHolder eh)

evictBatch
```
public int evictBatch(int evictionQuota)
```
evict a quota of entries from cache.

Specified by:

evictBatch in class AbstractCacheManager

Returns:

number of actual evicted

insertEntry

public void insertEntry(Context context,
                        IEntryHolder entryHolder,
                        boolean shouldReplicate,
                        boolean origin,
                        boolean suppliedUid)
                 throws SAException,
                        EntryAlreadyInSpaceException

insert an entry to the space.

Throws:: SAException; EntryAlreadyInSpaceException

handleInsertEntryReplication

public void handleInsertEntryReplication(Context context,
                                         IEntryHolder entryHolder)
                                  throws SAException

Throws:: SAException

handleInsertEntryReplication

public void handleInsertEntryReplication(Context context,
                                         IEntryHolder entryHolder,
                                         int blobstoreBulkId)
                                  throws SAException

Throws:: SAException

getEvictionPolicyReplicationMembersGroupName

public String getEvictionPolicyReplicationMembersGroupName()

updateEntry

public IEntryHolder updateEntry(Context context,
                                IEntryHolder entry,
                                ITemplateHolder template,
                                boolean shouldReplicate,
                                boolean origin)
                         throws SAException

update entry- if the entry should be updated under a xtn - insert to xtn lists. update entry cache, call SA to perform update NOTE- if the template is under xtn associateEntryWithXtn is called by the engine- and not this routine

Throws:: SAException

handleUpdateEntryReplication

public void handleUpdateEntryReplication(Context context,
                                         IEntryHolder new_eh,
                                         IEntryData originalData,
                                         Collection<SpaceEntryMutator> mutators)

handleUpdateEntryReplication

public void handleUpdateEntryReplication(Context context,
                                         IEntryHolder new_eh,
                                         IEntryData originalData,
                                         Collection<SpaceEntryMutator> mutators,
                                         int blobstoreBulkId)

makeChangeOpEntry

public IEntryHolder makeChangeOpEntry(Context context,
                                      ITemplateHolder template,
                                      IEntryHolder currentEntry)

insertTemplate

public void insertTemplate(Context context,
                           ITemplateHolder templateHolder,
                           boolean shouldReplicate)

insert a template to the cache and DB.

getEntry

public IEntryHolder getEntry(Context context,
                             IEntryHolder entryHolder,
                             boolean tryInsertToCache,
                             boolean lockedEntry,
                             boolean useOnlyCache)
                      throws SAException

Parameters:: lockedEntry - - true if the entry is locked by the caller
Throws:: SAException

getEntry

public IEntryHolder getEntry(Context context,
                             IEntryHolder entryHolder,
                             boolean tryInsertToCache,
                             boolean lockedEntry)
                      throws SAException

Throws:: SAException

getEntry

public IEntryHolder getEntry(Context context,
                             String uid,
                             String inputClassName,
                             IEntryHolder template,
                             boolean tryInsertToCache,
                             boolean lockedEntry,
                             boolean useOnlyCache)
                      throws SAException

get entry by its uid, and, optionally, by its template className is passed if known, can be null template is not null if isCacheExternalDB is true: external DB, the template must contain the PK fields insertToCache- true if entry shouldbe inserted to cache

Throws:: SAException

getTemplatesInfo
```
public List<TemplateInfo> getTemplatesInfo(String className)
```
returns a list of all the pending templates for the given class

getTemplate

public ITemplateHolder getTemplate(String uid)

getMatchingMemoryEntriesForScanning

public IScanListIterator<IEntryCacheInfo> getMatchingMemoryEntriesForScanning(Context context,
                                                                              IServerTypeDesc currServerTypeDesc,
                                                                              ITemplateHolder template,
                                                                              IServerTypeDesc serverTypeDesc)

removeEntry

public int removeEntry(Context context,
                       IEntryHolder entryHolder,
                       IEntryCacheInfo pEntry,
                       boolean shouldReplicate,
                       boolean origin,
                       SpaceEngine.EntryRemoveReasonCodes removeReason,
                       boolean disableSAcall)
                throws SAException

remove entry from cache & SA

Parameters:: disableSAcall - - if true don't call the underlying SA
Returns:: number of completed sync replications.
Throws:: SAException

handleRemoveEntryReplication

public void handleRemoveEntryReplication(Context context,
                                         IEntryHolder entryHolder,
                                         SpaceEngine.EntryRemoveReasonCodes removeReason)

handleRemoveEntryReplication

public void handleRemoveEntryReplication(Context context,
                                         IEntryHolder entryHolder,
                                         SpaceEngine.EntryRemoveReasonCodes removeReason,
                                         int blobstoreBulkId)

removeTemplate

public void removeTemplate(Context context,
                           ITemplateHolder template,
                           boolean fromReplication,
                           boolean origin,
                           boolean dontReplicate)

Marks template as DELETED and send a BUS Packet to the GC. Assumes the specified template is locked.

removeTemplate

public void removeTemplate(Context context,
                           ITemplateHolder template,
                           boolean fromReplication,
                           boolean origin,
                           boolean dontReplicate,
                           SpaceEngine.TemplateRemoveReasonCodes removeReason)

Marks template as DELETED and send a BUS Packet to the GC. Assumes the specified template is locked.

getFifoBackgroundDispatcher

public FifoBackgroundDispatcher getFifoBackgroundDispatcher()

makeWaitForInfo

public void makeWaitForInfo(Context context,
                            IEntryHolder entryHolder,
                            ITemplateHolder templateHolder)
                     throws SAException

Throws:: SAException

removeWaitingForInfo

public void removeWaitingForInfo(Context context,
                                 IEntryHolder entryHolder,
                                 ITemplateHolder templateHolder,
                                 boolean unpinIfPossible)

associateEntryWithXtn

public IEntryHolder associateEntryWithXtn(Context context,
                                          IEntryHolder entryHolder,
                                          ITemplateHolder template,
                                          XtnEntry xtnEntry,
                                          IEntryHolder new_content)
                                   throws SAException

tie an entry with a transaction. new_content is the new values in case of update operation

Throws:: SAException

getPEntryByUid

public IEntryCacheInfo getPEntryByUid(String uid)

getEntryByUidFromPureCache

public IEntryHolder getEntryByUidFromPureCache(String uid)

isEntryInPureCache
```
public boolean isEntryInPureCache(String uid)
```
Parameters:

uid - of entry to check

Returns:

true if this entry is in pure cache; false otherwise.

disconnectEntryFromXtn

public void disconnectEntryFromXtn(Context context,
                                   IEntryHolder entryHolder,
                                   XtnEntry xtnEntry,
                                   boolean xtnEnd)
                            throws SAException

disconnect an entry from xtn

Parameters:: entryHolder - - entry to disconnect; xtnEnd - - true if its part of commit/rb process
Throws:: SAException

prepare

public void prepare(Context context,
                    XtnEntry xtnEntry,
                    boolean supportsTwoPhaseReplication,
                    boolean handleReplication,
                    boolean handleSA)
             throws SAException

Throws:: SAException

prePrepare
```
public void prePrepare(XtnEntry xtnEntry)
```
this method is called by the engine in order to make a "snapshot" of entries needed for notify.

handleUnderXtnUpdate

public void handleUnderXtnUpdate(Context context,
                                 ServerTransaction xtn,
                                 IEntryHolder eh,
                                 boolean isCommitting,
                                 XtnData pXtn)

xtn terminating-handle under xtn updates.

preCommit

public void preCommit(Context context,
                      XtnEntry xtnEntry,
                      boolean supportsTwoPhaseReplication)

commit

public void commit(Context context,
                   XtnEntry xtnEntry,
                   boolean singleParticipant,
                   boolean anyUpdates,
                   boolean supportsTwoPhaseReplication)
            throws SAException

Throws:: SAException

rollback

public void rollback(Context context,
                     XtnEntry xtnEntry,
                     boolean alreadyPrepared,
                     boolean anyUpdates,
                     boolean supportsTwoPhaseReplication)
              throws SAException

Throws:: SAException

extendLeasePeriod

public void extendLeasePeriod(Context context,
                              long time,
                              long original_time,
                              String uid,
                              String classname,
                              int objectType,
                              boolean shouldReplicate,
                              boolean origin)

findTemplatesByIndex

public Object findTemplatesByIndex(Context context,
                                   IServerTypeDesc typeDesc,
                                   IEntryHolder entry,
                                   MatchTarget matchTarget)

given a class name return the SL of matching templates. This API is more efficient than direct use of templates iterator

getEntryFromCacheHolder

public IEntryHolder getEntryFromCacheHolder(IEntryCacheInfo pt)

given a PEntry, return the entry.

getEntryCacheInfo

public IEntryCacheInfo getEntryCacheInfo(IEntryHolder eh)

get PEntry for entry.

getTemplateCacheInfo

public TemplateCacheInfo getTemplateCacheInfo(ITemplateHolder th)

get PEntry for entry.

makeEntriesIter

public ISAdapterIterator<IEntryHolder> makeEntriesIter(Context context,
                                                       ITemplateHolder template,
                                                       IServerTypeDesc serverTypeDesc,
                                                       long SCNFilter,
                                                       long leaseFilter,
                                                       boolean memoryOnly,
                                                       boolean transientOnly)
                                                throws SAException

Throws:: SAException

makeEntriesIter

public ISAdapterIterator<IEntryHolder> makeEntriesIter(Context context,
                                                       ITemplateHolder template,
                                                       IServerTypeDesc serverTypeDesc,
                                                       long SCNFilter,
                                                       long leaseFilter,
                                                       boolean memoryOnly)
                                                throws SAException

Throws:: SAException

makeScanableEntriesIter

public IScanListIterator makeScanableEntriesIter(Context context,
                                                 ITemplateHolder template,
                                                 IServerTypeDesc serverTypeDesc,
                                                 long SCNFilter,
                                                 long leaseFilter,
                                                 boolean memoryOnly)
                                          throws SAException

Throws:: SAException

makeUnderXtnTemplatesIter

public ISAdapterIterator<ITemplateHolder> makeUnderXtnTemplatesIter(Context context,
                                                                    XtnEntry xtnEntry)
                                                             throws SAException

Throws:: SAException

makeUnderXtnEntriesIter

public ISAdapterIterator makeUnderXtnEntriesIter(Context context,
                                                 XtnEntry xtnEntry,
                                                 int selectType)
                                          throws SAException

Throws:: SAException

makeUnderXtnEntriesIter

public ISAdapterIterator makeUnderXtnEntriesIter(Context context,
                                                 XtnEntry xtnEntry,
                                                 int selectType,
                                                 boolean returnPentries)
                                          throws SAException

Throws:: SAException

count

public int count(Context context,
                 ITemplateHolder template,
                 XtnEntry xtnFilter)
          throws SAException

Throws:: SAException

getTypeDataFactory

public TypeDataFactory getTypeDataFactory()

getTypeData

public TypeData getTypeData(IServerTypeDesc typeDesc)

safeInsertEntryToCache

public IEntryCacheInfo safeInsertEntryToCache(Context context,
                                              IEntryHolder entryHolder,
                                              boolean newEntry,
                                              TypeData pType,
                                              boolean pin,
                                              CacheManager.InitialLoadOrigin fromInitialLoad)

Inserts the specified entry to cache, perform memory manager check.

forceSpaceIdIndexIfEqual

public boolean forceSpaceIdIndexIfEqual()

getBlobStoreStatistics

public BlobStoreStatistics getBlobStoreStatistics()

insertEntryReferences

public void insertEntryReferences(Context context,
                                  IEntryCacheInfo pEntry,
                                  TypeData pType,
                                  boolean applySequenceNumber)

Inserts the refs to cache.

removeEntryFromCache
```
public boolean removeEntryFromCache(IEntryHolder entryHolder)
```
Removes the specified entry from cache. return true if removal ok

removeEntryFromCache

public boolean removeEntryFromCache(IEntryHolder entryHolder,
                                    boolean initiatedByEvictionStrategy,
                                    boolean locked,
                                    IEntryCacheInfo pEntry,
                                    CacheManager.RecentDeleteCodes recentDeleteUsage)

Removes the specified entry from cache. return true if removal ok

getSqlFunctions
```
public SQLFunctions getSqlFunctions()
```

removeEntryReferences

public void removeEntryReferences(IEntryCacheInfo pEntry,
                                  TypeData pType,
                                  int numOfIndexesInsertedOnError)

Removes entry refs from cache.

getEntryByUniqueId

public IEntryCacheInfo getEntryByUniqueId(IServerTypeDesc currServerTypeDesc,
                                          Object templateValue,
                                          ITemplateHolder template)

getEntriesByUniqueIds

public IEntryCacheInfo[] getEntriesByUniqueIds(IServerTypeDesc currServerTypeDesc,
                                               Object[] ids,
                                               ITemplateHolder template)

getEntriesMinIndex

public IStoredList<IEntryCacheInfo> getEntriesMinIndex(Context context,
                                                       TypeData typeData,
                                                       int numOfFields,
                                                       ITemplateHolder template)

Computes the best way to reach a list of potential match of entries of the specified type.

Handles also unindexed entries.

Assumes the specified template is a superclass (in the wide sense) of the specified entry.

Parameters:: typeData - the type of entries to search for; template - the template to match against
Returns:: a SL containing potential matches or null if there are no matches.

getEntriesMinIndexExtended
```
public Object getEntriesMinIndexExtended(Context context,
                                         TypeData entryType,
                                         int numOfFields,
                                         ITemplateHolder template)
```
Using extended match-
Computes the best way to reach a list of potential match of entries of the specified type.
Handles also un-indexed entries.
Assumes the specified template is a superclass (in the wide sense) of the specified entry.

Parameters:

entryType - the type of entries to search for

template - the template to match against

Returns:

a SL or IOrderedIndexScan containing potential matches or null if there are no matches.

getEntryByIdFromPureCache

public IEntryHolder getEntryByIdFromPureCache(Object id,
                                              IServerTypeDesc typeDesc)

tryEvict
```
public boolean tryEvict(EvictableServerEntry entry)
```
get permission to evict an entry, and if granted remove the entry from cache. this function must be called by the eviction Strategy prior to performing an eviction of an entry. eviction must be performed only if permission is granted by the space. permission can be denied if the entry is currently locked by another thread that is performing a space operation on it NOTE: after calling grantEvictionPermissionAndRemove and receiving true as an answer the eviction strategy should remove the entry from its internal state and call reportEvictionCompletion(entry)

Specified by:

tryEvict in interface SpaceEvictionManager

Parameters:

entry - The entry to evict.

Returns:

true if permission is granted and entry was removed from cache

unpinIfNeeded

public boolean unpinIfNeeded(Context context,
                             IEntryHolder entry,
                             ITemplateHolder template,
                             IEntryCacheInfo pEntry)

if relevant-unpin the entry method is called after each operation or xtn termination entry should be locked when method is called

Returns:: null if not unpinned

initiatedEviction

public boolean initiatedEviction(Context context,
                                 IEntryHolder entry,
                                 boolean shouldReplicate)
                          throws SAException

Throws:: SAException

isMemorySpace
```
public boolean isMemorySpace()
```
is this space a memory space ?

Returns:

true if the space is a memory space

isResidentCacheEntry

public boolean isResidentCacheEntry(EvictableServerEntry entry)

getReplicationContext

public IReplicationOutContext getReplicationContext(Context context)

isFromFifoClass
```
public boolean isFromFifoClass(IServerTypeDesc typeDesc)
```
Returns:

true if the class represented by enumeration a fifo class

getTemplatesManager

public TemplatesManager getTemplatesManager()

getNumberOfLockedObjectsUnderTxn
```
public int getNumberOfLockedObjectsUnderTxn(XtnEntry xtnEntry)
```
used by getTransactionsInfo to retrieve number of Locked Objects

Returns:

the number of Locked Objects by the given Transaction

getMinExtendedIndexActivationSize

public int getMinExtendedIndexActivationSize()

getEnriesSize
```
public int getEnriesSize()
```

getLatestTTransactionTerminationNum
```
public long getLatestTTransactionTerminationNum()
```
get the Terminating fifo transaction

setLatestTransactionTerminationNum
```
public void setLatestTransactionTerminationNum(long xtnTerminationNum)
```
get the Terminating fifo transaction //NOTE- must be called when xtns are locked !!!!!!!!

setFifoXtnNumber

public void setFifoXtnNumber(XtnEntry xtnEntry,
                             long fifoXtnNumber)

set the fifo xtn number of a xtn

getFifoXtnNumber

public long getFifoXtnNumber(XtnEntry xtnEntry)

get the fifo xtn number of a xtn

updateFifoXtnInfoForEntry

public void updateFifoXtnInfoForEntry(IEntryHolder eh,
                                      long xtnNumber,
                                      boolean writeLock,
                                      boolean entryWritingXtn)

update fifo xtn info for entry MUST be called when entry is locked update write lock if writeLock is true, else update read lock entryWritingXtn = true if this is the commit of the entry write

setFifoCreationXtnInfoForEntry
```
public void setFifoCreationXtnInfoForEntry(IEntryHolder eh,
                                           long xtnNumber)
```
create fifo xtn info for entry MUST be called when entry is locked

Parameters:

xtnNumber - - the xtn in the system when entry was created

getFifoEntryXtnInfo

public TerminatingFifoXtnsInfo.FifoXtnEntryInfo getFifoEntryXtnInfo(IEntryHolder eh)

removeFifoXtnInfoForEntry
```
public void removeFifoXtnInfoForEntry(IEntryHolder eh)
```
remove fifo xtn info for entry MUST be called when entry is locked

getTerminatingXtnsEntries

public ConcurrentHashMap<TerminatingFifoXtnsInfo.FifoXtnEntryInfo,TerminatingFifoXtnsInfo.FifoXtnEntryInfo> getTerminatingXtnsEntries()

lockEntry

public void lockEntry(XtnData xtn,
                      IEntryCacheInfo pEntry,
                      OperationID operationID)

updateLock

public void updateLock(XtnData xtn,
                       IEntryCacheInfo pEntry,
                       OperationID operationID,
                       int templateOperation)

removeLockedEntry

public void removeLockedEntry(XtnData xtn,
                              IEntryCacheInfo pEntry)

getStorageAdapter

public IStorageAdapter getStorageAdapter()

Returns:: the sA

getFifoGroupCacheImpl

public FifoGroupCacheImpl getFifoGroupCacheImpl()

getCacheContext
```
public Context getCacheContext()
```

freeCacheContext

public Context freeCacheContext(Context context)

viewCacheContext
```
public Context viewCacheContext()
```

startTemplateExpirationManager

public void startTemplateExpirationManager()

getTemplateExpirationManager

public TemplateExpirationManager getTemplateExpirationManager()

testAndSetFGCacheForEntry

public boolean testAndSetFGCacheForEntry(Context context,
                                         IEntryHolder entry,
                                         ITemplateHolder template,
                                         boolean testOnly,
                                         IServerTypeDesc tte)

handleFifoGroupsCacheOnXtnEnd

public void handleFifoGroupsCacheOnXtnEnd(Context context,
                                          XtnEntry xtnEntry)

addToEvictionStrategy

public void addToEvictionStrategy(EvictableServerEntry entry,
                                  boolean isNew)

removeFromEvictionStrategy

public void removeFromEvictionStrategy(EvictableServerEntry entry)

getLocalCaches

public Map<String,LocalCacheDetails> getLocalCaches()

getCacheLogger

public static org.slf4j.Logger getCacheLogger()

getNumberOfEntries
```
public int getNumberOfEntries()
```

getNumberOfEntries

public int getNumberOfEntries(String typeName,
                              boolean includeSubtypes)

getNumberOfNotifyTemplates

public int getNumberOfNotifyTemplates()

getNumberOfNotifyTemplates

public int getNumberOfNotifyTemplates(String typeName,
                                      boolean includeSubtypes)

getRuntimeInfo

public SpaceRuntimeInfo getRuntimeInfo(String typeName)

getQueryExtensionManager

public QueryExtensionIndexManagerWrapper getQueryExtensionManager(String namespace)

closeQueryExtensionManagers

public void closeQueryExtensionManagers()

Class CacheManager

Nested Class Summary

Field Summary

Fields inherited from class com.j_spaces.core.cache.AbstractCacheManager

Constructor Summary

Method Summary

Methods inherited from class com.j_spaces.core.cache.AbstractCacheManager

Methods inherited from class java.lang.Object

Field Detail

_terminatingXtnsInfo

MIN_SIZE_TO_PERFORM_EXPLICIT_PROPERTIES_INDEX_SCAN_

GS_13953_ENABLED

MIN_SIZE_TO_CONSIDER_COMPOUND_INDICES

Constructor Detail

CacheManager

Method Detail

isSyncHybrid

getLogger

setLeaseManager

init

isTimeBasedEvictionStrategy

requiresEvictionReplicationProtection

getEvictionReplicationsMarkersRepository

initCache

isCacheExternalDB

getEngine

getTypeManager

getLeaseManager

isblobStoreDataSpace

getBlobStoreStorageHandler

getBlobStoreMemoryMonitor

getBlobStoreRecoveryHelper

useBlobStoreBulks

useBlobStoreReplicationBackupBulks

useBlobStorePreFetch

isPersistentBlobStore

optimizedBlobStoreClear

needReReadAfterEntryLock

mayNeedEntriesUnpinning

isClusteredExternalDBEnabled

isCentralDB

isVersionedExternalDB

isEmptyAfterInitialLoadStage

isDirectPersistencyEmbeddedtHandlerUsed

getLockManager

touchByEntry

getBlobStoreInternalCache

hasBlobStoreOffHeapCache

hasBlobStoreOffHeapStore

getConfigInfo

shutDown

useRecentDeletes

insertToRecentDeletes

removeFromRecentDeletes

getRecentDeletesIterator

getRecentDeleteInfo

getNumOfRecentDeletes

useRecentUpdatesForPinning

insertToRecentUpdates

insertToRecentUpdatesIfNeeded

removeFromRecentUpdatesIfNeeded

getRecentUpdatesIterator

getRecentUpdateInfo

getNumOfRecentUpdates

isEntryInRecentUpdates

isDummyEntry

evictBatch

insertEntry

handleInsertEntryReplication

handleInsertEntryReplication

getEvictionPolicyReplicationMembersGroupName

updateEntry

handleUpdateEntryReplication

handleUpdateEntryReplication

makeChangeOpEntry

insertTemplate

getEntry

getEntry

getEntry

getTemplatesInfo