com.j_spaces.core.cache.context

Class Context

java.lang.Object

com.j_spaces.core.cache.context.Context

public class Context
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static OperationTimeoutException	_operationTimeoutExecption

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and Description
void	clean() clean all context.
void	clearNumOfIndexesInserted()
ITemplateHolder	get_take_template()
IServerTypeDesc	get_take_typeDesc()
BlobStoreBulkInfo	getBlobStoreBulkInfo()
IEntryHolder	getBlobStoreEntry()
BlobStorePreFetchBatchResult	getBlobStorePreFetchBatchResult()
List<Object>	getChangeResultsForCurrentEntry()
MultiIntersectedStoredList<IEntryCacheInfo>	getChosenIntersectedList(boolean finalChoice)
ServerTransaction	getCommittingXtn()
HashMap<Object,TypeDataIndex>	getFfoGroupIndexResultsUsedInFifoGroupScan()
int	getFifoThreadNumber()
TypeDataIndex	getIndexUsedInFifoGroupScan(Object res)
InitialLoadInfo	getInitialLoadInfo()
MatchResult	getLastMatchResult()
IEntryHolder	getLastRawmatchEntry()
ITransactionalEntryData	getLastRawMatchSnapshot()
ITemplateHolder	getLastRawmatchTemplate()
Collection<SpaceEntryMutator>	getMutators()
Lease	getNotifyLease()
IEntryHolder	getNotifyNewEntry()
int	getNumberOfEntriesMatched()
int	getNumOfIndexesInserted()
IEntryCacheInfo	getOffHeapOpEntryCacheInfo()
IEntryHolder	getOffHeapOpEntryHolder()
boolean	getOffHeapOpPin()
OperationID	getOperationID()
OperationID[]	getOperationIDs()
long	getOperationVisibilityTime()
int	getOrdinalForMultipleIdsOperation()
IEntryData	getOriginalData()
short	getOriginalOffHeapVersion()
String	getOwningThreadName()
boolean[]	getPartialUpdatedValuesIndicators()
Map<String,IEntryHolder>	getPrefetchedNonBlobStoreEntries()
ReadByIdsInfo	getReadByIdsInfo()
FifoBackgroundRequest	getRecentFifoObject()
SpaceEngine.EntryRemoveReasonCodes	getRemoveReason()
IReplicationOutContext	getReplicationContext()
WriteEntryResult	getWriteResult()
void	incrementNumOfEntriesMatched()
void	incrementNumOfIndexesInserted()
boolean	isActive() A thread safe check.
boolean	isActiveBlobStoreBulk()
boolean	isAnyFifoGroupIndex()
boolean	isBlobStoreTryNonPersistentOp()
boolean	isBlobStoreUsePureIndexesAccess()
boolean	isDelayedReplicationForbulkOpUsed()
boolean	isDisableBlobStorePreFetching()
boolean	isDisableSyncReplication()
boolean	isExhaustedFifoGroupsTemplatesSearch()
boolean	isFifoGroupQueryContainsOrCondition()
boolean	isFifoGroupScanEncounteredXtnConflict()
boolean	isFifoGroupValueForMiltipleOperations(Object val)
boolean	isFifoThread()
boolean	isFromGateway()
boolean	isFromReplication()
boolean	isIndexUsed()
boolean	isIndicesIntersectionEnabled()
boolean	isLocalActive() Not a thread safe check, an optimized call for the local thread only.
boolean	isMainThread()
boolean	isMultipleOperation()
boolean	isNonBlockingReadOp()
boolean	isOpResultByThread()
boolean	isOrigin()
boolean	isPendingExpiredEntriesExist()
boolean	isPossibleIEBlockingMatch()
boolean	isReRegisterLeaseOnUpdate()
boolean	isSyncReplFromMultipleOperation()
boolean	isTemplateInitialSearch()
boolean	isTransactionalMultipleOperation()
boolean	isUnstableEntry()
boolean	isUpdateLastSentKey()
boolean	isUsingIntersectedListForScanning()
void	resetFifoGroupIndexUsedInFifoGroupScan()
void	resetRecentFifoObject()
void	resetTemplateInitialSearchThread()
void	set_take_template(ITemplateHolder _take_template)
void	set_take_typeDesc(IServerTypeDesc _take_typeDesc)
void	setActive(boolean _active)
void	setAnyFifoGroupIndex()
void	setBlobStoreBulkInfo(BlobStoreBulkInfo bi)
void	setBlobStorePreFetchBatchResult(BlobStorePreFetchBatchResult r)
void	setBlobStoreTryNonPersistentOp(boolean val)
void	setBlobStoreUsePureIndexesAccess(boolean val)
void	setChangeResultsForCurrentEntry(List<Object> results)
void	setChosenIntersectedList(MultiIntersectedStoredList<IEntryCacheInfo> chosenIntersectedList)
void	setCommittingXtn(ServerTransaction xtn)
void	setDelayedReplicationForbulkOpUsed(boolean delayedReplicationForbulkOpUsed)
void	setDisableBlobStorePreFetching(boolean val)
void	setDisableSyncReplication(boolean disableSyncReplication)
void	setExhaustedFifoGroupsTemplatesSearch(boolean val)
void	setFifoGroupIndexUsedInFifoGroupScan(Object res, TypeDataIndex usedIndex)
void	setFifoGroupQueryContainsOrCondition(boolean val)
void	setFifoGroupScanEncounteredXtnConflict(boolean val)
void	setFifoThread()
void	setFifoThreadNumber(int fifoThreadNumber)
void	setForBulkInsert(IEntryHolder eh)
void	setForBulkRemove(IEntryHolder eh, SpaceEngine.EntryRemoveReasonCodes removeReason)
void	setForBulkUpdate(IEntryHolder eh, IEntryData originalData, Collection<SpaceEntryMutator> mutators)
void	setFromGateway(boolean fromGateway)
void	setFromReplication(boolean fromReplication)
void	setIndexUsed(boolean val)
void	setInitialLoadInfo(InitialLoadInfo ili)
void	setIntersectionEnablment(boolean val)
void	setLastMatchResult(MatchResult res)
void	setLastRawmatchEntry(IEntryHolder entry)
void	setLastRawMatchSnapshot(ITransactionalEntryData entryData)
void	setLastRawmatchTemplate(ITemplateHolder template)
void	setMainThread(boolean mainThread)
void	setMultipleOperation()
void	setNonBlockingReadOp(boolean value)
void	setNotifyLease(Lease lease)
void	setNotifyNewEntry(IEntryHolder fifoNotifyNewEntry)
void	setOffHeapOpParams(IEntryCacheInfo offHeapEntryCacheInfo, IEntryHolder offHeapOpEntryHolder, boolean offHeapOpPin)
void	setOffHeapOriginalEntryInfo(IEntryData originalData, short originalOffHeapVersion)
void	setOperationAnswer(ITemplateHolder template, IEntryPacket entryPacket, Exception ex) fills the template with the answer to be sent to the client.
void	setOperationID(OperationID operationID)
void	setOperationIDs(OperationID[] opIDs)
void	setOperationVisibilityTime(long operationVisibilityTime)
void	setOpResultByThread(boolean opResultByThread)
void	setOrdinalForMultipleIdsOperation(int ordinal)
void	setOrigin(boolean origin)
void	setOwningThreadName(String name)
void	setPartialUpdatedValuesIndicators(boolean[] partialUpdatedValuesIndicators)
void	setPendingExpiredEntriesExist(boolean val)
void	setPossibleIEBlockingMatch(boolean val)
void	setPrefetchedNonBlobStoreEntries(Map<String,IEntryHolder> prefetchedEntries)
void	setRawmatchResult(ITransactionalEntryData entryData, MatchResult res, IEntryHolder entry, ITemplateHolder template)
void	setReadByIdsInfo(ReadByIdsInfo readByIdsInfo)
void	setRecentFifoObject(FifoBackgroundRequest fb)
void	setReplicationContext(IReplicationOutContext replicationContext)
void	setReRegisterLeaseOnUpdate(boolean value)
void	setSyncReplFromMultipleOperation(boolean syncReplFromMultipleOperation)
void	setTemplateInitialSearchThread()
void	setToFifoGroupValueForMiltipleOperations(Object val)
void	setTransactionalMultipleOperation(boolean isMultipleOperation)
void	setUnstableEntry(boolean value)
void	setUpdateLastSentKey(boolean _updateLastSentKey)
void	setWriteResult(WriteEntryResult result)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

_operationTimeoutExecption

public static OperationTimeoutException _operationTimeoutExecption

Constructor Detail

Context

public Context()

Method Detail

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)

isPossibleIEBlockingMatch

public boolean isPossibleIEBlockingMatch()

setPossibleIEBlockingMatch

public void setPossibleIEBlockingMatch(boolean val)

clean

public void clean()

clean all context.

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()

getOffHeapOpEntryCacheInfo

public IEntryCacheInfo getOffHeapOpEntryCacheInfo()

getOffHeapOpEntryHolder

public IEntryHolder getOffHeapOpEntryHolder()

getOffHeapOpPin

public boolean getOffHeapOpPin()

setOffHeapOpParams

public void setOffHeapOpParams(IEntryCacheInfo offHeapEntryCacheInfo,
                               IEntryHolder offHeapOpEntryHolder,
                               boolean offHeapOpPin)

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()

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)

setOffHeapOriginalEntryInfo

public void setOffHeapOriginalEntryInfo(IEntryData originalData,
                                        short originalOffHeapVersion)

getOriginalOffHeapVersion

public short getOriginalOffHeapVersion()

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.