Class InterruptibleRMIClientSocket

java.lang.Object

java.net.Socket

ecmwf.common.rmi.interruptible.InterruptibleRMIClientSocket

All Implemented Interfaces:

Closeable, AutoCloseable

public final class InterruptibleRMIClientSocket
extends Socket

The Class InterruptibleRMIClientSocket.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Socket	currentDecoratee	The current decoratee.
protected static final byte	SHUTDOWN_SOCKET	The Constant SHUTDOWN_SOCKET.

Constructor Summary

Constructors

Constructor	Description
InterruptibleRMIClientSocket(Socket decoratee)	Instantiates a new interruptible RMI client socket.

Method Summary

Modifier and Type	Method	Description
void	bind(SocketAddress bindpoint)	Bind.
void	close()	Close.
void	connect(SocketAddress endpoint)	Connect.
void	connect(SocketAddress endpoint, int timeout)	Connect.
boolean	equals(Object obj)	Equals.
SocketChannel	getChannel()	This decorator does not implement a decorated SocketChannel.
InetAddress	getInetAddress()	Gets the inet address.
InputStream	getInputStream()	Gets the input stream.
boolean	getKeepAlive()	Gets the keep alive.
InetAddress	getLocalAddress()	Gets the local address.
int	getLocalPort()	Gets the local port.
SocketAddress	getLocalSocketAddress()	Gets the local socket address.
boolean	getOOBInline()	Gets the OOB inline.
OutputStream	getOutputStream()	Gets the output stream.
int	getPort()	Gets the port.
int	getReceiveBufferSize()	Gets the receive buffer size.
SocketAddress	getRemoteSocketAddress()	Gets the remote socket address.
boolean	getReuseAddress()	Gets the reuse address.
int	getSendBufferSize()	Gets the send buffer size.
int	getSoLinger()	Gets the so linger.
int	getSoTimeout()	Gets the so timeout.
boolean	getTcpNoDelay()	Gets the tcp no delay.
int	getTrafficClass()	Gets the traffic class.
int	hashCode()	Hash code.
boolean	isBound()	Checks if is bound.
boolean	isClosed()	Checks if is closed.
boolean	isConnected()	Checks if is connected.
boolean	isInputShutdown()	Checks if is input shutdown.
boolean	isOutputShutdown()	Checks if is output shutdown.
void	sendUrgentData(int data)	Send urgent data.
void	setKeepAlive(boolean on)	Sets the keep alive.
void	setOOBInline(boolean on)	Sets the OOB inline.
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	setSendBufferSize(int size)	Sets the send buffer size.
void	setSoLinger(boolean on, int linger)	Sets the so linger.
void	setSoTimeout(int timeout)	Sets the so timeout.
void	setTcpNoDelay(boolean on)	Sets the tcp no delay.
void	setTrafficClass(int tc)	Sets the traffic class.
void	shutdownInput()	Shutdown input.
void	shutdownOutput()	Shutdown output.
String	toString()	To string.

Methods inherited from class Socket

getOption, setOption, setSocketImplFactory, supportedOptions

Methods inherited from class Object

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

Field Details

SHUTDOWN_SOCKET

protected static final byte SHUTDOWN_SOCKET

The Constant SHUTDOWN_SOCKET.

See Also:

• Constant Field Values

currentDecoratee

protected final Socket currentDecoratee

The current decoratee.

Constructor Details

InterruptibleRMIClientSocket

public InterruptibleRMIClientSocket(Socket decoratee)

Instantiates a new interruptible RMI client socket.

Parameters:

decoratee - the decoratee

Method Details

getInputStream

public InputStream getInputStream()
                           throws IOException

Gets the input stream.

Overrides:

getInputStream in class Socket

Returns:

the input stream

Throws:

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

getOutputStream

public OutputStream getOutputStream()
                             throws IOException

Gets the output stream.

Overrides:

getOutputStream in class Socket

Returns:

the output stream

Throws:

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

bind

public void bind(SocketAddress bindpoint)
          throws IOException

Bind.

Overrides:

bind in class Socket

Parameters:

bindpoint - the bindpoint

Throws:

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

close

public void close()
           throws IOException

Close.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Overrides:

close in class Socket

Throws:

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

connect

public void connect(SocketAddress endpoint)
             throws IOException

Connect.

Overrides:

connect in class Socket

Parameters:

endpoint - the endpoint

Throws:

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

connect

public void connect(SocketAddress endpoint,
 int timeout)
             throws IOException

Connect.

Overrides:

connect in class Socket

Parameters:

endpoint - the endpoint

timeout - the timeout

Throws:

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

equals

public boolean equals(Object obj)

Equals.

Overrides:

equals in class Object

Parameters:

obj - the obj

Returns:

true, if successful

getChannel

public SocketChannel getChannel()

This decorator does not implement a decorated SocketChannel. This method will always return null.

Overrides:

getChannel in class Socket

Returns:

the channel

getInetAddress

public InetAddress getInetAddress()

Gets the inet address.

Overrides:

getInetAddress in class Socket

Returns:

the inet address

getKeepAlive

public boolean getKeepAlive()
                     throws SocketException

Gets the keep alive.

Overrides:

getKeepAlive in class Socket

Returns:

the keep alive

Throws:

SocketException - the socket exception

getLocalAddress

public InetAddress getLocalAddress()

Gets the local address.

Overrides:

getLocalAddress in class Socket

Returns:

the local address

getLocalPort

public int getLocalPort()

Gets the local port.

Overrides:

getLocalPort in class Socket

Returns:

the local port

getLocalSocketAddress

public SocketAddress getLocalSocketAddress()

Gets the local socket address.

Overrides:

getLocalSocketAddress in class Socket

Returns:

the local socket address

getOOBInline

public boolean getOOBInline()
                     throws SocketException

Gets the OOB inline.

Overrides:

getOOBInline in class Socket

Returns:

the OOB inline

Throws:

SocketException - the socket exception

getPort

public int getPort()

Gets the port.

Overrides:

getPort in class Socket

Returns:

the port

getReceiveBufferSize

public int getReceiveBufferSize()
                         throws SocketException

Gets the receive buffer size.

Overrides:

getReceiveBufferSize in class Socket

Returns:

the receive buffer size

Throws:

SocketException - the socket exception

getRemoteSocketAddress

public SocketAddress getRemoteSocketAddress()

Gets the remote socket address.

Overrides:

getRemoteSocketAddress in class Socket

Returns:

the remote socket address

getReuseAddress

public boolean getReuseAddress()
                        throws SocketException

Gets the reuse address.

Overrides:

getReuseAddress in class Socket

Returns:

the reuse address

Throws:

SocketException - the socket exception

getSendBufferSize

public int getSendBufferSize()
                      throws SocketException

Gets the send buffer size.

Overrides:

getSendBufferSize in class Socket

Returns:

the send buffer size

Throws:

SocketException - the socket exception

getSoLinger

public int getSoLinger()
                throws SocketException

Gets the so linger.

Overrides:

getSoLinger in class Socket

Returns:

the so linger

Throws:

SocketException - the socket exception

getSoTimeout

public int getSoTimeout()
                 throws SocketException

Gets the so timeout.

Overrides:

getSoTimeout in class Socket

Returns:

the so timeout

Throws:

SocketException - the socket exception

getTcpNoDelay

public boolean getTcpNoDelay()
                      throws SocketException

Gets the tcp no delay.

Overrides:

getTcpNoDelay in class Socket

Returns:

the tcp no delay

Throws:

SocketException - the socket exception

getTrafficClass

public int getTrafficClass()
                    throws SocketException

Gets the traffic class.

Overrides:

getTrafficClass in class Socket

Returns:

the traffic class

Throws:

SocketException - the socket exception

hashCode

public int hashCode()

Hash code.

Overrides:

hashCode in class Object

Returns:

the int

isBound

public boolean isBound()

Checks if is bound.

Overrides:

isBound in class Socket

Returns:

true, if is bound

isClosed

public boolean isClosed()

Checks if is closed.

Overrides:

isClosed in class Socket

Returns:

true, if is closed

isConnected

public boolean isConnected()

Checks if is connected.

Overrides:

isConnected in class Socket

Returns:

true, if is connected

isInputShutdown

public boolean isInputShutdown()

Checks if is input shutdown.

Overrides:

isInputShutdown in class Socket

Returns:

true, if is input shutdown

isOutputShutdown

public boolean isOutputShutdown()

Checks if is output shutdown.

Overrides:

isOutputShutdown in class Socket

Returns:

true, if is output shutdown

sendUrgentData

public void sendUrgentData(int data)
                    throws IOException

Send urgent data.

Overrides:

sendUrgentData in class Socket

Parameters:

data - the data

Throws:

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

setKeepAlive

public void setKeepAlive(boolean on)
                  throws SocketException

Sets the keep alive.

Overrides:

setKeepAlive in class Socket

Parameters:

on - the new keep alive

Throws:

SocketException - the socket exception

setOOBInline

public void setOOBInline(boolean on)
                  throws SocketException

Sets the OOB inline.

Overrides:

setOOBInline in class Socket

Parameters:

on - the new OOB inline

Throws:

SocketException - the socket exception

setPerformancePreferences

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

Sets the performance preferences.

Overrides:

setPerformancePreferences in class Socket

Parameters:

connectionTime - the connection time

latency - the latency

bandwidth - the bandwidth

setReceiveBufferSize

public void setReceiveBufferSize(int size)
                          throws SocketException

Sets the receive buffer size.

Overrides:

setReceiveBufferSize in class Socket

Parameters:

size - the new receive buffer size

Throws:

SocketException - the socket exception

setReuseAddress

public void setReuseAddress(boolean on)
                     throws SocketException

Sets the reuse address.

Overrides:

setReuseAddress in class Socket

Parameters:

on - the new reuse address

Throws:

SocketException - the socket exception

setSendBufferSize

public void setSendBufferSize(int size)
                       throws SocketException

Sets the send buffer size.

Overrides:

setSendBufferSize in class Socket

Parameters:

size - the new send buffer size

Throws:

SocketException - the socket exception

setSoLinger

public void setSoLinger(boolean on,
 int linger)
                 throws SocketException

Sets the so linger.

Overrides:

setSoLinger in class Socket

Parameters:

on - the on

linger - the linger

Throws:

SocketException - the socket exception

setSoTimeout

public void setSoTimeout(int timeout)
                  throws SocketException

Sets the so timeout.

Overrides:

setSoTimeout in class Socket

Parameters:

timeout - the new so timeout

Throws:

SocketException - the socket exception

setTcpNoDelay

public void setTcpNoDelay(boolean on)
                   throws SocketException

Sets the tcp no delay.

Overrides:

setTcpNoDelay in class Socket

Parameters:

on - the new tcp no delay

Throws:

SocketException - the socket exception

setTrafficClass

public void setTrafficClass(int tc)
                     throws SocketException

Sets the traffic class.

Overrides:

setTrafficClass in class Socket

Parameters:

tc - the new traffic class

Throws:

SocketException - the socket exception

shutdownInput

public void shutdownInput()
                   throws IOException

Shutdown input.

Overrides:

shutdownInput in class Socket

Throws:

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

shutdownOutput

public void shutdownOutput()
                    throws IOException

Shutdown output.

Overrides:

shutdownOutput in class Socket

Throws:

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

toString

public String toString()

To string.

Overrides:

toString in class Socket

Returns:

the string