public class CleanerFileReader extends FileReader
FileReader.EOFException, FileReader.ReadWindow
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, logger, nextEntryOffset, startLsn, window
Constructor and Description |
---|
CleanerFileReader(EnvironmentImpl env,
int readBufferSize,
long startLsn,
java.lang.Long fileNum,
FileSummary fileSummary,
INSummary inSummary)
Create this reader to start at a given LSN.
|
Modifier and Type | Method and Description |
---|---|
void |
countObsolete()
Records the current log entry as obsolete in the FileSummary used to
count true utilization.
|
BINDelta |
getBINDelta() |
DatabaseId |
getDatabaseId()
Get the last databaseId seen by the reader.
|
FileHeader |
getFileHeader() |
IN |
getIN(DatabaseImpl dbImpl)
Get the last entry seen by the reader as an IN.
|
VLSN |
getLastVLSN()
Returns the last VLSN encountered, or NULL_VLSN if no entries were
replicated.
|
LNLogEntry |
getLNLogEntry()
Get the last LN log entry seen by the reader.
|
boolean |
isBINDelta() |
boolean |
isDbTree() |
boolean |
isFileHeader() |
boolean |
isIN() |
boolean |
isLN() |
boolean |
isLNDeleted() |
protected boolean |
processEntry(java.nio.ByteBuffer entryBuffer)
Process the header to track the last VLSN and count true utilization.
|
entryIsReplicated, getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, isTargetEntry, makeWindow, readNextEntry, readNextEntryAllowExceptions, resyncReader, setAlwaysValidateChecksum, setBackwardPosition, setForwardPosition, skipData, skipEntry, threadSafeBufferFlip, threadSafeBufferPosition, threadSafeBufferPosition
public CleanerFileReader(EnvironmentImpl env, int readBufferSize, long startLsn, java.lang.Long fileNum, FileSummary fileSummary, INSummary inSummary) throws DatabaseException
env
- The relevant EnvironmentImpl.readBufferSize
- buffer size in bytes for reading in log.startLsn
- where to start in the log, or null for the beginning.fileNum
- single file number.fileSummary
- returns true utilization.inSummary
- returns IN utilization.DatabaseException
protected boolean processEntry(java.nio.ByteBuffer entryBuffer) throws DatabaseException
processEntry
in class FileReader
entryBuffer
- contains the entry data and is positioned at the
dataDatabaseException
public void countObsolete()
public boolean isIN()
public boolean isBINDelta()
public boolean isLN()
public boolean isDbTree()
public boolean isFileHeader()
public LNLogEntry getLNLogEntry()
public boolean isLNDeleted()
public IN getIN(DatabaseImpl dbImpl)
public BINDelta getBINDelta()
public FileHeader getFileHeader()
public DatabaseId getDatabaseId()
public VLSN getLastVLSN()
Copyright (c) 2004-2012 Oracle. All rights reserved.