Constructor and Description |
---|
DirectPersistencyBlobStoreIO(CacheManager cacheManager,
Logger logger,
long currentGenerationId) |
DirectPersistencyOpIterBlobStoreIO(DirectPersistencyBlobStoreIO ioMgr,
CacheManager cacheManager,
Logger logger,
boolean isCurrentGeneration) |
DirectPersistencyOverflowIterBlobStoreIO(DirectPersistencyBlobStoreIO ioMgr,
CacheManager cacheManager,
Logger logger,
boolean isCurrentGeneration) |
Constructor and Description |
---|
NotificationReplicationChannelDataFilter(CacheManager cacheManager,
String groupName,
RegexCache regexCache,
SpaceTypeManager typeManager,
FilterManager filterManager,
NotifyTemplateHolder tHolder) |
Constructor and Description |
---|
ViewReplicationChannelDataFilter(CacheManager cacheManager,
String groupName,
ITemplatePacket[] templates,
RegexCache regexCache,
SpaceTypeManager typeManager) |
Modifier and Type | Method and Description |
---|---|
boolean |
CompoundOrCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
abstract boolean |
AbstractCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CompoundContainsItemsCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CustomSpaceQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
PropertiesQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ICustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath)
Checks whether the specified entry matches this query.
|
boolean |
CompoundAndCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
Modifier and Type | Method and Description |
---|---|
void |
ISpacePredicate.setCacheManagerForExecution(CacheManager cacheManager) |
void |
AbstractSpacePredicate.setCacheManagerForExecution(CacheManager cacheManager) |
Modifier and Type | Method and Description |
---|---|
void |
RelationPredicate.setCacheManagerForExecution(CacheManager cacheManager) |
Modifier and Type | Field and Description |
---|---|
protected CacheManager |
MultipleCompositeSpacePredicate._cacheManager |
Modifier and Type | Method and Description |
---|---|
void |
MultipleCompositeSpacePredicate.setCacheManagerForExecution(CacheManager cacheManager) |
Modifier and Type | Method and Description |
---|---|
CacheManager |
SpaceEngine.getCacheManager() |
Constructor and Description |
---|
TemplateExpirationManager(CacheManager cacheManager) |
TemplateScanner(SpaceTypeManager typeManager,
CacheManager cacheManager,
SpaceDataEventManager dataEventManager,
SpaceEngine engine) |
TemplatesManager(CacheManager cacheManager,
int numNotifyFifoThreads,
int numNonNotifyFifoThreads) |
Modifier and Type | Method and Description |
---|---|
CacheManager |
TypeDataFactory.getCcheManager() |
Modifier and Type | Method and Description |
---|---|
<K> TypeDataIndex<K> |
TypeDataFactory.createCompoundCustomTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
CompoundIndexSegmentTypeData[] segments,
int indexCreationNumber,
int indexPosition,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
<K> TypeDataIndex<K> |
TypeDataFactory.createCustomMultiValuePerEntryTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
ISpaceIndex.MultiValuePerEntryIndexTypes indexType) |
<K> TypeDataIndex<K> |
TypeDataFactory.createCustomTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
<K> TypeDataIndex<K> |
TypeDataFactory.createMultiValuePerEntryTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
ISpaceIndex.MultiValuePerEntryIndexTypes indexType) |
<K> TypeDataIndex<K> |
TypeDataFactory.createTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
Class<?> indexValueClass,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
Constructor and Description |
---|
TypeDataFactory(SpaceConfigReader configReader,
CacheManager cacheManager) |
Modifier and Type | Method and Description |
---|---|
static boolean |
TemplateHolder.isOptimizedForBlobStoreClear(CacheManager cacheManager,
ITemplatePacket templatePacket,
TemplateEntryData templateEntryData) |
boolean |
ITemplateHolder.isOptimizedForBlobStoreClearOp(CacheManager cacheManager) |
boolean |
TemplateHolder.isOptimizedForBlobStoreClearOp(CacheManager cacheManager) |
MatchResult |
ITemplateHolder.match(CacheManager cacheManager,
IEntryHolder entry,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
boolean safeEntry,
Context context,
RegexCache regexCache) |
MatchResult |
TemplateHolder.match(CacheManager cacheManager,
IEntryHolder entry,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
boolean safeEntry,
Context context,
RegexCache regexCache) |
boolean |
TemplateEntryData.match(CacheManager cacheManager,
ServerEntry entry,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
RegexCache regexCache) |
Constructor and Description |
---|
SyncHybridStorageAdapter(CacheManager cacheManager,
IStorageAdapter syncSA,
IStorageAdapter offHeapSA) |
Modifier and Type | Method and Description |
---|---|
int |
XtnEntry.getNumOfChangesUnderTransaction(CacheManager cacheManager) |
Modifier and Type | Field and Description |
---|---|
protected CacheManager |
SAIterBase._cacheManager |
Modifier and Type | Method and Description |
---|---|
CacheManager |
TypeData.getCacheManager() |
CacheManager |
TypeDataIndex.getCacheManager() |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
void |
TypeData.prepareForUpdatingIndexValues(CacheManager cacheManager,
IEntryCacheInfo pEntry,
IEntryData newEntryData)
used only in economy-hash maps
index values are about to be replaced in entryData .
|
void |
TypeData.updateEntryReferences(CacheManager cacheManager,
IEntryHolder eh,
IEntryCacheInfo pEntry,
IEntryData oldEntryData)
update the entry refs in cache.
|
void |
TypeData.updateEntryReferencesUnderXtn(CacheManager cacheManager,
IEntryCacheInfo pEntry,
IEntryData oldEntryData)
update the entry refs in cache when there is an updating xtn, we keep the master entry and
shadow entry as one object pointing at eatch other so we cant remove the original index
references
|
Constructor and Description |
---|
CacheContextFactory(CacheManager cacheManager,
String fullSpaceName) |
CompoundCustomTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
CompoundIndexSegmentTypeData[] segments,
int indexCreationNumber,
int indexPosition,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
CustomMultiValueTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
ISpaceIndex.MultiValuePerEntryIndexTypes multiValueType) |
CustomTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber) |
CustomTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
int indexCreationNumber,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
EntriesIter(Context context,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc,
CacheManager cacheManager,
long SCNFilter,
long leaseFilter,
boolean memoryOnly,
boolean transientOnly) |
MultiValueTypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
boolean useEconomyHashmap,
int indexCreationNumber,
ISpaceIndex.MultiValuePerEntryIndexTypes multiValueType) |
RecentExtendedIndexUpdates(CacheManager cacheManager) |
SAIterBase(Context context,
CacheManager cacheManager) |
SpaceServerEntryImpl(IEntryCacheInfo eci,
CacheManager cm) |
TypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
boolean useEconomyHashmap,
int indexCreationNumber) |
TypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
boolean useEconomyHashmap,
int indexCreationNumber,
Class<?> valueClass,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
TypeDataIndex(CacheManager cacheManager,
ISpaceIndex index,
int pos,
boolean useEconomyHashmap,
int indexCreationNumber,
ISpaceIndex.FifoGroupsIndexTypes fifoGroupsIndexType) |
UnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType,
CacheManager cacheManager,
boolean returnPEntry) |
UnderXtnTemplatesIter(Context context,
XtnEntry xtnEntry,
MatchTarget matchTarget,
CacheManager cacheManager) |
Constructor and Description |
---|
FifoGroupCacheImpl(CacheManager cacheManager,
Logger logger) |
FifoGroupsCacheHandler(CacheManager cacheManager) |
FifoGroupsCompoundIndexExtention(CacheManager cacheManager,
TypeDataIndex<K> index) |
FifoGroupsMainIndexExtention(CacheManager cacheManager,
TypeDataIndex<K> index) |
Modifier and Type | Method and Description |
---|---|
OffHeapEntryHolder |
OffHeapEntryLayout.buildOffHeapEntryHolder(CacheManager cacheManager) |
void |
OffHeapRefEntryCacheInfo.bulkUnRegister(CacheManager cacheManager) |
void |
IOffHeapRefCacheInfo.bulkUnRegister(CacheManager cm) |
void |
OffHeapRefEntryCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
IOffHeapRefCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
OffHeapRefEntryCacheInfo.flushedFromBulk(CacheManager cacheManager,
Object offHeapPos,
boolean removed) |
void |
IOffHeapRefCacheInfo.flushedFromBulk(CacheManager cacheManager,
Object offHeapPos,
boolean removed) |
IEntryHolder |
OffHeapRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
OffHeapRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
Serializable |
OffHeapRefEntryCacheInfo.getEntryLayout(CacheManager cacheManager) |
Serializable |
IOffHeapRefCacheInfo.getEntryLayout(CacheManager cacheManager) |
OffHeapEntryHolder |
OffHeapRefEntryCacheInfo.getFromInternalCache(CacheManager cacheManager) |
OffHeapEntryHolder |
IOffHeapRefCacheInfo.getFromInternalCache(CacheManager cacheManager) |
IEntryHolder |
IOffHeapEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
OffHeapEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
OffHeapRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IOffHeapEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
IOffHeapRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IOffHeapEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
OffHeapRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IOffHeapEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
IEntryHolder |
IOffHeapRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IOffHeapEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
void |
IOffHeapEntryHolder.insertOrTouchInternalCache(CacheManager cacheManager) |
void |
OffHeapEntryHolder.insertOrTouchInternalCache(CacheManager cacheManager) |
void |
OffHeapRefEntryCacheInfo.insertOrTouchInternalCache(CacheManager cacheManager,
OffHeapEntryHolder entry) |
void |
OffHeapEntryLayout.readExternal(ObjectInput in,
CacheManager cacheManager,
boolean fromInitialLoad,
boolean onlyIndexedPart) |
void |
OffHeapRefEntryCacheInfo.removeEntryFromOffHeapStorage(CacheManager cacheManager) |
void |
IOffHeapRefCacheInfo.removeEntryFromOffHeapStorage(CacheManager cacheManager) |
void |
OffHeapRefEntryCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(CacheManager cm) |
void |
IOffHeapRefCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(CacheManager cm) |
void |
OffHeapRefEntryCacheInfo.setDirty(boolean value,
CacheManager cacheManager) |
void |
IOffHeapRefCacheInfo.setDirty(boolean value,
CacheManager cacheManager) |
void |
IOffHeapEntryHolder.setDirty(CacheManager cacheManager) |
void |
OffHeapEntryHolder.setDirty(CacheManager cacheManager) |
void |
OffHeapRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
IOffHeapRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
OffHeapRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context,
InternalCacheControl internalCacheControl) |
void |
IOffHeapRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context,
InternalCacheControl internalCacheControl) |
void |
OffHeapEntryLayout.writeExternal(ObjectOutput out,
CacheManager cacheManager) |
Constructor and Description |
---|
BlobStoreMemoryMonitorWrapper(BlobStoreMemoryMonitor impl,
CacheManager cm,
String spaceName,
Properties properties) |
BlobStoreOperationsWrapper(CacheManager cacheManager,
BlobStoreStorageHandler blobStore) |
BlobStoreSerializationUtils(CacheManager _cacheManager) |
Modifier and Type | Method and Description |
---|---|
static void |
BlobStoreErrorsHandler.onFailedRemove(CacheManager cm,
Context context,
OffHeapRefEntryCacheInfo eci,
IEntryHolder eh) |
static void |
BlobStoreErrorsHandler.onFailedUpdate(CacheManager cm,
Context context,
OffHeapRefEntryCacheInfo eci,
IEntryHolder eh) |
static void |
BlobStoreErrorsHandler.onFailedWrite(CacheManager cm,
Context context,
OffHeapRefEntryCacheInfo eci,
IEntryHolder eh) |
static boolean |
BlobStoreErrorsHandler.revertOpOnBlobStoreError(CacheManager cm) |
Constructor and Description |
---|
OffHeapSegmentInitialLoader(CacheManager cacheManager,
DataIterator<BlobStoreGetBulkOperationResult> segmentIter,
CountDownLatch sync,
int segmentNumber,
InitialLoadInfo initialLoadInfo) |
Constructor and Description |
---|
BlobStoreBulkInfo(CacheManager cacheManager,
boolean takeMultipleBulk) |
BlobStoreReadBulkHandler(CacheManager cacheManager,
BlobStorePreFetchBatchHandler request) |
Modifier and Type | Method and Description |
---|---|
static IScanListIterator<IEntryCacheInfo> |
BlobStorePreFetchIteratorBasedHandler.createPreFetchIterIfRelevant(Context context,
CacheManager cacheManager,
IScanListIterator<IEntryCacheInfo> mainIterator,
ITemplateHolder template,
Logger logger) |
Constructor and Description |
---|
BlobStorePreFetchBatchHandler(CacheManager cacheManager,
boolean executeByMainThread,
BlobStorePreFetchIteratorBasedHandler caller,
Logger logger) |
BlobStorePreFetchIteratorBasedHandler(Context mainThreadContext,
CacheManager cacheManager,
IScanListIterator<IEntryCacheInfo> mainIterator,
ITemplateHolder template,
int numEntriesRequested,
Logger logger) |
Modifier and Type | Field and Description |
---|---|
protected CacheManager |
FifoWorkerThread._cacheManager |
Modifier and Type | Method and Description |
---|---|
protected abstract FifoWorkerThread |
FifoBackgroundDispatcher.createFifoWorkerThread(int num,
boolean isNotify,
CacheManager cacheManager,
SpaceEngine engine) |
protected FifoWorkerThread |
DefaultFifoBackgroundDispatcher.createFifoWorkerThread(int num,
boolean isNotify,
CacheManager cacheManager,
SpaceEngine engine) |
Constructor and Description |
---|
DefaultFifoBackgroundDispatcher(int numNotifyFifoThreads,
int numNonNotifyFifoThreads,
CacheManager cacheManager,
SpaceEngine engine) |
FifoBackgroundDispatcher(int numNotifyFifoThreads,
int numNonNotifyFifoThreads,
CacheManager cacheManager,
SpaceEngine engine) |
FifoWorkerThread(int num,
boolean isNotify,
String workerType,
CacheManager cacheManager,
SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
boolean |
ContainsCompositeRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ContainsValueRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
EmptyRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ContainsItemValueRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
Range.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
Copyright © GigaSpaces.