public class FeederReader extends VLSNReader
Modifier and Type | Class and Description |
---|---|
(package private) static class |
FeederReader.SwitchWindow
The SwitchWindow can fill itself from either the log file or the log
buffers.
|
FileReader.EOFException, FileReader.ReadWindow
currentFeedRecord, currentVLSN, nReposition, nScanned, vlsnIndex
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, logger, nextEntryOffset, startLsn, window
Constructor and Description |
---|
FeederReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
long startLsn,
int readBufferSize)
For unit testing only!! Bypass the VLSNIndex cache, provide a node name.
|
FeederReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
long startLsn,
int readBufferSize,
NameIdPair nameIdPair) |
Modifier and Type | Method and Description |
---|---|
(package private) java.lang.String |
dumpState() |
void |
initScan(VLSN startVLSN)
Set up the FeederReader to start scanning from this VLSN.
|
protected boolean |
isTargetEntry()
Return true if this entry is replicated and its VLSN is currentVLSN.
|
protected FileReader.ReadWindow |
makeWindow(int readBufferSize)
Use a ReadWindow which can read from LogBuffers as well as the physical
file.
|
OutputWireRecord |
scanForwards(VLSN vlsn,
int waitTime)
Forward scanning for feeding the replica: get the log record for this
VLSN.
|
getNReposition, getNScanned, processEntry, resetStats, setPosition
entryIsReplicated, getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, readNextEntry, readNextEntryAllowExceptions, resyncReader, setAlwaysValidateChecksum, setBackwardPosition, setForwardPosition, skipData, skipEntry
public FeederReader(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, long startLsn, int readBufferSize, NameIdPair nameIdPair)
FeederReader(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, long startLsn, int readBufferSize)
protected FileReader.ReadWindow makeWindow(int readBufferSize)
makeWindow
in class FileReader
DatabaseException
public void initScan(VLSN startVLSN) throws java.io.IOException
java.io.IOException
public OutputWireRecord scanForwards(VLSN vlsn, int waitTime) throws java.lang.InterruptedException
java.lang.InterruptedException
protected boolean isTargetEntry()
isTargetEntry
in class FileReader
java.lang.String dumpState()
Copyright (c) 2004-2012 Oracle. All rights reserved.