Class MonitoredSocket

java.lang.Object

java.net.Socket

ecmwf.common.technical.MonitoredSocket

All Implemented Interfaces:

Closeable, AutoCloseable

public class MonitoredSocket
extends Socket

The Class MonitoredSocket.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Socket	decoratee	The decoratee.

Constructor Summary

Constructors

Constructor	Description
MonitoredSocket()	Instantiates a new monitored socket.
MonitoredSocket(Socket decoratee)	Instantiates a new monitored 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 object)	Equals.
SocketChannel	getChannel()	Gets the channel.
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 java.net.Socket

getOption, setOption, setSocketImplFactory, supportedOptions

Methods inherited from class java.lang.Object

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

Field Details

decoratee

protected final Socket decoratee

The decoratee.

Constructor Details

MonitoredSocket

public MonitoredSocket()

Instantiates a new monitored socket.

MonitoredSocket

public MonitoredSocket(Socket decoratee)

Instantiates a new monitored socket.

Parameters:

decoratee - the decoratee

Method Details

bind

public void bind(SocketAddress bindpoint)
          throws IOException

Bind.

Overrides:

bind in class Socket

Throws:

IOException

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

connect

public void connect(SocketAddress endpoint)
             throws IOException

Connect.

Overrides:

connect in class Socket

Throws:

IOException

connect

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

Connect.

Overrides:

connect in class Socket

Throws:

IOException

equals

public boolean equals(Object object)

Equals.

Overrides:

equals in class Object

getChannel

public SocketChannel getChannel()

Gets the channel.

Overrides:

getChannel in class Socket

getInetAddress

public InetAddress getInetAddress()

Gets the inet address.

Overrides:

getInetAddress in class Socket

getInputStream

public InputStream getInputStream()
                           throws IOException

Gets the input stream.

Overrides:

getInputStream in class Socket

Throws:

IOException

getKeepAlive

public boolean getKeepAlive()
                     throws SocketException

Gets the keep alive.

Overrides:

getKeepAlive in class Socket

Throws:

SocketException

getLocalAddress

public InetAddress getLocalAddress()

Gets the local address.

Overrides:

getLocalAddress in class Socket

getLocalPort

public int getLocalPort()

Gets the local port.

Overrides:

getLocalPort in class Socket

getLocalSocketAddress

public SocketAddress getLocalSocketAddress()

Gets the local socket address.

Overrides:

getLocalSocketAddress in class Socket

getOOBInline

public boolean getOOBInline()
                     throws SocketException

Gets the OOB inline.

Overrides:

getOOBInline in class Socket

Throws:

SocketException

getOutputStream

public OutputStream getOutputStream()
                             throws IOException

Gets the output stream.

Overrides:

getOutputStream in class Socket

Throws:

IOException

getPort

public int getPort()

Gets the port.

Overrides:

getPort in class Socket

getReceiveBufferSize

public int getReceiveBufferSize()
                         throws SocketException

Gets the receive buffer size.

Overrides:

getReceiveBufferSize in class Socket

Throws:

SocketException

getRemoteSocketAddress

public SocketAddress getRemoteSocketAddress()

Gets the remote socket address.

Overrides:

getRemoteSocketAddress in class Socket

getReuseAddress

public boolean getReuseAddress()
                        throws SocketException

Gets the reuse address.

Overrides:

getReuseAddress in class Socket

Throws:

SocketException

getSendBufferSize

public int getSendBufferSize()
                      throws SocketException

Gets the send buffer size.

Overrides:

getSendBufferSize in class Socket

Throws:

SocketException

getSoLinger

public int getSoLinger()
                throws SocketException

Gets the so linger.

Overrides:

getSoLinger in class Socket

Throws:

SocketException

getSoTimeout

public int getSoTimeout()
                 throws SocketException

Gets the so timeout.

Overrides:

getSoTimeout in class Socket

Throws:

SocketException

getTcpNoDelay

public boolean getTcpNoDelay()
                      throws SocketException

Gets the tcp no delay.

Overrides:

getTcpNoDelay in class Socket

Throws:

SocketException

getTrafficClass

public int getTrafficClass()
                    throws SocketException

Gets the traffic class.

Overrides:

getTrafficClass in class Socket

Throws:

SocketException

hashCode

public int hashCode()

Hash code.

Overrides:

hashCode in class Object

isBound

public boolean isBound()

Checks if is bound.

Overrides:

isBound in class Socket

isClosed

public boolean isClosed()

Checks if is closed.

Overrides:

isClosed in class Socket

isConnected

public boolean isConnected()

Checks if is connected.

Overrides:

isConnected in class Socket

isInputShutdown

public boolean isInputShutdown()

Checks if is input shutdown.

Overrides:

isInputShutdown in class Socket

isOutputShutdown

public boolean isOutputShutdown()

Checks if is output shutdown.

Overrides:

isOutputShutdown in class Socket

sendUrgentData

public void sendUrgentData(int data)
                    throws IOException

Send urgent data.

Overrides:

sendUrgentData in class Socket

Throws:

IOException

setKeepAlive

public void setKeepAlive(boolean on)
                  throws SocketException

Sets the keep alive.

Overrides:

setKeepAlive in class Socket

Throws:

SocketException

setOOBInline

public void setOOBInline(boolean on)
                  throws SocketException

Sets the OOB inline.

Overrides:

setOOBInline in class Socket

Throws:

SocketException

setPerformancePreferences

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

Sets the performance preferences.

Overrides:

setPerformancePreferences in class Socket

setReceiveBufferSize

public void setReceiveBufferSize(int size)
                          throws SocketException

Sets the receive buffer size.

Overrides:

setReceiveBufferSize in class Socket

Throws:

SocketException

setReuseAddress

public void setReuseAddress(boolean on)
                     throws SocketException

Sets the reuse address.

Overrides:

setReuseAddress in class Socket

Throws:

SocketException

setSendBufferSize

public void setSendBufferSize(int size)
                       throws SocketException

Sets the send buffer size.

Overrides:

setSendBufferSize in class Socket

Throws:

SocketException

setSoLinger

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

Sets the so linger.

Overrides:

setSoLinger in class Socket

Throws:

SocketException

setSoTimeout

public void setSoTimeout(int timeout)
                  throws SocketException

Sets the so timeout.

Overrides:

setSoTimeout in class Socket

Throws:

SocketException

setTcpNoDelay

public void setTcpNoDelay(boolean on)
                   throws SocketException

Sets the tcp no delay.

Overrides:

setTcpNoDelay in class Socket

Throws:

SocketException

setTrafficClass

public void setTrafficClass(int tc)
                     throws SocketException

Sets the traffic class.

Overrides:

setTrafficClass in class Socket

Throws:

SocketException

shutdownInput

public void shutdownInput()
                   throws IOException

Shutdown input.

Overrides:

shutdownInput in class Socket

Throws:

IOException

shutdownOutput

public void shutdownOutput()
                    throws IOException

Shutdown output.

Overrides:

shutdownOutput in class Socket

Throws:

IOException

toString

public String toString()

To string.

Overrides:

toString in class Socket