| java.lang.Object com.sleepycat.je.log.FileReader com.sleepycat.je.log.LNFileReader
LNFileReader | public class LNFileReader extends FileReader (Code) | | LNFileReader scans log files for LNs. Also, if it's going backwards for the
undo phase in recovery, it reads transaction commit entries.
|
Constructor Summary | |
public | LNFileReader(EnvironmentImpl env, int readBufferSize, long startLsn, boolean redo, long endOfFileLsn, long finishLsn, Long singleFileNum) Create this reader to start at a given LSN.
Parameters: env - The relevant EnvironmentImpl Parameters: readBufferSize - buffer size in bytes for reading in log Parameters: startLsn - where to start in the log Parameters: redo - If true, we're going to go forward fromthe start LSN to the end of the log. |
targetEntryMap | protected Map targetEntryMap(Code) | | |
LNFileReader | public LNFileReader(EnvironmentImpl env, int readBufferSize, long startLsn, boolean redo, long endOfFileLsn, long finishLsn, Long singleFileNum) throws IOException, DatabaseException(Code) | | Create this reader to start at a given LSN.
Parameters: env - The relevant EnvironmentImpl Parameters: readBufferSize - buffer size in bytes for reading in log Parameters: startLsn - where to start in the log Parameters: redo - If true, we're going to go forward fromthe start LSN to the end of the log. If false, we're goingbackwards from the end of the log to the start LSN. Parameters: finishLsn - the last LSN to read in the log. May be null if wewant to read to the end of the log. Parameters: endOfFileLsn - the virtual LSN that marks the end of the log. (Theone off the end of the log). Only used if we're reading backwards.Different from the startLsn because the startLsn tells us where thebeginning of the start entry is, but not the length/end of the startentry. May be null if we're going foward. |
getAbortKnownDeleted | public boolean getAbortKnownDeleted()(Code) | | Get last abort known deleted seen by the reader.
|
getAbortLsn | public long getAbortLsn()(Code) | | Get last abort LSN seen by the reader (may be null).
|
getDatabaseId | public DatabaseId getDatabaseId()(Code) | | Get the last databaseId seen by the reader.
|
getDupTreeKey | public byte[] getDupTreeKey()(Code) | | Get the last key seen by the reader.
|
getKey | public byte[] getKey()(Code) | | Get the last key seen by the reader.
|
getLN | public LN getLN()(Code) | | Get the last LN seen by the reader.
|
getNodeId | public long getNodeId()(Code) | | Get node id of current LN.
|
getTxnAbortId | public long getTxnAbortId()(Code) | | Get the last txn abort id seen by the reader.
|
getTxnCommitId | public long getTxnCommitId()(Code) | | Get the last txn commit id seen by the reader.
|
getTxnId | public Long getTxnId()(Code) | | the transaction id of the current entry. |
getTxnPrepareId | public long getTxnPrepareId()(Code) | | Get the last txn prepare id seen by the reader.
|
getTxnPrepareXid | public Xid getTxnPrepareXid()(Code) | | Get the last txn prepare Xid seen by the reader.
|
isAbort | public boolean isAbort()(Code) | | |
isLN | public boolean isLN()(Code) | | true if the last entry was an LN. |
isPrepare | public boolean isPrepare()(Code) | | |
isTargetEntry | protected boolean isTargetEntry(byte entryTypeNum, byte entryTypeVersion)(Code) | | true if this is a transactional LN or Locker Commit entry. |
processEntry | protected boolean processEntry(ByteBuffer entryBuffer) throws DatabaseException(Code) | | This reader instantiates an LN and key for every LN entry.
|
|
|