public class INFileReader extends FileReader
This file reader can also be run in tracking mode to keep track of the maximum node id, database id and txn id seen so those sequences can be updated properly at recovery. In this mode it also performs utilization counting. It is only run once in tracking mode per recovery, in the first phase of recovery.
anticipateChecksumErrors, cksumValidator, currentEntryHeader, currentEntryOffset, currentEntryPrevOffset, envImpl, eof, fileManager, nextEntryOffset, readBufferFileEnd, readBufferFileNum, readBufferFileStart, startLsn
Constructor and Description |
---|
INFileReader(EnvironmentImpl env,
int readBufferSize,
long startLsn,
long finishLsn,
boolean trackIds,
boolean mapDbOnly,
long partialCkptStart,
long ckptEnd,
RecoveryUtilizationTracker tracker)
Create this reader to start at a given LSN.
|
Modifier and Type | Method and Description |
---|---|
void |
addTargetType(LogEntryType entryType)
Configure this reader to target this kind of entry.
|
DatabaseId |
getDatabaseId()
Get the last databaseId seen by the reader.
|
byte[] |
getDeletedIdKey()
Get the deleted id key stored in the last delete info log entry.
|
long |
getDeletedNodeId()
Get the deleted node id stored in the last delete info log entry.
|
byte[] |
getDupDeletedDupKey()
Get the deleted main key stored in the last delete info log entry.
|
byte[] |
getDupDeletedMainKey()
Get the deleted main key stored in the last delete info log entry.
|
long |
getDupDeletedNodeId()
Get the deleted node id stored in the last delete info log entry.
|
java.util.Collection<FileMapper> |
getFileMappers() |
IN |
getIN()
Get the last IN seen by the reader.
|
long |
getLsnOfIN()
Get the LSN that should represent this IN.
|
int |
getMaxDbId()
Get the maximum db id seen by the reader.
|
long |
getMaxNodeId()
Get the maximum node id seen by the reader.
|
long |
getMaxTxnId()
Get the maximum txn id seen by the reader.
|
int |
getMinReplicatedDbId() |
long |
getMinReplicatedNodeId() |
long |
getMinReplicatedTxnId() |
boolean |
isDeleteInfo() |
boolean |
isDupDeleteInfo() |
protected boolean |
isTargetEntry()
If we're tracking node, database and txn ids, we want to see all node
log entries.
|
protected boolean |
processEntry(java.nio.ByteBuffer entryBuffer)
This reader returns non-provisional INs and IN delete entries.
|
getAndResetNReads, getLastEntrySize, getLastLsn, getNRepeatIteratorReads, getNumRead, initStartingPosition, readNextEntry, resyncReader, setAlwaysValidateChecksum
public INFileReader(EnvironmentImpl env, int readBufferSize, long startLsn, long finishLsn, boolean trackIds, boolean mapDbOnly, long partialCkptStart, long ckptEnd, RecoveryUtilizationTracker tracker) throws java.io.IOException, DatabaseException
java.io.IOException
DatabaseException
public void addTargetType(LogEntryType entryType) throws DatabaseException
DatabaseException
protected boolean isTargetEntry() throws DatabaseException
isTargetEntry
in class FileReader
DatabaseException
protected boolean processEntry(java.nio.ByteBuffer entryBuffer) throws DatabaseException
processEntry
in class FileReader
DatabaseException
public IN getIN() throws DatabaseException
DatabaseException
public DatabaseId getDatabaseId()
public long getMaxNodeId()
public long getMinReplicatedNodeId()
public int getMaxDbId()
public int getMinReplicatedDbId()
public long getMaxTxnId()
public long getMinReplicatedTxnId()
public boolean isDeleteInfo()
public boolean isDupDeleteInfo()
public long getDeletedNodeId()
public byte[] getDeletedIdKey()
public long getDupDeletedNodeId()
public byte[] getDupDeletedMainKey()
public byte[] getDupDeletedDupKey()
public long getLsnOfIN()
public java.util.Collection<FileMapper> getFileMappers()