Uses of Interface
seda.sandStorm.api.QueueElementIF

Packages that use QueueElementIF
<Unnamed>   
seda.sandStorm.api   
seda.sandStorm.api.internal   
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 QueueElementIF in <Unnamed>
 

Classes in <Unnamed> 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 <Unnamed> with parameters of type QueueElementIF
 void SimpleGnutellaServer.handleEvent(QueueElementIF item)
          The main event handling code.
 void CopyFile.handleEvent(QueueElementIF item)
           
 void TestHandler.handleEvent(QueueElementIF item)
           
 void TestServer.handleEvent(QueueElementIF item)
           
 void DevNullHandler.handleEvent(QueueElementIF item)
           
 void GenericHandler.handleEvent(QueueElementIF item)
           
 void TimerHandler.handleEvent(QueueElementIF item)
           
 void ProcessStage.handleEvent(QueueElementIF item)
           
 void RecvStage.handleEvent(QueueElementIF item)
           
 void ClientStage.handleEvent(QueueElementIF item)
           
 void CompletionWorker.handleEvent(QueueElementIF item)
           
 void GenericWorker.handleEvent(QueueElementIF item)
           
 void TaskRecvWorker.handleEvent(QueueElementIF item)
           
 void SimpleGnutellaServer.handleEvents(QueueElementIF[] items)
           
 void CopyFile.handleEvents(QueueElementIF[] items)
           
 void TestHandler.handleEvents(QueueElementIF[] items)
           
 void TestServer.handleEvents(QueueElementIF[] items)
           
 void DevNullHandler.handleEvents(QueueElementIF[] items)
           
 void GenericHandler.handleEvents(QueueElementIF[] items)
           
 void TimerHandler.handleEvents(QueueElementIF[] items)
           
 void ProcessStage.handleEvents(QueueElementIF[] items)
           
 void RecvStage.handleEvents(QueueElementIF[] items)
           
 void ClientStage.handleEvents(QueueElementIF[] items)
           
 void CompletionWorker.handleEvents(QueueElementIF[] items)
           
 void GenericWorker.handleEvents(QueueElementIF[] items)
           
 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 SinkCloggedEvent.element
          The element which clogged.
 QueueElementIF SinkDrainedEvent.element
          The element which was processed.
 QueueElementIF BadQueueElementException.event
          The event that was received.
 QueueElementIF UnknownEventException.event
          The event that was received.
 

Methods in seda.sandStorm.api that return QueueElementIF
 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)
          Just like blocking_dequeue_all, but returns only a single element.
 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.
 QueueElementIF[] SourceIF.dequeue_all()
          Dequeues all available elements, or returns null if there is nothing left on the queue.
 QueueElementIF SourceIF.dequeue()
          Dequeues the next element, 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.
 

Methods in seda.sandStorm.api with parameters of type QueueElementIF
 boolean EnqueuePredicateIF.accept(QueueElementIF element)
          Tests the given element for acceptance 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.
 void SinkIF.enqueue(QueueElementIF element)
          Enqueues the given element 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.
 

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.blocking_dequeue_all(int timeout_millis)
           
 QueueElementIF FiniteQueue.blocking_dequeue(int timeout_millis)
           
 QueueElementIF[] FiniteQueue.blocking_dequeue(int timeout_millis, int num)
           
 QueueElementIF[] FiniteQueue.blocking_dequeue(int timeout_millis, int num, boolean mustReturnNum)
           
 QueueElementIF[] FiniteQueue.dequeue_all()
           
 QueueElementIF FiniteQueue.dequeue()
           
 QueueElementIF[] FiniteQueue.dequeue(int num)
           
 QueueElementIF[] FiniteQueue.dequeue(int num, boolean mustReturnNum)
           
 

Methods in seda.sandStorm.core with parameters of type QueueElementIF
 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.
 boolean FiniteQueue.enqueue_lossy(QueueElementIF enqueueMe)
           
 boolean SimpleSink.enqueue_lossy(QueueElementIF enqueueMe)
          Calls enqueue() and returns false if SinkException occurs.
 void FiniteQueue.enqueue_many(QueueElementIF[] enqueueMe)
           
 void SimpleSink.enqueue_many(QueueElementIF[] enqueueMe)
          Simply calls enqueue() on each item in the array.
 java.lang.Object FiniteQueue.enqueue_prepare(QueueElementIF[] enqueueMe)
          Provisionally enqueue the given elements.
 java.lang.Object SimpleSink.enqueue_prepare(QueueElementIF[] enqueueMe)
          Not supported; throws an IllegalArgumentException.
 void FiniteQueue.enqueue(QueueElementIF enqueueMe)
           
abstract  void SimpleSink.enqueue(QueueElementIF enqueueMe)
          Must be implemented by subclasses.
 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 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 procTime)
           
 void ResponseTimeControllerMulticlass.adjustThreshold(QueueElementIF[] fetched, long procTime)
           
 void ResponseTimeControllerPID.adjustThreshold(QueueElementIF[] fetched, long procTime)
           
 void ResponseTimeControllerMM1.adjustThreshold(QueueElementIF[] fetched, long startTime, long endTime, boolean isFirst, int numThreads)
           
 boolean SinkProxy.enqueue_lossy(QueueElementIF enqueueMe)
           
 void SinkProxy.enqueue_many(QueueElementIF[] enqueueMe)
           
 java.lang.Object SinkProxy.enqueue_prepare(QueueElementIF[] enqueueMe)
           
 void SinkProxy.enqueue(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
(package private)  void AFileRequest.complete(QueueElementIF comp)
           
 boolean AFile.enqueue_lossy(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.
 boolean AFileTPImpl.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_many(QueueElementIF[] elements)
          Enqueues the given requests (which must be AFileRequests) to the file.
 void AFileTPImpl.enqueue_many(QueueElementIF[] elements)
          Enqueues the given requests (which must be AFileRequests) to the file.
 void AFile.enqueue(QueueElementIF req)
          Enqueues the given request (which must be an AFileRequest) to the file.
abstract  void AFileImpl.enqueue(QueueElementIF req)
          Enqueues the given request (which must be an AFileRequest) to the file.
 void AFileTPImpl.enqueue(QueueElementIF req)
          Enqueues the given request (which must be an AFileRequest) to the file.
 void AFileTPEventHandler.handleEvent(QueueElementIF qel)
           
 void AFileTPEventHandler.handleEvents(QueueElementIF[] qelarr)
           
 

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
 boolean ATcpConnection.enqueue_lossy(QueueElementIF buf)
          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 ATcpConnection.enqueue_many(QueueElementIF[] bufarr)
          Enqueue a set of outgoing packets to be written to this socket.
 void AUdpSocket.enqueue_many(QueueElementIF[] packets)
          Enqueue an set of outgoing packets to this socket.
 void ATcpConnection.enqueue(QueueElementIF buf)
          Enqueue an outgoing packet to be written to this socket.
 void AUdpSocket.enqueue(QueueElementIF packet)
          Enqueue an outgoing packet to be written to this socket.
 void ListenEventHandler.handleEvent(QueueElementIF qel)
           
 void ReadEventHandler.handleEvent(QueueElementIF qel)
           
 void WriteEventHandler.handleEvent(QueueElementIF qel)
           
abstract  void aSocketEventHandler.handleEvent(QueueElementIF qel)
           
 void ListenEventHandler.handleEvents(QueueElementIF[] qelarr)
           
 void ReadEventHandler.handleEvents(QueueElementIF[] qelarr)
           
 void WriteEventHandler.handleEvents(QueueElementIF[] qelarr)
           
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.blocking_dequeue_all(int timeout_millis)
          Dequeue a set of elements from the SelectSource.
 QueueElementIF SelectSource.blocking_dequeue(int timeout_millis)
          Dequeue the next element from the SelectSource.
 QueueElementIF[] SelectSource.blocking_dequeue(int timeout_millis, int num)
          Dequeue a set of elements from the SelectSource.
 QueueElementIF[] SelectSource.dequeue_all()
          Dequeues all elements which are ready from the SelectSource.
 QueueElementIF SelectSource.dequeue()
          Dequeues the next element from the SelectSource without blocking.
 QueueElementIF[] SelectSource.dequeue(int num)
          Dequeues at most num elements which are ready 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.blocking_dequeue_all(int timeout_millis)
          Dequeue a set of elements from the SelectSource.
 QueueElementIF NIOSelectSource.blocking_dequeue(int timeout_millis)
          Dequeue the next element from the SelectSource.
 QueueElementIF[] NIOSelectSource.blocking_dequeue(int timeout_millis, int num)
          Dequeue a set of elements from the SelectSource.
 QueueElementIF[] NIOSelectSource.dequeue_all()
          Dequeues all elements which are ready from the SelectSource.
 QueueElementIF NIOSelectSource.dequeue()
          Dequeues the next element from the SelectSource without blocking.
 QueueElementIF[] NIOSelectSource.dequeue(int num)
          Dequeues at most num elements which are ready 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
 boolean GnutellaConnection.enqueue_lossy(QueueElementIF element)
           
 void GnutellaConnection.enqueue_many(QueueElementIF[] elements)
           
 java.lang.Object GnutellaConnection.enqueue_prepare(QueueElementIF[] enqueueMe)
           
 void GnutellaConnection.enqueue(QueueElementIF element)
           
 void GnutellaCatcher.handleEvent(QueueElementIF item)
           
 void GnutellaServer.handleEvent(QueueElementIF qel)
           
 void GnutellaCatcher.handleEvents(QueueElementIF[] qelarr)
           
 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
 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 httpConnection.enqueue(QueueElementIF element)
          Enqueue outgoing data on this connection.
 void httpServer.handleEvent(QueueElementIF qel)
          The main event handler.
 void httpServer.handleEvents(QueueElementIF[] qelarr)