com.sleepycat.je.rep.stream
Class VLSNReader
java.lang.Object
com.sleepycat.je.log.FileReader
com.sleepycat.je.rep.stream.VLSNReader
- Direct Known Subclasses:
- FeederReader, FeederSyncupReader, ReplicaSyncupReader
abstract class VLSNReader
- extends FileReader
The VLSNReader returns picks out replicated log entries from the log. It
works in tandem with the VLSNIndex, using vlsn->lsn mappings if those are
available, and otherwise scanning the log for replicated entries.
A VLSNReader is not thread safe, and can only be used serially.
Fields inherited from class com.sleepycat.je.log.FileReader |
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, logger, nextEntryOffset, startLsn, window |
Methods inherited from class com.sleepycat.je.log.FileReader |
entryIsReplicated, getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, isTargetEntry, makeWindow, readNextEntry, readNextEntryAllowExceptions, resyncReader, setAlwaysValidateChecksum, setBackwardPosition, setForwardPosition, skipData, skipEntry |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
vlsnIndex
final VLSNIndex vlsnIndex
currentVLSN
VLSN currentVLSN
currentFeedRecord
OutputWireRecord currentFeedRecord
nScanned
long nScanned
nReposition
long nReposition
VLSNReader
VLSNReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
boolean forward,
long startLsn,
int readBufferSize,
NameIdPair nameIdPair,
long finishLsn)
throws DatabaseException
- Throws:
DatabaseException
setPosition
void setPosition(long startLsn)
throws ChecksumException,
FileNotFoundException,
DatabaseException
- Throws:
ChecksumException
FileNotFoundException
DatabaseException
processEntry
protected boolean processEntry(ByteBuffer entryBuffer)
- Instantiate a WireRecord to house this log entry.
- Specified by:
processEntry
in class FileReader
- Parameters:
entryBuffer
- contains the entry data and is positioned at the
data
- Returns:
- true if this entry should be returned
getNReposition
long getNReposition()
getNScanned
long getNScanned()
resetStats
void resetStats()
Copyright (c) 2004-2012 Oracle. All rights reserved.