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) |
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) |
Modifier and Type | Method and Description |
---|---|
void |
SynchronizationStorageAdapter.commit(ServerTransaction xtn,
boolean anyUpdates) |
int |
SynchronizationStorageAdapter.count(ITemplateHolder template,
String[] subClasses) |
Map<String,IEntryHolder> |
SynchronizationStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
SynchronizationStorageAdapter.getEntry(Context context,
Object uid,
String typeName,
IEntryHolder template) |
void |
SynchronizationStorageAdapter.initialize() |
ISAdapterIterator<?> |
SynchronizationStorageAdapter.initialLoad(Context context,
ITemplateHolder template) |
void |
SynchronizationStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
ISAdapterIterator<IEntryHolder> |
SynchronizationStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subTypes) |
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.rollback(ServerTransaction xtn,
boolean anyUpdates) |
void |
SynchronizationStorageAdapter.shutDown() |
void |
SynchronizationStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean updateRedoLog,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Modifier and Type | Method and Description |
---|---|
protected void |
MirrorReplicationInHandler.execute(IReplicationInBatchContext batchContext,
TransactionParticipantDataImpl transactionParticipantData) |
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.close() |
void |
UnderXtnEntriesIter.close()
overrides com.j_spaces.core.cache.SAIterBase.close()
|
void |
SAIterBase.close()
Cleans up open resources
|
void |
UnderXtnTemplatesIter.close()
overrides com.j_spaces.core.cache.SAIterBase.close()
|
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
|
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
|
void |
CacheManager.handleInsertEntryReplication(Context context,
IEntryHolder entryHolder) |
void |
CacheManager.handleInsertEntryReplication(Context context,
IEntryHolder entryHolder,
int blobstoreBulkId) |
boolean |
MemoryBasedEntryCacheInfo.hasNext() |
boolean |
RecentExtendedIndexUpdates.RecentExtendedUpdatesIter.hasNext() |
boolean |
ScanListSAIterator.hasNext() |
boolean |
QueryExtensionIndexEntryIteratorWrapper.hasNext() |
void |
CacheManager.init(Properties properties) |
void |
CacheManager.initCache(boolean loadDataFromDB,
Properties properties)
Init.
|
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.
|
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) |
IEntryHolder |
EntriesIter.next() |
Object |
UnderXtnEntriesIter.next() |
IEntryCacheInfo |
MemoryBasedEntryCacheInfo.next() |
IEntryCacheInfo |
RecentExtendedIndexUpdates.RecentExtendedUpdatesIter.next() |
IEntryCacheInfo |
QueryExtensionIndexEntryIteratorWrapper.next() |
ITemplateHolder |
UnderXtnTemplatesIter.next() |
IEntryCacheInfo |
EntriesIter.nextEntryCacheInfo() |
Object |
EntriesIter.nextObject() |
void |
CacheManager.prepare(Context context,
XtnEntry xtnEntry,
boolean supportsTwoPhaseReplication,
boolean handleReplication,
boolean handleSA) |
void |
MemoryBasedEntryCacheInfo.releaseScan()
release SLHolder for this scan
|
void |
RecentExtendedIndexUpdates.RecentExtendedUpdatesIter.releaseScan()
release SLHolder for this scan
|
void |
ScanListSAIterator.releaseScan()
release SLHolder for this scan
|
void |
QueryExtensionIndexEntryIteratorWrapper.releaseScan()
release SLHolder for this scan
|
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.rollback(Context context,
XtnEntry xtnEntry,
boolean alreadyPrepared,
boolean anyUpdates,
boolean supportsTwoPhaseReplication) |
void |
PersistentGC.shutdown()
close persistentGC.
|
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 |
---|---|
boolean |
FifoGroupsScanByFGIndexIterator.hasNext() |
boolean |
FifoGroupsScanAllValuesIterator.hasNext() |
boolean |
FifoGroupsScanByGeneralIndexIterator.hasNext() |
EntryCacheInfo |
FifoGroupsScanByFGIndexIterator.next() |
T |
FifoGroupsScanAllValuesIterator.next() |
IEntryCacheInfo |
FifoGroupsScanByGeneralIndexIterator.next() |
void |
FifoGroupsScanByFGIndexIterator.nextGroup()
move to next group-value
|
void |
IFifoGroupIterator.nextGroup()
move to next group-value in multi-group iter , called when the checked group is "occupied"
|
void |
FifoGroupsScanAllValuesIterator.nextGroup()
move to next group-value
|
void |
FifoGroupsScanByGeneralIndexIterator.nextGroup()
move to next group-value
|
void |
FifoGroupsMultiList.nextGroup() |
void |
FifoGroupsScanByFGIndexIterator.releaseScan()
release SLHolder for this scan
|
void |
FifoGroupsScanAllValuesIterator.releaseScan()
release SLHolder for this scan
|
void |
FifoGroupsScanByGeneralIndexIterator.releaseScan()
release SLHolder for this scan
|
Modifier and Type | Method and Description |
---|---|
boolean |
OffHeapRefEntryCacheInfo.hasNext() |
IEntryCacheInfo |
OffHeapRefEntryCacheInfo.next() |
void |
OffHeapRefEntryCacheInfo.releaseScan()
release SLHolder for this scan
|
Modifier and Type | Method and Description |
---|---|
void |
OffHeapDataIterator.close() |
void |
OffHeapMetaDataIterator.close() |
void |
OffHeapStorageAdapter.commit(ServerTransaction xtn,
boolean anyUpdates) |
int |
OffHeapStorageAdapter.count(ITemplateHolder template,
String[] subClasses) |
Map<String,IEntryHolder> |
OffHeapStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
OffHeapStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
void |
OffHeapStorageAdapter.initialize() |
ISAdapterIterator |
OffHeapStorageAdapter.initialLoad(Context context,
ITemplateHolder template) |
void |
OffHeapStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
boolean shouldReplicate) |
ISAdapterIterator<IEntryHolder> |
OffHeapStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subClasses) |
IEntryHolder |
OffHeapDataIterator.next() |
ITypeDesc |
OffHeapMetaDataIterator.next() |
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.rollback(ServerTransaction xtn,
boolean anyUpdates) |
void |
OffHeapStorageAdapter.shutDown() |
void |
OffHeapStorageAdapter.updateEntry(Context context,
IEntryHolder updatedEntry,
boolean shouldReplicate,
boolean origin,
boolean[] partialUpdateValuesIndicators) |
Constructor and Description |
---|
OffHeapMetaDataIterator(SpaceEngine engine) |
Modifier and Type | Method and Description |
---|---|
boolean |
BlobStorePreFetchIteratorBasedHandler.hasNext() |
IEntryCacheInfo |
BlobStorePreFetchIteratorBasedHandler.next() |
void |
BlobStorePreFetchIteratorBasedHandler.releaseScan() |
Modifier and Type | Method and Description |
---|---|
protected void |
FifoWorkerThread.handleNonNotifyRequest(FifoBackgroundRequest rd) |
protected abstract void |
FifoWorkerThread.handleNotifyRequest(FifoBackgroundRequest rd) |
protected void |
FifoWorkerThread.handleNotifyRequest(FifoBackgroundRequest rd,
NotifyActionType notifyType) |
protected void |
FifoWorkerThread.performGeneralEntryNonNotify(IEntryHolder eh,
FifoBackgroundRequest rd)
perform general non-notify
|
protected void |
FifoWorkerThread.performTemplateOnEntryNonNotify(IEntryHolder eh,
ITemplateHolder template,
FifoBackgroundRequest rd) |
protected void |
FifoWorkerThread.processRejectedRequestsToPerform(FifoBackgroundRequest rd,
List<FifoBackgroundRequest> rejectedRequestsToPerform) |
Modifier and Type | Method and Description |
---|---|
void |
ISAdapterIterator.close() |
void |
MemorySA.commit(ServerTransaction xtn,
boolean anyUpdates)
Performs commit to transaction- delete taken entries, commit new entries.
|
void |
IStorageAdapter.commit(ServerTransaction xtn,
boolean anyUpdates)
Performs commit to transaction- delete taken entries, commit new entries.
|
int |
MemorySA.count(ITemplateHolder template,
String[] subClasses)
Returns the number of entries that match the template.
|
int |
IStorageAdapter.count(ITemplateHolder template,
String[] subClasses)
Returns the number of entries that match the template.
|
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.
|
void |
MemorySA.initialize() |
void |
IStorageAdapter.initialize()
Initializes the SA for work (first API called by engine) If initMode is WARM : SA is
required to set its internal working tables and environment to the state recorded in its
persistent storage, and verify that all the SA space-related data is in consistent state.
|
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.
|
ISAdapterIterator |
MemorySA.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subClasses)
Returns an iterator with entries that match the template, and the other parameters.
|
ISAdapterIterator<IEntryHolder> |
IStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subClasses)
Returns an iterator with entries that match the template, and the other parameters.
|
T |
ISAdapterIterator.next() |
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.rollback(ServerTransaction xtn,
boolean anyUpdates)
Performs rollback to transaction- rewrite taken entries, remove new entries.
|
void |
IStorageAdapter.rollback(ServerTransaction xtn,
boolean anyUpdates)
Performs rollback to transaction- rewrite taken entries, remove new entries.
|
void |
MemorySA.shutDown()
called by the engine after all connections have been closed.
|
void |
IStorageAdapter.shutDown()
called by the engine after all connections have been closed.
|
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.entryArrivedSA(EntryArrivedPacket packet)
Handles EntryArrived packets.
|
void |
Processor.entryUnmatchedSA(EntryUnmatchedPacket packet)
Handles overridden packets.
|
void |
Processor.entryUpdatedSA(EntryUpdatedPacket packet) |
void |
Processor.handleCommitSA(CommitBusPacket packet)
Handles commit SA.
|
void |
Processor.handleCommittedTakenEntries(Context context,
XtnEntry xtnEntry)
handle taken entries under commit .
|
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
|
void |
Processor.handleRemoveWaitingForInfoSA(RemoveWaitingForInfoSABusPacket packet)
Handles the remove of waiting for info of a entry .
|
void |
Processor.handleRollbackSA(RollbackBusPacket packet)
Handles rollback SA.
|
Modifier and Type | Method and Description |
---|---|
boolean |
IScanListIterator.hasNext() |
T |
IScanListIterator.next() |
void |
IScanListIterator.releaseScan()
release SLHolder for this scan
|
Modifier and Type | Method and Description |
---|---|
void |
DataAdaptorIterator.close()
Closes this iterator.
|
IEntryHolder |
DataAdaptorIterator.next() |
Copyright © GigaSpaces.