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 |
countObsoleteINs(java.util.List lsnList)
Counts the given obsolete IN LSNs under the log write latch.
|
protected void |
countObsoleteINsInternal(java.util.List lsnList) |
abstract void |
countObsoleteNode(long lsn,
LogEntryType type,
int size)
Count node as obsolete under the log write latch.
|
protected void |
countObsoleteNodeInternal(UtilizationTracker tracker,
long lsn,
LogEntryType type,
int size) |
abstract void |
countObsoleteNodes(java.util.Collection summaries)
Counts file summary info under the log write latch.
|
protected void |
countObsoleteNodesInternal(UtilizationTracker tracker,
java.util.Collection summaries) |
void |
flush()
Flush all log entries, fsync the log file.
|
protected abstract void |
flushInternal() |
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.
|
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.
|
protected TrackedFileSummary |
getUnflushableTrackedSummaryInternal(long file) |
abstract void |
loadEndOfLogStat(EnvironmentStats stats) |
void |
loadStats(StatsConfig config,
EnvironmentStats stats) |
long |
log(LogEntry item)
Write a log entry.
|
long |
log(LogEntry item,
boolean isProvisional,
boolean backgroundIO,
long oldNodeLsn,
int oldNodeSize)
Write a log entry.
|
long |
logForceFlip(LogEntry item)
Log this single object and force a flip of the log files.
|
long |
logForceFlush(LogEntry item,
boolean fsyncRequired)
Log this single object and force a write of the log files.
|
protected com.sleepycat.je.log.LogManager.LogResult |
logInternal(LogEntryHeader header,
LogEntry item,
boolean isProvisional,
boolean flushRequired,
boolean forceNewLogFile,
long oldNodeLsn,
int oldNodeSize,
boolean marshallOutsideLatch,
java.nio.ByteBuffer marshalledBuffer,
UtilizationTracker tracker,
boolean shouldReplicate)
Called within the log write critical section.
|
protected abstract com.sleepycat.je.log.LogManager.LogResult |
logItem(LogEntryHeader header,
LogEntry item,
boolean isProvisional,
boolean flushRequired,
boolean forceNewLogFile,
long oldNodeLsn,
int oldNodeSize,
boolean marshallOutsideLatch,
java.nio.ByteBuffer marshalledBuffer,
UtilizationTracker tracker,
boolean shouldReplicate) |
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) |
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 item, boolean fsyncRequired) throws DatabaseException
item
- object to be loggedfsyncRequired
- if true, log files should also be fsynced.DatabaseException
public long logForceFlip(LogEntry item) throws DatabaseException
item
- object to be loggedfsyncRequired
- if true, log files should also be fsynced.DatabaseException
public long log(LogEntry item) throws DatabaseException
DatabaseException
public long log(LogEntry item, boolean isProvisional, boolean backgroundIO, long oldNodeLsn, int oldNodeSize) throws DatabaseException
DatabaseException
protected abstract com.sleepycat.je.log.LogManager.LogResult logItem(LogEntryHeader header, LogEntry item, boolean isProvisional, boolean flushRequired, boolean forceNewLogFile, long oldNodeLsn, int oldNodeSize, boolean marshallOutsideLatch, java.nio.ByteBuffer marshalledBuffer, UtilizationTracker tracker, boolean shouldReplicate) throws java.io.IOException, DatabaseException
java.io.IOException
DatabaseException
protected com.sleepycat.je.log.LogManager.LogResult logInternal(LogEntryHeader header, LogEntry item, boolean isProvisional, boolean flushRequired, boolean forceNewLogFile, long oldNodeLsn, int oldNodeSize, boolean marshallOutsideLatch, java.nio.ByteBuffer marshalledBuffer, UtilizationTracker tracker, boolean shouldReplicate) throws java.io.IOException, DatabaseException
java.io.IOException
DatabaseException
public LogEntry getLogEntry(long lsn) throws DatabaseException
lsn
- location of entry in log.DatabaseException
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
protected abstract void flushInternal() throws LogException, DatabaseException
LogException
DatabaseException
public void loadStats(StatsConfig config, EnvironmentStats stats) throws DatabaseException
DatabaseException
public abstract TrackedFileSummary getUnflushableTrackedSummary(long file) throws DatabaseException
DatabaseException
protected TrackedFileSummary getUnflushableTrackedSummaryInternal(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) throws DatabaseException
DatabaseException
protected void countObsoleteNodeInternal(UtilizationTracker tracker, long lsn, LogEntryType type, int size) throws DatabaseException
DatabaseException
public abstract void countObsoleteNodes(java.util.Collection summaries) throws DatabaseException
DatabaseException
protected void countObsoleteNodesInternal(UtilizationTracker tracker, java.util.Collection summaries) throws DatabaseException
DatabaseException
public abstract void countObsoleteINs(java.util.List lsnList) throws DatabaseException
DatabaseException
protected void countObsoleteINsInternal(java.util.List lsnList) throws DatabaseException
DatabaseException
public abstract void loadEndOfLogStat(EnvironmentStats stats) throws DatabaseException
DatabaseException
public void setReadHook(TestHook hook)