| 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.