public abstract class LogManager
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected EnvironmentImpl |
envImpl |
protected com.sleepycat.je.log.LogBufferPool |
logBufferPool |
protected Latch |
logWriteLatch |
Constructor and Description |
---|
LogManager(EnvironmentImpl envImpl,
boolean readOnly)
There is a single log manager per database environment.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
countObsoleteDb(DatabaseImpl db) |
abstract void |
countObsoleteINs(java.util.List<java.lang.Long> lsnList,
DatabaseImpl nodeDb)
Counts the given obsolete IN LSNs under the log write latch.
|
abstract void |
countObsoleteNode(long lsn,
LogEntryType type,
int size,
DatabaseImpl nodeDb)
Count node as obsolete under the log write latch.
|
void |
flush()
Flush all log entries, fsync the log file.
|
void |
flushNoSync()
May be used to avoid sync to speed unit tests.
|
java.lang.Object |
get(long lsn)
Fault in the first object in the log entry log entry at this LSN.
|
java.nio.ByteBuffer |
getByteBufferFromLog(long lsn)
Return a ByteBuffer holding the log entry at this LSN.
|
boolean |
getChecksumOnRead() |
long |
getLastLsnAtRecovery() |
LogEntry |
getLogEntry(long lsn)
Instantiate all the objects in the log entry at this LSN.
|
LogSource |
getLogSource(long lsn)
Find the LSN, whether in a file or still in the log buffers.
|
abstract TrackedFileSummary |
getUnflushableTrackedSummary(long file)
Returns a tracked summary for the given file which will not be flushed.
|
abstract void |
loadEndOfLogStat(EnvironmentStats stats) |
void |
loadStats(StatsConfig config,
EnvironmentStats stats) |
long |
log(LogEntry entry,
boolean isProvisional,
boolean backgroundIO,
long oldNodeLsn,
DatabaseImpl nodeDb,
ReplicationContext repContext)
Write a log entry.
|
long |
log(LogEntry entry,
Provisional provisional,
boolean backgroundIO,
long oldNodeLsn,
DatabaseImpl nodeDb,
ReplicationContext repContext)
Write a log entry.
|
long |
log(LogEntry entry,
ReplicationContext repContext)
Write a log entry.
|
void |
log(LogItem item,
LogContext context)
Convenience method for logging a single entry.
|
long |
logForceFlip(LogEntry entry)
Log this single object and force a flip of the log files.
|
long |
logForceFlush(LogEntry entry,
boolean fsyncRequired,
ReplicationContext repContext)
Log this single object and force a write of the log files.
|
java.nio.ByteBuffer |
marshallIntoBuffer(LogEntryHeader header,
LogEntry entry)
Serialize a loggable object into this buffer.
|
void |
multiLog(LogItem[] itemArray,
LogContext context) |
abstract boolean |
removeDbFileSummary(DatabaseImpl db,
java.lang.Long fileNum) |
abstract void |
removeTrackedFile(TrackedFileSummary tfs)
Removes the tracked summary for the given file.
|
protected void |
removeTrackedFileInternal(TrackedFileSummary tfs) |
void |
resetPool(DbConfigManager configManager)
Reset the pool when the cache is resized.
|
void |
setLastLsnAtRecovery(long lastLsnAtRecovery) |
void |
setReadHook(TestHook hook) |
abstract void |
transferToUtilizationTracker(LocalUtilizationTracker localTracker) |
protected com.sleepycat.je.log.LogBufferPool logBufferPool
protected Latch logWriteLatch
protected EnvironmentImpl envImpl
public LogManager(EnvironmentImpl envImpl, boolean readOnly) throws DatabaseException
DatabaseException
public boolean getChecksumOnRead()
public long getLastLsnAtRecovery()
public void setLastLsnAtRecovery(long lastLsnAtRecovery)
public void resetPool(DbConfigManager configManager) throws DatabaseException
DatabaseException
public long logForceFlush(LogEntry entry, boolean fsyncRequired, ReplicationContext repContext) throws DatabaseException
entry
- object to be loggedfsyncRequired
- if true, log files should also be fsynced.DatabaseException
public long logForceFlip(LogEntry entry) throws DatabaseException
entry
- object to be loggedDatabaseException
public long log(LogEntry entry, ReplicationContext repContext) throws DatabaseException
entry
- object to be loggedDatabaseException
public long log(LogEntry entry, boolean isProvisional, boolean backgroundIO, long oldNodeLsn, DatabaseImpl nodeDb, ReplicationContext repContext) throws DatabaseException
entry
- object to be loggedisProvisional
- true if this entry should not be read during
recovery.backgroundIO
- if true, sleep when the backgroundIOLimit is
exceeded.oldNodeLsn
- is the previous version of the node to be counted as
obsolete, or NULL_LSN if the entry is not a node or has no old LSN.nodeDb
- database of the node, or null if entry is not a node.DatabaseException
public long log(LogEntry entry, Provisional provisional, boolean backgroundIO, long oldNodeLsn, DatabaseImpl nodeDb, ReplicationContext repContext) throws DatabaseException
entry
- object to be loggedprovisional
- whether this entry should be processed during
recovery.backgroundIO
- if true, sleep when the backgroundIOLimit is
exceeded.oldNodeLsn
- is the previous version of the node to be counted as
obsolete, or NULL_LSN if the entry is not a node or has no old LSN.nodeDb
- database of the node, or null if entry is not a node.DatabaseException
public void log(LogItem item, LogContext context) throws DatabaseException
DatabaseException
public void multiLog(LogItem[] itemArray, LogContext context) throws DatabaseException
DatabaseException
public java.nio.ByteBuffer marshallIntoBuffer(LogEntryHeader header, LogEntry entry) throws DatabaseException
DatabaseException
public LogEntry getLogEntry(long lsn) throws DatabaseException
lsn
- location of entry in log.DatabaseException
public java.nio.ByteBuffer getByteBufferFromLog(long lsn) throws DatabaseException
lsn
- location of entry in logDatabaseException
public java.lang.Object get(long lsn) throws DatabaseException
lsn
- location of object in logDatabaseException
public LogSource getLogSource(long lsn) throws DatabaseException
DatabaseException
public void flush() throws DatabaseException
DatabaseException
public void flushNoSync() throws DatabaseException
DatabaseException
public void loadStats(StatsConfig config, EnvironmentStats stats) throws DatabaseException
DatabaseException
public abstract TrackedFileSummary getUnflushableTrackedSummary(long file) throws DatabaseException
DatabaseException
public abstract void removeTrackedFile(TrackedFileSummary tfs) throws DatabaseException
DatabaseException
protected void removeTrackedFileInternal(TrackedFileSummary tfs)
public abstract void countObsoleteNode(long lsn, LogEntryType type, int size, DatabaseImpl nodeDb) throws DatabaseException
DatabaseException
public abstract void transferToUtilizationTracker(LocalUtilizationTracker localTracker) throws DatabaseException
DatabaseException
BaseLocalUtilizationTracker.transferToUtilizationTracker(com.sleepycat.je.cleaner.UtilizationTracker)
public abstract void countObsoleteINs(java.util.List<java.lang.Long> lsnList, DatabaseImpl nodeDb) throws DatabaseException
DatabaseException
public abstract void countObsoleteDb(DatabaseImpl db) throws DatabaseException
public abstract boolean removeDbFileSummary(DatabaseImpl db, java.lang.Long fileNum) throws DatabaseException
DatabaseException
public abstract void loadEndOfLogStat(EnvironmentStats stats) throws DatabaseException
DatabaseException
public void setReadHook(TestHook hook)