java.lang.Object
- org.objectweb.joram.mom.proxies.tcp.IOControl

```
public class IOControl
extends Object
```

Nested Class Summary

Nested Classes
Modifier and Type Class Description

(package private) static class IOControl.NetOutputStream

(package private) class IOControl.Reader

Field Summary

Fields
Modifier and Type	Field	Description
`private BufferedInputStream`	`bis`
`private static boolean`	`DEBUG`
`private long`	`inputCounter`
`private static Logger`	`logger`
`(package private) boolean`	`noAckedQueue`
`private IOControl.NetOutputStream`	`nos`
`private IOControl.Reader`	`reader`
`private long`	`receivedCount`
`private LinkedBlockingQueue<byte[]>`	`receiveQueue`
`private long`	`sentCount`
`private Socket`	`sock`
`private int`	`unackCounter`
`private int`	`windowSize`

Constructor Summary

Constructors
Constructor Description

IOControl(Socket sock)

IOControl(Socket sock, long inputCounter)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`close()`
`long`	`getReceivedCount()`
`int`	`getreceiveQueueSize()`
`long`	`getSentCount()`
`(package private) Socket`	`getSocket()`
`ProxyMessage`	`receive()`
`void`	`send(ProxyMessage msg)`
`void`	`setNoAckedQueue(boolean noAckedQueue)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger
```
private static final Logger logger
```

DEBUG
```
private static final boolean DEBUG
```

inputCounter
```
private long inputCounter
```

sock
```
private Socket sock
```

nos
```
private IOControl.NetOutputStream nos
```

bis
```
private BufferedInputStream bis
```

windowSize
```
private int windowSize
```

unackCounter
```
private int unackCounter
```

receivedCount
```
private long receivedCount
```

sentCount
```
private long sentCount
```

receiveQueue

private LinkedBlockingQueue<byte[]> receiveQueue

reader
```
private IOControl.Reader reader
```

noAckedQueue
```
boolean noAckedQueue
```

Constructor Detail

IOControl

public IOControl(Socket sock)
          throws IOException

Throws:: IOException

IOControl

public IOControl(Socket sock,
                 long inputCounter)
          throws IOException

Throws:: IOException

Method Detail

send

public void send(ProxyMessage msg)
          throws IOException

Throws:: IOException

setNoAckedQueue

public void setNoAckedQueue(boolean noAckedQueue)

receive

public ProxyMessage receive()
                     throws Exception

Throws:: Exception

close
```
public void close()
```

getSocket
```
Socket getSocket()
```

getSentCount
```
public long getSentCount()
```

getReceivedCount
```
public long getReceivedCount()
```

getreceiveQueueSize
```
public int getreceiveQueueSize()
```

Modifier and Type	Class	Description
`(package private) static class`	`IOControl.NetOutputStream`
`(package private) class`	`IOControl.Reader`

Constructor	Description
`IOControl(Socket sock)`
`IOControl(Socket sock, long inputCounter)`

Class IOControl

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

logger

DEBUG

inputCounter

sock

nos

bis

windowSize

unackCounter

receivedCount

sentCount

receiveQueue

reader

noAckedQueue

Constructor Detail

IOControl

IOControl

Method Detail

send

setNoAckedQueue

receive

close

getSocket

getSentCount

getReceivedCount

getreceiveQueueSize