Package com.j_spaces.core.cache.context
Class Context
java.lang.Object
com.j_spaces.core.cache.context.Context
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidapplyMVCCGenerationsState(boolean mvccEnabled, XtnEntry xtnEntry, SpaceContext sc) voidvoidcacheViewEntryDataIfNeeded(IEntryData entryData, IEntryPacket packet) voidclean()clean all context.voidbooleangetCacheViewEntryDataIfNeeded(IEntryData entryData) getChosenIntersectedList(boolean finalChoice) intintintlongintshortboolean[]getViewEntryData(IEntryData entryData) voidvoidbooleanisActive()A thread safe check.booleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanNot a thread safe check, an optimized call for the local thread only.booleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanisOrigin()booleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanbooleanvoidvoidvoidvoidset_take_template(ITemplateHolder _take_template) voidset_take_typeDesc(IServerTypeDesc _take_typeDesc) voidsetActive(boolean _active) voidvoidvoidvoidsetBlobStoreOpParams(IEntryCacheInfo blobStoreEntryCacheInfo, IEntryHolder blobStoreOpEntryHolder, boolean blobStoreOpPin) voidsetBlobStoreOriginalEntryInfo(IEntryData originalData, short originalBlobStoreVersion) voidvoidsetBlobStoreTryNonPersistentOp(boolean val) voidsetBlobStoreUsePureIndexesAccess(boolean val) voidsetChangeResultsForCurrentEntry(List<Object> results) voidsetChosenIntersectedList(MultiIntersectedStoredList<IEntryCacheInfo> chosenIntersectedList) voidvoidsetDelayedReplicationForbulkOpUsed(boolean delayedReplicationForbulkOpUsed) voidsetDisableBlobStorePreFetching(boolean val) voidsetDisableSyncReplication(boolean disableSyncReplication) voidsetEntryTieredState(TieredState entryTieredState) voidsetExhaustedFifoGroupsTemplatesSearch(boolean val) voidsetExplainPlanContext(ExplainPlanContext _explainPlanContext) voidsetFifoGroupIndexUsedInFifoGroupScan(Object res, TypeDataIndex usedIndex) voidsetFifoGroupQueryContainsOrCondition(boolean val) voidsetFifoGroupScanEncounteredXtnConflict(boolean val) voidvoidsetFifoThreadNumber(int fifoThreadNumber) voidvoidsetForBulkRemove(IEntryHolder eh, SpaceEngine.EntryRemoveReasonCodes removeReason) voidsetForBulkUpdate(IEntryHolder eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators) voidsetFromClustered(boolean fromClustered) voidsetFromGateway(boolean fromGateway) voidsetFromReplication(boolean fromReplication) voidsetIndexMetricsContext(IndexMetricsContext indexMetricsContext) voidsetIndexUsed(boolean val) voidsetInInitialLoad(boolean val) voidvoidsetInMemoryRecovery(boolean inMemoryRecovery) voidsetIntersectionEnablment(boolean val) voidvoidsetLastRawmatchEntry(IEntryHolder entry) voidsetLastRawMatchSnapshot(ITransactionalEntryData entryData) voidsetLastRawmatchTemplate(ITemplateHolder template) voidsetMainThread(boolean mainThread) voidsetMatchOnDirtyEntry(boolean matchOnDirtyEntry) voidvoidsetMutators(Collection<SpaceEntryMutator> _mutators) voidsetNonBlockingReadOp(boolean value) voidsetNotifyLease(Lease lease) voidsetNotifyNewEntry(IEntryHolder fifoNotifyNewEntry) voidsetOnMatchUid(String uid) voidsetOperationAnswer(ITemplateHolder template, IEntryPacket entryPacket, Exception ex) fills the template with the answer to be sent to the client.voidsetOperationID(OperationID operationID) voidsetOperationIDs(OperationID[] opIDs) voidsetOperationVisibilityTime(long operationVisibilityTime) voidsetOpResultByThread(boolean opResultByThread) voidsetOptimizedBlobStoreReadEnabled(boolean optimizedBlobStoreReadEnabled) voidsetOrdinalForMultipleIdsOperation(int ordinal) voidsetOrigin(boolean origin) voidsetOwningThreadName(String name) voidsetPartialUpdatedValuesIndicators(boolean[] partialUpdatedValuesIndicators) voidsetPendingExpiredEntriesExist(boolean val) voidsetPossibleIEBlockingMatch(boolean val) voidsetPrefetchedNonBlobStoreEntries(Map<String, IEntryHolder> prefetchedEntries) voidsetRawmatchResult(ITransactionalEntryData entryData, MatchResult res, IEntryHolder entry, ITemplateHolder template) voidsetReadByIdsInfo(ReadByIdsInfo readByIdsInfo) voidvoidsetReplicationContext(IReplicationOutContext replicationContext) voidsetReRegisterLeaseOnUpdate(boolean value) voidsetSyncHybridOperationDetails(SyncHybridOperationDetails[] syncHybridOperationsDetails) voidsetSyncReplFromMultipleOperation(boolean syncReplFromMultipleOperation) voidvoidsetTemplateMaybeUnderTransaction(boolean templateMaybeUnderTransaction) voidsetTemplateTieredState(TemplateMatchTier templateTieredState) voidvoidsetTransactionalMultipleOperation(boolean isMultipleOperation) voidsetUnstableEntry(boolean value) voidsetUpdateLastSentKey(boolean _updateLastSentKey) voidsetWriteResult(WriteEntryResult result)
-
Field Details
-
_operationTimeoutExecption
-
-
Constructor Details
-
Context
public Context()
-
-
Method Details
-
setOwningThreadName
-
getOwningThreadName
-
getOperationID
-
setOperationID
-
isTemplateInitialSearch
public boolean isTemplateInitialSearch() -
setTemplateInitialSearchThread
public void setTemplateInitialSearchThread() -
resetTemplateInitialSearchThread
public void resetTemplateInitialSearchThread() -
setFifoThread
public void setFifoThread() -
isFifoThread
public boolean isFifoThread() -
getRecentFifoObject
-
setRecentFifoObject
-
resetRecentFifoObject
public void resetRecentFifoObject() -
getFifoThreadNumber
public int getFifoThreadNumber() -
setFifoThreadNumber
public void setFifoThreadNumber(int fifoThreadNumber) -
isFromReplication
public boolean isFromReplication() -
setFromReplication
public void setFromReplication(boolean fromReplication) -
setMainThread
public void setMainThread(boolean mainThread) -
isMainThread
public boolean isMainThread() -
setOpResultByThread
public void setOpResultByThread(boolean opResultByThread) -
isOpResultByThread
public boolean isOpResultByThread() -
getLastRawMatchSnapshot
-
setLastRawMatchSnapshot
-
setLastMatchResult
-
getLastMatchResult
-
getLastRawmatchEntry
-
setLastRawmatchEntry
-
getLastRawmatchTemplate
-
setLastRawmatchTemplate
-
setRawmatchResult
public void setRawmatchResult(ITransactionalEntryData entryData, MatchResult res, IEntryHolder entry, ITemplateHolder template) -
getExplainPlanContext
-
setExplainPlanContext
-
isPossibleIEBlockingMatch
public boolean isPossibleIEBlockingMatch() -
setPossibleIEBlockingMatch
public void setPossibleIEBlockingMatch(boolean val) -
clean
public void clean()clean all context. -
setOnMatchUid
-
getOnMatchUid
-
setSyncReplFromMultipleOperation
public void setSyncReplFromMultipleOperation(boolean syncReplFromMultipleOperation) - Parameters:
syncReplFromMultipleOperation- the m_SyncReplFromMultipleOperation to set
-
isSyncReplFromMultipleOperation
public boolean isSyncReplFromMultipleOperation() -
isTransactionalMultipleOperation
public boolean isTransactionalMultipleOperation()- Returns:
- the isMultipleOperation
-
setTransactionalMultipleOperation
public void setTransactionalMultipleOperation(boolean isMultipleOperation) - Parameters:
isMultipleOperation- the isMultipleOperation to set
-
setOperationIDs
-
getOperationIDs
-
getOperationVisibilityTime
public long getOperationVisibilityTime() -
setOperationVisibilityTime
public void setOperationVisibilityTime(long operationVisibilityTime) -
isMultipleOperation
public boolean isMultipleOperation() -
setMultipleOperation
public void setMultipleOperation() -
isNonBlockingReadOp
public boolean isNonBlockingReadOp() -
setNonBlockingReadOp
public void setNonBlockingReadOp(boolean value) -
isUnstableEntry
public boolean isUnstableEntry() -
setUnstableEntry
public void setUnstableEntry(boolean value) -
setActive
public void setActive(boolean _active) -
isActive
public boolean isActive()A thread safe check. -
isLocalActive
public boolean isLocalActive()Not a thread safe check, an optimized call for the local thread only. -
getPartialUpdatedValuesIndicators
public boolean[] getPartialUpdatedValuesIndicators() -
setPartialUpdatedValuesIndicators
public void setPartialUpdatedValuesIndicators(boolean[] partialUpdatedValuesIndicators) -
getWriteResult
-
setWriteResult
-
getNotifyLease
-
setNotifyLease
-
setReRegisterLeaseOnUpdate
public void setReRegisterLeaseOnUpdate(boolean value) -
isReRegisterLeaseOnUpdate
public boolean isReRegisterLeaseOnUpdate() -
setReplicationContext
-
getReplicationContext
-
setOrigin
public void setOrigin(boolean origin) -
isOrigin
public boolean isOrigin() -
isFromGateway
public boolean isFromGateway() -
setFromGateway
public void setFromGateway(boolean fromGateway) -
setUpdateLastSentKey
public void setUpdateLastSentKey(boolean _updateLastSentKey) -
isUpdateLastSentKey
public boolean isUpdateLastSentKey() -
setNotifyNewEntry
-
getNotifyNewEntry
-
setDisableSyncReplication
public void setDisableSyncReplication(boolean disableSyncReplication) -
isDisableSyncReplication
public boolean isDisableSyncReplication() -
get_take_template
-
set_take_template
-
get_take_typeDesc
-
set_take_typeDesc
-
setReadByIdsInfo
-
getReadByIdsInfo
-
getPrefetchedNonBlobStoreEntries
-
setPrefetchedNonBlobStoreEntries
-
setPendingExpiredEntriesExist
public void setPendingExpiredEntriesExist(boolean val) -
isPendingExpiredEntriesExist
public boolean isPendingExpiredEntriesExist() -
getCommittingXtn
-
setCommittingXtn
-
isAnyFifoGroupIndex
public boolean isAnyFifoGroupIndex() -
setAnyFifoGroupIndex
public void setAnyFifoGroupIndex() -
getIndexUsedInFifoGroupScan
-
setFifoGroupIndexUsedInFifoGroupScan
-
resetFifoGroupIndexUsedInFifoGroupScan
public void resetFifoGroupIndexUsedInFifoGroupScan() -
getFfoGroupIndexResultsUsedInFifoGroupScan
-
isFifoGroupScanEncounteredXtnConflict
public boolean isFifoGroupScanEncounteredXtnConflict() -
setFifoGroupScanEncounteredXtnConflict
public void setFifoGroupScanEncounteredXtnConflict(boolean val) -
isFifoGroupValueForMiltipleOperations
-
setToFifoGroupValueForMiltipleOperations
-
isExhaustedFifoGroupsTemplatesSearch
public boolean isExhaustedFifoGroupsTemplatesSearch() -
setExhaustedFifoGroupsTemplatesSearch
public void setExhaustedFifoGroupsTemplatesSearch(boolean val) -
isFifoGroupQueryContainsOrCondition
public boolean isFifoGroupQueryContainsOrCondition() -
setFifoGroupQueryContainsOrCondition
public void setFifoGroupQueryContainsOrCondition(boolean val) -
setOrdinalForMultipleIdsOperation
public void setOrdinalForMultipleIdsOperation(int ordinal) -
getOrdinalForMultipleIdsOperation
public int getOrdinalForMultipleIdsOperation() -
getChangeResultsForCurrentEntry
-
setChangeResultsForCurrentEntry
-
getNumOfIndexesInserted
public int getNumOfIndexesInserted() -
clearNumOfIndexesInserted
public void clearNumOfIndexesInserted() -
incrementNumOfIndexesInserted
public void incrementNumOfIndexesInserted() -
incrementNumOfEntriesMatched
public void incrementNumOfEntriesMatched() -
getNumberOfEntriesMatched
public int getNumberOfEntriesMatched() -
setIntersectionEnablment
public void setIntersectionEnablment(boolean val) -
isIndicesIntersectionEnabled
public boolean isIndicesIntersectionEnabled() -
getChosenIntersectedList
-
setChosenIntersectedList
public void setChosenIntersectedList(MultiIntersectedStoredList<IEntryCacheInfo> chosenIntersectedList) -
isUsingIntersectedListForScanning
public boolean isUsingIntersectedListForScanning() -
getBlobStoreOpEntryCacheInfo
-
getBlobStoreOpEntryHolder
-
getBlobStoreOpPin
public boolean getBlobStoreOpPin() -
setBlobStoreOpParams
public void setBlobStoreOpParams(IEntryCacheInfo blobStoreEntryCacheInfo, IEntryHolder blobStoreOpEntryHolder, boolean blobStoreOpPin) -
isIndexUsed
public boolean isIndexUsed() -
setIndexUsed
public void setIndexUsed(boolean val) -
setInitialLoadInfo
-
getInitialLoadInfo
-
getBlobStoreBulkInfo
-
isActiveBlobStoreBulk
public boolean isActiveBlobStoreBulk() -
setBlobStoreBulkInfo
-
setBlobStoreUsePureIndexesAccess
public void setBlobStoreUsePureIndexesAccess(boolean val) -
isBlobStoreUsePureIndexesAccess
public boolean isBlobStoreUsePureIndexesAccess() -
isBlobStoreTryNonPersistentOp
public boolean isBlobStoreTryNonPersistentOp() -
setBlobStoreTryNonPersistentOp
public void setBlobStoreTryNonPersistentOp(boolean val) -
getBlobStorePreFetchBatchResult
-
setBlobStorePreFetchBatchResult
-
isDisableBlobStorePreFetching
public boolean isDisableBlobStorePreFetching() -
setDisableBlobStorePreFetching
public void setDisableBlobStorePreFetching(boolean val) -
isDelayedReplicationForbulkOpUsed
public boolean isDelayedReplicationForbulkOpUsed() -
setDelayedReplicationForbulkOpUsed
public void setDelayedReplicationForbulkOpUsed(boolean delayedReplicationForbulkOpUsed) -
getBlobStoreEntry
-
getOriginalData
-
getMutators
-
setMutators
-
getRemoveReason
-
setForBulkInsert
-
setForBulkUpdate
public void setForBulkUpdate(IEntryHolder eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators) -
setForBulkRemove
-
setBlobStoreOriginalEntryInfo
-
getOriginalBlobStoreVersion
public short getOriginalBlobStoreVersion() -
isFromClustered
public boolean isFromClustered() -
setFromClustered
public void setFromClustered(boolean fromClustered) -
setOperationAnswer
fills the template with the answer to be sent to the client. if template is in callbackmode and main thread has returned then performs a callback to the client. this method MUST be called under template lock. after this method is called the template should be removed from the cache. -
setSyncHybridOperationDetails
-
getSyncHybridOperationDetails
-
getOptimizedBlobStoreReadEnabled
-
setOptimizedBlobStoreReadEnabled
public void setOptimizedBlobStoreReadEnabled(boolean optimizedBlobStoreReadEnabled) -
isInInitialLoad
public boolean isInInitialLoad() -
setInInitialLoad
public void setInInitialLoad(boolean val) -
isInMemoryRecovery
public boolean isInMemoryRecovery() -
setInMemoryRecovery
public void setInMemoryRecovery(boolean inMemoryRecovery) -
getIndexMetricsContext
-
setIndexMetricsContext
-
setBackupOnly
public void setBackupOnly() -
isBackupOnly
public boolean isBackupOnly() -
getViewEntryData
-
getViewEntryData
-
getCacheViewEntryDataIfNeeded
-
cacheViewEntryDataIfNeeded
-
applyOperationContext
-
getEntryTieredState
-
setEntryTieredState
-
getTemplateTieredState
-
setTemplateTieredState
-
isMemoryOnlyEntry
public boolean isMemoryOnlyEntry() -
isDiskOnlyEntry
public boolean isDiskOnlyEntry() -
isMemoryAndDiskEntry
public boolean isMemoryAndDiskEntry() -
isTemplateMaybeUnderTransaction
public boolean isTemplateMaybeUnderTransaction() -
setTemplateMaybeUnderTransaction
public void setTemplateMaybeUnderTransaction(boolean templateMaybeUnderTransaction) -
getMVCCGenerationsState
-
applyMVCCGenerationsState
-
isMatchOnDirtyEntry
public boolean isMatchOnDirtyEntry() -
setMatchOnDirtyEntry
public void setMatchOnDirtyEntry(boolean matchOnDirtyEntry)
-