org.openorb.notify
Class ResourceReaper

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--org.openorb.notify.ResourceReaper
All Implemented Interfaces:
java.lang.Runnable

public class ResourceReaper
extends java.lang.Thread

The ResourceReaper class is responsible for checking the clients objects. If an invocation _non_existent() returns a COMM_FAILURE or OBJECT_NOT_EXIST. It allows PSS database cleaning when a certain amount of events have been processed by the channels.

Author:
Olivier Modica

Fields inherited from class java.lang.Thread
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
 
Constructor Summary
ResourceReaper()
          Default constructor with the PersistenceHelper object as an argument.
 
Method Summary
 void doEventsClean()
          This method checks if the events database should be cleaned.
 void doResourcesClean()
          This method checks the clients state by invoking _non_existent() on them.
 void run()
          The run method enables the ResourceReaper to do checkings on a timer basis.
 
Methods inherited from class java.lang.Thread
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ResourceReaper

public ResourceReaper()
Default constructor with the PersistenceHelper object as an argument.
Method Detail

doResourcesClean

public void doResourcesClean()
This method checks the clients state by invoking _non_existent() on them.

doEventsClean

public void doEventsClean()
This method checks if the events database should be cleaned.

run

public void run()
The run method enables the ResourceReaper to do checkings on a timer basis.
Overrides:
run in class java.lang.Thread