Modifier and Type | Method and Description |
---|---|
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) |
protected IObjectsList |
InValueIndexScanner.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 |
RegexIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
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 |
RangeIndexScanner.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 |
RelationIndexScanner.getEntriesByIndex(Context context,
TypeData typeData,
TypeDataIndex<Object> index,
boolean fifoGroupsScan) |
IObjectsList |
NotRegexIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
InValueIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
RegexIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
CompoundOrIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
IQueryIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
CompoundAndIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
AbstractQueryIndex.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
IObjectsList |
RelationIndexScanner.getIndexedEntriesByType(Context context,
TypeData typeData,
ITemplateHolder template,
int latestIndexToConsider) |
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) |
protected void |
SpaceEngine.setFromGatewayIfNeeded(SpaceContext sc,
Context context) |
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 |
---|---|
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 |
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,
Object uid,
String typeName,
IEntryHolder template) |
ISAdapterIterator<?> |
SynchronizationStorageAdapter.initialLoad(Context context,
ITemplateHolder template) |
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 |
---|---|
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 |
CacheManager.getCacheContext() |
Context |
CacheContextFactory.getCacheContext()
returns a free Context from the pool.
|
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 |
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.
|
Context |
CacheManager.freeCacheContext(Context context) |
void |
CacheContextFactory.freeCacheContext(Context ctx)
Free a Context acquired by getCacheContext().
|
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-
Computes the best way to reach a list of potential match of entries of the specified type.
|
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
|
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)
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)
Inserts the specified entry to cache, perform memory manager check.
|
boolean |
CacheManager.testAndSetFGCacheForEntry(Context context,
IEntryHolder entry,
ITemplateHolder template,
boolean testOnly,
IServerTypeDesc tte) |
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 |
---|---|
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 | Method and Description |
---|---|
Context |
BlobStoreReplicaConsumeHelper.getContext() |
Context |
BlobStoreReplicationBulkConsumeHelper.getContext() |
Modifier and Type | Method and Description |
---|---|
void |
OffHeapRefEntryCacheInfo.bulkRegister(Context context,
BlobStoreBulkInfo bulkInfo,
int spaceOperation,
boolean registerDirectPersistency) |
void |
IOffHeapRefCacheInfo.bulkRegister(Context context,
BlobStoreBulkInfo bulkInfo,
int spaceOperation,
boolean registerDirectPersistency) |
void |
OffHeapRefEntryCacheInfo.flush(CacheManager cacheManager,
Context context) |
void |
IOffHeapRefCacheInfo.flush(CacheManager cacheManager,
Context context) |
IEntryHolder |
OffHeapRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
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) |
boolean |
OffHeapRefEntryCacheInfo.preMatch(Context context,
ITemplateHolder template) |
void |
OffHeapRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
IOffHeapRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context) |
void |
OffHeapRefEntryCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context,
boolean fromInitialLoad) |
void |
IOffHeapRefCacheInfo.unLoadFullEntryIfPossible(CacheManager cacheManager,
Context context,
boolean fromInitialLoad) |
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 void |
BlobStoreErrorBulkEntryInfo.setOnContext(Context context,
BlobStoreErrorBulkEntryInfo eri) |
Constructor and Description |
---|
BlobStoreErrorBulkEntryInfo(Context context) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
OffHeapStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
OffHeapStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
ISAdapterIterator |
OffHeapStorageAdapter.initialLoad(Context context,
ITemplateHolder template) |
void |
OffHeapStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
void |
OffHeapStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
void |
OffHeapStorageAdapter.removeEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean fromLeaseExpiration,
boolean shouldReplicate) |
void |
OffHeapStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean shouldReplicate,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
void |
BlobStoreBulkInfo.add(Context context,
OffHeapRefEntryCacheInfo eci,
int operation,
boolean registerDirectPersistency) |
void |
BlobStoreBulkInfo.addDelayedReplicationInfo(Context context,
OffHeapRefEntryCacheInfo 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,
Logger logger) |
BlobStorePreFetchBatchResult |
BlobStorePreFetchBatchHandler.execute(Context context) |
Constructor and Description |
---|
BlobStorePreFetchIteratorBasedHandler(Context mainThreadContext,
CacheManager cacheManager,
IScanListIterator<IEntryCacheInfo> mainIterator,
ITemplateHolder template,
int numEntriesRequested,
Logger logger) |
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,
Object uid,
String classname,
IEntryHolder template)
Gets an entry object from the storage adapter.
|
IEntryHolder |
IStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template)
Gets an entry object from the storage adapter.
|
ISAdapterIterator |
MemorySA.initialLoad(Context context,
ITemplateHolder template) |
ISAdapterIterator |
IStorageAdapter.initialLoad(Context context,
ITemplateHolder template) |
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.handleDirectReadOrTakeSA(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) |
Copyright © GigaSpaces.