Package com.j_spaces.core.cache

Class XtnData

java.lang.Object
com.j_spaces.core.cache.XtnData
public class XtnData extends Object

  • Constructor Details

    • XtnData

      public XtnData(XtnEntry xtnEntry)

  • Method Details

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