|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.utilint.DaemonThread
com.sleepycat.je.recovery.Checkpointer
public class Checkpointer
The Checkpointer looks through the tree for internal nodes that must be flushed to the log. Checkpoint flushes must be done in ascending order from the bottom of the tree up.
Nested Class Summary | |
---|---|
(package private) static class |
Checkpointer.CheckpointReference
|
Field Summary |
---|
Fields inherited from class com.sleepycat.je.utilint.DaemonThread |
---|
name, nWakeupRequests, workQueue, workQueueLatch |
Constructor Summary | |
---|---|
Checkpointer(EnvironmentImpl envImpl,
long waitTime,
String name)
|
Method Summary | |
---|---|
void |
clearEnv()
|
void |
doCheckpoint(CheckpointConfig config,
boolean flushAll,
String invokingSource)
The real work to do a checkpoint. |
long |
getFirstActiveLsn()
|
int |
getHighestFlushLevel()
|
static long |
getWakeupPeriod(DbConfigManager configManager)
Figure out the wakeup period. |
void |
loadStats(StatsConfig config,
EnvironmentStats stat)
Load stats. |
protected int |
nDeadlockRetries()
Return the number of retries when a deadlock exception occurs. |
protected void |
onWakeup()
Called whenever the DaemonThread wakes up from a sleep. |
void |
setCheckpointId(long lastCheckpointId)
Set checkpoint id -- can only be done after recovery. |
void |
setFirstActiveLsn(long lastFirstActiveLsn)
Initialize the FirstActiveLsn during recovery. |
String |
toString()
|
Methods inherited from class com.sleepycat.je.utilint.DaemonThread |
---|
addToQueue, addToQueueAlreadyLatched, getNWakeupRequests, getQueueSize, getThread, isRunning, isShutdownRequested, requestShutdown, run, runOrPause, shutdown, wakeup |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public Checkpointer(EnvironmentImpl envImpl, long waitTime, String name) throws DatabaseException
DatabaseException
Method Detail |
---|
public int getHighestFlushLevel()
public static long getWakeupPeriod(DbConfigManager configManager) throws IllegalArgumentException, DatabaseException
IllegalArgumentException
DatabaseException
public void setCheckpointId(long lastCheckpointId)
public String toString()
toString
in class DaemonThread
public void loadStats(StatsConfig config, EnvironmentStats stat) throws DatabaseException
DatabaseException
public long getFirstActiveLsn()
public void setFirstActiveLsn(long lastFirstActiveLsn)
public void clearEnv()
protected int nDeadlockRetries() throws DatabaseException
nDeadlockRetries
in class DaemonThread
DatabaseException
protected void onWakeup() throws DatabaseException
onWakeup
in class DaemonThread
DatabaseException
public void doCheckpoint(CheckpointConfig config, boolean flushAll, String invokingSource) throws DatabaseException
allowDeltas
- if true, this checkpoint may opt to log BIN deltas
instead of the full node.flushAll
- if true, this checkpoint must flush all the way to
the top of the dbtree, instead of stopping at the highest level
last modified.invokingSource
- a debug aid, to indicate who invoked this
checkpoint. (i.e. recovery, the checkpointer daemon, the cleaner,
programatically)
DatabaseException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |