|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.log.LogManager
public abstract class LogManager
The LogManager supports reading and writing to the JE log.
Field Summary | |
---|---|
protected EnvironmentImpl |
envImpl
|
protected LogBufferPool |
logBufferPool
|
protected Latch |
logWriteLatch
|
Constructor Summary | |
---|---|
LogManager(EnvironmentImpl envImpl,
boolean readOnly)
There is a single log manager per database environment. |
Method Summary | |
---|---|
abstract void |
countObsoleteDb(DatabaseImpl db)
|
(package private) void |
countObsoleteDbInternal(DatabaseImpl db)
|
abstract void |
countObsoleteNode(long lsn,
LogEntryType type,
int size,
DatabaseImpl nodeDb,
boolean countExact)
Count node as obsolete under the log write latch. |
abstract void |
countObsoleteNodeDupsAllowed(long lsn,
LogEntryType type,
int size,
DatabaseImpl nodeDb)
A flavor of countObsoleteNode which does not fire an assert if the offset has already been counted. |
(package private) void |
countObsoleteNodeDupsAllowedInternal(long lsn,
LogEntryType type,
int size,
DatabaseImpl nodeDb)
|
(package private) void |
countObsoleteNodeInternal(long lsn,
LogEntryType type,
int size,
DatabaseImpl nodeDb,
boolean countExact)
|
void |
flush()
Flush all log entries, fsync the log file. |
(package private) abstract void |
flushInternal()
|
void |
flushNoSync()
May be used to avoid sync, for unit tests and for rep syncup. |
ByteBuffer |
getByteBufferFromLog(long lsn)
Return a ByteBuffer holding the log entry at this LSN. |
boolean |
getChecksumOnRead()
|
Object |
getEntry(long lsn)
Fault in the first object in the log entry log entry at this LSN. |
Object |
getEntryHandleFileNotFound(long lsn)
|
long |
getLastLsnAtRecovery()
|
LogEntry |
getLogEntry(long lsn)
Instantiate all the objects in the log entry at this LSN. |
(package private) LogEntry |
getLogEntryAllowChecksumException(long lsn)
Throws ChecksumException rather than translating it to EnvironmentFailureException and invalidating the environment. |
(package private) LogEntry |
getLogEntryAllowChecksumException(long lsn,
RandomAccessFile file,
int logVersion)
|
WholeEntry |
getLogEntryAllowInvisible(long lsn)
Instantiate all the objects in the log entry at this LSN. |
LogEntry |
getLogEntryAllowInvisibleAtRecovery(long lsn)
Instantiate all the objects in the log entry at this LSN. |
LogEntry |
getLogEntryHandleFileNotFound(long lsn)
|
LogSource |
getLogSource(long lsn)
Find the LSN, whether in a file or still in the log buffers. |
LogBuffer |
getReadBufferByLsn(long lsn)
Return a log buffer locked for reading, or null if no log buffer holds this LSN location. |
abstract TrackedFileSummary |
getUnflushableTrackedSummary(long file)
Returns a tracked summary for the given file which will not be flushed. |
(package private) TrackedFileSummary |
getUnflushableTrackedSummaryInternal(long file)
|
abstract void |
loadEndOfLogStat()
|
(package private) void |
loadEndOfLogStatInternal()
|
StatGroup |
loadStats(StatsConfig config)
|
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. |
void |
logLazily(LogEntry entry,
ReplicationContext repContext)
Write a log entry lazily. |
void |
multiLog(LogItem[] itemArray,
LogContext context)
|
(package private) ByteBuffer |
putIntoBuffer(LogEntry entry,
long prevLogEntryOffset)
Serialize a log entry into this buffer with proper entry header. |
abstract boolean |
removeDbFileSummary(DatabaseImpl db,
Long fileNum)
|
(package private) boolean |
removeDbFileSummaryInternal(DatabaseImpl db,
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. |
(package private) abstract void |
serialLog(LogItem[] itemArray,
LogContext context)
Log one or more items while latched or synchronized in order to serialize log output. |
(package private) void |
serialLogInternal(LogItem[] itemArray,
LogContext context)
Called within the log write critical section. |
void |
setLastLsnAtRecovery(long lastLsnAtRecovery)
|
void |
setReadHook(TestHook hook)
|
abstract void |
transferToUtilizationTracker(LocalUtilizationTracker localTracker)
|
(package private) void |
transferToUtilizationTrackerInternal(LocalUtilizationTracker localTracker)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected LogBufferPool logBufferPool
protected Latch logWriteLatch
protected EnvironmentImpl envImpl
Constructor Detail |
---|
public LogManager(EnvironmentImpl envImpl, boolean readOnly) throws DatabaseException
DatabaseException
Method Detail |
---|
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 logged
DatabaseException
public long log(LogEntry entry, ReplicationContext repContext) throws DatabaseException
entry
- object to be logged
DatabaseException
public void logLazily(LogEntry entry, ReplicationContext repContext)
entry
- object to be loggedpublic 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
abstract void serialLog(LogItem[] itemArray, LogContext context) throws IOException, DatabaseException
IOException
DatabaseException
void serialLogInternal(LogItem[] itemArray, LogContext context) throws IOException, DatabaseException
IOException
DatabaseException
ByteBuffer putIntoBuffer(LogEntry entry, long prevLogEntryOffset)
public LogEntry getLogEntry(long lsn) throws FileNotFoundException
FileNotFoundException
public LogEntry getLogEntryAllowInvisibleAtRecovery(long lsn) throws FileNotFoundException
FileNotFoundException
public WholeEntry getLogEntryAllowInvisible(long lsn) throws FileNotFoundException
FileNotFoundException
public LogEntry getLogEntryHandleFileNotFound(long lsn) throws DatabaseException
DatabaseException
LogEntry getLogEntryAllowChecksumException(long lsn) throws ChecksumException, FileNotFoundException, DatabaseException
ChecksumException
FileNotFoundException
DatabaseException
LogEntry getLogEntryAllowChecksumException(long lsn, RandomAccessFile file, int logVersion) throws ChecksumException, DatabaseException
ChecksumException
DatabaseException
public ByteBuffer getByteBufferFromLog(long lsn) throws DatabaseException
lsn
- location of entry in log
DatabaseException
public Object getEntry(long lsn) throws FileNotFoundException, DatabaseException
lsn
- location of object in log
FileNotFoundException
DatabaseException
public Object getEntryHandleFileNotFound(long lsn)
public LogSource getLogSource(long lsn) throws FileNotFoundException, ChecksumException, DatabaseException
FileNotFoundException
ChecksumException
DatabaseException
public LogBuffer getReadBufferByLsn(long lsn)
public void flush() throws DatabaseException
DatabaseException
public void flushNoSync() throws DatabaseException
DatabaseException
abstract void flushInternal() throws DatabaseException
DatabaseException
public StatGroup loadStats(StatsConfig config) throws DatabaseException
DatabaseException
public abstract TrackedFileSummary getUnflushableTrackedSummary(long file) throws DatabaseException
DatabaseException
TrackedFileSummary getUnflushableTrackedSummaryInternal(long file)
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, boolean countExact) throws DatabaseException
DatabaseException
void countObsoleteNodeInternal(long lsn, LogEntryType type, int size, DatabaseImpl nodeDb, boolean countExact)
public abstract void countObsoleteNodeDupsAllowed(long lsn, LogEntryType type, int size, DatabaseImpl nodeDb) throws DatabaseException
DatabaseException
void countObsoleteNodeDupsAllowedInternal(long lsn, LogEntryType type, int size, DatabaseImpl nodeDb)
public abstract void transferToUtilizationTracker(LocalUtilizationTracker localTracker) throws DatabaseException
DatabaseException
BaseLocalUtilizationTracker.transferToUtilizationTracker(com.sleepycat.je.cleaner.UtilizationTracker)
void transferToUtilizationTrackerInternal(LocalUtilizationTracker localTracker) throws DatabaseException
DatabaseException
public abstract void countObsoleteDb(DatabaseImpl db) throws DatabaseException
DatabaseException
DatabaseImpl.countObsoleteDb(com.sleepycat.je.cleaner.BaseUtilizationTracker, long)
void countObsoleteDbInternal(DatabaseImpl db)
public abstract boolean removeDbFileSummary(DatabaseImpl db, Long fileNum) throws DatabaseException
DatabaseException
boolean removeDbFileSummaryInternal(DatabaseImpl db, Long fileNum)
public abstract void loadEndOfLogStat() throws DatabaseException
DatabaseException
void loadEndOfLogStatInternal()
public void setReadHook(TestHook hook)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |