com.sleepycat.je.recovery

Class DirtyINMap

java.lang.Object

com.sleepycat.je.recovery.DirtyINMap

 class DirtyINMap
extends java.lang.Object

Map of Integer->Set level->Set of checkpoint references

Constructor Summary

Constructors

Constructor and Description
DirtyINMap(EnvironmentImpl envImpl)

Method Summary

Methods

Modifier and Type	Method and Description
(package private) void	addCostToMemoryBudget()
(package private) java.lang.Integer	addIN(IN in, boolean updateMemoryBudget) Add a node unconditionally to the dirty map.
(package private) boolean	containsNode(java.lang.Integer level, java.lang.Long nodeId)
(package private) void	flushMapLNs(long checkpointStart) Flushes all saved dirty/temp MapLNs and clears the saved set.
(package private) void	flushRoot(long checkpointStart) Flushes the DB mapping tree root at the end of the checkpoint, if either mapping DB is dirty and the root was not flushed previously during the checkpoint.
(package private) java.util.Iterator<Checkpointer.CheckpointReference>	getIterator(java.lang.Integer level) Get an iterator over the references corresponding to the given level.
(package private) java.lang.Integer	getLowestLevelSet() Get the lowest level currently stored in the map.
(package private) int	getNumLevels()
(package private) void	removeCostFromMemoryBudget()
(package private) void	removeLevel(java.lang.Integer level) Removes the set corresponding to the given level.
(package private) Checkpointer.CheckpointReference	removeNextNode(java.lang.Integer level)
(package private) Checkpointer.CheckpointReference	removeNode(java.lang.Integer level, java.lang.Long nodeId)
(package private) java.util.Map<DatabaseImpl,java.lang.Integer>	selectDirtyINsForCheckpoint(boolean flushAll, boolean flushExtraLevel) Scan the INList for all dirty INs, excluding temp DB INs.
(package private) java.util.Map<DatabaseImpl,java.lang.Integer>	selectDirtyINsForDbSync(DatabaseImpl dbImpl) Scan the INList for all dirty INs for a given database.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DirtyINMap

DirtyINMap(EnvironmentImpl envImpl)

Method Detail

selectDirtyINsForCheckpoint

java.util.Map<DatabaseImpl,java.lang.Integer> selectDirtyINsForCheckpoint(boolean flushAll,
                                                                        boolean flushExtraLevel)
                                                                    throws DatabaseException

Scan the INList for all dirty INs, excluding temp DB INs. Save them in a tree-level ordered map for level ordered flushing. Take this opportunity to reset the memory budget tree value.

Returns:

highestFlushLevels, map of DatabaseImpl to Integer.

Throws:

DatabaseException

selectDirtyINsForDbSync

java.util.Map<DatabaseImpl,java.lang.Integer> selectDirtyINsForDbSync(DatabaseImpl dbImpl)
                                                                throws DatabaseException

Scan the INList for all dirty INs for a given database. Arrange them in level sorted map for level ordered flushing.

Returns:

highestFlushLevels, map of DatabaseImpl to Integer.

Throws:

DatabaseException

getNumLevels

int getNumLevels()

addCostToMemoryBudget

void addCostToMemoryBudget()

removeCostFromMemoryBudget

void removeCostFromMemoryBudget()

addIN

java.lang.Integer addIN(IN in,
                      boolean updateMemoryBudget)

Add a node unconditionally to the dirty map. The dirty map is keyed by level (Integers) and holds sets of IN references.

Parameters:

updateMemoryBudget - if true then update the memory budget as the map is changed; if false then addCostToMemoryBudget must be called later.

Returns:

level of IN added to the dirty map. The level is returned rather than a boolean simply to avoid allocating another Integer in the caller.

getLowestLevelSet

java.lang.Integer getLowestLevelSet()

Get the lowest level currently stored in the map.

getIterator

java.util.Iterator<Checkpointer.CheckpointReference> getIterator(java.lang.Integer level)

Get an iterator over the references corresponding to the given level.

removeLevel

void removeLevel(java.lang.Integer level)

Removes the set corresponding to the given level.

containsNode

boolean containsNode(java.lang.Integer level,
                   java.lang.Long nodeId)

removeNode

Checkpointer.CheckpointReference removeNode(java.lang.Integer level,
                                          java.lang.Long nodeId)

removeNextNode

Checkpointer.CheckpointReference removeNextNode(java.lang.Integer level)

flushMapLNs

void flushMapLNs(long checkpointStart)
           throws DatabaseException

Flushes all saved dirty/temp MapLNs and clears the saved set.

If dirty, a MapLN must be flushed at each checkpoint to record updated utilization info in the checkpoint interval. If it is a temporary DB, the MapLN must be flushed because all temp DBs must be encountered by recovery so they can be removed if they were not closed (and removed) by the user.

Parameters:

checkpointStart - start LSN of the checkpoint in progress. To reduce unnecessary logging, the MapLN is only flushed if it has not been written since that LSN.

Throws:

DatabaseException

flushRoot

void flushRoot(long checkpointStart)
         throws DatabaseException

Flushes the DB mapping tree root at the end of the checkpoint, if either mapping DB is dirty and the root was not flushed previously during the checkpoint.

Parameters:

checkpointStart - start LSN of the checkpoint in progress. To reduce unnecessary logging, the Root is only flushed if it has not been written since that LSN.

Throws:

DatabaseException