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.