| Package | Description | 
|---|---|
| com.gigaspaces.lrmi.nio.watchdog | 
| Modifier and Type | Method and Description | 
|---|---|
Watchdog.WatchedObject | 
Watchdog.WatchdogGroup.addIdleWatch(ConnectionResource client)
Add CPeer to the watched objects (idle group) 
 | 
Watchdog.WatchedObject | 
Watchdog.WatchdogGroup.addRequestWatch(SocketChannel sock,
               ConnectionResource client)
Add given socket to the watched objects (request group) 
 | 
Watchdog.WatchedObject | 
Watchdog.WatchdogGroup.addResponseWatch(SocketChannel sock,
                ConnectionResource client)
Add given socket and cpeer to the watched objects (response group) 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected String | 
RequestTimeoutObserver.getInvalidConnectionMessage(SocketAddress serverAddress,
                           SocketChannel watchedSocketChannel,
                           Watchdog.WatchedObject watched)  | 
protected String | 
RequestResponseTimeoutObserver.getInvalidConnectionMessage(SocketAddress serverAddress,
                           SocketChannel watchedSocketChannel,
                           Watchdog.WatchedObject watched)  | 
protected static String | 
RequestTimeoutObserver.getWatchedObjectInvocationMessage(Watchdog.WatchedObject watched)  | 
void | 
Watchdog.WatchdogGroup.removeWatch(Watchdog.WatchedObject watched)
Remove given watched object from watch . 
 | 
| Modifier and Type | Method and Description | 
|---|---|
protected void | 
Watchdog.WatchdogGroup.fireTimeoutOccured(Map<Watchdog.WatchedObject,Collection<Watchdog.WatchedObject>> watchedObjects)
Fire timeout event about the watched object to the TimeoutObserver 
 | 
protected void | 
Watchdog.WatchdogGroup.fireTimeoutOccured(Map<Watchdog.WatchedObject,Collection<Watchdog.WatchedObject>> watchedObjects)
Fire timeout event about the watched object to the TimeoutObserver 
 | 
void | 
RequestTimeoutObserver.timeoutOccured(Collection<Watchdog.WatchedObject> bucket)
bucket can never be empty 
 | 
void | 
IdleConnectionTimeoutObserver.timeoutOccured(Collection<Watchdog.WatchedObject> bucket)
Handle a watched object that exceeded its allowed timeout 
 | 
Copyright © GigaSpaces.