Class InterruptibleRMIServerSocket

java.lang.Object

java.net.ServerSocket

ecmwf.common.rmi.interruptible.InterruptibleRMIServerSocket

All Implemented Interfaces:

Closeable, AutoCloseable

public final class InterruptibleRMIServerSocket
extends ServerSocket

The Class InterruptibleRMIServerSocket.

Constructor Summary

Constructors

Constructor	Description
InterruptibleRMIServerSocket(ServerSocket serverSocket)	Create decorator for given socket.

Method Summary

Modifier and Type	Method	Description
Socket	accept()	Accept.
void	bind(SocketAddress endpoint)	Bind.
void	bind(SocketAddress endpoint, int backlog)	Bind.
void	close()	Close.
boolean	equals(Object obj)	Returns true if the decoratee's equals method returns true.
ServerSocketChannel	getChannel()	Not implemented - always returns null.
static Socket	getCurrentRMIServerThreadSocket()	Return the socket associated with the RMI server thread (the current thread).
InetAddress	getInetAddress()	Gets the inet address.
int	getLocalPort()	Gets the local port.
SocketAddress	getLocalSocketAddress()	Gets the local socket address.
int	getReceiveBufferSize()	Gets the receive buffer size.
boolean	getReuseAddress()	Gets the reuse address.
int	getSoTimeout()	Gets the so timeout.
int	hashCode()	Return the hashcode of the decorated socket.
boolean	isBound()	Checks if is bound.
boolean	isClosed()	Checks if is closed.
static boolean	isCurrentRMIServerThreadSocketAlive()	Return true if the socket associated with the RMI server thread (the current thread) has not been closed or marked for shutdown by the client of the RMI thread.
static boolean	isCurrentRMIServerThreadSocketAlive(Socket socket)	Return true if the socket provided has not been closed or marked for shutdown by the client of the RMI thread.
void	setPerformancePreferences(int connectionTime, int latency, int bandwidth)	Sets the performance preferences.
void	setReceiveBufferSize(int size)	Sets the receive buffer size.
void	setReuseAddress(boolean on)	Sets the reuse address.
void	setSoTimeout(int timeout)	Sets the so timeout.
String	toString()	To string.

Methods inherited from class java.net.ServerSocket

getOption, implAccept, setOption, setSocketFactory, supportedOptions

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

InterruptibleRMIServerSocket

public InterruptibleRMIServerSocket(ServerSocket serverSocket)
                             throws IOException

Create decorator for given socket.

Parameters:

serverSocket - the server socket

Throws:

IOException - Signals that an I/O exception has occurred.

Method Details

getCurrentRMIServerThreadSocket

public static Socket getCurrentRMIServerThreadSocket()

Return the socket associated with the RMI server thread (the current thread).

Returns:

socket

isCurrentRMIServerThreadSocketAlive

public static boolean isCurrentRMIServerThreadSocketAlive()

Return true if the socket associated with the RMI server thread (the current thread) has not been closed or marked for shutdown by the client of the RMI thread.

Returns:

true, if is current RMI server thread socket alive

isCurrentRMIServerThreadSocketAlive

public static boolean isCurrentRMIServerThreadSocketAlive(Socket socket)

Return true if the socket provided has not been closed or marked for shutdown by the client of the RMI thread. The socket is provided beforehand by a call to the getCurrentRMIServerThreadSocket method.

Parameters:

socket - the socket

Returns:

true, if is current RMI server thread socket alive

accept

public Socket accept()
              throws IOException

Accept.

Overrides:

accept in class ServerSocket

Throws:

IOException

See Also:

• ServerSocket.accept()

bind

public void bind(SocketAddress endpoint,
 int backlog)
          throws IOException

Bind.

Overrides:

bind in class ServerSocket

Throws:

IOException

See Also:

• ServerSocket.bind(java.net.SocketAddress, int)

bind

public void bind(SocketAddress endpoint)
          throws IOException

Bind.

Overrides:

bind in class ServerSocket

Throws:

IOException

See Also:

• ServerSocket.bind(java.net.SocketAddress)

close

public void close()
           throws IOException

Close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class ServerSocket

Throws:

IOException

See Also:

• ServerSocket.close()

equals

public boolean equals(Object obj)

Returns true if the decoratee's equals method returns true.

Overrides:

equals in class Object

getChannel

public ServerSocketChannel getChannel()

Not implemented - always returns null.

Overrides:

getChannel in class ServerSocket

See Also:

• ServerSocket.getChannel()

getInetAddress

public InetAddress getInetAddress()

Gets the inet address.

Overrides:

getInetAddress in class ServerSocket

See Also:

• ServerSocket.getInetAddress()

getLocalPort

public int getLocalPort()

Gets the local port.

Overrides:

getLocalPort in class ServerSocket

See Also:

• ServerSocket.getLocalPort()

getLocalSocketAddress

public SocketAddress getLocalSocketAddress()

Gets the local socket address.

Overrides:

getLocalSocketAddress in class ServerSocket

See Also:

• ServerSocket.getLocalSocketAddress()

getReceiveBufferSize

public int getReceiveBufferSize()
                         throws SocketException

Gets the receive buffer size.

Overrides:

getReceiveBufferSize in class ServerSocket

Throws:

SocketException

See Also:

• ServerSocket.getReceiveBufferSize()

getReuseAddress

public boolean getReuseAddress()
                        throws SocketException

Gets the reuse address.

Overrides:

getReuseAddress in class ServerSocket

Throws:

SocketException

See Also:

• ServerSocket.getReuseAddress()

getSoTimeout

public int getSoTimeout()
                 throws IOException

Gets the so timeout.

Overrides:

getSoTimeout in class ServerSocket

Throws:

IOException

See Also:

• ServerSocket.getSoTimeout()

hashCode

public int hashCode()

Return the hashcode of the decorated socket.

Overrides:

hashCode in class Object

isBound

public boolean isBound()

Checks if is bound.

Overrides:

isBound in class ServerSocket

See Also:

• ServerSocket.isBound()

isClosed

public boolean isClosed()

Checks if is closed.

Overrides:

isClosed in class ServerSocket

See Also:

• ServerSocket.isClosed()

setPerformancePreferences

public void setPerformancePreferences(int connectionTime,
 int latency,
 int bandwidth)

Sets the performance preferences.

Overrides:

setPerformancePreferences in class ServerSocket

See Also:

• ServerSocket.setPerformancePreferences(int, int, int)

setReceiveBufferSize

public void setReceiveBufferSize(int size)
                          throws SocketException

Sets the receive buffer size.

Overrides:

setReceiveBufferSize in class ServerSocket

Throws:

SocketException

See Also:

• ServerSocket.setReceiveBufferSize(int)

setReuseAddress

public void setReuseAddress(boolean on)
                     throws SocketException

Sets the reuse address.

Overrides:

setReuseAddress in class ServerSocket

Throws:

SocketException

See Also:

• ServerSocket.setReuseAddress(boolean)

setSoTimeout

public void setSoTimeout(int timeout)
                  throws SocketException

Sets the so timeout.

Overrides:

setSoTimeout in class ServerSocket

Throws:

SocketException

See Also:

• ServerSocket.setSoTimeout(int)

toString

public String toString()

To string.

Overrides:

toString in class ServerSocket

See Also:

• ServerSocket.toString()