com.gigaspaces.lrmi.nio.watchdog

Class RequestTimeoutObserver

java.lang.Object

com.gigaspaces.lrmi.nio.watchdog.RequestTimeoutObserver

Direct Known Subclasses:

RequestResponseTimeoutObserver

public class RequestTimeoutObserver
extends Object

RequestTimeoutObserver handles NIO connection timeouts on the client side. If client doesn't receive a reply, it checks the connection with the server and if it is not valid anymore, the connection is closed.

Since:

5.1

Version:

1.0

Author:

anna

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	_INSPECT_TIMEOUT
protected static org.slf4j.Logger	_logger

Constructor Summary

Constructors

Constructor and Description
RequestTimeoutObserver(long requestTimeout)

Method Summary

Modifier and Type	Method and Description
protected LogLevel	getCloseConnectionLoggingLevel()
protected String	getFailureToCloseInvalidConnectionMessage(SocketAddress serverAddress, SocketChannel watchedSocketChannel)
protected String	getInvalidConnectionMessage(SocketAddress serverAddress, SocketChannel watchedSocketChannel, Watchdog.WatchedObject watched)
protected String	getLocalAddressString(SocketChannel socketChannel)
protected String	getValidConnectionMessage(SocketAddress serverAddress)
protected static String	getWatchedObjectInvocationMessage(Watchdog.WatchedObject watched)
protected void	handleOpenSocket(SocketChannel socketChannel, int watchedObjectLocalPort, long absoluteTimeout, ConnectionResource connectionResource)
void	timeoutOccured(Collection<Watchdog.WatchedObject> bucket) bucket can never be empty

Methods inherited from class java.lang.Object

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

Field Detail

_INSPECT_TIMEOUT

protected static final int _INSPECT_TIMEOUT

_logger

protected static final org.slf4j.Logger _logger

Constructor Detail

RequestTimeoutObserver

public RequestTimeoutObserver(long requestTimeout)

Method Detail

timeoutOccured

public void timeoutOccured(Collection<Watchdog.WatchedObject> bucket)
                    throws Exception

bucket can never be empty

Throws:

Exception

See Also:

nio.watchdog.Watchdog#add(Map>, WatchedObject), nio.watchdog.TimeoutObserver#timeoutOccured(nio.watchdog.Watchdog.WatchedObject)

handleOpenSocket

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

Parameters:

connectionResource - the monitored cpeer

Throws:

IOException

getValidConnectionMessage

protected String getValidConnectionMessage(SocketAddress serverAddress)

getInvalidConnectionMessage

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

getFailureToCloseInvalidConnectionMessage

protected String getFailureToCloseInvalidConnectionMessage(SocketAddress serverAddress,
                                                           SocketChannel watchedSocketChannel)

getLocalAddressString

protected String getLocalAddressString(SocketChannel socketChannel)

getCloseConnectionLoggingLevel

protected LogLevel getCloseConnectionLoggingLevel()

getWatchedObjectInvocationMessage

protected static String getWatchedObjectInvocationMessage(Watchdog.WatchedObject watched)