Class Context

java.lang.Object
com.j_spaces.core.cache.context.Context

public class Context extends Object
  • Field Details

  • Constructor Details

    • Context

      public Context()
  • Method Details

    • setOwningThreadName

      public void setOwningThreadName(String name)
    • getOwningThreadName

      public String getOwningThreadName()
    • getOperationID

      public OperationID getOperationID()
    • setOperationID

      public void setOperationID(OperationID operationID)
    • isTemplateInitialSearch

      public boolean isTemplateInitialSearch()
    • setTemplateInitialSearchThread

      public void setTemplateInitialSearchThread()
    • resetTemplateInitialSearchThread

      public void resetTemplateInitialSearchThread()
    • setFifoThread

      public void setFifoThread()
    • isFifoThread

      public boolean isFifoThread()
    • getRecentFifoObject

      public FifoBackgroundRequest getRecentFifoObject()
    • setRecentFifoObject

      public void setRecentFifoObject(FifoBackgroundRequest fb)
    • 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

      public ITransactionalEntryData getLastRawMatchSnapshot()
    • setLastRawMatchSnapshot

      public void setLastRawMatchSnapshot(ITransactionalEntryData entryData)
    • setLastMatchResult

      public void setLastMatchResult(MatchResult res)
    • getLastMatchResult

      public MatchResult getLastMatchResult()
    • getLastRawmatchEntry

      public IEntryHolder getLastRawmatchEntry()
    • setLastRawmatchEntry

      public void setLastRawmatchEntry(IEntryHolder entry)
    • getLastRawmatchTemplate

      public ITemplateHolder getLastRawmatchTemplate()
    • setLastRawmatchTemplate

      public void setLastRawmatchTemplate(ITemplateHolder template)
    • setRawmatchResult

      public void setRawmatchResult(ITransactionalEntryData entryData, MatchResult res, IEntryHolder entry, ITemplateHolder template)
    • getExplainPlanContext

      public ExplainPlanContext getExplainPlanContext()
    • setExplainPlanContext

      public void setExplainPlanContext(ExplainPlanContext _explainPlanContext)
    • isPossibleIEBlockingMatch

      public boolean isPossibleIEBlockingMatch()
    • setPossibleIEBlockingMatch

      public void setPossibleIEBlockingMatch(boolean val)
    • clean

      public void clean()
      clean all context.
    • setOnMatchUid

      public void setOnMatchUid(String uid)
    • getOnMatchUid

      public String 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

      public void setOperationIDs(OperationID[] opIDs)
    • getOperationIDs

      public OperationID[] 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

      public WriteEntryResult getWriteResult()
    • setWriteResult

      public void setWriteResult(WriteEntryResult result)
    • getNotifyLease

      public Lease getNotifyLease()
    • setNotifyLease

      public void setNotifyLease(Lease lease)
    • setReRegisterLeaseOnUpdate

      public void setReRegisterLeaseOnUpdate(boolean value)
    • isReRegisterLeaseOnUpdate

      public boolean isReRegisterLeaseOnUpdate()
    • setReplicationContext

      public void setReplicationContext(IReplicationOutContext replicationContext)
    • getReplicationContext

      public IReplicationOutContext 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

      public void setNotifyNewEntry(IEntryHolder fifoNotifyNewEntry)
    • getNotifyNewEntry

      public IEntryHolder getNotifyNewEntry()
    • setDisableSyncReplication

      public void setDisableSyncReplication(boolean disableSyncReplication)
    • isDisableSyncReplication

      public boolean isDisableSyncReplication()
    • get_take_template

      public ITemplateHolder get_take_template()
    • set_take_template

      public void set_take_template(ITemplateHolder _take_template)
    • get_take_typeDesc

      public IServerTypeDesc get_take_typeDesc()
    • set_take_typeDesc

      public void set_take_typeDesc(IServerTypeDesc _take_typeDesc)
    • setReadByIdsInfo

      public void setReadByIdsInfo(ReadByIdsInfo readByIdsInfo)
    • getReadByIdsInfo

      public ReadByIdsInfo getReadByIdsInfo()
    • getPrefetchedNonBlobStoreEntries

      public Map<String,IEntryHolder> getPrefetchedNonBlobStoreEntries()
    • setPrefetchedNonBlobStoreEntries

      public void setPrefetchedNonBlobStoreEntries(Map<String,IEntryHolder> prefetchedEntries)
    • setPendingExpiredEntriesExist

      public void setPendingExpiredEntriesExist(boolean val)
    • isPendingExpiredEntriesExist

      public boolean isPendingExpiredEntriesExist()
    • getCommittingXtn

      public ServerTransaction getCommittingXtn()
    • setCommittingXtn

      public void setCommittingXtn(ServerTransaction xtn)
    • isAnyFifoGroupIndex

      public boolean isAnyFifoGroupIndex()
    • setAnyFifoGroupIndex

      public void setAnyFifoGroupIndex()
    • getIndexUsedInFifoGroupScan

      public TypeDataIndex getIndexUsedInFifoGroupScan(Object res)
    • setFifoGroupIndexUsedInFifoGroupScan

      public void setFifoGroupIndexUsedInFifoGroupScan(Object res, TypeDataIndex usedIndex)
    • resetFifoGroupIndexUsedInFifoGroupScan

      public void resetFifoGroupIndexUsedInFifoGroupScan()
    • getFfoGroupIndexResultsUsedInFifoGroupScan

      public HashMap<Object,TypeDataIndex> getFfoGroupIndexResultsUsedInFifoGroupScan()
    • isFifoGroupScanEncounteredXtnConflict

      public boolean isFifoGroupScanEncounteredXtnConflict()
    • setFifoGroupScanEncounteredXtnConflict

      public void setFifoGroupScanEncounteredXtnConflict(boolean val)
    • isFifoGroupValueForMiltipleOperations

      public boolean isFifoGroupValueForMiltipleOperations(Object val)
    • setToFifoGroupValueForMiltipleOperations

      public void setToFifoGroupValueForMiltipleOperations(Object val)
    • 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

      public List<Object> getChangeResultsForCurrentEntry()
    • setChangeResultsForCurrentEntry

      public void setChangeResultsForCurrentEntry(List<Object> results)
    • 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

      public MultiIntersectedStoredList<IEntryCacheInfo> getChosenIntersectedList(boolean finalChoice)
    • setChosenIntersectedList

      public void setChosenIntersectedList(MultiIntersectedStoredList<IEntryCacheInfo> chosenIntersectedList)
    • isUsingIntersectedListForScanning

      public boolean isUsingIntersectedListForScanning()
    • getBlobStoreOpEntryCacheInfo

      public IEntryCacheInfo getBlobStoreOpEntryCacheInfo()
    • getBlobStoreOpEntryHolder

      public IEntryHolder 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

      public void setInitialLoadInfo(InitialLoadInfo ili)
    • getInitialLoadInfo

      public InitialLoadInfo getInitialLoadInfo()
    • getBlobStoreBulkInfo

      public BlobStoreBulkInfo getBlobStoreBulkInfo()
    • isActiveBlobStoreBulk

      public boolean isActiveBlobStoreBulk()
    • setBlobStoreBulkInfo

      public void setBlobStoreBulkInfo(BlobStoreBulkInfo bi)
    • setBlobStoreUsePureIndexesAccess

      public void setBlobStoreUsePureIndexesAccess(boolean val)
    • isBlobStoreUsePureIndexesAccess

      public boolean isBlobStoreUsePureIndexesAccess()
    • isBlobStoreTryNonPersistentOp

      public boolean isBlobStoreTryNonPersistentOp()
    • setBlobStoreTryNonPersistentOp

      public void setBlobStoreTryNonPersistentOp(boolean val)
    • getBlobStorePreFetchBatchResult

      public BlobStorePreFetchBatchResult getBlobStorePreFetchBatchResult()
    • setBlobStorePreFetchBatchResult

      public void setBlobStorePreFetchBatchResult(BlobStorePreFetchBatchResult r)
    • isDisableBlobStorePreFetching

      public boolean isDisableBlobStorePreFetching()
    • setDisableBlobStorePreFetching

      public void setDisableBlobStorePreFetching(boolean val)
    • isDelayedReplicationForbulkOpUsed

      public boolean isDelayedReplicationForbulkOpUsed()
    • setDelayedReplicationForbulkOpUsed

      public void setDelayedReplicationForbulkOpUsed(boolean delayedReplicationForbulkOpUsed)
    • getBlobStoreEntry

      public IEntryHolder getBlobStoreEntry()
    • getOriginalData

      public IEntryData getOriginalData()
    • getMutators

      public Collection<SpaceEntryMutator> getMutators()
    • setMutators

      public void setMutators(Collection<SpaceEntryMutator> _mutators)
    • getRemoveReason

      public SpaceEngine.EntryRemoveReasonCodes getRemoveReason()
    • setForBulkInsert

      public void setForBulkInsert(IEntryHolder eh)
    • setForBulkUpdate

      public void setForBulkUpdate(IEntryHolder eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators)
    • setForBulkRemove

      public void setForBulkRemove(IEntryHolder eh, SpaceEngine.EntryRemoveReasonCodes removeReason)
    • setBlobStoreOriginalEntryInfo

      public void setBlobStoreOriginalEntryInfo(IEntryData originalData, short originalBlobStoreVersion)
    • getOriginalBlobStoreVersion

      public short getOriginalBlobStoreVersion()
    • isFromClustered

      public boolean isFromClustered()
    • setFromClustered

      public void setFromClustered(boolean fromClustered)
    • setOperationAnswer

      public void setOperationAnswer(ITemplateHolder template, IEntryPacket entryPacket, Exception ex)
      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

      public void setSyncHybridOperationDetails(SyncHybridOperationDetails[] syncHybridOperationsDetails)
    • getSyncHybridOperationDetails

      public SyncHybridOperationDetails[] getSyncHybridOperationDetails()
    • getOptimizedBlobStoreReadEnabled

      public Boolean 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

      public IndexMetricsContext getIndexMetricsContext()
    • setIndexMetricsContext

      public void setIndexMetricsContext(IndexMetricsContext indexMetricsContext)
    • setBackupOnly

      public void setBackupOnly()
    • isBackupOnly

      public boolean isBackupOnly()
    • getViewEntryData

      public IEntryData getViewEntryData(IEntryData entryData)
    • getViewEntryData

      public ViewPropertiesEntryData getViewEntryData()
    • getCacheViewEntryDataIfNeeded

      public IEntryData getCacheViewEntryDataIfNeeded(IEntryData entryData)
    • cacheViewEntryDataIfNeeded

      public void cacheViewEntryDataIfNeeded(IEntryData entryData, IEntryPacket packet)
    • applyOperationContext

      public void applyOperationContext(SpaceContext sc)
    • getEntryTieredState

      public TieredState getEntryTieredState()
    • setEntryTieredState

      public void setEntryTieredState(TieredState entryTieredState)
    • getTemplateTieredState

      public TemplateMatchTier getTemplateTieredState()
    • setTemplateTieredState

      public void setTemplateTieredState(TemplateMatchTier templateTieredState)
    • isMemoryOnlyEntry

      public boolean isMemoryOnlyEntry()
    • isDiskOnlyEntry

      public boolean isDiskOnlyEntry()
    • isMemoryAndDiskEntry

      public boolean isMemoryAndDiskEntry()
    • isTemplateMaybeUnderTransaction

      public boolean isTemplateMaybeUnderTransaction()
    • setTemplateMaybeUnderTransaction

      public void setTemplateMaybeUnderTransaction(boolean templateMaybeUnderTransaction)
    • getMVCCGenerationsState

      public MVCCGenerationsState getMVCCGenerationsState()
    • applyMVCCGenerationsState

      public void applyMVCCGenerationsState(boolean mvccEnabled, XtnEntry xtnEntry, SpaceContext sc)
    • isMatchOnDirtyEntry

      public boolean isMatchOnDirtyEntry()
    • setMatchOnDirtyEntry

      public void setMatchOnDirtyEntry(boolean matchOnDirtyEntry)