|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of QueueElementIF in |
Classes in Default Package that implement QueueElementIF | |
class |
ClassedMessage
|
(package private) class |
ClientStage.MessageSendEvent
|
(package private) class |
ClientStageMulticlass.ClassedMessageSendEvent
|
class |
Message
|
(package private) class |
SimpleGnutellaServer.timerEvent
Small internal class to represent a timer event. |
(package private) class |
SimpleP2PClient.MessageSendEvent
|
Methods in Default Package with parameters of type QueueElementIF | |
void |
SimpleGnutellaServer.handleEvent(QueueElementIF item)
The main event handling code. |
void |
SimpleGnutellaServer.handleEvents(QueueElementIF[] items)
|
void |
CopyFile.handleEvent(QueueElementIF item)
|
void |
CopyFile.handleEvents(QueueElementIF[] items)
|
void |
TestHandler.handleEvent(QueueElementIF item)
|
void |
TestHandler.handleEvents(QueueElementIF[] items)
|
void |
TestServer.handleEvent(QueueElementIF item)
|
void |
TestServer.handleEvents(QueueElementIF[] items)
|
void |
DevNullHandler.handleEvent(QueueElementIF item)
|
void |
DevNullHandler.handleEvents(QueueElementIF[] items)
|
void |
GenericHandler.handleEvent(QueueElementIF item)
|
void |
GenericHandler.handleEvents(QueueElementIF[] items)
|
void |
TimerHandler.handleEvent(QueueElementIF item)
|
void |
TimerHandler.handleEvents(QueueElementIF[] items)
|
void |
ProcessStage.handleEvent(QueueElementIF item)
|
void |
ProcessStage.handleEvents(QueueElementIF[] items)
|
void |
RecvStage.handleEvent(QueueElementIF item)
|
void |
RecvStage.handleEvents(QueueElementIF[] items)
|
void |
ClientStage.handleEvents(QueueElementIF[] items)
|
void |
ClientStage.handleEvent(QueueElementIF item)
|
void |
CompletionWorker.handleEvent(QueueElementIF item)
|
void |
CompletionWorker.handleEvents(QueueElementIF[] items)
|
void |
GenericWorker.handleEvent(QueueElementIF item)
|
void |
GenericWorker.handleEvents(QueueElementIF[] items)
|
void |
TaskRecvWorker.handleEvent(QueueElementIF item)
|
void |
TaskRecvWorker.handleEvents(QueueElementIF[] items)
|
Uses of QueueElementIF in seda.sandStorm.api |
Subinterfaces of QueueElementIF in seda.sandStorm.api | |
interface |
ClassQueueElementIF
A ClassQueueElementIF represents an event with an associated 'class' used for class-based admission control. |
interface |
SignalIF
This is an empty interface that must be implemented by all classes representing signal events. |
Classes in seda.sandStorm.api that implement QueueElementIF | |
class |
SinkCloggedEvent
This event indicates that a sink was clogged when trying to process the given element. |
class |
SinkClosedEvent
This event indicates that a sink has closed, either intentionally by the application, or unintentionally, due to an error condition. |
class |
SinkDrainedEvent
This event indicates that a sink element was processed. |
class |
SinkFlushedEvent
This event indicates that the given sink was successfully flushed; this event is generated in response to a SinkIF.flush() call. |
class |
StagesInitializedSignal
This signal indicates that all stages specified in the initial Sandstorm configuration, or created during the init() method from a stage specified in the initial configuration, have been initialized. |
Fields in seda.sandStorm.api declared as QueueElementIF | |
QueueElementIF |
BadQueueElementException.event
The event that was received. |
QueueElementIF |
SinkCloggedEvent.element
The element which clogged. |
QueueElementIF |
SinkDrainedEvent.element
The element which was processed. |
QueueElementIF |
UnknownEventException.event
The event that was received. |
Methods in seda.sandStorm.api that return QueueElementIF | |
QueueElementIF |
SourceIF.dequeue()
Dequeues the next element, or returns null if there is
nothing left on the queue. |
QueueElementIF[] |
SourceIF.dequeue_all()
Dequeues all available elements, or returns null if there is
nothing left on the queue. |
QueueElementIF[] |
SourceIF.dequeue(int num)
Dequeues at most num available elements, or returns
null if there is nothing left on the queue. |
QueueElementIF |
SourceIF.blocking_dequeue(int timeout_millis)
Just like blocking_dequeue_all, but returns only a single element. |
QueueElementIF[] |
SourceIF.blocking_dequeue_all(int timeout_millis)
This method blocks on the queue up until a timeout occurs or until an element appears on the queue. |
QueueElementIF[] |
SourceIF.blocking_dequeue(int timeout_millis,
int num)
This method blocks on the queue up until a timeout occurs or until an element appears on the queue. |
Methods in seda.sandStorm.api with parameters of type QueueElementIF | |
boolean |
EnqueuePredicateIF.accept(QueueElementIF element)
Tests the given element for acceptance onto the queue. |
void |
EventHandlerIF.handleEvent(QueueElementIF elem)
Handle the event corresponding to the given QueueElementIF. |
void |
EventHandlerIF.handleEvents(QueueElementIF[] elemarr)
Handle the events corresponding to the given QueueElementIF array. |
void |
SinkIF.enqueue(QueueElementIF element)
Enqueues the given element onto the queue. |
boolean |
SinkIF.enqueue_lossy(QueueElementIF element)
Enqueues the given element onto the queue. |
void |
SinkIF.enqueue_many(QueueElementIF[] elements)
Given an array of elements, atomically enqueues all of the elements in the array. |
java.lang.Object |
SinkIF.enqueue_prepare(QueueElementIF[] elements)
Support for transactional enqueue. |
Constructors in seda.sandStorm.api with parameters of type QueueElementIF | |
BadQueueElementException(java.lang.String msg,
QueueElementIF event)
Create a new BadQueueElementException with the given explanatory message and event. |
|
SinkCloggedEvent(SinkIF sink,
QueueElementIF element)
Create a new SinkCloggedEvent with the given sink and element. |
|
SinkDrainedEvent(SinkIF sink,
QueueElementIF element)
Create a new SinkDrainedEvent with the given sink and element. |
|
UnknownEventException(java.lang.String msg,
QueueElementIF event)
Create a new UnknownEventException with the given explanatory message and event. |
Uses of QueueElementIF in seda.sandStorm.api.internal |
Methods in seda.sandStorm.api.internal with parameters of type QueueElementIF | |
void |
ResponseTimeControllerIF.adjustThreshold(QueueElementIF[] fetched,
long serviceTime)
Invoked by the stage's thread manager to adjust admission control parameters. |
Uses of QueueElementIF in seda.sandStorm.core |
Classes in seda.sandStorm.core that implement QueueElementIF | |
class |
BufferElement
A BufferElement is a QueueElementIF which represents a memory buffer. |
class |
NullElement
This is a 'null' QueueElementIF implementation, which can be used for signalling. |
class |
TimeStampedEvent
A TimeStampedEvent is an abstract superclass for events that wish to carry a timestamp. |
Fields in seda.sandStorm.core declared as QueueElementIF | |
QueueElementIF |
ssTimer.ssTimerEvent.obj
|
Methods in seda.sandStorm.core that return QueueElementIF | |
QueueElementIF |
FiniteQueue.dequeue()
|
QueueElementIF[] |
FiniteQueue.dequeue_all()
|
QueueElementIF[] |
FiniteQueue.dequeue(int num)
|
QueueElementIF[] |
FiniteQueue.dequeue(int num,
boolean mustReturnNum)
|
QueueElementIF[] |
FiniteQueue.blocking_dequeue_all(int timeout_millis)
|
QueueElementIF[] |
FiniteQueue.blocking_dequeue(int timeout_millis,
int num,
boolean mustReturnNum)
|
QueueElementIF[] |
FiniteQueue.blocking_dequeue(int timeout_millis,
int num)
|
QueueElementIF |
FiniteQueue.blocking_dequeue(int timeout_millis)
|
Methods in seda.sandStorm.core with parameters of type QueueElementIF | |
void |
FiniteQueue.enqueue(QueueElementIF enqueueMe)
|
boolean |
FiniteQueue.enqueue_lossy(QueueElementIF enqueueMe)
|
void |
FiniteQueue.enqueue_many(QueueElementIF[] enqueueMe)
|
java.lang.Object |
FiniteQueue.enqueue_prepare(QueueElementIF[] enqueueMe)
Provisionally enqueue the given elements. |
boolean |
MulticlassRateLimitingPredicate.accept(QueueElementIF qel)
Returns true if the given element can be accepted into the queue. |
boolean |
QueueThresholdPredicate.accept(QueueElementIF qel)
Returns true if the given element can be accepted into the queue. |
boolean |
RateLimitingPredicate.accept(QueueElementIF qel)
Returns true if the given element can be accepted into the queue. |
abstract void |
SimpleSink.enqueue(QueueElementIF enqueueMe)
Must be implemented by subclasses. |
boolean |
SimpleSink.enqueue_lossy(QueueElementIF enqueueMe)
Calls enqueue() and returns false if SinkException occurs. |
void |
SimpleSink.enqueue_many(QueueElementIF[] enqueueMe)
Simply calls enqueue() on each item in the array. |
java.lang.Object |
SimpleSink.enqueue_prepare(QueueElementIF[] enqueueMe)
Not supported; throws an IllegalArgumentException. |
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. |
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 . |
Constructors in seda.sandStorm.core with parameters of type QueueElementIF | |
ssTimer.ssTimerEvent(long m,
QueueElementIF o,
SinkIF q)
|
Uses of QueueElementIF in seda.sandStorm.internal |
Methods in seda.sandStorm.internal with parameters of type QueueElementIF | |
abstract void |
ResponseTimeController.adjustThreshold(QueueElementIF[] fetched,
long serviceTime)
|
void |
ResponseTimeControllerDirect.adjustThreshold(QueueElementIF[] fetched,
long procTime)
|
void |
ResponseTimeControllerMM1.adjustThreshold(QueueElementIF[] fetched,
long startTime,
long endTime,
boolean isFirst,
int numThreads)
|
void |
ResponseTimeControllerMM1.adjustThreshold(QueueElementIF[] fetched,
long procTime)
|
void |
ResponseTimeControllerMulticlass.adjustThreshold(QueueElementIF[] fetched,
long procTime)
|
void |
ResponseTimeControllerPID.adjustThreshold(QueueElementIF[] fetched,
long procTime)
|
void |
SinkProxy.enqueue(QueueElementIF enqueueMe)
|
boolean |
SinkProxy.enqueue_lossy(QueueElementIF enqueueMe)
|
void |
SinkProxy.enqueue_many(QueueElementIF[] enqueueMe)
|
java.lang.Object |
SinkProxy.enqueue_prepare(QueueElementIF[] enqueueMe)
|
Uses of QueueElementIF in seda.sandStorm.lib.aDisk |
Classes in seda.sandStorm.lib.aDisk that implement QueueElementIF | |
class |
AFileCloseRequest
A request to close the given file. |
class |
AFileCompletion
Abstract base class of AFile I/O completion events. |
class |
AFileEOFReached
A completion event indicating that EOF was reached on the given file during an attempted I/O operation. |
class |
AFileFlushRequest
A request to flush all pending I/O events on the given file. |
class |
AFileIOCompleted
Completion event indicating that a previous I/O request on the file completed. |
class |
AFileIOExceptionOccurred
A completion event indicating that an IOException occurred during the corresponding I/O request. |
class |
AFileReadRequest
A request to read data from a file. |
class |
AFileRequest
Abstract base class of I/O requests which can be posted to the AFile enqueue() methods. |
class |
AFileSeekRequest
A request to seek to the given offset of the given file. |
(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. |
(package private) class |
AFileTPTM.fileQueueEntry
|
class |
AFileWriteRequest
A request to write to a file. |
Methods in seda.sandStorm.lib.aDisk with parameters of type QueueElementIF | |
void |
AFile.enqueue(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
boolean |
AFile.enqueue_lossy(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
void |
AFile.enqueue_many(QueueElementIF[] elements)
Enqueues the given requests (which must be AFileRequests) to the file. |
abstract void |
AFileImpl.enqueue(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
abstract boolean |
AFileImpl.enqueue_lossy(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
abstract void |
AFileImpl.enqueue_many(QueueElementIF[] elements)
Enqueues the given requests (which must be AFileRequests) to the file. |
(package private) void |
AFileRequest.complete(QueueElementIF comp)
|
void |
AFileTPEventHandler.handleEvent(QueueElementIF qel)
|
void |
AFileTPEventHandler.handleEvents(QueueElementIF[] qelarr)
|
void |
AFileTPImpl.enqueue(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
boolean |
AFileTPImpl.enqueue_lossy(QueueElementIF req)
Enqueues the given request (which must be an AFileRequest) to the file. |
void |
AFileTPImpl.enqueue_many(QueueElementIF[] elements)
Enqueues the given requests (which must be AFileRequests) to the file. |
Uses of QueueElementIF in seda.sandStorm.lib.aSocket |
Classes in seda.sandStorm.lib.aSocket that implement QueueElementIF | |
class |
aSocketErrorEvent
This is the base class for all error events passed up by the aSocket library. |
class |
aSocketRequest
This is the superclass for the various requests that can be issued to the aSocketMgr. |
class |
ATcpCloseRequest
Request to close a connection. |
(package private) class |
ATcpCloseServerRequest
Request to close a server socket. |
class |
ATcpConnectFailedEvent
ATcpConnectFailedEvent objects will be passed to the SinkIF associated with an ATcpClientSocket when a connection attempt fails. |
class |
ATcpConnection
An ATcpConnection represents an established connection on an asynchronous socket. |
class |
ATcpConnectRequest
Request to establish a connection. |
(package private) class |
ATcpFlushRequest
Request to flush a connection. |
class |
ATcpInPacket
An ATcpInPacket represents a packet which was received from an asynchronous socket. |
class |
ATcpListenFailedEvent
ATcpListenFailedEvent objects will be passed to the SinkIF associated with an ATcpServerSocket when an attempt to create that server socket fails. |
class |
ATcpListenRequest
Request to listen on a TCP port. |
class |
ATcpListenSuccessEvent
ATcpListenSuccessEvent objects will be passed to the SinkIF associated with an ATcpServerSocket when the socket successfully listens on the requested port. |
(package private) class |
ATcpResumeAcceptRequest
Request to resume accepting new connections on a server socket. |
class |
ATcpServerSocketClosedEvent
ATcpServerSocketClosedEvent objects will be passed up to the SinkIF associated with an ATcpServerSocket when a server socket dies. |
(package private) class |
ATcpStartReadRequest
Request to initiate read events on a connection. |
(package private) class |
ATcpSuspendAcceptRequest
Request to suspend accepting new connections on a server socket. |
class |
ATcpWriteRequest
Request to write data to a connection. |
class |
AUdpCloseRequest
Request to close a UDP socket. |
class |
AUdpConnectEvent
AUdpConnectEvent objects will be passed to the SinkIF associated with an AUdpSocket when the socket successfully connects. |
class |
AUdpConnectRequest
Request to connect a UDP socket. |
class |
AUdpDisconnectEvent
AUdpDisconnectEvent objects will be passed to the SinkIF associated with an AUdpSocket when the socket successfully disconnects. |
class |
AUdpDisconnectRequest
Request to disconnect a UDP socket. |
class |
AUdpFlushRequest
Request to flush a connection. |
class |
AUdpInPacket
An AUdpInPacket represents a packet which was received from a datagram socket. |
class |
AUdpPacket
An AUdpPacket is an extension to BufferElement that supports specifying the destination address and port for a given packet. |
class |
AUdpStartReadRequest
Request to initiate read events on a UDP socket. |
class |
AUdpWriteRequest
Request to write data to a connection. |
class |
SelectQueueElement
A SelectQueueElement is a wrapper for SelectItem which makes it a QueueElementIF. |
Fields in seda.sandStorm.lib.aSocket declared as QueueElementIF | |
protected QueueElementIF |
DatagramSockState.clogged_qel
|
protected QueueElementIF |
SockState.clogged_qel
|
Methods in seda.sandStorm.lib.aSocket with parameters of type QueueElementIF | |
void |
ATcpConnection.enqueue(QueueElementIF buf)
Enqueue an outgoing packet to be written to this socket. |
boolean |
ATcpConnection.enqueue_lossy(QueueElementIF buf)
Enqueue an outgoing packet to be written to this socket. |
void |
ATcpConnection.enqueue_many(QueueElementIF[] bufarr)
Enqueue a set of outgoing packets to be written to this socket. |
void |
AUdpSocket.enqueue(QueueElementIF packet)
Enqueue an outgoing packet to be written to this socket. |
boolean |
AUdpSocket.enqueue_lossy(QueueElementIF packet)
Enqueue an outgoing packet to be written to this socket. |
void |
AUdpSocket.enqueue_many(QueueElementIF[] packets)
Enqueue an set of outgoing packets to this socket. |
void |
ListenEventHandler.handleEvent(QueueElementIF qel)
|
void |
ListenEventHandler.handleEvents(QueueElementIF[] qelarr)
|
void |
ReadEventHandler.handleEvent(QueueElementIF qel)
|
void |
ReadEventHandler.handleEvents(QueueElementIF[] qelarr)
|
void |
WriteEventHandler.handleEvent(QueueElementIF qel)
|
void |
WriteEventHandler.handleEvents(QueueElementIF[] qelarr)
|
abstract void |
aSocketEventHandler.handleEvent(QueueElementIF qel)
|
abstract void |
aSocketEventHandler.handleEvents(QueueElementIF[] qelarr)
|
Uses of QueueElementIF in seda.sandStorm.lib.aSocket.nbio |
Methods in seda.sandStorm.lib.aSocket.nbio that return QueueElementIF | |
QueueElementIF |
SelectSource.dequeue()
Dequeues the next element from the SelectSource without blocking. |
QueueElementIF[] |
SelectSource.dequeue_all()
Dequeues all elements which are ready from the SelectSource. |
QueueElementIF[] |
SelectSource.dequeue(int num)
Dequeues at most num elements which are ready from the SelectSource. |
QueueElementIF |
SelectSource.blocking_dequeue(int timeout_millis)
Dequeue the next element from the SelectSource. |
QueueElementIF[] |
SelectSource.blocking_dequeue_all(int timeout_millis)
Dequeue a set of elements from the SelectSource. |
QueueElementIF[] |
SelectSource.blocking_dequeue(int timeout_millis,
int num)
Dequeue a set of elements from the SelectSource. |
Uses of QueueElementIF in seda.sandStorm.lib.aSocket.nio |
Classes in seda.sandStorm.lib.aSocket.nio that implement QueueElementIF | |
class |
NIOSelectorQueueElement
A NIOSelectorQueueElement is a wrapper for NIO's SelectionKey which makes it a QueueElementIF. |
Methods in seda.sandStorm.lib.aSocket.nio that return QueueElementIF | |
QueueElementIF |
NIOSelectSource.dequeue()
Dequeues the next element from the SelectSource without blocking. |
QueueElementIF[] |
NIOSelectSource.dequeue_all()
Dequeues all elements which are ready from the SelectSource. |
QueueElementIF[] |
NIOSelectSource.dequeue(int num)
Dequeues at most num elements which are ready from the SelectSource. |
QueueElementIF |
NIOSelectSource.blocking_dequeue(int timeout_millis)
Dequeue the next element from the SelectSource. |
QueueElementIF[] |
NIOSelectSource.blocking_dequeue_all(int timeout_millis)
Dequeue a set of elements from the SelectSource. |
QueueElementIF[] |
NIOSelectSource.blocking_dequeue(int timeout_millis,
int num)
Dequeue a set of elements from the SelectSource. |
Uses of QueueElementIF in seda.sandStorm.lib.Gnutella |
Classes in seda.sandStorm.lib.Gnutella that implement QueueElementIF | |
class |
GnutellaConnectFailedEvent
This event indicates that an attempt to establish a Gnutella connection failed. |
class |
GnutellaConnection
A GnutellaConnection represents a virtual connection to the Gnutella network. |
class |
GnutellaPacket
This is the base class for all Gnutella network packets. |
class |
GnutellaPingPacket
A Gnutella network ping packet. |
class |
GnutellaPongPacket
A Gnutella network pong packet. |
class |
GnutellaPushPacket
A Gnutella push packet. |
class |
GnutellaQueryHitsPacket
A Gnutella query hits packet. |
class |
GnutellaQueryPacket
A Gnutella query packet. |
Methods in seda.sandStorm.lib.Gnutella with parameters of type QueueElementIF | |
void |
GnutellaCatcher.handleEvent(QueueElementIF item)
|
void |
GnutellaCatcher.handleEvents(QueueElementIF[] qelarr)
|
void |
GnutellaConnection.enqueue(QueueElementIF element)
|
boolean |
GnutellaConnection.enqueue_lossy(QueueElementIF element)
|
void |
GnutellaConnection.enqueue_many(QueueElementIF[] elements)
|
java.lang.Object |
GnutellaConnection.enqueue_prepare(QueueElementIF[] enqueueMe)
|
void |
GnutellaServer.handleEvent(QueueElementIF qel)
|
void |
GnutellaServer.handleEvents(QueueElementIF[] qelarr)
|
Uses of QueueElementIF in seda.sandStorm.lib.http |
Classes in seda.sandStorm.lib.http that implement QueueElementIF | |
class |
httpBadRequestResponse
An httpResponse corresponding to a '404 Bad Request' (i.e. |
class |
httpConnection
This class represents a single HTTP connection. |
class |
httpInternalServerErrorResponse
An httpResponse corresponding to a '500 Internal Server Error' Use httpNotFoundResponse for a '404 Not Found'. |
class |
httpNotFoundResponse
An httpResponse corresponding to a '404 Not Found' error. |
class |
httpOKResponse
An httpResponse corresponding to a '200 OK' response. |
class |
httpRedirectResponse
An httpResponse corresponding to a '301 Moved Permanently' response. |
class |
httpRequest
This class represents a single HTTP client request. |
class |
httpResponder
This class is used to wrap an HTTP response along with the connection which it is destined for. |
class |
httpResponse
This is an abstract class corresponding to an HTTP response. |
class |
httpServiceUnavailableResponse
An httpResponse corresponding to a '503 Service Unavailable' error. |
Methods in seda.sandStorm.lib.http with parameters of type QueueElementIF | |
void |
httpConnection.enqueue(QueueElementIF element)
Enqueue outgoing data on this connection. |
boolean |
httpConnection.enqueue_lossy(QueueElementIF element)
Enqueue outgoing data on this connection. |
void |
httpConnection.enqueue_many(QueueElementIF[] elements)
Enqueue outgoing data on this connection. |
java.lang.Object |
httpConnection.enqueue_prepare(QueueElementIF[] enqueueMe)
|
void |
httpServer.handleEvent(QueueElementIF qel)
The main event handler. |
void |
httpServer.handleEvents(QueueElementIF[] qelarr)
|
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |