protected class FlashJournalRM.PreparerDaemon extends Daemon
Daemon.DaemonWorkerBase.LoggingWriter, Base.StackFrame| Constructor and Description |
|---|
PreparerDaemon()
Construct a PreparerDaemon.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
changeState(int nState, Daemon.DaemonWorker worker)
Change the state of the daemon.
|
protected Daemon.DaemonWorker |
instantiateWorker()
Instantiate a DaemonWorker that will be used as a daemon.
|
void |
notifyItemQueued(FlashJournalRM.JournalFile jrnlfile, long lTicket)
Notify the PreparerDaemon that an item has been queued to be written to the specified JournalFile.
|
void |
notifyJournalFileFull(FlashJournalRM.JournalFile jrnlfile)
Notify the PreparerDaemon that the specified JournalFile has been cut off for new additions.
|
void |
run()
The daemon's implementation method.
|
void |
stop()
Request the daemon to stop.
|
configureWorker, ensureThreadGroup, finishStarting, finishStopping, getConfiguredName, getConfiguredPriority, getContext, getDescription, getGuardRegisterAction, getMaxWaitMillis, getState, getThread, getThreadContextClassLoader, getWorker, guardIfNeeded, heartbeat, heartbeat, isGuarded, isOnWorkerThread, isRunning, isStopping, recover, setConfiguredName, setConfiguredPriority, setContext, setGuardPolicy, setGuardRegisterAction, setThreadContextClassLoader, shutdown, start, terminate, toStateString, toStringazzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, waitprotected Daemon.DaemonWorker instantiateWorker()
instantiateWorker in class Daemonpublic void run()
An example implementation is:
while (!isStopping())
{
// do some processing
// ...
synchronized (this)
{
// wait for notification of more work
wait();
}
}
protected void changeState(int nState,
Daemon.DaemonWorker worker)
changeState in class DaemonnState - one of the STATE_enumsworker - the new worker, if starting, otherwise the current workerpublic void stop()
Daemon.isStopping().public void notifyItemQueued(FlashJournalRM.JournalFile jrnlfile, long lTicket)
jrnlfile - the JournalFile that is being appended tolTicket - the ticket for the item that was queuedpublic void notifyJournalFileFull(FlashJournalRM.JournalFile jrnlfile)
jrnlfile - the JournalFile that is now full