org.objectweb.joram.mom.proxies.tcp
Class IOControl

java.lang.Object
  extended by org.objectweb.joram.mom.proxies.tcp.IOControl

public class IOControl
extends java.lang.Object


Nested Class Summary
(package private) static class IOControl.NetOutputStream
           
 
Field Summary
private  java.io.BufferedInputStream bis
           
private  long inputCounter
           
static org.objectweb.util.monolog.api.Logger logger
           
private  IOControl.NetOutputStream nos
           
private  long receivedCount
           
private  long sentCount
           
private  java.net.Socket sock
           
private  int unackCounter
           
private  int windowSize
           
 
Constructor Summary
IOControl(java.net.Socket sock)
           
IOControl(java.net.Socket sock, long inputCounter)
           
 
Method Summary
 void close()
           
 long getReceivedCount()
           
 long getSentCount()
           
(package private)  java.net.Socket getSocket()
           
 ProxyMessage receive()
           
 void send(ProxyMessage msg)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

logger

public static org.objectweb.util.monolog.api.Logger logger

inputCounter

private long inputCounter

sock

private java.net.Socket sock

nos

private IOControl.NetOutputStream nos

bis

private java.io.BufferedInputStream bis

windowSize

private int windowSize

unackCounter

private int unackCounter

receivedCount

private long receivedCount

sentCount

private long sentCount
Constructor Detail

IOControl

public IOControl(java.net.Socket sock)
          throws java.io.IOException
Throws:
java.io.IOException

IOControl

public IOControl(java.net.Socket sock,
                 long inputCounter)
          throws java.io.IOException
Throws:
java.io.IOException
Method Detail

send

public void send(ProxyMessage msg)
          throws java.io.IOException
Throws:
java.io.IOException

receive

public ProxyMessage receive()
                     throws java.lang.Exception
Throws:
java.lang.Exception

close

public void close()

getSocket

java.net.Socket getSocket()

getSentCount

public long getSentCount()

getReceivedCount

public long getReceivedCount()


Copyright © 2010 ScalAgent D.T.. All Rights Reserved.