|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.sleepycat.je.cleaner.UtilizationProfile
public class UtilizationProfile
The UP tracks utilization summary information for all log files.
Unlike the UtilizationTracker, the UP is not accessed under the log write latch and is instead synchronized on itself for protecting the cache. It is not accessed during the primary data access path, except for when flushing (writing) file summary LNs. This occurs in the following cases:
The cache is populated by the RecoveryManager just before performing the initial checkpoint. The UP must be open and populated in order to respond to requests to flush summaries and to evict tracked detail, even if the cleaner is disabled.
WARNING: While synchronized on this object, eviction is not permitted. If it were, this could cause deadlocks because the order of locking would be the UP object and then the evictor. During normal eviction the order is to first lock the evictor and then the UP, when evicting tracked detail.
The methods in this class synchronize to protect the cached summary information. Some methods also access the UP database. However, because eviction must not occur while synchronized, UP database access is not performed while synchronized except in one case: when inserting a new summary record. In that case we disallow eviction during the database operation.
Field Summary | |
---|---|
(package private) int |
minAge
Minumum age to qualify for cleaning. |
(package private) int |
minFileUtilization
Minimum utilization threshold for an individual log file that triggers cleaning. |
(package private) int |
minUtilization
Minimum overall utilization threshold that triggers cleaning. |
Constructor Summary | |
---|---|
UtilizationProfile(EnvironmentImpl env,
UtilizationTracker tracker)
Creates an empty UP. |
Method Summary | |
---|---|
void |
clearCache()
Clears the cache of file summary info. |
(package private) void |
close()
Update memory budgets when this profile is closed and will never be accessed again. |
void |
envConfigUpdate(DbConfigManager cm,
EnvironmentMutableConfig ignore)
Process notifications of mutable property changes. |
void |
flushFileSummary(TrackedFileSummary tfs)
Updates and stores the FileSummary for a given tracked file, if flushing of the summary is allowed. |
void |
flushFileUtilization(Collection<TrackedFileSummary> activeFiles)
Flush a FileSummaryLN node for each TrackedFileSummary that is currently active in the given tracker. |
void |
flushLocalTracker(LocalUtilizationTracker localTracker)
Count the given locally tracked info as obsolete and then log the file and database info.. |
(package private) Long |
getBestFileForCleaning(FileSelector fileSelector,
boolean forceCleaning,
Set<Long> lowUtilizationFiles,
boolean isBacklog)
Returns the best file that qualifies for cleaning, or null if no file qualifies. |
(package private) Long |
getCheapestFileToClean(SortedSet<Long> files)
Returns the cheapest file to clean from the given list of files. |
DatabaseImpl |
getFileSummaryDb()
For unit testing. |
SortedMap<Long,FileSummary> |
getFileSummaryMap(boolean includeTrackedFiles)
Returns a copy of the current file summary map, optionally including tracked summary information, for use by the DbSpace utility and by unit tests. |
(package private) int |
getNumberOfFiles()
Returns the number of files in the profile. |
(package private) TrackedFileSummary |
getObsoleteDetail(Long fileNum,
PackedOffsets packedOffsets,
boolean logUpdate)
Returns the stored/packed obsolete offsets and the tracked obsolete offsets for the given file. |
(package private) long |
getTotalLogSize()
Returns an approximation of the total log size. |
boolean |
insertFileSummary(FileSummaryLN ln,
long fileNum,
int sequence)
Insert the given LN with the given key values. |
boolean |
isRMWFixEnabled()
|
boolean |
populateCache()
Populate the profile for file selection. |
(package private) void |
removeFile(Long fileNum,
Set<DatabaseId> databases)
Removes a file from the utilization database and the profile, after it has been deleted by the cleaner. |
static int |
utilization(long obsoleteSize,
long totalSize)
Calculate the utilization percentage. |
boolean |
verifyFileSummaryDatabase()
Checks that all FSLN offsets are indeed obsolete. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
int minUtilization
int minFileUtilization
int minAge
Constructor Detail |
---|
public UtilizationProfile(EnvironmentImpl env, UtilizationTracker tracker)
Method Detail |
---|
public void envConfigUpdate(DbConfigManager cm, EnvironmentMutableConfig ignore)
envConfigUpdate
in interface EnvConfigObserver
public boolean isRMWFixEnabled()
EnvironmentParams.CLEANER_RMW_FIX
,
FileSummaryLN.postFetchInit(com.sleepycat.je.dbi.DatabaseImpl, long)
int getNumberOfFiles()
long getTotalLogSize()
Long getCheapestFileToClean(SortedSet<Long> files)
Long getBestFileForCleaning(FileSelector fileSelector, boolean forceCleaning, Set<Long> lowUtilizationFiles, boolean isBacklog) throws DatabaseException
fileSelector
- is used to determine valid cleaning candidates.forceCleaning
- is true to always select a file, even if its
utilization is above the minimum utilization threshold.lowUtilizationFiles
- is a returned set of files that are below the
minimum utilization threshold.
DatabaseException
public static int utilization(long obsoleteSize, long totalSize)
public void flushLocalTracker(LocalUtilizationTracker localTracker) throws DatabaseException
DatabaseException
public void flushFileUtilization(Collection<TrackedFileSummary> activeFiles) throws DatabaseException
DatabaseException
public SortedMap<Long,FileSummary> getFileSummaryMap(boolean includeTrackedFiles)
public void clearCache()
void removeFile(Long fileNum, Set<DatabaseId> databases) throws DatabaseException
DatabaseException
public void flushFileSummary(TrackedFileSummary tfs) throws DatabaseException
DatabaseException
TrackedFileSummary getObsoleteDetail(Long fileNum, PackedOffsets packedOffsets, boolean logUpdate) throws DatabaseException
logUpdate
- if true, log any updates to the utilization profile. If
false, only retrieve the new information.
DatabaseException
public boolean populateCache() throws DatabaseException
DatabaseException
public DatabaseImpl getFileSummaryDb()
public boolean insertFileSummary(FileSummaryLN ln, long fileNum, int sequence) throws DatabaseException
DatabaseException
public boolean verifyFileSummaryDatabase() throws DatabaseException
DatabaseException
void close()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |