seda.sandStorm.lib.aSocket
Class SockState
java.lang.Object
seda.sandStorm.lib.aSocket.SockState
- All Implemented Interfaces:
- aSocketConst
- Direct Known Subclasses:
- SockState, SockState
public abstract class SockState
- extends java.lang.Object
- implements aSocketConst
Internal class used to represent state of an active socket connection.
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
nbsock
protected java.net.Socket nbsock
conn
protected ATcpConnection conn
readCompQ
protected SinkIF readCompQ
clogged_qel
protected QueueElementIF clogged_qel
clogged_numtries
protected int clogged_numtries
readClogTries
protected int readClogTries
writeClogThreshold
protected int writeClogThreshold
readBuf
protected byte[] readBuf
closed
protected boolean closed
seqNum
protected long seqNum
outstanding_writes
protected int outstanding_writes
numEmptyWrites
protected int numEmptyWrites
writeReqList
protected ssLinkedList writeReqList
cur_write_req
protected ATcpWriteRequest cur_write_req
cur_offset
protected int cur_offset
cur_length_target
protected int cur_length_target
writeBuf
protected byte[] writeBuf
pkt
protected ATcpInPacket pkt
numActiveWriteSockets
protected static int numActiveWriteSockets
SockState
public SockState()
readInit
protected abstract void readInit(SelectSourceIF read_selsource,
SinkIF compQ,
int readClogTries)
doRead
protected abstract void doRead()
addWriteRequest
protected abstract boolean addWriteRequest(aSocketRequest req,
SelectSourceIF write_selsource)
initWrite
protected abstract void initWrite(ATcpWriteRequest req)
tryWrite
protected abstract boolean tryWrite()
throws SinkClosedException
- Throws:
SinkClosedException
writeReset
void writeReset()
writeMaskEnable
protected abstract void writeMaskEnable()
writeMaskDisable
protected abstract void writeMaskDisable()
numActiveWriters
static int numActiveWriters()
isClosed
boolean isClosed()
close
protected abstract void close(SinkIF closeEventQueue)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object