Package 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	Description
RequestResponseTimeoutObserver(long requestTimeout, boolean protocolValidationEnabled)

Method Summary

Modifier and Type	Method	Description
protected LogLevel	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 Details

RequestResponseTimeoutObserver

public RequestResponseTimeoutObserver(long requestTimeout,
 boolean protocolValidationEnabled)

Method Details

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 LogLevel getCloseConnectionLoggingLevel()

Overrides:

getCloseConnectionLoggingLevel in class RequestTimeoutObserver