Package com.gigaspaces.lrmi.nio.watchdog

Class Watchdog

java.lang.Object

java.lang.Thread

com.gigaspaces.internal.utils.concurrent.GSThread

com.gigaspaces.lrmi.nio.watchdog.Watchdog

All Implemented Interfaces:

Runnable

public class Watchdog
extends GSThread

Watchdog for network failure detection and handling idle threads.

Since:

5.0

Version:

1.0

Author:

anna

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	Watchdog.Group	Groups indices
final class	Watchdog.WatchdogGroup	WatchdogGroup is a group of objects that are monitored by the Watchdog.
static class	Watchdog.WatchedObject	Object watched by the Watchdog - WatchedObject is used to watch NIO connections

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
Watchdog(String name, long requestTimeout, long listeningTimeout, long idleTimeout, int timeoutResolution, boolean protocolValidationEnabled)	Constructor

Method Summary

Modifier and Type	Method	Description
static Watchdog.WatchdogGroup	getGroup(Watchdog.Group group)	Get WatchdogGroup and initialize singleton WatchDog daemon per JVM.
void	run()	Watchdog main method.
static void	shutdown()	Shuts down the watchdog if operation, this is irreversable process.

Methods inherited from class com.gigaspaces.internal.utils.concurrent.GSThread

daemon

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

Watchdog

public Watchdog(String name,
 long requestTimeout,
 long listeningTimeout,
 long idleTimeout,
 int timeoutResolution,
 boolean protocolValidationEnabled)

Constructor

Method Details

getGroup

public static Watchdog.WatchdogGroup getGroup(Watchdog.Group group)

Get WatchdogGroup and initialize singleton WatchDog daemon per JVM.

shutdown

public static void shutdown()

Shuts down the watchdog if operation, this is irreversable process.

run

public void run()

Watchdog main method. Watchdog monitors several WatchdogGroups that have different timeout settings. Therefore its sleeping timeout is calculated each time to be the next closest running time of its groups. TODO verify that Watchdog processing time that is not taken into consideration doesn't create a large timing error

Specified by:

run in interface Runnable

Overrides:

run in class Thread