seda.sandStorm.lib.aSocket.nbio
Class DatagramSockState
java.lang.Object
seda.sandStorm.lib.aSocket.DatagramSockState
seda.sandStorm.lib.aSocket.nbio.DatagramSockState
- All Implemented Interfaces:
- aSocketConst
public class DatagramSockState
- extends DatagramSockState
Internal class used to represent state of an active datagram socket.
Fields inherited from class seda.sandStorm.lib.aSocket.DatagramSockState |
clogged_numtries, clogged_qel, closed, cur_write_buf, cur_write_req, maxPacketSize, numEmptyWrites, outstanding_writes, pkt, readBuf, readClogTries, readCompQ, seqNum, udpsock, 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
dgsock
private seda.nbio.NonblockingDatagramSocket dgsock
readsi
private seda.nbio.SelectItem readsi
writesi
private seda.nbio.SelectItem writesi
read_selsource
private SelectSource read_selsource
write_selsource
private SelectSource write_selsource
DatagramSockState
public DatagramSockState(AUdpSocket sock,
java.net.InetAddress addr,
int port)
throws java.io.IOException
- Throws:
java.io.IOException
readInit
protected void readInit(SelectSourceIF read_selsource,
SinkIF compQ,
int readClogTries)
- Specified by:
readInit
in class DatagramSockState
doRead
protected void doRead()
- Specified by:
doRead
in class DatagramSockState
addWriteRequest
protected boolean addWriteRequest(aSocketRequest req,
SourceIF write_selsource)
- Specified by:
addWriteRequest
in class DatagramSockState
initWrite
void initWrite(AUdpWriteRequest req)
tryWrite
protected boolean tryWrite()
throws SinkClosedException
- Specified by:
tryWrite
in class DatagramSockState
- Throws:
SinkClosedException
writeReset
void writeReset()
writeMaskEnable
protected void writeMaskEnable()
- Specified by:
writeMaskEnable
in class DatagramSockState
writeMaskDisable
protected void writeMaskDisable()
- Specified by:
writeMaskDisable
in class DatagramSockState
isClosed
boolean isClosed()
close
protected void close(SinkIF closeEventQueue)
- Specified by:
close
in class DatagramSockState
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
getSocket
protected java.net.DatagramSocket getSocket()
- Specified by:
getSocket
in class DatagramSockState
connect
protected void connect(java.net.InetAddress addr,
int port)
- Specified by:
connect
in class DatagramSockState