Uses of Interface
seda.sandStorm.api.SinkIF

Packages that use SinkIF
<Unnamed>   
seda.sandStorm.api   
seda.sandStorm.core   
seda.sandStorm.internal   
seda.sandStorm.lib.aDisk   
seda.sandStorm.lib.aSocket   
seda.sandStorm.lib.aSocket.nbio   
seda.sandStorm.lib.aSocket.nio   
seda.sandStorm.lib.Gnutella   
seda.sandStorm.lib.http   
 

Uses of SinkIF in <Unnamed>
 

Fields in <Unnamed> declared as SinkIF
(package private)  SinkIF MessageReader.compQ
           
protected  SinkIF ClientStage.compQ
           
protected  SinkIF ClientStage.recvSink
           
(package private)  SinkIF MultiBandwidth.ConnState.sink
           
(package private)  SinkIF Bandwidth.sink
           
(package private)  SinkIF Pingpong.sink
           
(package private)  SinkIF PingpongUDP.sink
           
 

Constructors in <Unnamed> with parameters of type SinkIF
ClassedMessage(int seqNum, int status, int theclass, SinkIF sendQ, SinkIF replyQ)
           
MessageReader(ATcpConnection conn, SinkIF compQ)
           
MessageReader(SinkIF compQ)
           
MultiBandwidth.ConnState(SinkIF sink)
           
 

Uses of SinkIF in seda.sandStorm.api
 

Subinterfaces of SinkIF in seda.sandStorm.api
 interface QueueIF
          A QueueIF implements a finite-length event queue.
 

Fields in seda.sandStorm.api declared as SinkIF
 SinkIF SinkCloggedEvent.sink
          The sink which clogged.
 SinkIF SinkClosedEvent.sink
          The sink that closed.
 SinkIF SinkDrainedEvent.sink
          The sink which was processed.
 SinkIF SinkFlushedEvent.sink
          The sink which was flushed.
 

Methods in seda.sandStorm.api that return SinkIF
 SinkIF StageIF.getSink()
          Return the event sink for this stage.
 

Methods in seda.sandStorm.api with parameters of type SinkIF
 void SignalMgrIF.deregister(SignalIF signalType, SinkIF sink)
          Deregister for the given signal type.
 void SignalMgrIF.register(SignalIF signalType, SinkIF sink)
          Register for the given signal type.
 

Constructors in seda.sandStorm.api with parameters of type SinkIF
SinkCloggedEvent(SinkIF sink, QueueElementIF element)
          Create a new SinkCloggedEvent with the given sink and element.
SinkClosedEvent(SinkIF sink)
          Create a new SinkClosedEvent with the given sink.
SinkDrainedEvent(SinkIF sink, QueueElementIF element)
          Create a new SinkDrainedEvent with the given sink and element.
SinkFlushedEvent(SinkIF sink)
          Generate a new SinkFlushedEvent with the given sink.
 

Uses of SinkIF in seda.sandStorm.core
 

Classes in seda.sandStorm.core that implement SinkIF
 class FiniteQueue
          The FiniteQueue class is a simple implementation of the QueueIF interface, using a linked list.
 class SimpleSink
          The SimpleSink class is an abstract class which implements 'null' functionality for most of the administrative methods of SinkIF.
 

Fields in seda.sandStorm.core declared as SinkIF
 SinkIF BufferElement.compQ
          The completion queue associated with this buffer.
 SinkIF ssTimer.ssTimerEvent.queue
           
 

Methods in seda.sandStorm.core that return SinkIF
 SinkIF BufferElement.getCompletionQueue()
          Return the completion queue for this buffer.
 

Methods in seda.sandStorm.core with parameters of type SinkIF
 ssTimer.ssTimerEvent ssTimer.registerEvent(java.util.Date the_date, QueueElementIF obj, SinkIF queue)
          Object obj will be placed on SinkIF queue no earlier than absolute time the_date.
 ssTimer.ssTimerEvent ssTimer.registerEvent(long millis, QueueElementIF obj, SinkIF queue)
          Object obj will be placed on SinkIF queue no earlier than millis milliseconds from now.
 

Constructors in seda.sandStorm.core with parameters of type SinkIF
BufferElement(byte[] data, int offset, int size, SinkIF compQ)
          Create a BufferElement with the given data, offset, size, and completion queue.
BufferElement(byte[] data, SinkIF compQ)
          Create a BufferElement with the given data, an offset of 0, and a size of data.length, with the given completion queue.
MulticlassRateLimitingPredicate(SinkIF sink, int numclasses, double targetRate, int depth)
          Create a new RateLimitingPredicate for the given sink, targetRate, and token bucket depth.
QueueThresholdPredicate(SinkIF sink, int threshold)
          Create a new QueueThresholdPredicate for the given sink and threshold.
RateLimitingPredicate(SinkIF sink, double targetRate, int depth)
          Create a new RateLimitingPredicate for the given sink, targetRate, and token bucket depth.
ssTimer.ssTimerEvent(long m, QueueElementIF o, SinkIF q)
           
 

Uses of SinkIF in seda.sandStorm.internal
 

Classes in seda.sandStorm.internal that implement SinkIF
 class SinkProxy
          Used as a proxy to observe and measure communication behavior between stages.
 

Fields in seda.sandStorm.internal declared as SinkIF
(package private)  SinkIF StageGraphEdge.sink
           
 SinkIF SinkProxy.thesink
           
 

Methods in seda.sandStorm.internal that return SinkIF
 SinkIF Stage.getSink()
          Return the event sink.
 

Methods in seda.sandStorm.internal with parameters of type SinkIF
 void SignalMgr.deregister(SignalIF signalType, SinkIF sink)
          Deregister for the given signal type.
 void SignalMgr.register(SignalIF signalType, SinkIF sink)
          Register for the given signal type.
 

Constructors in seda.sandStorm.internal with parameters of type SinkIF
SinkProxy(SinkIF sink, ManagerIF mgr, StageWrapperIF toStage)
          Create a SinkProxy for the given sink.
Stage(java.lang.String name, StageWrapperIF wrapper, SinkIF mainsink, ConfigDataIF config)
          Create a Stage with the given name, wrapper, and sink.
 

Uses of SinkIF in seda.sandStorm.lib.aDisk
 

Classes in seda.sandStorm.lib.aDisk that implement SinkIF
 class AFile
          This class represents an asynchronous file I/O interface.
(package private)  class AFileImpl
          Package-access only abstract class representing an implementation of the AFile interface.
(package private)  class AFileTPImpl
          This is an implementation of AFile which uses a pool of threads which perform blocking I/O (through the java.io.RandomAccessFile class) on files.
 

Fields in seda.sandStorm.lib.aDisk declared as SinkIF
(package private)  SinkIF AFileRequest.compQ
           
protected  SinkIF AFileTPEventHandler.eventQ
           
 

Methods in seda.sandStorm.lib.aDisk that return SinkIF
(package private)  SinkIF AFileRequest.getCompQ()
           
 

Constructors in seda.sandStorm.lib.aDisk with parameters of type SinkIF
AFile(java.lang.String name, SinkIF compQ, boolean create, boolean readOnly)
          Open the file with the given pathname.
AFileCloseRequest(AFile afile, SinkIF compQ)
           
AFileCloseRequest(SinkIF compQ)
           
AFileFlushRequest(AFile afile, SinkIF compQ)
           
AFileFlushRequest(SinkIF compQ)
           
AFileReadRequest(BufferElement buf, SinkIF compQ)
          Create a read request to fill in the given BufferElement.
AFileRequest(AFile afile, SinkIF compQ)
           
AFileRequest(SinkIF compQ)
           
AFileSeekRequest(int offset, SinkIF compQ)
          Seek to the given offset.
AFileTPImpl(AFile afile, java.lang.String fname, SinkIF compQ, boolean create, boolean readOnly, AFileTPTM tm)
          Create an AFileTPIMpl with the given AFile, filename, completion queue, create/readOnly flags, and Thread Manager.
AFileWriteRequest(BufferElement buf, SinkIF compQ)
          Create a write request using the given buffer and completion queue.
 

Uses of SinkIF in seda.sandStorm.lib.aSocket
 

Classes in seda.sandStorm.lib.aSocket that implement SinkIF
 class ATcpConnection
          An ATcpConnection represents an established connection on an asynchronous socket.
 class AUdpSocket
          An AUdpSocket implements an asynchronous datagram socket.
 

Fields in seda.sandStorm.lib.aSocket declared as SinkIF
 SinkIF ATcpCloseRequest.compQ
           
 SinkIF ATcpConnectRequest.compQ
           
(package private)  SinkIF ATcpFlushRequest.compQ
           
 SinkIF ATcpListenRequest.compQ
           
(package private)  SinkIF ATcpStartReadRequest.compQ
           
 SinkIF AUdpCloseRequest.compQ
           
(package private)  SinkIF AUdpFlushRequest.compQ
           
 SinkIF AUdpSocket.compQ
           
(package private)  SinkIF AUdpStartReadRequest.compQ
           
protected  SinkIF ConnectSockState.compQ
           
protected  SinkIF ListenSockState.compQ
           
protected  SinkIF aSocketEventHandler.eventQ
           
protected  SinkIF DatagramSockState.readCompQ
           
protected  SinkIF SockState.readCompQ
           
 

Methods in seda.sandStorm.lib.aSocket with parameters of type SinkIF
 void ATcpConnection.close(SinkIF compQ)
          Close the socket.
 void AUdpSocket.close(SinkIF compQ)
          Close the socket.
protected abstract  void DatagramSockState.close(SinkIF closeEventQueue)
           
protected abstract  void SockState.close(SinkIF closeEventQueue)
           
 void ATcpConnection.flush(SinkIF compQ)
          Flush the socket.
 void AUdpSocket.flush(SinkIF compQ)
          Flush the socket.
protected abstract  void DatagramSockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
protected abstract  void SockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
 void ATcpConnection.startReader(SinkIF receiveQ)
          Associate a SinkIF with this connection and allow data to start flowing into it.
 void AUdpSocket.startReader(SinkIF receiveQ)
          Associate a SinkIF with this socket and allow data to start flowing into it.
 void ATcpConnection.startReader(SinkIF receiveQ, int readClogTries)
          Associate a SinkIF with this connection and allow data to start flowing into it.
 void AUdpSocket.startReader(SinkIF receiveQ, int readClogTries)
          Associate a SinkIF with this socket and allow data to start flowing into it.
 

Constructors in seda.sandStorm.lib.aSocket with parameters of type SinkIF
ATcpClientSocket(java.net.InetAddress addr, int port, SinkIF compQ)
          Create a socket connecting to the given address and port.
ATcpClientSocket(java.net.InetAddress addr, int port, SinkIF compQ, int writeClogThreshold, int connectClogTries)
          Create a socket connecting to the given address and port with the given writeClogThreshold value.
ATcpClientSocket(java.lang.String host, int port, SinkIF compQ)
          Create a socket connecting to the given host and port.
ATcpClientSocket(java.lang.String host, int port, SinkIF compQ, int writeClogThreshold, int connectClogTries)
          Create a socket connecting to the given host and port with the given writeClogThreshold value.
ATcpCloseRequest(ATcpConnection conn, SinkIF compQ)
           
ATcpConnectRequest(ATcpClientSocket clisock, java.net.InetAddress addr, int port, SinkIF compQ, int writeClogThreshold, int connectClogTries)
           
ATcpFlushRequest(ATcpConnection conn, SinkIF compQ)
           
ATcpListenRequest(ATcpServerSocket servsock, int port, SinkIF compQ, int writeClogThreshold)
           
ATcpServerSocket(int serverPort, SinkIF compQ)
          Open a server socket listening on the given port.
ATcpServerSocket(int serverPort, SinkIF compQ, int writeClogThreshold)
          Open a server socket listening on the given port.
ATcpStartReadRequest(ATcpConnection conn, SinkIF compQ, int readClogTries)
           
AUdpCloseRequest(AUdpSocket sock, SinkIF compQ)
           
AUdpFlushRequest(AUdpSocket sock, SinkIF compQ)
           
AUdpPacket(byte[] data, int offset, int size, SinkIF compQ)
          Create an AUdpPacket with the given data, offset, size, and completion queue.
AUdpPacket(byte[] data, int offset, int size, SinkIF compQ, java.net.InetAddress address, int port)
          Create an AUdpPacket with the given data, offset, size, completion queue, destination address, and port.
AUdpPacket(byte[] data, SinkIF compQ)
          Create an AUdpPacket with the given data, an offset of 0, and a size of data.length, with the given completion queue.
AUdpSocket(java.net.InetAddress localaddr, int localport, SinkIF compQ, int maxPacketSize, int writeClogThreshold)
          Create a socket bound to the given local address and local port.
AUdpSocket(int localport, SinkIF compQ)
          Create a socket bound to the given local port.
AUdpSocket(SinkIF compQ)
          Create a socket bound to any available local port.
AUdpStartReadRequest(AUdpSocket sock, SinkIF compQ, int readClogTries)
           
 

Uses of SinkIF in seda.sandStorm.lib.aSocket.nbio
 

Methods in seda.sandStorm.lib.aSocket.nbio with parameters of type SinkIF
protected  void DatagramSockState.close(SinkIF closeEventQueue)
           
protected  void SockState.close(SinkIF closeEventQueue)
           
protected  void DatagramSockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
protected  void SockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
 

Uses of SinkIF in seda.sandStorm.lib.aSocket.nio
 

Methods in seda.sandStorm.lib.aSocket.nio with parameters of type SinkIF
protected  void DatagramSockState.close(SinkIF closeEventQueue)
           
protected  void SockState.close(SinkIF closeEventQueue)
           
protected  void DatagramSockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
protected  void SockState.readInit(SelectSourceIF read_selsource, SinkIF compQ, int readClogTries)
           
 

Uses of SinkIF in seda.sandStorm.lib.Gnutella
 

Classes in seda.sandStorm.lib.Gnutella that implement SinkIF
 class GnutellaConnection
          A GnutellaConnection represents a virtual connection to the Gnutella network.
 

Methods in seda.sandStorm.lib.Gnutella that return SinkIF
(package private)  SinkIF GnutellaServer.getSink()
           
 

Methods in seda.sandStorm.lib.Gnutella with parameters of type SinkIF
 void GnutellaConnection.close(SinkIF compQ)
           
(package private)  void GnutellaServer.closeConnection(ATcpConnection tcpconn, SinkIF compQ)
           
 void GnutellaConnection.flush(SinkIF compQ)
           
 void GnutellaServer.registerSink(SinkIF sink)
          Register a sink to receive incoming packets on this connection.
 

Constructors in seda.sandStorm.lib.Gnutella with parameters of type SinkIF
GnutellaServer(ManagerIF mgr, SinkIF clientSink)
          Create a Gnutella server listening for incoming connections on the default port of 6346.
GnutellaServer(ManagerIF mgr, SinkIF clientSink, int listenPort)
          Create a Gnutella server listening for incoming connections on the given listenPort.
 

Uses of SinkIF in seda.sandStorm.lib.http
 

Classes in seda.sandStorm.lib.http that implement SinkIF
 class httpConnection
          This class represents a single HTTP connection.
 

Fields in seda.sandStorm.lib.http declared as SinkIF
protected  SinkIF httpServer.clientSink
           
protected  SinkIF httpServer.mySink
           
 

Methods in seda.sandStorm.lib.http that return SinkIF
(package private)  SinkIF httpServer.getSink()
           
 

Methods in seda.sandStorm.lib.http with parameters of type SinkIF
 void httpConnection.close(SinkIF compQ)
          Close the connection.
 void httpConnection.flush(SinkIF compQ)
          Flush the connection; a SinkFlushedEvent will be pushed to the user when all packets have drained.
 void httpServer.registerSink(SinkIF sink)
          Register a sink to receive incoming packets on this connection.
 

Constructors in seda.sandStorm.lib.http with parameters of type SinkIF
httpConnection(ATcpConnection tcpconn, httpServer hs, SinkIF compQ)
          Package-internal: Create an httpConnection with the given TCP connection and completion queue.
httpOKResponse(java.lang.String contentType, int payloadSize, SinkIF compQ)
          Create an httpOKResponse with a given response payload size, MIME type, and completion sink.
httpPacketReader(httpConnection conn, SinkIF compQ)
          Create an httpPacketReader with the given httpConnection and completion queue.
httpResponse(int code, java.lang.String contentType, int payloadSize, SinkIF compQ)
          Create an httpResponse with the the given response code, with an empty payload of the given size.
httpServer(ManagerIF mgr, SinkIF clientSink)
          Create an HTTP server listening for incoming connections on the default port of 8080.
httpServer(ManagerIF mgr, SinkIF clientSink, int listenPort)
          Create an HTTP server listening for incoming connections on the given listenPort.