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 |
ICustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath)
Checks whether the specified entry matches this query.
|
abstract boolean |
AbstractCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CompoundOrCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CustomSpaceQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CompoundAndCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
PropertiesQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
CompoundContainsItemsCustomQuery.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSpacePredicate.setCacheManagerForExecution(CacheManager cacheManager) |
void |
ISpacePredicate.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 |
TemplateHolder.isOptimizedForBlobStoreOp(CacheManager cacheManager) |
boolean |
ITemplateHolder.isOptimizedForBlobStoreOp(CacheManager cacheManager) |
MatchResult |
TemplateHolder.match(CacheManager cacheManager,
IEntryHolder entry,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
boolean safeEntry,
Context context,
RegexCache regexCache) |
MatchResult |
ITemplateHolder.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 blobStoreSA) |
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 |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
IEntryCacheInfo.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) |
Modifier and Type | Method and Description |
---|---|
BlobStoreEntryHolder |
BlobStoreEntryLayout.buildBlobStoreEntryHolder(CacheManager cacheManager) |
void |
BlobStoreRefEntryCacheInfo.bulkUnRegister(CacheManager cacheManager) |
void |
IBlobStoreRefCacheInfo.bulkUnRegister(CacheManager cm) |
void |
BlobStoreRefEntryCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
IBlobStoreRefCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
BlobStoreRefEntryCacheInfo.flushedFromBulk(Context context,
CacheManager cacheManager,
Object blobStorePos,
boolean removed,
boolean onTxnEnd) |
void |
IBlobStoreRefCacheInfo.flushedFromBulk(Context context,
CacheManager cacheManager,
Object BlobStorePos,
boolean removed,
boolean onTxnEnd) |
void |
BlobStoreRefEntryCacheInfo.freeOffHeap(CacheManager cacheManager,
AbstractMemoryPool offHeapMemoryPool) |
void |
IBlobStoreRefCacheInfo.freeOffHeap(CacheManager cacheManager,
AbstractMemoryPool offHeapMemoryPool) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
Serializable |
BlobStoreRefEntryCacheInfo.getEntryLayout(CacheManager cacheManager) |
Serializable |
IBlobStoreRefCacheInfo.getEntryLayout(CacheManager cacheManager) |
BlobStoreEntryHolder |
BlobStoreRefEntryCacheInfo.getFromInternalCache(CacheManager cacheManager) |
BlobStoreEntryHolder |
IBlobStoreRefCacheInfo.getFromInternalCache(CacheManager cacheManager) |
byte[] |
BlobStoreEntryLayout.getIndexValuesBytes(CacheManager cacheManager) |
IEntryHolder |
IBlobStoreEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
BlobStoreEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
IBlobStoreRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
IEntryHolder |
IBlobStoreRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
void |
BlobStoreRefEntryCacheInfo.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
BlobStoreEntryHolder entry,
CacheOperationReason cacheOperationReason) |
void |
IBlobStoreEntryHolder.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
CacheOperationReason cacheOperationReason) |
void |
BlobStoreEntryHolder.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
CacheOperationReason cacheOperationReason) |
void |
BlobStoreEntryLayout.readExternal(ObjectInput in,
CacheManager cacheManager,
boolean fromInitialLoad,
boolean onlyIndexedPart,
IBlobStoreOffHeapInfo offHeapInfo) |
void |
BlobStoreEntryLayout.readIndexValuesBytes(CacheManager cacheManager,
short serverTypeDescCode,
byte[] bytes) |
void |
BlobStoreRefEntryCacheInfo.removeEntryFromBlobStoreStorage(Context context,
CacheManager cacheManager) |
void |
IBlobStoreRefCacheInfo.removeEntryFromBlobStoreStorage(Context context,
CacheManager cacheManager) |
void |
BlobStoreRefEntryCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(Context context,
CacheManager cm) |
void |
IBlobStoreRefCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(Context context,
CacheManager cm) |
void |
BlobStoreRefEntryCacheInfo.setDirty(boolean value,
CacheManager cacheManager) |
void |
IBlobStoreRefCacheInfo.setDirty(boolean value,
CacheManager cacheManager) |
void |
IBlobStoreEntryHolder.setDirty(CacheManager cacheManager) |
void |
BlobStoreEntryHolder.setDirty(CacheManager cacheManager) |
void |
BlobStoreRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
IBlobStoreRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
BlobStoreEntryLayout.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,
BlobStoreRefEntryCacheInfo eci,
IEntryHolder eh) |
static void |
BlobStoreErrorsHandler.onFailedUpdate(CacheManager cm,
Context context,
BlobStoreRefEntryCacheInfo eci,
IEntryHolder eh) |
static void |
BlobStoreErrorsHandler.onFailedWrite(CacheManager cm,
Context context,
BlobStoreRefEntryCacheInfo eci,
IEntryHolder eh) |
static boolean |
BlobStoreErrorsHandler.revertOpOnBlobStoreError(CacheManager cm) |
Constructor and Description |
---|
BlobStoreSegmentInitialLoader(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) |
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 | Field and Description |
---|---|
protected CacheManager |
FifoWorkerThread._cacheManager |
Modifier and Type | Method and Description |
---|---|
protected FifoWorkerThread |
DefaultFifoBackgroundDispatcher.createFifoWorkerThread(int num,
boolean isNotify,
CacheManager cacheManager,
SpaceEngine engine) |
protected abstract FifoWorkerThread |
FifoBackgroundDispatcher.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 |
Range.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ContainsValueRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ContainsCompositeRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
ContainsItemValueRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
boolean |
EmptyRange.matches(CacheManager cacheManager,
ServerEntry entry,
String skipAlreadyMatchedIndexPath) |
Copyright © GigaSpaces.