com.j_spaces.core.cache

Class XtnData

java.lang.Object

com.j_spaces.core.cache.XtnData

public class XtnData
extends Object

Constructor Summary

Constructors

Constructor and Description
XtnData(XtnEntry xtnEntry)

Method Summary

Modifier and Type	Method and Description
void	addLockedEntry(IEntryCacheInfo pEntry, OperationID operationID, boolean fifo)
void	addMvccNewGenerationsEntry(MVCCEntryCacheInfo mvccEntryCacheInfo)
void	addToEntriesForFifoGroupScan(IEntryHolder entry)
void	addToFifoGroupsEntries(IEntryHolder eh, Object groupValue)
void	addToTakenEntriesIfNotInside(IEntryCacheInfo entry)
void	addWriteActiveLogicallyDeletedEntry(MVCCEntryCacheInfo mvccEntryCacheInfo)
boolean	anyEntriesForFifoGroupScan()
boolean	anyFifoEntries()
boolean	anyFifoGroupOperations()
boolean	anyLockedEntries()
List<IEntryHolder>	getEntriesForFifoGroupScan()
List<IEntryHolder>	getEntriesForReplicationIn2PCommit()
Map<String,Object>	getFifoGroupsEntries()
long	getFifoXtnNumber()
IStoredList<IEntryCacheInfo>	getLockedEntries()
IStoredList<IEntryCacheInfo>	getLockedEntries(boolean createIfNull)
IStoredList<IEntryCacheInfo>	getLockedFifoEntries()
IStoredList<IEntryCacheInfo>	getLockedFifoEntries(boolean createIfNull)
MVCCEntryCacheInfo	getMvccNewGenerationsEntry(String uid)
MVCCEntryCacheInfo	getMvccWriteActiveLogicallyDeletedEntry(String uid)
IStoredList<IEntryCacheInfo>	getNeedNotifyEntries()
IStoredList<IEntryCacheInfo>	getNeedNotifyEntries(boolean createIfNull)
IStoredList<IEntryCacheInfo>	getNewEntries()
IStoredList<IEntryCacheInfo>	getNewEntries(boolean createIfNull)
IStoredList<TemplateCacheInfo>	getNTemplates()
IStoredList<TemplateCacheInfo>	getNTemplates(boolean createIfNull)
OperationID	getOperationID(String uid)
IStoredList<TemplateCacheInfo>	getRTTemplates()
IStoredList<TemplateCacheInfo>	getRTTemplates(boolean createIfNull)
IStoredList<IEntryCacheInfo>	getTakenEntries()
IStoredList<IEntryCacheInfo>	getTakenEntries(boolean createIfNull)
IStoredList<IEntryCacheInfo>	getUnderXtnEntries(int selectType) get the relevant entries under the xtn according to selected type
HashMap<String,Object>	getUpdatedEntries()
ServerTransaction	getXtn()
XtnEntry	getXtnEntry()
boolean	isLockedEntry(IEntryCacheInfo pEntry)
boolean	isOperationID(OperationID oi)
boolean	isReWrittenEntry(String uid) check weather an entry is rewritten under xtn
boolean	isUpdatedEntry(IEntryHolder eh)
void	removeFromNewEntries(IEntryCacheInfo subject)
MVCCEntryCacheInfo	removeMvccNewGenerationsEntry(String uid)
void	removeRewrittenEntryIndication(String uid) remove reWritten entry indication if exists
void	removeTakenEntry(IEntryCacheInfo entry)
void	removeUpdatedEntry(IEntryCacheInfo entry)
MVCCEntryCacheInfo	removeWriteActiveLogicallyDeletedEntry(String uid)
void	resetEntriesForFifoGroupsScan()
void	setEntriesForReplicationIn2PCommit(List<IEntryHolder> pLocked)
void	setFifoXtnNumber(long fifoXtnNumber)
void	setInPlaceUpdatedEntry(IEntryHolder eh, Collection<SpaceEntryMutator> mutators)
void	setUpdatedEntry(IEntryHolder eh, boolean[] partialUpdateIndicators)
void	signalRewrittenEntry(String uid) given a uid, signal the entry as rewritten under the xtn
void	updateLock(IEntryCacheInfo pEntry, OperationID operationID, boolean isReadOperation, boolean fifo) When user operation under transaction is upgraded from read to update/take, the order of entry should be changed to the most recent, so that the changes in prepare come in the right order.

Methods inherited from class java.lang.Object

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

Constructor Detail

XtnData

public XtnData(XtnEntry xtnEntry)

Method Detail

isLockedEntry

public boolean isLockedEntry(IEntryCacheInfo pEntry)

signalRewrittenEntry

public void signalRewrittenEntry(String uid)

given a uid, signal the entry as rewritten under the xtn

Parameters:

uid - - uid of entry to signal

isReWrittenEntry

public boolean isReWrittenEntry(String uid)

check weather an entry is rewritten under xtn

Parameters:

uid - - uid of entry to check

Returns:

true is entry with this uid is rewritten under xtn

removeRewrittenEntryIndication

public void removeRewrittenEntryIndication(String uid)

remove reWritten entry indication if exists

Parameters:

uid - -uid of entry

getUnderXtnEntries

public IStoredList<IEntryCacheInfo> getUnderXtnEntries(int selectType)

get the relevant entries under the xtn according to selected type

Parameters:

selectType - - selected type of entries under the xtn, from com.j_spaces.core.sadapter.SelctType

Returns:

IStoredList

anyFifoEntries

public boolean anyFifoEntries()

getXtn

public ServerTransaction getXtn()

Returns:

the xtn

getXtnEntry

public XtnEntry getXtnEntry()

Returns:

the xtn entry

addLockedEntry

public void addLockedEntry(IEntryCacheInfo pEntry,
                           OperationID operationID,
                           boolean fifo)

updateLock

public void updateLock(IEntryCacheInfo pEntry,
                       OperationID operationID,
                       boolean isReadOperation,
                       boolean fifo)

When user operation under transaction is upgraded from read to update/take, the order of entry should be changed to the most recent, so that the changes in prepare come in the right order. For example: read object A read object B take object B take object A will cause a prepare of: B,A instead of A,B. Repeatable read doesn't cause the upgrade since it is not reflected in prepare.

getOperationID

public OperationID getOperationID(String uid)

isOperationID

public boolean isOperationID(OperationID oi)

setUpdatedEntry

public void setUpdatedEntry(IEntryHolder eh,
                            boolean[] partialUpdateIndicators)

setInPlaceUpdatedEntry

public void setInPlaceUpdatedEntry(IEntryHolder eh,
                                   Collection<SpaceEntryMutator> mutators)

isUpdatedEntry

public boolean isUpdatedEntry(IEntryHolder eh)

getUpdatedEntries

public HashMap<String,Object> getUpdatedEntries()

addToEntriesForFifoGroupScan

public void addToEntriesForFifoGroupScan(IEntryHolder entry)

getEntriesForFifoGroupScan

public List<IEntryHolder> getEntriesForFifoGroupScan()

resetEntriesForFifoGroupsScan

public void resetEntriesForFifoGroupsScan()

anyEntriesForFifoGroupScan

public boolean anyEntriesForFifoGroupScan()

addToFifoGroupsEntries

public void addToFifoGroupsEntries(IEntryHolder eh,
                                   Object groupValue)

getFifoGroupsEntries

public Map<String,Object> getFifoGroupsEntries()

anyFifoGroupOperations

public boolean anyFifoGroupOperations()

getLockedEntries

public IStoredList<IEntryCacheInfo> getLockedEntries()

getLockedEntries

public IStoredList<IEntryCacheInfo> getLockedEntries(boolean createIfNull)

anyLockedEntries

public boolean anyLockedEntries()

setFifoXtnNumber

public void setFifoXtnNumber(long fifoXtnNumber)

getFifoXtnNumber

public long getFifoXtnNumber()

getLockedFifoEntries

public IStoredList<IEntryCacheInfo> getLockedFifoEntries()

getLockedFifoEntries

public IStoredList<IEntryCacheInfo> getLockedFifoEntries(boolean createIfNull)

getNeedNotifyEntries

public IStoredList<IEntryCacheInfo> getNeedNotifyEntries()

getNeedNotifyEntries

public IStoredList<IEntryCacheInfo> getNeedNotifyEntries(boolean createIfNull)

getNewEntries

public IStoredList<IEntryCacheInfo> getNewEntries()

getNewEntries

public IStoredList<IEntryCacheInfo> getNewEntries(boolean createIfNull)

removeFromNewEntries

public void removeFromNewEntries(IEntryCacheInfo subject)

getTakenEntries

public IStoredList<IEntryCacheInfo> getTakenEntries()

getTakenEntries

public IStoredList<IEntryCacheInfo> getTakenEntries(boolean createIfNull)

addToTakenEntriesIfNotInside

public void addToTakenEntriesIfNotInside(IEntryCacheInfo entry)

removeTakenEntry

public void removeTakenEntry(IEntryCacheInfo entry)

removeUpdatedEntry

public void removeUpdatedEntry(IEntryCacheInfo entry)

getNTemplates

public IStoredList<TemplateCacheInfo> getNTemplates()

getNTemplates

public IStoredList<TemplateCacheInfo> getNTemplates(boolean createIfNull)

getRTTemplates

public IStoredList<TemplateCacheInfo> getRTTemplates()

getRTTemplates

public IStoredList<TemplateCacheInfo> getRTTemplates(boolean createIfNull)

setEntriesForReplicationIn2PCommit

public void setEntriesForReplicationIn2PCommit(List<IEntryHolder> pLocked)

getEntriesForReplicationIn2PCommit

public List<IEntryHolder> getEntriesForReplicationIn2PCommit()

getMvccNewGenerationsEntry

public MVCCEntryCacheInfo getMvccNewGenerationsEntry(String uid)

addMvccNewGenerationsEntry

public void addMvccNewGenerationsEntry(MVCCEntryCacheInfo mvccEntryCacheInfo)

removeMvccNewGenerationsEntry

public MVCCEntryCacheInfo removeMvccNewGenerationsEntry(String uid)

getMvccWriteActiveLogicallyDeletedEntry

public MVCCEntryCacheInfo getMvccWriteActiveLogicallyDeletedEntry(String uid)

addWriteActiveLogicallyDeletedEntry

public void addWriteActiveLogicallyDeletedEntry(MVCCEntryCacheInfo mvccEntryCacheInfo)

removeWriteActiveLogicallyDeletedEntry

public MVCCEntryCacheInfo removeWriteActiveLogicallyDeletedEntry(String uid)