abstract class VLSNReader extends FileReader
FileReader.EOFException, FileReader.ReadWindow
Modifier and Type | Field and Description |
---|---|
(package private) OutputWireRecord |
currentFeedRecord |
(package private) VLSN |
currentVLSN |
(package private) long |
nReposition |
(package private) long |
nScanned |
(package private) VLSNIndex |
vlsnIndex |
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, logger, nextEntryOffset, startLsn, window
Constructor and Description |
---|
VLSNReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
boolean forward,
long startLsn,
int readBufferSize,
NameIdPair nameIdPair,
long finishLsn) |
Modifier and Type | Method and Description |
---|---|
(package private) long |
getNReposition() |
(package private) long |
getNScanned() |
protected boolean |
processEntry(java.nio.ByteBuffer entryBuffer)
Instantiate a WireRecord to house this log entry.
|
(package private) void |
resetStats() |
(package private) void |
setPosition(long startLsn) |
entryIsReplicated, getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, isTargetEntry, makeWindow, readNextEntry, readNextEntryAllowExceptions, resyncReader, setAlwaysValidateChecksum, setBackwardPosition, setForwardPosition, skipData, skipEntry
final VLSNIndex vlsnIndex
VLSN currentVLSN
OutputWireRecord currentFeedRecord
long nScanned
long nReposition
VLSNReader(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, boolean forward, long startLsn, int readBufferSize, NameIdPair nameIdPair, long finishLsn) throws DatabaseException
DatabaseException
void setPosition(long startLsn) throws ChecksumException, java.io.FileNotFoundException, DatabaseException
ChecksumException
java.io.FileNotFoundException
DatabaseException
protected boolean processEntry(java.nio.ByteBuffer entryBuffer)
processEntry
in class FileReader
entryBuffer
- contains the entry data and is positioned at the
datalong getNReposition()
long getNScanned()
void resetStats()
Copyright (c) 2004-2012 Oracle. All rights reserved.