com.gigaspaces.lrmi.nio.watchdog

Class Watchdog.WatchdogGroup

java.lang.Object

com.gigaspaces.lrmi.nio.watchdog.Watchdog.WatchdogGroup

Enclosing class:

Watchdog

public final class Watchdog.WatchdogGroup
extends Object

WatchdogGroup is a group of objects that are monitored by the Watchdog. Each WatchdogGroup instance has its own configuration.

Since:

5.1

Version:

1.0

Author:

anna

Constructor Summary

Constructors

Constructor and Description
WatchdogGroup(String name, long timeout, int timeoutResolution, com.gigaspaces.lrmi.nio.watchdog.TimeoutObserver observer) Constructor.

Method Summary

Modifier and Type	Method and Description
Watchdog.WatchedObject	addIdleWatch(ConnectionResource client) Add CPeer to the watched objects (idle group)
Watchdog.WatchedObject	addRequestWatch(SocketChannel sock, ConnectionResource client) Add given socket to the watched objects (request group)
Watchdog.WatchedObject	addResponseWatch(SocketChannel sock, ConnectionResource client) Add given socket and cpeer to the watched objects (response group)
protected void	fireTimeoutOccured(Map<Watchdog.WatchedObject,Collection<Watchdog.WatchedObject>> watchedObjects) Fire timeout event about the watched object to the TimeoutObserver
long	getTimeout()
void	removeWatch(Watchdog.WatchedObject watched) Remove given watched object from watch .

Methods inherited from class java.lang.Object

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

Constructor Detail

WatchdogGroup

public WatchdogGroup(String name,
                     long timeout,
                     int timeoutResolution,
                     com.gigaspaces.lrmi.nio.watchdog.TimeoutObserver observer)

Constructor.

Parameters:

timeout - watchdog group timeout in milliseconds

timeoutResolution - in percents

Method Detail

fireTimeoutOccured

protected void fireTimeoutOccured(Map<Watchdog.WatchedObject,Collection<Watchdog.WatchedObject>> watchedObjects)
                           throws Exception

Fire timeout event about the watched object to the TimeoutObserver

Throws:

Exception

See Also:

TimeoutObserver, Watchdog.WatchedObject

addRequestWatch

public Watchdog.WatchedObject addRequestWatch(SocketChannel sock,
                                              ConnectionResource client)

Add given socket to the watched objects (request group)

Parameters:

sock - socket

addResponseWatch

public Watchdog.WatchedObject addResponseWatch(SocketChannel sock,
                                               ConnectionResource client)

Add given socket and cpeer to the watched objects (response group)

Parameters:

sock - socket

addIdleWatch

public Watchdog.WatchedObject addIdleWatch(ConnectionResource client)

Add CPeer to the watched objects (idle group)

removeWatch

public void removeWatch(Watchdog.WatchedObject watched)

Remove given watched object from watch . WatchedObject is set as not in use and later removed by the Watchdog.

getTimeout

public long getTimeout()