|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.util.Base
com.tangosol.util.Daemon
com.tangosol.io.journal.AbstractJournalRM.CollectorDaemon
protected class AbstractJournalRM.CollectorDaemon
The CollectorDaemon evaluates the JournalFile objects to see which ones should be evacuated, it evacuates those that should be, and it deletes those that have been successfully evacuated.
This daemon is not intended to be guarded.
Nested Class Summary | |
---|---|
protected class |
AbstractJournalRM.CollectorDaemon.CollectionCoordinator A CollectionCoordinator is responsible for shaping an evacuation as well as managing any reserved files created to ensure the journal continues to operate. |
protected class |
AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile A AbstractJournalRM.JournalFile implementation returned when the journal has consumed all known capacity. |
Nested classes/interfaces inherited from class com.tangosol.util.Daemon |
---|
Daemon.DaemonWorker |
Constructor Summary | |
---|---|
AbstractJournalRM.CollectorDaemon() Construct a CollectorDaemon. |
Method Summary | |
---|---|
protected void |
dedupe() Give the in-memory radix key stores a chance to de-dupe their byte[] values, similar to the concept behind String's intern() method. |
protected AbstractJournalRM.CollectorDaemon.CollectionCoordinator |
getCoordinator() Return a AbstractJournalRM.CollectorDaemon.CollectionCoordinator . |
protected java.lang.String |
getDescription() Format the Daemon attributes into a String for inclusion in the String returned from the Daemon.toString() method. |
protected int |
getReservedFileId() Return the currently reserved file id. |
protected Daemon.DaemonWorker |
instantiateWorker() Instantiate a DaemonWorker that will be used as a daemon. |
void |
notifyReleased(int cbReleased, int nFileId) Notifies the collector that a AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile has had some memory released. |
void |
run() The daemon's implementation method. |
protected void |
setGuardPolicy(Guardian guardian, long cTimeoutMillis, float flPctRecover) Set the Guardian and policy to guard this Daemon with. |
protected java.util.Iterator |
sortedIterator() Returns a sorted Iterator based on the amount of released memory in each AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile . |
void |
stop() Request the daemon to stop. |
Methods inherited from class com.tangosol.util.Daemon |
---|
changeState, configureWorker, ensureThreadGroup, finishStarting, finishStopping, getConfiguredName, getConfiguredPriority, getContext, getGuardRegisterAction, getMaxWaitMillis, getState, getThread, getThreadContextClassLoader, getWorker, guardIfNeeded, heartbeat, heartbeat, isGuarded, isOnWorkerThread, isRunning, isStopping, recover, setConfiguredName, setConfiguredPriority, setContext, setGuardRegisterAction, setThreadContextClassLoader, shutdown, start, terminate, toStateString, toString |
Constructor Detail |
---|
public AbstractJournalRM.CollectorDaemon()
Method Detail |
---|
protected Daemon.DaemonWorker instantiateWorker()
instantiateWorker
in class Daemon
public void stop()
Daemon.isStopping()
.stop
in class Daemon
public void run()
An example implementation is:
while (!isStopping())
{
// do some processing
// ...
synchronized (this)
{
// wait for notification of more work
wait();
}
}
run
in interface java.lang.Runnable
run
in class Daemon
protected void setGuardPolicy(Guardian guardian, long cTimeoutMillis, float flPctRecover)
setGuardPolicy
in class Daemon
guardian
- the Guardian that will be guarding this DaemoncTimeoutMillis
- the timeout in ms for this Daemon, or 0 for the service guardian timeoutflPctRecover
- the recovery percentage for this Daemonprotected java.util.Iterator sortedIterator()
Iterator
based on the amount of released memory in each AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile
.protected java.lang.String getDescription()
Daemon.toString()
method.getDescription
in class Daemon
protected void dedupe()
public void notifyReleased(int cbReleased, int nFileId)
AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile
has had some memory released.cbReleased
- the number of bytes releasednFileId
- the AbstractJournalRM.CollectorDaemon.InvokeGCJournalFile
's file idprotected int getReservedFileId()
protected AbstractJournalRM.CollectorDaemon.CollectionCoordinator getCoordinator()
AbstractJournalRM.CollectorDaemon.CollectionCoordinator
.
|
Oracle® Fusion Middleware Java API Reference for Oracle Coherence 12c (12.1.3.0.0) E47890-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |