com.gigaspaces.lrmi.nio.watchdog

Class RequestResponseTimeoutObserver

java.lang.Object

com.gigaspaces.lrmi.nio.watchdog.RequestTimeoutObserver

com.gigaspaces.lrmi.nio.watchdog.RequestResponseTimeoutObserver

public class RequestResponseTimeoutObserver
extends RequestTimeoutObserver

On top of RequestTimeoutObserver behaviour, The request response timeout observer also sends a monitor request to the corresponding server and checks whether the corresponding channel entry in currently in progress. If not the connection is considered dead and will be closed.

Since:

9.5

Author:

Dan Kilman

Field Summary

Fields inherited from class com.gigaspaces.lrmi.nio.watchdog.RequestTimeoutObserver

_INSPECT_TIMEOUT, _logger

Constructor Summary

Constructors

Constructor and Description
RequestResponseTimeoutObserver(long requestTimeout, boolean protocolValidationEnabled)

Method Summary

Modifier and Type	Method and Description
protected Level	getCloseConnectionLoggingLevel()
protected String	getFailureToCloseInvalidConnectionMessage(SocketAddress serverAddress, SocketChannel watchedSocketChannel)
protected String	getInvalidConnectionMessage(SocketAddress serverAddress, SocketChannel watchedSocketChannel, Watchdog.WatchedObject watched)
protected String	getValidConnectionMessage(SocketAddress serverAddress)
protected void	handleOpenSocket(SocketChannel socketChannel, int watchedSocketLocalPort, long absoluteTimeout, ConnectionResource connectionResource)

Methods inherited from class com.gigaspaces.lrmi.nio.watchdog.RequestTimeoutObserver

getLocalAddressString, getWatchedObjectInvocationMessage, timeoutOccured

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestResponseTimeoutObserver

public RequestResponseTimeoutObserver(long requestTimeout,
                                      boolean protocolValidationEnabled)

Method Detail

handleOpenSocket

protected void handleOpenSocket(SocketChannel socketChannel,
                                int watchedSocketLocalPort,
                                long absoluteTimeout,
                                ConnectionResource connectionResource)
                         throws IOException

Overrides:

handleOpenSocket in class RequestTimeoutObserver

connectionResource - the monitored cpeer

Throws:

IOException

getValidConnectionMessage

protected String getValidConnectionMessage(SocketAddress serverAddress)

Overrides:

getValidConnectionMessage in class RequestTimeoutObserver

getInvalidConnectionMessage

protected String getInvalidConnectionMessage(SocketAddress serverAddress,
                                             SocketChannel watchedSocketChannel,
                                             Watchdog.WatchedObject watched)

Overrides:

getInvalidConnectionMessage in class RequestTimeoutObserver

getFailureToCloseInvalidConnectionMessage

protected String getFailureToCloseInvalidConnectionMessage(SocketAddress serverAddress,
                                                           SocketChannel watchedSocketChannel)

Overrides:

getFailureToCloseInvalidConnectionMessage in class RequestTimeoutObserver

getCloseConnectionLoggingLevel

protected Level getCloseConnectionLoggingLevel()

Overrides:

getCloseConnectionLoggingLevel in class RequestTimeoutObserver