|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |