public class ReplicaSyncupReader extends VLSNReader
FileReader.EOFException, FileReader.ReadWindow
currentFeedRecord, currentVLSN, nReposition, nScanned, vlsnIndex
cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, forward, nextEntryOffset, startLsn, window
Constructor and Description |
---|
ReplicaSyncupReader(EnvironmentImpl envImpl,
VLSNIndex vlsnIndex,
long endOfLogLsn,
int readBufferSize,
NameIdPair nameIdPair,
VLSN startVLSN,
long finishLsn,
MatchpointSearchResults searchResults) |
Modifier and Type | Method and Description |
---|---|
OutputWireRecord |
findPrevSyncEntry()
Backward scanning for finding an earlier candidate syncup matchpoint.
|
protected boolean |
isTargetEntry()
Return true for ckpt entries, for syncable entries, and if we're in
specific vlsn scan mode, any replicated entry.
|
protected boolean |
processEntry(java.nio.ByteBuffer entryBuffer)
ProcessEntry does additional filtering before deciding whether to
return an entry as a candidate for matching.
|
OutputWireRecord |
scanBackwards(VLSN vlsn)
Backward scanning for the replica'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 ReplicaSyncupReader(EnvironmentImpl envImpl, VLSNIndex vlsnIndex, long endOfLogLsn, int readBufferSize, NameIdPair nameIdPair, VLSN startVLSN, long finishLsn, MatchpointSearchResults searchResults) throws java.io.IOException, DatabaseException
java.io.IOException
DatabaseException
public OutputWireRecord scanBackwards(VLSN vlsn) throws DatabaseException
DatabaseException
public OutputWireRecord findPrevSyncEntry() throws DatabaseException
DatabaseException
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.