public class FeederSyncupReader extends VLSNReader
FileReader.EOFException, FileReader.ReadWindow
currentFeedRecord, currentVLSN, nReposition, nScanned, vlsnIndex
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, logger, nextEntryOffset, startLsn, window
Constructor and Description |
---|
FeederSyncupReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
long endOfLogLsn,
int readBufferSize,
NameIdPair nameIdPair,
VLSN startVLSN,
long finishLsn) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
isTargetEntry() |
protected boolean |
processEntry(java.nio.ByteBuffer entryBuffer)
Instantiate a WireRecord to house this log entry.
|
OutputWireRecord |
scanBackwards(VLSN vlsn)
Backward scanning for records for the feeder's part in syncup.
|
getNReposition, getNScanned, resetStats, setPosition
entryIsReplicated, getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, makeWindow, readNextEntry, readNextEntryAllowExceptions, resyncReader, setAlwaysValidateChecksum, setBackwardPosition, setForwardPosition, skipData, skipEntry
public FeederSyncupReader(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, long endOfLogLsn, int readBufferSize, NameIdPair nameIdPair, VLSN startVLSN, long finishLsn) throws java.io.IOException, DatabaseException
java.io.IOException
DatabaseException
public OutputWireRecord scanBackwards(VLSN vlsn) throws java.io.FileNotFoundException, ChecksumException
ChecksumException
java.io.FileNotFoundException
protected boolean isTargetEntry() throws DatabaseException
isTargetEntry
in class FileReader
DatabaseException
- from subclasses.protected boolean processEntry(java.nio.ByteBuffer entryBuffer)
processEntry
in class VLSNReader
entryBuffer
- contains the entry data and is positioned at the
dataCopyright (c) 2004-2012 Oracle. All rights reserved.