Constructor and Description |
---|
DataSourceIdsQueryImpl(ITypeDesc typeDescriptor,
Object[] ids,
IEntryHolder[] templates,
SQLQueryBuilder queryBuilder,
Class<?> dataClass,
IDataConverter<IEntryPacket> converter) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationNode.outCancelEntryLease(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry lease was canceled
|
void |
IReplicationNode.outChangeEntry(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry was changed
|
void |
IReplicationNode.outEntryLeaseExpired(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry lease expired
|
void |
IReplicationNode.outEvictEntry(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry was evicted
|
void |
IReplicationNode.outExtendEntryLeasePeriod(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry lease is extended
|
void |
IReplicationNode.outRemoveEntry(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry was removed
|
void |
IReplicationNode.outUpdateEntry(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that an entry was updated
|
void |
IReplicationNode.outWriteEntry(IReplicationOutContext context,
IEntryHolder entryHolder)
Notify replication node that a new entry was written
|
Modifier and Type | Method and Description |
---|---|
void |
IReplicationNode.outTransaction(IReplicationOutContext context,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries)
Notify replication node that a transaction is executed in one stage (one phase commit)
|
void |
IReplicationNode.outTransactionPrepare(IReplicationOutContext context,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries)
Notify replication node that a transaction prepare is executed (two phase commit)
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationNode.outCancelEntryLease(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outChangeEntry(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outEntryLeaseExpired(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outEvictEntry(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outExtendEntryLeasePeriod(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outRemoveEntry(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outUpdateEntry(IReplicationOutContext context,
IEntryHolder entryHolder) |
void |
ReplicationNode.outWriteEntry(IReplicationOutContext context,
IEntryHolder entryHolder) |
Modifier and Type | Method and Description |
---|---|
void |
ReplicationNode.outTransaction(IReplicationOutContext context,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries) |
void |
ReplicationNode.outTransactionPrepare(IReplicationOutContext context,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationAsyncGroupBacklog.add(IAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationAsyncGroupBacklog.addTransaction(IAsyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
GlobalOrderAsyncGroupBacklog.add(IAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
void |
GlobalOrderSyncGroupBacklog.add(ISyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
void |
GlobalOrderReliableAsyncGroupBacklog.add(ReliableAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
protected IReplicationOrderedPacket |
AbstractGlobalOrderGroupBacklog.addSingleOperationPacket(IReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
MultiBucketSingleFileSyncGroupBacklog.add(ISyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
void |
MultiBucketSingleFileReliableAsyncGroupBacklog.add(ReliableAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
SingleBucketOrderedPacket |
AbstractMultiBucketSingleFileGroupBacklog.addSingleOperationPacket(ISyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
MultiBucketSingleFileSyncGroupBacklog.addTransaction(ISyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
void |
MultiBucketSingleFileReliableAsyncGroupBacklog.addTransaction(ReliableAsyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
IMultiBucketSingleFileReplicationOrderedPacket |
AbstractMultiBucketSingleFileGroupBacklog.addTransactionOperationPacket(ISyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
MultiSourceSingleFileAsyncGroupBacklog.add(IAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
void |
MultiSourceSingleFileReliableAsyncGroupBacklog.add(ReliableAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
protected IReplicationOrderedPacket |
AbstractMultiSourceSingleFileGroupBacklog.addSingleOperationPacket(IReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
MultiSourceSingleFileAsyncGroupBacklog.addTransaction(IAsyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
void |
MultiSourceSingleFileReliableAsyncGroupBacklog.addTransaction(ReliableAsyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
protected IReplicationOrderedPacket |
AbstractMultiSourceSingleFileGroupBacklog.addTransactionOperationPacket(IReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationReliableAsyncGroupBacklog.add(ReliableAsyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationReliableAsyncGroupBacklog.addTransaction(ReliableAsyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationSyncGroupBacklog.add(ISyncReplicationGroupOutContext groupContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationSyncGroupBacklog.addTransaction(ISyncReplicationGroupOutContext groupContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
DirectPersistencySyncHandler.beforeDirectPersistencyOp(IReplicationOutContext replContext,
IEntryHolder entryHolder,
boolean phantom) |
void |
IDirectPersistencySyncHandler.beforeDirectPersistencyOp(IReplicationOutContext context,
IEntryHolder entryHolder,
boolean phantom) |
Modifier and Type | Method and Description |
---|---|
void |
DirectPersistencySyncHandler.beforeDirectPersistencyOp(IReplicationOutContext replContext,
List<String> uids,
Set<String> phantoms,
Map<String,IEntryHolder> entryHolderMap) |
void |
IDirectPersistencySyncHandler.beforeDirectPersistencyOp(IReplicationOutContext context,
List<String> uids,
Set<String> phantoms,
Map<String,IEntryHolder> entryHolderMap) |
Modifier and Type | Method and Description |
---|---|
boolean |
InitialLoadHandler.onLoadingEntry(IEntryHolder eh) |
Modifier and Type | Method and Description |
---|---|
void |
IReplicationSourceGroup.beforeExecute(ReplicationOutContext replicationContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType)
Creates a single entry holder operation replication data from the given properties and add it
to the provided context
|
String |
AllSpaceItemGroupsExtractor.extractGroupMapping(IEntryHolder entryHolder) |
String |
ISpaceItemGroupsExtractor.extractGroupMapping(IEntryHolder entryHolder)
Extract relevant group mapping for the provided entry holder
|
Modifier and Type | Method and Description |
---|---|
void |
IReplicationSourceGroup.beforeTransactionExecute(ReplicationOutContext replicationContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType)
Creates transaction replication data and adds it to the provided context
|
Modifier and Type | Method and Description |
---|---|
void |
AsyncReplicationSourceGroup.beforeExecute(ReplicationOutContext replicationContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
AsyncReplicationSourceGroup.beforeTransactionExecute(ReplicationOutContext replicationContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
ReliableAsyncReplicationSourceGroup.beforeExecute(ReplicationOutContext replicationContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
ReliableAsyncReplicationSourceGroup.beforeTransactionExecute(ReplicationOutContext replicationContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
SyncReplicationSourceGroup.beforeExecute(ReplicationOutContext replicationContext,
IEntryHolder entryHolder,
ReplicationSingleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
void |
SyncReplicationSourceGroup.beforeTransactionExecute(ReplicationOutContext replicationContext,
ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
T |
IReplicationPacketDataProducer.createSingleOperationData(IEntryHolder entryHolder,
ReplicationSingleOperationType operationType,
ReplicationOutContext replicationOutContext)
Convert a single entry operation to a representing
IReplicationPacketData |
IExecutableReplicationPacketData<?> |
BlobstoreReplicationPacketDataProducer.createSingleOperationData(IEntryHolder entryHolder,
ReplicationSingleOperationType operationType,
ReplicationOutContext replicationOutContext) |
IExecutableReplicationPacketData<?> |
ReplicationPacketDataProducer.createSingleOperationData(IEntryHolder entryHolder,
ReplicationSingleOperationType operationType,
ReplicationOutContext replicationOutContext) |
Modifier and Type | Method and Description |
---|---|
T |
IReplicationPacketDataProducer.createTransactionOperationData(ServerTransaction transaction,
ArrayList<IEntryHolder> lockedEntries,
ReplicationOutContext replicationOutContext,
ReplicationMultipleOperationType operationType)
Convert a transaction operation to a representing
IReplicationPacketData |
IExecutableReplicationPacketData<IReplicationTransactionalPacketEntryData> |
ReplicationPacketDataProducer.createTransactionOperationData(ServerTransaction transaction,
ArrayList<IEntryHolder> entries,
ReplicationOutContext replicationOutContext,
ReplicationMultipleOperationType operationType) |
Modifier and Type | Method and Description |
---|---|
protected AbstractEntryReplicaData |
EntryReplicaProducer.produceDataFromEntry(ISynchronizationCallback syncCallback,
IEntryHolder entry) |
Modifier and Type | Method and Description |
---|---|
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.
|
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 |
FifoGroupsHandler.handleRemoveWaitingForInfoSAFifoGroups_EntryBased(Context context,
IEntryHolder entry,
ITemplateHolder template) |
boolean |
SpaceEngine.isEntryFromPartition(IEntryHolder entryHolder)
return true if entry belongs to the partition of the space, false if entry is not from space
partition
|
boolean |
SpaceEngine.isExpiredEntryStayInSpace(IEntryHolder entry) |
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) |
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.
|
Modifier and Type | Field and Description |
---|---|
protected IEntryHolder |
NotifyContextsHolder._newEntry |
protected IEntryHolder |
NotifyContextsHolder._originalEntry |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
NotifyContext.getEntry() |
IEntryHolder |
NotifyContextsHolder.getNewEntry() |
IEntryHolder |
NotifyContextsHolder.getNotifyEntry() |
IEntryHolder |
NotifyContextsHolder.getOriginalEntry() |
IEntryHolder |
NotifyContext.getReferenceEntry() |
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.
|
Constructor and Description |
---|
NotifyContext(IEntryHolder notifyEntry,
IEntryHolder referanceEntry,
OperationID operationId,
NotifyActionType notifyType) |
NotifyContext(IEntryHolder notifyEntry,
OperationID operationId,
NotifyActionType notifyType) |
NotifyContextsHolder(IEntryHolder originalEntry,
IEntryHolder newEntry,
OperationID operationId,
NotifyActionType notifyType) |
UpdateNotifyContextHolder(IEntryHolder originalEntry,
IEntryHolder newEntry,
OperationID operationId,
boolean isMatched,
boolean isRematched) |
Modifier and Type | Method and Description |
---|---|
void |
RecentDeletesRepository.insertToRecentDeletes(IEntryHolder entry,
long duration,
ServerTransaction xtn) |
void |
RecentUpdatesRepository.insertToRecentUpdates(IEntryHolder entry,
long duration,
ServerTransaction xtn) |
boolean |
RecentDeletesRepository.removeFromRecentDeletes(IEntryHolder entry) |
boolean |
RecentUpdatesRepository.removeFromRecentUpdates(IEntryHolder entry) |
Modifier and Type | Interface and Description |
---|---|
interface |
ITemplateHolder |
Modifier and Type | Class and Description |
---|---|
class |
EntryHolder
This class represents an
Entry in a GigaSpace. |
class |
NotifyTemplateHolder
this class contains all the information relevant to a notify template.
|
class |
ReplicationEntryHolder
IEntryHolder implementation which holds the entry's previous version in space before
update operation. |
class |
ShadowEntryHolder
shadowEntry is an entry version under pending update- it contains the original entry values note
that shadow and master are connected via a mutual reference
|
class |
TemplateHolder
This class represents a template in a J-Space.
|
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
EntryHolder.createCopy() |
IEntryHolder |
TemplateHolder.createCopy() |
IEntryHolder |
IEntryHolder.createCopy() |
IEntryHolder |
EntryHolder.createDummy() |
IEntryHolder |
TemplateHolder.createDummy() |
IEntryHolder |
IEntryHolder.createDummy() |
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
IEntryPacket entryPacket,
EntryDataType entryDataType)
Used by DataAdaptor, the EntryHolder Ctor make sure the version is always bigger than 0.
|
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
IEntryPacket entryPacket,
EntryDataType entryDataType,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
boolean blobStoreEntryHolder) |
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
IEntryPacket entryPacket,
EntryDataType entryDataType,
String uid,
long expirationTime,
XtnEntry xidOriginated,
long scn,
int versionID,
boolean keepExpiration,
boolean blobStoreEntryHolder) |
static IEntryHolder |
EntryHolderFactory.createEntryHolder(IServerTypeDesc typeDesc,
ITransactionalEntryData entryData,
String uid,
boolean isTransient) |
IEntryHolder |
EntryHolder.getMaster() |
IEntryHolder |
ShadowEntryHolder.getMaster() |
IEntryHolder |
TemplateHolder.getMaster() |
IEntryHolder |
IEntryHolder.getMaster() |
IEntryHolder |
EntryHolder.getOriginalEntryHolder() |
IEntryHolder |
TemplateHolder.getOriginalEntryHolder() |
IEntryHolder |
IEntryHolder.getOriginalEntryHolder() |
IEntryHolder |
ReplicationEntryHolder.getOriginalEntryHolder() |
protected IEntryHolder |
EntryHolder.getOtherUpdateUnderXtnEntry() |
IEntryHolder |
ITransactionalEntryData.getOtherUpdateUnderXtnEntry() |
IEntryHolder |
AbstractEntryData.getOtherUpdateUnderXtnEntry() |
IEntryHolder |
TemplateHolder.getUpdatedEntry() |
IEntryHolder |
ITemplateHolder.getUpdatedEntry() |
Modifier and Type | Method and Description |
---|---|
Collection<IEntryHolder> |
TemplateHolder.getEntriesWaitingForTemplate() |
Collection<IEntryHolder> |
ITemplateHolder.getEntriesWaitingForTemplate() |
Modifier and Type | Method and Description |
---|---|
void |
TemplateHolder.addEntryWaitingForTemplate(IEntryHolder entry) |
void |
ITemplateHolder.addEntryWaitingForTemplate(IEntryHolder entry) |
RemoteEvent |
NotifyTemplateHolder.createRemoteEvent(IEntryHolder entryHolder,
IEntryHolder oldEntryHolder,
NotifyActionType notifyType,
OperationID operationID,
IJSpace spaceProxy,
boolean fromReplication) |
RemoteEvent |
NotifyTemplateHolder.createRemoteEvent(IEntryHolder entryHolder,
NotifyActionType notifyType,
OperationID operationID,
IJSpace spaceProxy,
boolean fromReplication) |
static ShadowEntryHolder |
EntryHolderFactory.createShadowEntryHolder(IEntryHolder master,
ArrayList<IObjectInfo<IEntryCacheInfo>> backRefs,
int[] backrefIndexPos,
IStoredList<Object> leaseManagerListRef,
IObjectInfo<Object> leaseManagerPosRef) |
boolean |
EntryHolder.isSameEntryInstance(IEntryHolder other) |
boolean |
TemplateHolder.isSameEntryInstance(IEntryHolder other) |
boolean |
IEntryHolder.isSameEntryInstance(IEntryHolder other) |
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) |
void |
TemplateHolder.removeEntryWaitingForTemplate(IEntryHolder entry) |
void |
ITemplateHolder.removeEntryWaitingForTemplate(IEntryHolder entry) |
void |
EntryHolder.setOtherUpdateUnderXtnEntry(IEntryHolder eh) |
void |
ITransactionalEntryData.setOtherUpdateUnderXtnEntry(IEntryHolder entryHolder) |
void |
TemplateHolder.setOtherUpdateUnderXtnEntry(IEntryHolder eh) |
void |
IEntryHolder.setOtherUpdateUnderXtnEntry(IEntryHolder eh) |
void |
AbstractEntryData.setOtherUpdateUnderXtnEntry(IEntryHolder eh) |
void |
TemplateHolder.setUpdatedEntry(IEntryHolder updatedEntry) |
void |
ITemplateHolder.setUpdatedEntry(IEntryHolder entryHolder) |
void |
EntryHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
void |
TemplateHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
void |
IEntryHolder.setWriteLockOwnerOperationAndShadow(XtnEntry writeLockOwner,
int writeLockOperation,
IEntryHolder otherEh) |
Constructor and Description |
---|
AbstractSpaceItem(IEntryHolder other) |
EntryHolder(IEntryHolder other) |
ReplicationEntryHolder(IEntryHolder entryHolder,
XtnEntry xtnEntry) |
ShadowEntryHolder(IEntryHolder master,
ArrayList<IObjectInfo<IEntryCacheInfo>> backRefs,
int[] backrefIndexPos,
IStoredList<Object> leaseManagerListRef,
IObjectInfo<Object> leaseManagerPosRef) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
SynchronizationStorageAdapter.getEntry(Context context,
Object uid,
String typeName,
IEntryHolder template) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
SynchronizationStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
ISAdapterIterator<IEntryHolder> |
SynchronizationStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subTypes) |
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) |
void |
SynchronizationStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
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 |
---|---|
void |
SynchronizationStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
SyncHybridStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
SyncHybridStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
ISAdapterIterator<IEntryHolder> |
SyncHybridStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subClasses) |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
SyncHybridStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
SyncHybridStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
void |
SyncHybridStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
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 |
---|---|
void |
SyncHybridStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
Modifier and Type | Method and Description |
---|---|
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entry,
ITemplateHolder template) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entry,
ITemplateHolder template,
IEntryData entryData) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entry,
ITemplateHolder template,
String uid) |
static IEntryPacket |
EntryPacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationId) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
IEntryData entryData,
OperationID operationID) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive,
OperationID operationId) |
static ITemplatePacket |
TemplatePacketFactory.createFullPacket(IEntryHolder entryHolder,
OperationID operationID) |
static IEntryPacket |
EntryPacketFactory.createFullPacketForReplication(IEntryHolder entryHolder,
ITemplateHolder template,
String uid,
long timeToLive) |
static IEntryPacket |
EntryPacketFactory.createFullPacketForReplication(IEntryHolder entryHolder,
OperationID operationID) |
static IEntryPacket |
EntryPacketFactory.createPartialUpdatePacketForReplication(IEntryHolder entryHolder,
OperationID operationID,
boolean[] partialUpdatedValuesIndicators) |
static IEntryPacket |
EntryPacketFactory.createRemovePacketForPersistency(IEntryHolder entryHolder,
OperationID operationID) |
Constructor and Description |
---|
NotifyEvent(IEntryHolder holder,
ITypeDesc tte,
NotifyContext notifyContext) |
Modifier and Type | Field and Description |
---|---|
protected IEntryHolder |
EntryImpl._entryHolder |
IEntryHolder |
EntryTakenPacket.m_EntryValueToNotify |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
LeaseManager.cancel(String entryUid,
String classname,
int objectType,
boolean fromReplication,
boolean origin,
boolean isFromGateway)
Cancel a lease for a registered Entry in this Lease Manager.
|
IEntryHolder |
LeaseManager.cancel(String entryUid,
String classname,
int objectType,
boolean fromReplication,
boolean origin,
boolean lease_expired,
OperationID operationID,
boolean isFromGateway) |
Modifier and Type | Method and Description |
---|---|
void |
PendingFifoSearch.addRejectedEntry(IEntryHolder eh,
FifoBackgroundRequest red) |
int |
FifoEntriesComparator.compare(IEntryHolder o1,
IEntryHolder o2)
Compare 2 entries.
|
EntryArrivedPacket |
EntryArrivedPacketsFactory.getPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
boolean notifyListeners,
IEntryHolder entryValueToNotify,
boolean fromReplication)
returns a constructed EntryArrivedPacket extracted from the pool of resources.
|
void |
LeaseManager.reRegisterLease(ILeasedEntryCacheInfo leaseCacheInfo,
IEntryHolder entry,
long original_expiration,
long new_expiration,
int objectType) |
Constructor and Description |
---|
EntryImpl(IEntryHolder entryHolder,
ITypeDesc typeDesc)
Constructs an Entry implementation including its class-type meta-data.
|
EntryTakenPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
IEntryHolder entryValueToNotify,
boolean fromReplication) |
NoMatchException(IEntryHolder entry) |
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.
|
IEntryHolder |
EntriesIter.getCurrentEntryHolder() |
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 |
CacheManager.getEntryByIdFromPureCache(Object id,
IServerTypeDesc typeDesc) |
IEntryHolder |
CacheManager.getEntryByUidFromPureCache(String uid) |
IEntryHolder |
CacheManager.getEntryFromCacheHolder(IEntryCacheInfo pt)
given a PEntry, return the entry.
|
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder() |
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
IEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
MemoryBasedEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
CacheManager.makeChangeOpEntry(Context context,
ITemplateHolder template,
IEntryHolder currentEntry) |
IEntryHolder |
EntriesIter.next_by_uid() |
IEntryHolder |
EntriesIter.next() |
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.
|
Modifier and Type | Method and Description |
---|---|
List<IEntryHolder> |
XtnData.getEntriesForFifoGroupScan() |
List<IEntryHolder> |
XtnData.getEntriesForReplicationIn2PCommit() |
IBasicLockManager<IEntryHolder> |
CacheManager.getLockManager()
get the lock manager
|
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) |
Modifier and Type | Method and Description |
---|---|
void |
XtnData.addToEntriesForFifoGroupScan(IEntryHolder entry) |
void |
XtnData.addToFifoGroupsEntries(IEntryHolder eh,
Object groupValue) |
IEntryHolder |
CacheManager.associateEntryWithXtn(Context context,
IEntryHolder entryHolder,
ITemplateHolder template,
XtnEntry xtnEntry,
IEntryHolder new_content)
tie an entry with a transaction.
|
<K> K |
CompoundIndexSegmentTypeData.cloneIndexValue(K fieldValue,
IEntryHolder entryHolder) |
static IEntryCacheInfo |
EntryCacheInfoFactory.createBlobStoreEntryCacheInfo(IEntryHolder entryHolder) |
static IEntryCacheInfo |
EntryCacheInfoFactory.createEntryCacheInfo(IEntryHolder EntryHolder) |
static IEntryCacheInfo |
EntryCacheInfoFactory.createEntryCacheInfo(IEntryHolder entryHolder,
int backRefsSize,
boolean pin,
SpaceEngine engine) |
static IEntryCacheInfo |
EntryCacheInfoFactory.createEntryCacheInfo(IEntryHolder entryHolder,
SpaceEngine engine) |
void |
CacheManager.disconnectEntryFromXtn(Context context,
IEntryHolder entryHolder,
XtnEntry xtnEntry,
boolean xtnEnd)
disconnect an entry from xtn
|
Object |
CacheManager.findTemplatesByIndex(Context context,
IServerTypeDesc typeDesc,
IEntryHolder entry,
MatchTarget matchTarget)
given a class name return the SL of matching templates.
|
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.getEntryCacheInfo(IEntryHolder eh)
get PEntry for entry.
|
TerminatingFifoXtnsInfo.FifoXtnEntryInfo |
CacheManager.getFifoEntryXtnInfo(IEntryHolder eh) |
TerminatingFifoXtnsInfo.FifoXtnEntryInfo |
TerminatingFifoXtnsInfo.getFifoEntryXtnInfo(IEntryHolder eh) |
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.insertToRecentDeletes(IEntryHolder entry,
long duration,
ServerTransaction committingXtn) |
void |
CacheManager.insertToRecentUpdates(IEntryHolder entry,
long duration,
ServerTransaction committingXtn) |
void |
CacheManager.insertToRecentUpdatesIfNeeded(IEntryHolder entry,
long duration,
ServerTransaction committingXtn) |
boolean |
CacheManager.isDummyEntry(IEntryHolder eh) |
boolean |
CacheManager.isEntryInRecentUpdates(IEntryHolder entry) |
boolean |
XtnData.isUpdatedEntry(IEntryHolder eh) |
IEntryHolder |
CacheManager.makeChangeOpEntry(Context context,
ITemplateHolder template,
IEntryHolder currentEntry) |
void |
CacheManager.makeWaitForInfo(Context context,
IEntryHolder entryHolder,
ITemplateHolder templateHolder) |
int |
CacheManager.removeEntry(Context context,
IEntryHolder entryHolder,
IEntryCacheInfo pEntry,
boolean shouldReplicate,
boolean origin,
SpaceEngine.EntryRemoveReasonCodes removeReason,
boolean disableSAcall)
remove entry from cache & SA
|
boolean |
CacheManager.removeEntryFromCache(IEntryHolder entryHolder)
Removes the specified entry from cache.
|
boolean |
CacheManager.removeEntryFromCache(IEntryHolder entryHolder,
boolean initiatedByEvictionStrategy,
boolean locked,
IEntryCacheInfo pEntry,
CacheManager.RecentDeleteCodes recentDeleteUsage)
Removes the specified entry from cache.
|
int |
TypeDataIndex.removeEntryIndexedField_impl(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
TypeDataIndex.removeEntryIndexedField_main(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
TypeDataIndex.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry)
remove entry indexed field from cache.
|
int |
CustomMultiValueTypeDataIndex.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
MultiValueTypeDataIndex.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
AbstractMultiValueIndexHandler.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
void |
IExtendedIndex.removeEntryIndexedField(IEntryHolder eh,
K fieldValue,
V Entry,
IObjectInfo oi) |
void |
ExtendedIndexHandler.removeEntryIndexedField(IEntryHolder eh,
Object fieldValue,
IEntryCacheInfo pEntry,
IObjectInfo oi)
remove entry indexed field from cache.
|
void |
FifoGroupsExtendedIndexHandler.removeEntryIndexedField(IEntryHolder eh,
Object fieldValue,
IEntryCacheInfo pEntry,
IObjectInfo oi) |
void |
TemplatesExtendedIndexHandler.removeEntryIndexedField(IEntryHolder eh,
Object fieldValue,
TemplateCacheInfo pTemplate,
IObjectInfo oi)
remove entry indexed field from cache.
|
void |
CacheManager.removeFifoXtnInfoForEntry(IEntryHolder eh)
remove fifo xtn info for entry MUST be called when entry is locked
|
void |
TerminatingFifoXtnsInfo.removeFifoXtnInfoForEntry(IEntryHolder eh)
remove fifo xtn info for entry MUST be called when entry is locked
|
boolean |
CacheManager.removeFromRecentDeletes(IEntryHolder entry) |
boolean |
CacheManager.removeFromRecentUpdatesIfNeeded(IEntryHolder entry) |
void |
CacheManager.removeWaitingForInfo(Context context,
IEntryHolder entryHolder,
ITemplateHolder templateHolder,
boolean unpinIfPossible) |
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.
|
void |
CacheManager.setFifoCreationXtnInfoForEntry(IEntryHolder eh,
long xtnNumber)
create fifo xtn info for entry MUST be called when entry is locked
|
void |
TerminatingFifoXtnsInfo.setFifoCreationXtnInfoForEntry(IEntryHolder eh,
long xtnNumber)
create fifo xtn info for entry MUST be called when entry is locked
|
void |
XtnData.setInPlaceUpdatedEntry(IEntryHolder eh,
Collection<SpaceEntryMutator> mutators) |
void |
XtnData.setUpdatedEntry(IEntryHolder eh,
boolean[] partialUpdateIndicators) |
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.
|
void |
TypeData.updateEntryReferences(CacheManager cacheManager,
IEntryHolder eh,
IEntryCacheInfo pEntry,
IEntryData oldEntryData)
update the entry refs in cache.
|
void |
CacheManager.updateFifoXtnInfoForEntry(IEntryHolder eh,
long xtnNumber,
boolean writeLock,
boolean entryWritingXtn)
update fifo xtn info for entry MUST be called when entry is locked update write lock if
writeLock is true, else update read lock entryWritingXtn = true if this is the commit of the
entry write
|
void |
TerminatingFifoXtnsInfo.updateFifoXtnInfoForEntry(IEntryHolder eh,
long xtnNumber,
boolean writeLock,
boolean entryWritingXtn)
update fifo xtn info for entry MUST be called when entry is locked update write lock if
writeLock is true, else update read lock, also update the xtn which committed the entry
|
int |
TypeDataIndex.updateIndexValue(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K original,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> originalBackRefs,
int refpos,
TypeDataIndex.UpdateIndexModes updateMode) |
int |
CustomMultiValueTypeDataIndex.updateIndexValue(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K original,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> originalBackRefs,
int refpos,
TypeDataIndex.UpdateIndexModes updateMode) |
int |
MultiValueTypeDataIndex.updateIndexValue(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K original,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> originalBackRefs,
int refpos,
TypeDataIndex.UpdateIndexModes updateMode) |
int |
TypeDataIndex.updateIndexValueUndexXtn(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K previous,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> previousBackRefs,
int refpos,
boolean entry_double_update) |
int |
CustomMultiValueTypeDataIndex.updateIndexValueUndexXtn(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K previous,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> previousBackRefs,
int refpos,
boolean entry_double_update) |
int |
MultiValueTypeDataIndex.updateIndexValueUndexXtn(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K previous,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> previousBackRefs,
int refpos,
boolean entry_double_update) |
int |
AbstractMultiValueIndexHandler.updateMultiValueIndex(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K original,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> originalBackRefs,
int refpos,
TypeDataIndex.UpdateIndexModes updateMode) |
int |
AbstractMultiValueIndexHandler.updateMultiValueIndexUndexXtn(TypeData pType,
IEntryHolder eh,
IEntryCacheInfo pEntry,
K previous,
K updated,
ArrayList<IObjectInfo<IEntryCacheInfo>> previousBackRefs,
int refpos) |
Modifier and Type | Method and Description |
---|---|
void |
XtnData.setEntriesForReplicationIn2PCommit(List<IEntryHolder> pLocked) |
Constructor and Description |
---|
EvictableEntryCacheInfo(IEntryHolder entryHolder) |
EvictableEntryCacheInfo(IEntryHolder entryHolder,
int backRefsSize) |
EvictableEntryCacheInfo(IEntryHolder entryHolder,
int backRefsSize,
boolean pinned) |
MemoryBasedEntryCacheInfo(IEntryHolder entryHolder)
Const used only for snapshots, called from CacheManager.prePrepare(Context,
ServerTransaction).
|
MemoryBasedEntryCacheInfo(IEntryHolder entryHolder,
int backRefsSize) |
Constructor and Description |
---|
ScanListSAIterator(ISAdapterIterator<IEntryHolder> list) |
Modifier and Type | Class and Description |
---|---|
class |
BlobStoreEntryHolder |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder() |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager) |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolder(CacheManager cacheManager,
Context context) |
IEntryHolder |
IBlobStoreRefCacheInfo.getEntryHolderIfInMemory() |
IEntryHolder |
BlobStoreRefEntryCacheInfo.getEntryHolderIfInMemory() |
IEntryHolder |
IBlobStoreEntryHolder.getLatestEntryVersion(CacheManager cacheManager,
boolean attatchToMemory,
Context attachingContext) |
IEntryHolder |
BlobStoreEntryHolder.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) |
Modifier and Type | Method and Description |
---|---|
boolean |
BlobStoreInternalCacheFilter.isEntryHotData(IEntryHolder eh,
Context context) |
boolean |
BlobStoreEntryHolder.isSameEntryInstance(IEntryHolder other) |
Constructor and Description |
---|
BlobStoreEntryHolder(IEntryHolder other) |
BlobStoreRefEntryCacheInfo(IEntryHolder eh) |
BlobStoreRefEntryCacheInfo(IEntryHolder eh,
int backRefsSize) |
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) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
BlobStoreStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
IEntryHolder |
BlobStoreInitialLoadDataIterator.next() |
IEntryHolder |
BlobStoreFifoInitialLoader.next() |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
BlobStoreStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
ISAdapterIterator<IEntryHolder> |
BlobStoreStorageAdapter.makeEntriesIter(ITemplateHolder template,
long SCNFilter,
long leaseFilter,
IServerTypeDesc[] subClasses) |
Modifier and Type | Method and Description |
---|---|
void |
BlobStoreFifoInitialLoader.add(IEntryHolder eh,
TypeData typeData) |
Map<String,IEntryHolder> |
BlobStoreStorageAdapter.getEntries(Context context,
Object[] ids,
String typeName,
IEntryHolder[] templates) |
IEntryHolder |
BlobStoreStorageAdapter.getEntry(Context context,
Object uid,
String classname,
IEntryHolder template) |
void |
BlobStoreStorageAdapter.insertEntry(Context context,
IEntryHolder entryHolder,
boolean origin,
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 |
BlobStoreStorageAdapter.prepare(Context context,
ServerTransaction xtn,
ArrayList<IEntryHolder> pLocked,
boolean singleParticipant,
Map<String,Object> partialUpdatesAndInPlaceUpdatesInfo,
boolean shouldReplicate) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
DelayedReplicationBasicInfo.getEntry() |
Constructor and Description |
---|
DelayedReplicationBasicInfo(IEntryHolder eh,
DelayedReplicationOpCodes opCode) |
DelayedReplicationInsertInfo(IEntryHolder eh) |
DelayedReplicationRemoveInfo(IEntryHolder entryHolder,
SpaceEngine.EntryRemoveReasonCodes removeReason) |
DelayedReplicationUpdateInfo(IEntryHolder new_eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
Context.getBlobStoreEntry() |
IEntryHolder |
Context.getBlobStoreOpEntryHolder() |
IEntryHolder |
Context.getLastRawmatchEntry() |
IEntryHolder |
Context.getNotifyNewEntry() |
Modifier and Type | Method and Description |
---|---|
Map<String,IEntryHolder> |
Context.getPrefetchedNonBlobStoreEntries() |
Modifier and Type | Method and Description |
---|---|
void |
Context.setBlobStoreOpParams(IEntryCacheInfo blobStoreEntryCacheInfo,
IEntryHolder blobStoreOpEntryHolder,
boolean blobStoreOpPin) |
void |
Context.setForBulkInsert(IEntryHolder eh) |
void |
Context.setForBulkRemove(IEntryHolder eh,
SpaceEngine.EntryRemoveReasonCodes removeReason) |
void |
Context.setForBulkUpdate(IEntryHolder eh,
IEntryData originalData,
Collection<SpaceEntryMutator> mutators) |
void |
Context.setLastRawmatchEntry(IEntryHolder entry) |
void |
Context.setNotifyNewEntry(IEntryHolder fifoNotifyNewEntry) |
void |
Context.setRawmatchResult(ITransactionalEntryData entryData,
MatchResult res,
IEntryHolder entry,
ITemplateHolder template) |
Modifier and Type | Method and Description |
---|---|
void |
Context.setPrefetchedNonBlobStoreEntries(Map<String,IEntryHolder> prefetchedEntries) |
Modifier and Type | Method and Description |
---|---|
IScanListIterator<IEntryCacheInfo> |
FifoGroupCacheImpl.getScannableEntriesByIndexValue(Context context,
ITemplateHolder template,
IEntryHolder entry,
IServerTypeDesc templateTypeDesc) |
int |
FifoGroupsMainIndexExtention.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
IFifoGroupsIndexExtention.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
int |
FifoGroupsCompoundIndexExtention.removeEntryIndexedField(IEntryHolder eh,
ArrayList<IObjectInfo<IEntryCacheInfo>> deletedBackRefs,
K fieldValue,
int refpos,
boolean removeIndexedValue,
IEntryCacheInfo pEntry) |
boolean |
FifoGroupCacheImpl.testAndSetFGCacheForEntry(Context context,
IEntryHolder entry,
ITemplateHolder template,
Object val,
boolean testOnly) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
FifoBackgroundRequest.getCloneEntry() |
IEntryHolder |
FifoBackgroundRequest.getEntry() |
IEntryHolder |
FifoBackgroundRequest.getOriginalEntry() |
Modifier and Type | Method and Description |
---|---|
protected void |
FifoWorkerThread.performGeneralEntryNonNotify(IEntryHolder eh,
FifoBackgroundRequest rd)
perform general non-notify
|
protected void |
FifoWorkerThread.performTemplateOnEntryNonNotify(IEntryHolder eh,
ITemplateHolder template,
FifoBackgroundRequest rd) |
Constructor and Description |
---|
FifoBackgroundRequest(OperationID operID,
boolean isNotifyRequest,
boolean isNonNotifyRequest,
IEntryHolder eh,
IEntryHolder originalEntry,
boolean fromReplication,
int spaceOperation,
ServerTransaction txn,
IEntryHolder cloneEH) |
FifoBackgroundRequest(OperationID operID,
boolean isNotifyRequest,
boolean isNonNotifyRequest,
IEntryHolder eh,
IEntryHolder originalEntry,
boolean fromReplication,
ITemplateHolder template) |
Constructor and Description |
---|
SpaceFilterEntryImpl(IEntryHolder entryHolder,
ITypeDesc typeDesc) |
Modifier and Type | Method and Description |
---|---|
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.
|
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
|
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.
|
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.
|
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.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 |
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
|
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
BusPacket.getEntryHolder() |
IEntryHolder |
EntryArrivedPacket.getEntryValueToNotify() |
IEntryHolder |
EntryUnmatchedPacket.getNewEntryHolder() |
IEntryHolder |
EntryUpdatedPacket.getNotifyEH() |
IEntryHolder |
EntryUpdatedPacket.getOriginalEntryHolder() |
Modifier and Type | Method and Description |
---|---|
void |
BusPacket.constructBusPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
long timeout)
Constructs a BusPacket.
|
void |
EntryArrivedPacket.constructEntryArrivedPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
boolean notifyListeners,
IEntryHolder entryValueToNotify,
boolean fromReplication)
Constructs an EntryArrivedPacket
|
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.handleEntryExpiredCoreSA(IEntryHolder entry,
ServerTransaction txn,
boolean fromReplication)
Handles EntryExpired packets.
|
Constructor and Description |
---|
BusPacket(OperationID operationID,
IEntryHolder entryHolder,
ServerTransaction xtn,
long timeout)
Creates a new BusPacket object.
|
EntryExpiredBusPacket(IEntryHolder entryHolder,
ServerTransaction xtn,
boolean fromReplication) |
EntryUnmatchedPacket(OperationID operationID,
IEntryHolder originalEntryHolder,
IEntryHolder newEntryHolder,
ServerTransaction xtn,
boolean fromReplication)
Constructs an EntryArrivedPacket
|
EntryUpdatedPacket(OperationID operationID,
IEntryHolder originalEntryHolder,
IEntryHolder newEntryHolder,
IEntryHolder notifyEH,
ServerTransaction xtn,
boolean fromReplication,
boolean notifyMatch,
boolean notifyRematch)
Constructs an EntryUpdatedPacket
|
RemoveWaitingForInfoSABusPacket(OperationID operationID,
IEntryHolder entryHolder,
ITemplateHolder template) |
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
EntryXtnInfo.getOtherUpdateUnderXtnEntry() |
Modifier and Type | Method and Description |
---|---|
void |
EntryXtnInfo.setOtherUpdateUnderXtnEntry(IEntryHolder eh) |
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 |
---|
CacheEntry(IEntryHolder entryHolder,
ITypeDesc typeDesc)
Constructs CacheEntry from IEntryHolder and TypeTableEntry.
|
Modifier and Type | Method and Description |
---|---|
IEntryHolder |
DataAdaptorIterator.next() |
Constructor and Description |
---|
BulkDataItem(IEntryHolder entryHolder,
ITypeDesc typeDesc,
short operation)
Constructs a
BulkDataItem out of IEntryHolder and TypeTableEntry. |
BulkDataItem(IEntryHolder entryHolder,
ITypeDesc typeDesc,
short operation,
IDataConverter<IEntryPacket> converter)
Constructs a
BulkDataItem out of IEntryHolder and TypeTableEntry.Given converter is used for internal entry conversion. |
EntryAdapter(IEntryHolder entryHolder,
ITypeDesc typeDesc) |
EntryAdapter(IEntryHolder entryHolder,
ITypeDesc typeDesc,
IDataConverter<IEntryPacket> converter) |
PartialUpdateBulkDataItem(IEntryHolder entryHolder,
boolean[] partialUpdateValuesIndicators,
ITypeDesc typeDesc,
IDataConverter<IEntryPacket> converter) |
Copyright © GigaSpaces.