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

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

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, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, 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.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread