Modifier and Type | Method and Description |
---|---|
protected IObjectsList |
ExactValueIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
NullValueIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
RegexIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
UidsIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected abstract IObjectsList |
AbstractQueryIndex.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
InValueIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
RangeIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
RelationIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
ExacValueCompoundIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
NotRegexIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
protected IObjectsList |
RangeCompoundIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
IObjectsList |
IQueryIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
RegexIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
UidsIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
AbstractQueryIndex.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
CompoundAndIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
CompoundOrIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
InValueIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
RelationIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
NotRegexIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
void |
EntryHolderAggregatorContext.scan(Context context,
IEntryData entryData,
String uid,
boolean isTransient) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceEngine.checkWFValidityAfterUpdate(Context context,
IEntryHolder entry)
update performed for an entry under xtn, if there are templates wf this entry, is there any
use to keep on waiting (i.e.
|
void |
SpaceEngine.executeOnMatchingEntries(Context context,
ITemplateHolder template,
boolean makeWaitForInfo)
Searches the engine for a matching entry using the BFS tree of the specified template.
|
IEntryHolder |
SpaceEngine.getMatchedEntryAndOperateSA(Context context,
ITemplateHolder template,
boolean makeWaitForInfo,
boolean useSCN)
Searches the engine for a matching entry using the BFS tree of the specified template.
|
void |
FifoGroupsHandler.handleNeedFgOnlyScanOnXtnEnd(Context context,
XtnEntry xtnEntry) |
void |
FifoGroupsHandler.handleRemoveWaitingForInfoSAFifoGroups_EntryBased(Context context,
IEntryHolder entry,
ITemplateHolder template) |
boolean |
TemplateScanner.match(Context context,
IEntryHolder entry,
ITemplateHolder template) |
boolean |
TemplateScanner.match(Context context,
IEntryHolder entry,
ITemplateHolder template,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
boolean safeEntry)
Checks if the specified template matches the specified entry.
|
boolean |
TemplateScanner.notifyMatch(Context context,
IEntryHolder entry,
ITemplateHolder template) |
int |
SpaceEngine.performReplication(Context context)
perform sync replication from sync-packets list or a single sync-packet contained in the
context.
|
void |
SpaceEngine.performTemplateOnEntrySA(Context context,
ITemplateHolder template,
IEntryHolder entry,
boolean makeWaitForInfo)
try to process an entry , if the entry has a shadow try it too if the entry don't suite
|
void |
SpaceEngine.removeEntrySA(Context context,
IEntryHolder entry,
boolean fromReplication,
boolean origin,
boolean ofReplicatableClass,
SpaceEngine.EntryRemoveReasonCodes removeReason,
boolean disableReplication,
boolean disableProcessorCall,
boolean disableSADelete) |
void |
SpaceEngine.removeEntrySA(Context context,
IEntryHolder entry,
IServerTypeDesc typeDesc,
boolean fromReplication,
boolean origin,
SpaceEngine.EntryRemoveReasonCodes removeReason)
Delete an entry (direct delete).
|
void |
SpaceEngine.removeEntrySA(Context context,
IEntryHolder entry,
IServerTypeDesc typeDesc,
boolean fromReplication,
boolean origin,
SpaceEngine.EntryRemoveReasonCodes removeReason,
boolean disableReplication,
boolean disableProcessorCall,
boolean disableSADelete)
Delete an entry (direct delete).
|
void |
TemplateScanner.scanNonNotifyTemplates(Context context,
IEntryHolder entry,
ServerTransaction txn,
FifoSearch fifoSearch)
Search for templates that match the specified entry and perform each such template.
|
void |
TemplateScanner.scanNonNotifyTemplates(Context context,
IEntryHolder entry,
ServerTransaction txn,
FifoSearch fifoSearch,
FifoGroupsSearch fifoGroupsSearch)
Search for templates that match the specified entry and perform each such template.
|
void |
TemplateScanner.scanNotifyTemplates(NotifyContextsHolder notifyContextsHolder,
Context context,
ServerTransaction txn,
FifoSearch fifoSearch) |
boolean |
SpaceEngine.skipBroadcastTable(Context context,
ITemplateHolder template) |
Modifier and Type | Method and Description |
---|---|
void |
SpaceDataEventManager.notifyTemplate(NotifyTemplateHolder template,
IEntryHolder entry,
IEntryHolder oldEntry,
NotifyContext notifyContext,
Context ctx)
Notifies a notification template with the specified remote event Notification is done
asynchronously, by sending a bus packet to the Notifier.
|
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
TieredStorageSA.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
TieredStorageSA.getEntry(Context context,
String uid,
String classname,
IEntryHolder template) |
ISAdapterIterator |
TieredStorageSA.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
void |
InternalRDBMS.initialLoad(Context context,
SpaceEngine engine,
InitialLoadInfo initialLoadInfo) |
void |
InternalRDBMS.insertEntry(Context context,
IEntryHolder entryHolder)
Inserts a new entry to the internalDiskStorage
|
void |
TieredStorageSA.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
void |
TieredStorageSA.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
boolean |
InternalRDBMS.removeEntry(Context context,
IEntryHolder entryHolder)
Removes an entry from the internalDiskStorage
|
void |
TieredStorageSA.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate) |
void |
InternalRDBMS.updateEntry(Context context,
IEntryHolder updatedEntry)
updates an entry.
|
void |
TieredStorageSA.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
static IEntryHolder |
EntryHolderFactory.createTieredStorageHollowEntry(Context context,
IServerTypeDesc typeDesc,
String uid,
boolean isTransient) |
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(Context cacheContext,
CacheManager cacheManager,
ServerEntry entry,
int skipAlreadyMatchedFixedPropertyIndex,
String skipAlreadyMatchedIndexPath,
RegexCache regexCache) |
boolean |
ITemplateHolder.quickReject(Context context,
FifoSearch fifoSearch) |
boolean |
TemplateHolder.quickReject(Context context,
FifoSearch fifoSearch) |
boolean |
NotifyTemplateHolder.quickReject(Context context,
FifoSearch fifoSearch,
ServerTransaction txn,
NotifyContextsHolder notifyContextsHolder) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
SynchronizationStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
SynchronizationStorageAdapter.getEntry(Context context,
String uid,
String typeName,
IEntryHolder template) |
ISAdapterIterator<?> |
SynchronizationStorageAdapter.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
void |
SynchronizationStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
void |
SynchronizationStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
void |
SynchronizationStorageAdapter.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate) |
void |
SynchronizationStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
SyncHybridStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
SyncHybridStorageAdapter.getEntry(Context context,
String uid,
String classname,
IEntryHolder template) |
ISAdapterIterator |
SyncHybridStorageAdapter.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
void |
SyncHybridStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
void |
SyncHybridStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
void |
SyncHybridStorageAdapter.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate) |
void |
SyncHybridStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
IEntryHolder entry,
ITemplateHolder template) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
IEntryHolder entry,
ITemplateHolder template,
IEntryData entryData) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
IEntryHolder entry,
ITemplateHolder template,
String uid) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(Context context,
ITemplateHolder template,
IEntryData entryData,
String uid,
boolean isTransient) |
Modifier and Type | Method and Description |
---|---|
Context |
UpdateOrWriteContext.getCacheContext() |
Modifier and Type | Method and Description |
---|---|
void |
UpdateOrWriteContext.setCacheContext(Context context) |
Modifier and Type | Field and Description |
---|---|
protected Context |
SAIterBase._context |
Modifier and Type | Method and Description |
---|---|
Context |
CacheManager.freeCacheContext(Context context) |
Context |
CacheContextFactory.getCacheContext()
returns a free Context from the pool.
|
Context |
CacheManager.getCacheContext() |
Context |
CacheContextFactory.viewCacheContext()
returns the active Context of this thread or null if none
|
Context |
CacheManager.viewCacheContext() |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
CacheManager.associateEntryWithXtn(Context context,
IEntryHolder entryHolder,
ITemplateHolder template,
XtnEntry xtnEntry,
IEntryHolder new_content)
tie an entry with a transaction.
|
void |
EntriesIter.beforeAlternatingThreadBatch(Context context) |
void |
CacheManager.commit(Context context,
XtnEntry xtnEntry,
boolean singleParticipant,
boolean anyUpdates,
boolean supportsTwoPhaseReplication) |
int |
CacheManager.count(Context context,
ITemplateHolder template,
XtnEntry xtnFilter) |
void |
CacheManager.disconnectEntryFromXtn(Context context,
IEntryHolder entryHolder,
XtnEntry xtnEntry,
boolean xtnEnd)
disconnect an entry from xtn
|
void |
CacheManager.extendLeasePeriod(Context context,
long time,
long original_time,
String uid,
String classname,
int objectType,
boolean shouldReplicate,
boolean origin) |
Object |
CacheManager.findTemplatesByIndex(Context context,
IServerTypeDesc typeDesc,
IEntryHolder entry,
MatchTarget matchTarget)
given a class name return the SL of matching templates.
|
void |
CacheContextFactory.freeCacheContext(Context ctx)
Free a Context acquired by getCacheContext().
|
Context |
CacheManager.freeCacheContext(Context context) |
IEntryCacheInfo[] |
CacheManager.getEntriesByUniqueIds(Context context,
IServerTypeDesc currServerTypeDesc,
Object[] ids,
ITemplateHolder template) |
IStoredList<IEntryCacheInfo> |
CacheManager.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 |
CacheManager.getEntriesMinIndexExtended(Context context,
TypeData entryType,
int numOfFields,
ITemplateHolder template)
Using extended match-
|
IEntryHolder |
CacheManager.getEntry(Context context,
IEntryHolder entryHolder,
boolean tryInsertToCache,
boolean lockedEntry) |
IEntryHolder |
CacheManager.getEntry(Context context,
IEntryHolder entryHolder,
boolean tryInsertToCache,
boolean lockedEntry,
boolean useOnlyCache) |
IEntryHolder |
CacheManager.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
|
IEntryCacheInfo |
CacheManager.getEntryByUniqueId(Context context,
IServerTypeDesc currServerTypeDesc,
Object templateValue,
ITemplateHolder template) |
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IScanListIterator<IEntryCacheInfo> |
CacheManager.getMatchingMemoryEntriesForScanning(Context context,
IServerTypeDesc currServerTypeDesc,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc) |
IReplicationOutContext |
CacheManager.getReplicationContext(Context context) |
void |
CacheManager.handleFifoGroupsCacheOnXtnEnd(Context context,
XtnEntry xtnEntry) |
void |
CacheManager.handleInsertEntryReplication(Context context,
IEntryHolder entryHolder) |
void |
CacheManager.handleInsertEntryReplication(Context context,
IEntryHolder entryHolder,
int blobstoreBulkId) |
void |
CacheManager.handleRemoveEntryReplication(Context context,
IEntryHolder entryHolder,
SpaceEngine.EntryRemoveReasonCodes removeReason) |
void |
CacheManager.handleRemoveEntryReplication(Context context,
IEntryHolder entryHolder,
SpaceEngine.EntryRemoveReasonCodes removeReason,
int blobstoreBulkId) |
void |
CacheManager.handleUnderXtnUpdate(Context context,
ServerTransaction xtn,
IEntryHolder eh,
boolean isCommitting,
XtnData pXtn)
xtn terminating-handle under xtn updates.
|
void |
CacheManager.handleUpdateEntryReplication(Context context,
IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
void |
CacheManager.handleUpdateEntryReplication(Context context,
IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators,
int blobstoreBulkId) |
boolean |
CacheManager.initiatedEviction(Context context,
IEntryHolder entry,
boolean shouldReplicate) |
void |
CacheManager.insertEntry(Context context,
IEntryHolder entryHolder,
boolean shouldReplicate,
boolean origin,
boolean suppliedUid,
boolean fromReplication)
insert an entry to the space.
|
void |
CacheManager.insertEntryReferences(Context context,
IEntryCacheInfo pEntry,
TypeData pType,
boolean applySequenceNumber)
Inserts the refs to cache.
|
void |
CacheManager.insertTemplate(Context context,
ITemplateHolder templateHolder,
boolean shouldReplicate)
insert a template to the cache and DB.
|
IEntryHolder |
CacheManager.makeChangeOpEntry(Context context,
ITemplateHolder template,
IEntryHolder currentEntry) |
ISAdapterIterator<IEntryHolder> |
CacheManager.makeEntriesIter(Context context,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc,
long SCNFilter,
long leaseFilter,
boolean memoryOnly) |
ISAdapterIterator<IEntryHolder> |
CacheManager.makeEntriesIter(Context context,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc,
long SCNFilter,
long leaseFilter,
boolean memoryOnly,
boolean transientOnly) |
IScanListIterator |
CacheManager.makeScanableEntriesIter(Context context,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc,
long SCNFilter,
long leaseFilter,
boolean memoryOnly) |
ISAdapterIterator |
CacheManager.makeUnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType) |
ISAdapterIterator |
CacheManager.makeUnderXtnEntriesIter(Context context,
XtnEntry xtnEntry,
int selectType,
boolean returnPentries) |
ISAdapterIterator<ITemplateHolder> |
CacheManager.makeUnderXtnTemplatesIter(Context context,
XtnEntry xtnEntry) |
void |
CacheManager.makeWaitForInfo(Context context,
IEntryHolder entryHolder,
ITemplateHolder templateHolder) |
void |
CacheManager.preCommit(Context context,
XtnEntry xtnEntry,
boolean supportsTwoPhaseReplication) |
boolean |
IEntryCacheInfo.preMatch(Context context,
ITemplateHolder template) |
boolean |
MemoryBasedEntryCacheInfo.preMatch(Context context,
ITemplateHolder template) |
void |
CacheManager.prepare(Context context,
XtnEntry xtnEntry,
boolean supportsTwoPhaseReplication,
boolean handleReplication,
boolean handleSA) |
int |
CacheManager.removeEntry(Context context,
IEntryHolder entryHolder,
IEntryCacheInfo pEntry,
boolean shouldReplicate,
boolean origin,
SpaceEngine.EntryRemoveReasonCodes removeReason,
boolean disableSAcall)
remove entry from cache & SA
|
void |
CacheManager.removeTemplate(Context context,
ITemplateHolder template,
boolean fromReplication,
boolean origin,
boolean dontReplicate)
Marks template as DELETED and send a BUS Packet to the GC.
|
void |
CacheManager.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 |
CacheManager.removeWaitingForInfo(Context context,
IEntryHolder entryHolder,
ITemplateHolder templateHolder,
boolean unpinIfPossible) |
void |
CacheManager.rollback(Context context,
XtnEntry xtnEntry,
boolean alreadyPrepared,
boolean anyUpdates,
boolean supportsTwoPhaseReplication) |
IEntryCacheInfo |
CacheManager.safeInsertEntryToCache(Context context,
IEntryHolder entryHolder,
boolean newEntry,
TypeData pType,
boolean pin,
CacheManager.InitialLoadOrigin fromInitialLoad)
Inserts the specified entry to cache, perform memory manager check.
|
boolean |
CacheManager.testAndSetFGCacheForEntry(Context context,
IEntryHolder entry,
ITemplateHolder template,
boolean testOnly,
IServerTypeDesc tte) |
void |
CacheManager.touchByEntry(Context context,
IEntryHolder entry,
boolean modifyOp,
ITemplateHolder template,
CacheOperationReason cacheOperationReason) |
boolean |
CacheManager.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 |
CacheManager.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.
|
Constructor and Description |
---|
EntriesIter(Context context,
ITemplateHolder template,
IServerTypeDesc serverTypeDesc,
CacheManager cacheManager,
long SCNFilter,
long leaseFilter,
boolean memoryOnly,
boolean transientOnly) |
SAIterBase(Context context,
CacheManager cacheManager) |
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 |
---|---|
Context |
BlobStoreReplicaConsumeHelper.getContext() |
Context |
BlobStoreReplicationBulkConsumeHelper.getContext() |
Modifier and Type | Method and Description |
---|---|
void |
IBlobStoreRefCacheInfo.bulkRegister(Context context,
BlobStoreBulkInfo bulkInfo,
int spaceOperation,
boolean registerDirectPersistency) |
void |
BlobStoreRefEntryCacheInfo.bulkRegister(Context context,
BlobStoreBulkInfo bulkInfo,
int spaceOperation,
boolean registerDirectPersistency) |
void |
IBlobStoreRefCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
BlobStoreRefEntryCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
IBlobStoreRefCacheInfo.flushedFromBulk(Context context,
CacheManager cacheManager,
Object BlobStorePos,
boolean removed,
boolean onTxnEnd) |
void |
BlobStoreRefEntryCacheInfo.flushedFromBulk(Context context,
CacheManager cacheManager,
Object blobStorePos,
boolean removed,
boolean onTxnEnd) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
BlobStoreEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
IBlobStoreEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
IBlobStoreRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext) |
IEntryHolder |
IBlobStoreRefCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getLatestEntryVersion(CacheManager cacheManager,
boolean attach,
IBlobStoreEntryHolder lastKnownEntry,
Context attachingContext,
boolean onlyIndexesPart) |
void |
IBlobStoreCacheHandler.handleOnSpaceOperation(Context context,
BlobStoreEntryHolder entry,
CacheOperationReason cacheOperationReason) |
void |
BlobStoreCacheHandler.handleOnSpaceOperation(Context context,
BlobStoreEntryHolder entry,
CacheOperationReason cacheOperationReason) |
void |
BlobStoreRefEntryCacheInfo.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
BlobStoreEntryHolder entry,
CacheOperationReason cacheOperationReason) |
void |
BlobStoreEntryHolder.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
CacheOperationReason cacheOperationReason) |
void |
IBlobStoreEntryHolder.insertOrTouchInternalCache(Context context,
CacheManager cacheManager,
CacheOperationReason cacheOperationReason) |
boolean |
BlobStoreInternalCacheFilter.isEntryHotData(IEntryHolder eh,
Context context) |
boolean |
BlobStoreRefEntryCacheInfo.preMatch(Context context,
ITemplateHolder template) |
void |
IBlobStoreRefCacheInfo.removeEntryFromBlobStoreStorage(Context context,
CacheManager cacheManager) |
void |
BlobStoreRefEntryCacheInfo.removeEntryFromBlobStoreStorage(Context context,
CacheManager cacheManager) |
void |
IBlobStoreRefCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(Context context,
CacheManager cm) |
void |
BlobStoreRefEntryCacheInfo.resetNonTransactionalFailedBlobstoreOpStatus(Context context,
CacheManager cm) |
void |
IBlobStoreRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
BlobStoreRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
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 void |
BlobStoreErrorBulkEntryInfo.setOnContext(Context context,
BlobStoreErrorBulkEntryInfo eri) |
Constructor and Description |
---|
BlobStoreErrorBulkEntryInfo(Context context) |
Modifier and Type | Method and Description |
---|---|
static boolean |
BlobStoreOperationOptimizations.isConsiderOptimizedForBlobstore(SpaceEngine spaceEngine,
Context context,
ITemplateHolder template,
IEntryCacheInfo pEntry) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
BlobStoreStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
BlobStoreStorageAdapter.getEntry(Context context,
String uid,
String classname,
IEntryHolder template) |
ISAdapterIterator |
BlobStoreStorageAdapter.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
void |
BlobStoreStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
void |
BlobStoreStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
void |
BlobStoreStorageAdapter.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate) |
void |
BlobStoreStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean shouldReplicate,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
void |
BlobStoreBulkInfo.add(Context context,
BlobStoreRefEntryCacheInfo eci,
int operation,
boolean registerDirectPersistency) |
void |
BlobStoreBulkInfo.addDelayedReplicationInfo(Context context,
BlobStoreRefEntryCacheInfo eci,
DelayedReplicationBasicInfo dri) |
void |
BlobStoreBulkInfo.bulk_flush(Context context,
boolean only_if_chunk_reached) |
void |
BlobStoreBulkInfo.bulk_flush(Context context,
boolean only_if_chunk_reached,
boolean termination) |
Modifier and Type | Method and Description |
---|---|
static IScanListIterator<IEntryCacheInfo> |
BlobStorePreFetchIteratorBasedHandler.createPreFetchIterIfRelevant(Context context,
CacheManager cacheManager,
IScanListIterator<IEntryCacheInfo> mainIterator,
ITemplateHolder template,
org.slf4j.Logger logger) |
BlobStorePreFetchBatchResult |
BlobStorePreFetchBatchHandler.execute(Context context) |
Constructor and Description |
---|
BlobStorePreFetchIteratorBasedHandler(Context mainThreadContext,
CacheManager cacheManager,
IScanListIterator<IEntryCacheInfo> mainIterator,
ITemplateHolder template,
int numEntriesRequested,
org.slf4j.Logger logger) |
Modifier and Type | Method and Description |
---|---|
IScanListIterator<IEntryCacheInfo> |
FifoGroupCacheImpl.getScannableEntriesByIndexValue(Context context,
ITemplateHolder template,
IEntryHolder entry,
IServerTypeDesc templateTypeDesc) |
IScanListIterator<IEntryCacheInfo> |
FifoGroupCacheImpl.getScannableEntriesMinIndex(Context context,
TypeData typeData,
int numOfFields,
ITemplateHolder template) |
IScanListIterator<IEntryCacheInfo> |
FifoGroupCacheImpl.getScannableEntriesMinIndexExtended(Context context,
TypeData entryType,
int numOfFields,
ITemplateHolder template) |
void |
FifoGroupCacheImpl.handleFifoGroupsCacheOnXtnEnd(Context context,
XtnEntry xtnEntry) |
boolean |
FifoGroupCacheImpl.testAndSetFGCacheForEntry(Context context,
IEntryHolder entry,
ITemplateHolder template,
Object val,
boolean testOnly) |
Modifier and Type | Field and Description |
---|---|
protected Context |
FifoWorkerThread._context |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
MemorySA.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
Map<String,IEntryHolder> |
IStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates)
Gets a map of entries from the storage adapter
|
IEntryHolder |
MemorySA.getEntry(Context context,
String uid,
String classname,
IEntryHolder template)
Gets an entry object from the storage adapter.
|
IEntryHolder |
IStorageAdapter.getEntry(Context context,
String uid,
String classname,
IEntryHolder template)
Gets an entry object from the storage adapter.
|
ISAdapterIterator |
MemorySA.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
ISAdapterIterator |
IStorageAdapter.initialLoad(Context context,
ITemplateHolder template,
InitialLoadInfo initialLoadInfo) |
void |
MemorySA.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate)
Inserts a new entry to the SA storage.
|
void |
IStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate)
Inserts a new entry to the SA storage.
|
void |
MemorySA.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> locked_entries,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate)
Performs prepare to transaction- write to SA all new entries under the xtn, mark taken
entries under the xtn
|
void |
IStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate)
Performs prepare to transaction- write to SA all new entries under the xtn, mark taken
entries under the xtn
|
void |
MemorySA.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate)
Removes an entry from the SA storage.
|
void |
IStorageAdapter.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate)
Removes an entry from the SA storage.
|
void |
MemorySA.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators)
updates an entry.
|
void |
IStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators)
updates an entry.
|
Modifier and Type | Method and Description |
---|---|
void |
Processor.handleCommittedTakenEntries(Context context,
XtnEntry xtnEntry)
handle taken entries under commit .
|
void |
Processor.handleDirectChangeSA(Context context,
ITemplateHolder template,
boolean fromReplication,
boolean origin) |
void |
Processor.handleDirectMultipleChangeSA(Context context,
ITemplateHolder template) |
void |
Processor.handleDirectMultipleReadIEOrTakeIESA(Context context,
ITemplateHolder template) |
void |
Processor.handleDirectMultipleReadTakeSA(Context context,
ITemplateHolder template) |
void |
Processor.handleDirectReadIEOrTakeIESA(Context context,
ITemplateHolder template,
boolean fromReplication,
boolean origin) |
void |
Processor.handleDirectReadTakeOrIPUpdateSA(Context context,
ITemplateHolder template,
boolean fromReplication,
boolean origin) |
void |
Processor.handleDirectUpdateSA(Context context,
ITemplateHolder template)
perform update given a template which is the updated entry.
|
WriteEntryResult |
Processor.handleDirectWriteSA(Context context,
IEntryHolder entry,
IServerTypeDesc typeDesc,
boolean fromReplication,
boolean origin,
boolean reInsertedEntry,
boolean supplied_uid,
boolean lockXtnsIfNeeded,
int modifiers)
Handles Direct write SA.
|
void |
Processor.handleLockedFifoEntriesBeforeXtnEnd(Context context,
XtnEntry xtnEntry,
boolean fromRollback)
before xtn terminated update the last readLock/Writelock fifo xtn number for this entryin
order to have a coherent picture its is called during prepare/commit/rb from the engine main
routines before status change
|
void |
Processor.handleLockedFifoEntriesOnXtnEnd(Context context,
XtnEntry xtnEntry,
boolean fromRollback)
when xtn terminated send the fifo entries to look for for fifo templates its is called during
commit/rb from the engine main routines
|
void |
Processor.handleNewRolledbackEntries(Context context,
XtnEntry xtnEntry)
handle new entries under rollback .
|
boolean |
Processor.handleNotifyFifoInCommit(Context context,
XtnEntry xtnEntry,
boolean fifoNotifyForNonFifoEvents)
this routine is called if the m_CrossXtnsFifoNotifications proprty is set if inserts the
entries to the recentFifo queue of notify this routine is called directly after commit and
not by backgroud thread return true if any entry considered
|
Modifier and Type | Method and Description |
---|---|
void |
TransactionHandler.xtnLockEntryOnTemplateOperation(Context context,
IEntryHolder eh,
ITemplateHolder th,
XtnEntry alreadyLockedXtn)
/** given an entry + template- perform the xtn locks and set the appropriate
|
Constructor and Description |
---|
MultiIntersectedStoredList(Context context,
IObjectsList list,
boolean fifoScan,
IObjectsList allElementslist,
boolean falsePositiveFilterOnly) |
MultiIntersectedStoredList(Context context,
IObjectsList list,
boolean fifoScan,
IObjectsList allElementslist,
boolean falsePositiveFilterOnly,
boolean alternatingThread) |
Copyright © GigaSpaces.