seda.sandStorm.lib.aSocket.nbio
Class SockState
java.lang.Object
seda.sandStorm.lib.aSocket.SockState
seda.sandStorm.lib.aSocket.nbio.SockState
- All Implemented Interfaces:
- aSocketConst
class SockState
- extends SockState
Internal class used to represent state of an active socket connection.
Fields inherited from class seda.sandStorm.lib.aSocket.SockState |
clogged_numtries, clogged_qel, closed, conn, cur_length_target, cur_offset, cur_write_req, nbsock, numActiveWriteSockets, numEmptyWrites, outstanding_writes, pkt, readBuf, readClogTries, readCompQ, seqNum, writeBuf, writeClogThreshold, writeReqList |
Fields inherited from interface seda.sandStorm.lib.aSocket.aSocketConst |
EVENT_QUEUE_SPIN, EVENT_QUEUE_TIMEOUT, LARGE_AGGREGATION, LISTENSTAGE_NAME, MAX_ACCEPTS_AT_ONCE, MAX_WRITE_LEN, MAX_WRITE_REQS_PER_SOCKET, MAX_WRITES_AT_ONCE, MEASUREMENT_SIZE, READ_BUFFER_COPY, READ_BUFFER_SIZE, READSTAGE_NAME, SELECT_SPIN, SELECT_TIMEOUT, TRYWRITE_SPIN, WRITE_MASK_DISABLE_THRESHOLD, WRITESTAGE_NAME |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
DEBUG
private static final boolean DEBUG
- See Also:
- Constant Field Values
nbis
private seda.nbio.NonblockingInputStream nbis
nbos
private seda.nbio.NonblockingOutputStream nbos
readsi
private seda.nbio.SelectItem readsi
writesi
private seda.nbio.SelectItem writesi
read_selsource
private SelectSource read_selsource
write_selsource
private SelectSource write_selsource
SockState
public SockState(ATcpConnection conn,
java.net.Socket nbsock,
int writeClogThreshold)
throws java.io.IOException
- Throws:
java.io.IOException
SockState
public SockState(ATcpConnection conn,
java.net.Socket nbsock,
java.lang.Integer writeClogThreshold)
throws java.io.IOException
- Throws:
java.io.IOException
readInit
protected void readInit(SelectSourceIF read_selsource,
SinkIF compQ,
int readClogTries)
- Specified by:
readInit
in class SockState
doRead
protected void doRead()
- Specified by:
doRead
in class SockState
addWriteRequest
protected boolean addWriteRequest(aSocketRequest req,
SelectSourceIF write_selsource)
- Specified by:
addWriteRequest
in class SockState
initWrite
protected void initWrite(ATcpWriteRequest req)
- Specified by:
initWrite
in class SockState
tryWrite
protected boolean tryWrite()
throws SinkClosedException
- Specified by:
tryWrite
in class SockState
- Throws:
SinkClosedException
writeMaskEnable
protected void writeMaskEnable()
- Specified by:
writeMaskEnable
in class SockState
writeMaskDisable
protected void writeMaskDisable()
- Specified by:
writeMaskDisable
in class SockState
close
protected void close(SinkIF closeEventQueue)
- Specified by:
close
in class SockState