public class IOControl extends Object
Modifier and Type | Class and Description |
---|---|
(package private) static class |
IOControl.NetOutputStream |
(package private) class |
IOControl.Reader |
Modifier and Type | Field and Description |
---|---|
private BufferedInputStream |
bis |
private long |
inputCounter |
static org.objectweb.util.monolog.api.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 and Description |
---|
IOControl(Socket sock) |
IOControl(Socket sock,
long inputCounter) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
long |
getReceivedCount() |
int |
getreceiveQueueSize() |
long |
getSentCount() |
(package private) Socket |
getSocket() |
ProxyMessage |
receive() |
void |
send(ProxyMessage msg) |
void |
setNoAckedQueue(boolean noAckedQueue) |
public static org.objectweb.util.monolog.api.Logger logger
private long inputCounter
private Socket sock
private IOControl.NetOutputStream nos
private BufferedInputStream bis
private int windowSize
private int unackCounter
private long receivedCount
private long sentCount
private LinkedBlockingQueue<byte[]> receiveQueue
private IOControl.Reader reader
boolean noAckedQueue
public IOControl(Socket sock) throws IOException
IOException
public IOControl(Socket sock, long inputCounter) throws IOException
IOException
public void send(ProxyMessage msg) throws IOException
IOException
public void setNoAckedQueue(boolean noAckedQueue)
public ProxyMessage receive() throws Exception
Exception
public void close()
Socket getSocket()
public long getSentCount()
public long getReceivedCount()
public int getreceiveQueueSize()
Copyright © 2019 ScalAgent D.T.. All rights reserved.