seda.sandStorm.lib.aSocket
Class WriteEventHandler
java.lang.Object
seda.sandStorm.lib.aSocket.aSocketEventHandler
seda.sandStorm.lib.aSocket.WriteEventHandler
- All Implemented Interfaces:
- EventHandlerIF, aSocketConst
class WriteEventHandler
- extends aSocketEventHandler
- implements EventHandlerIF, aSocketConst
Internal event handler used to handle socket write events.
Field Summary |
private static boolean |
DEBUG
|
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 |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEBUG
private static final boolean DEBUG
- See Also:
- Constant Field Values
WriteEventHandler
WriteEventHandler()
init
public void init(ConfigDataIF config)
- Description copied from interface:
EventHandlerIF
- Called when an event handler is initialized. This method should
perform any initialization operations as required by the application.
- Specified by:
init
in interface EventHandlerIF
- Specified by:
init
in class aSocketEventHandler
- Parameters:
config
- The set of configuration parameters for the stage.
destroy
public void destroy()
- Description copied from interface:
EventHandlerIF
- Called when an event handler is destroyed. This method should
perform any cleanup or shutdown operations as required by the
application before the event handler is removed from the system.
- Specified by:
destroy
in interface EventHandlerIF
- Specified by:
destroy
in class aSocketEventHandler
processConnection
private void processConnection(ConnectSockState css)
throws java.io.IOException
- Throws:
java.io.IOException
processTcpWrite
private void processTcpWrite(SockState ss)
throws java.io.IOException
- Throws:
java.io.IOException
processUdpWrite
private void processUdpWrite(DatagramSockState ss)
throws java.io.IOException
- Throws:
java.io.IOException
processWriteRequest
private void processWriteRequest(aSocketRequest req)
throws java.io.IOException
- Throws:
java.io.IOException
handleEvent
public void handleEvent(QueueElementIF qel)
- Description copied from interface:
EventHandlerIF
- Handle the event corresponding to the given QueueElementIF.
This method is invoked by the system when a single event is
pending for the event handler.
- Specified by:
handleEvent
in interface EventHandlerIF
- Specified by:
handleEvent
in class aSocketEventHandler
handleEvents
public void handleEvents(QueueElementIF[] qelarr)
- Description copied from interface:
EventHandlerIF
- Handle the events corresponding to the given QueueElementIF array.
This method is invoked when multiple events are pending for the
event handler. The application may reorder, filter, or drop
these events if it wishes to do so.
- Specified by:
handleEvents
in interface EventHandlerIF
- Specified by:
handleEvents
in class aSocketEventHandler