wt.util
Class WrappedPostlessSocket

java.lang.Object
  java.net.Socket
      wt.util.WrappedPostlessSocket

All Implemented Interfaces:

sun.rmi.transport.proxy.RMISocketInfo

public class WrappedPostlessSocket

extends Socket

implements sun.rmi.transport.proxy.RMISocketInfo

Nested Class Summary

(package private) class	WrappedPostlessSocket.Input
(package private) class	WrappedPostlessSocket.Output
(package private) static class	WrappedPostlessSocket.SocketCache

Field Summary

private static long	bytesIn
private static long	bytesOut
private boolean	closed
private int	inBufSize
private InputStream	inputStream
(package private) static byte[]	jrmi
private static int	numSockets
private int	outBufSize
private OutputStream	outputStream
(package private) static int	POST
private boolean	postLessDebug
private boolean	pseudoPost
private Socket	socket
private static Cache	socketCache
static boolean	VERBOSE_CLOSE
static boolean	VERBOSE_IO

Fields inherited from class java.net.Socket

Constructor Summary

WrappedPostlessSocket(Socket this_socket, int in_buf_size, int out_buf_size)

Method Summary

private void	active(WrappedPostlessSocket wrapped_socket)
private void	activeIn(WrappedPostlessSocket wrapped_socket, int bytes_in)
private void	activeOut(WrappedPostlessSocket wrapped_socket, int bytes_out)
void	close()
private static void	decrementNumSockets()
protected void	finalize()
static long	getBytesIn()
static long	getBytesOut()
InetAddress	getInetAddress()
InputStream	getInputStream()
InetAddress	getLocalAddress()
int	getLocalPort()
static int	getNumSockets()
OutputStream	getOutputStream()
int	getPort()
int	getSoLinger()
int	getSoTimeout()
boolean	getTcpNoDelay()
private static void	incrementNumSockets()
boolean	isReusable()
static void	setMaxSockets(int max_sockets)
void	setSoLinger(boolean on, int val)
void	setSoTimeout(int timeout)
void	setTcpNoDelay(boolean on)
String	toString()

Methods inherited from class java.net.Socket

bind, connect, connect, getChannel, getKeepAlive, getLocalSocketAddress, getOOBInline, getReceiveBufferSize, getRemoteSocketAddress, getReuseAddress, getSendBufferSize, getTrafficClass, isBound, isClosed, isConnected, isInputShutdown, isOutputShutdown, sendUrgentData, setKeepAlive, setOOBInline, setReceiveBufferSize, setReuseAddress, setSendBufferSize, setSocketImplFactory, setTrafficClass, shutdownInput, shutdownOutput

Methods inherited from class java.lang.Object

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

Field Detail

POST

static final int POST

See Also:

Constant Field Values

jrmi

static final byte[] jrmi

pseudoPost

private boolean pseudoPost

postLessDebug

private final boolean postLessDebug

See Also:

Constant Field Values

VERBOSE_CLOSE

public static boolean VERBOSE_CLOSE

VERBOSE_IO

public static boolean VERBOSE_IO

socketCache

private static Cache socketCache

numSockets

private static int numSockets

bytesIn

private static long bytesIn

bytesOut

private static long bytesOut

inBufSize

private int inBufSize

outBufSize

private int outBufSize

socket

private Socket socket

inputStream

private InputStream inputStream

outputStream

private OutputStream outputStream

closed

private boolean closed

Constructor Detail

WrappedPostlessSocket

public WrappedPostlessSocket(Socket this_socket,
                             int in_buf_size,
                             int out_buf_size)
                      throws SocketException

Method Detail

incrementNumSockets

private static void incrementNumSockets()

decrementNumSockets

private static void decrementNumSockets()

getNumSockets

public static int getNumSockets()

getBytesIn

public static long getBytesIn()

getBytesOut

public static long getBytesOut()

setMaxSockets

public static void setMaxSockets(int max_sockets)

active

private void active(WrappedPostlessSocket wrapped_socket)

activeIn

private void activeIn(WrappedPostlessSocket wrapped_socket,
                      int bytes_in)

activeOut

private void activeOut(WrappedPostlessSocket wrapped_socket,
                       int bytes_out)

isReusable

public boolean isReusable()

Specified by:

isReusable in interface sun.rmi.transport.proxy.RMISocketInfo

finalize

protected void finalize()
                 throws Throwable

Throws:

Throwable

getInputStream

public InputStream getInputStream()
                           throws IOException

Throws:

IOException

getOutputStream

public OutputStream getOutputStream()
                             throws IOException

Throws:

IOException

getInetAddress

public InetAddress getInetAddress()

getLocalAddress

public InetAddress getLocalAddress()

getPort

public int getPort()

getLocalPort

public int getLocalPort()

setTcpNoDelay

public void setTcpNoDelay(boolean on)
                   throws SocketException

Throws:

SocketException

getTcpNoDelay

public boolean getTcpNoDelay()
                      throws SocketException

Throws:

SocketException

setSoLinger

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

Throws:

SocketException

getSoLinger

public int getSoLinger()
                throws SocketException

Throws:

SocketException

setSoTimeout

public void setSoTimeout(int timeout)
                  throws SocketException

Throws:

SocketException

getSoTimeout

public int getSoTimeout()
                 throws SocketException

Throws:

SocketException

close

public void close()
           throws IOException

Throws:

IOException

toString

public String toString()