More information: http://www.cs.berkeley.edu/~mdw/proj/seda/

seda.sandStorm.lib.aSocket
Class DatagramSockState

java.lang.Object
  |
  +--seda.sandStorm.lib.aSocket.DatagramSockState
All Implemented Interfaces:
aSocketConst

public abstract class DatagramSockState
extends java.lang.Object
implements aSocketConst

Internal class used to represent state of an active datagram socket.


Field Summary
protected  int clogged_numtries
           
protected  QueueElementIF clogged_qel
           
protected  boolean closed
           
protected  BufferElement cur_write_buf
           
protected  AUdpWriteRequest cur_write_req
           
protected  int maxPacketSize
           
protected  int numEmptyWrites
           
protected  int outstanding_writes
           
protected  AUdpInPacket pkt
           
protected  byte[] readBuf
           
protected  int readClogTries
           
protected  SinkIF readCompQ
           
protected  long seqNum
           
protected  AUdpSocket udpsock
           
protected  int writeClogThreshold
           
protected  ssLinkedList 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
 
Constructor Summary
DatagramSockState()
           
 
Method Summary
protected abstract  boolean addWriteRequest(aSocketRequest req, SourceIF write_selsource)
           
protected abstract  void close(SinkIF closeEventQueue)
           
protected abstract  void connect(java.net.InetAddress addr, int port)
           
protected abstract  void doRead()
           
protected abstract  java.net.DatagramSocket getSocket()
           
(package private)  void initWrite(AUdpWriteRequest req)
           
(package private)  boolean isClosed()
           
protected abstract  void readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
protected abstract  boolean tryWrite()
           
protected abstract  void writeMaskDisable()
           
protected abstract  void writeMaskEnable()
           
(package private)  void writeReset()
           
 
Methods inherited from class java.lang.Object
, clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

udpsock

protected AUdpSocket udpsock

readCompQ

protected SinkIF readCompQ

clogged_qel

protected QueueElementIF clogged_qel

clogged_numtries

protected int clogged_numtries

readClogTries

protected int readClogTries

writeClogThreshold

protected int writeClogThreshold

maxPacketSize

protected int maxPacketSize

readBuf

protected byte[] readBuf

closed

protected boolean closed

seqNum

protected long seqNum

pkt

protected AUdpInPacket pkt

outstanding_writes

protected int outstanding_writes

numEmptyWrites

protected int numEmptyWrites

writeReqList

protected ssLinkedList writeReqList

cur_write_req

protected AUdpWriteRequest cur_write_req

cur_write_buf

protected BufferElement cur_write_buf
Constructor Detail

DatagramSockState

public DatagramSockState()
Method Detail

readInit

protected abstract void readInit(SelectSourceIF read_selsource,
                                 SinkIF compQ,
                                 int readClogTries)

doRead

protected abstract void doRead()

addWriteRequest

protected abstract boolean addWriteRequest(aSocketRequest req,
                                           SourceIF write_selsource)

tryWrite

protected abstract boolean tryWrite()
                             throws SinkClosedException

writeMaskEnable

protected abstract void writeMaskEnable()

writeMaskDisable

protected abstract void writeMaskDisable()

close

protected abstract void close(SinkIF closeEventQueue)

getSocket

protected abstract java.net.DatagramSocket getSocket()

connect

protected abstract void connect(java.net.InetAddress addr,
                                int port)

initWrite

void initWrite(AUdpWriteRequest req)

writeReset

void writeReset()

isClosed

boolean isClosed()

More information: http://www.cs.berkeley.edu/~mdw/proj/seda/