| java.lang.Object com.sleepycat.je.utilint.DaemonThread com.sleepycat.je.cleaner.FileProcessor
FileProcessor | class FileProcessor extends DaemonThread (Code) | | Reads all entries in a log file and either determines them to be obsolete or
marks them for migration. LNs are marked for migration by setting the BIN
entry MIGRATE flag. INs are marked for migration by setting the dirty flag.
May be invoked explicitly by calling doClean, or woken up if used as a
daemon thread.
|
Method Summary | |
void | addSentinalWorkObject() Adds a sentinal object to the work queue to force onWakeup to be
called immediately after setting je.env.runCleaner=true. | public void | addToQueue(Object o) Cleaner doesn't have a work queue so just throw an exception if it's
ever called. | public void | clearEnv() | public synchronized int | doClean(boolean invokedFromDaemon, boolean cleanMultipleFiles, boolean forceCleaning) Cleans selected files and returns the number of files cleaned. | protected int | nDeadlockRetries() Return the number of retries when a deadlock exception occurs. | public void | onWakeup() Activates the cleaner. |
addSentinalWorkObject | void addSentinalWorkObject()(Code) | | Adds a sentinal object to the work queue to force onWakeup to be
called immediately after setting je.env.runCleaner=true. We want to
process any backlog immediately.
|
addToQueue | public void addToQueue(Object o) throws DatabaseException(Code) | | Cleaner doesn't have a work queue so just throw an exception if it's
ever called.
|
clearEnv | public void clearEnv()(Code) | | |
doClean | public synchronized int doClean(boolean invokedFromDaemon, boolean cleanMultipleFiles, boolean forceCleaning) throws DatabaseException(Code) | | Cleans selected files and returns the number of files cleaned. May be
called by the daemon thread or programatically.
Parameters: invokedFromDaemon - currently has no effect. Parameters: cleanMultipleFiles - is true to clean until we're under budget,or false to clean at most one file. Parameters: forceCleaning - is true to clean even if we're not under theutilization threshold. the number of files cleaned, not including files cleanedunsuccessfully. |
nDeadlockRetries | protected int nDeadlockRetries() throws DatabaseException(Code) | | Return the number of retries when a deadlock exception occurs.
|
onWakeup | public void onWakeup() throws DatabaseException(Code) | | Activates the cleaner. Is normally called when je.cleaner.byteInterval
bytes are written to the log.
|
|
|