seda.sandStorm.lib.aSocket
Class aSocketRCTMSleep
java.lang.Object
seda.sandStorm.lib.aSocket.aSocketThreadManager
seda.sandStorm.lib.aSocket.aSocketRCTMSleep
- All Implemented Interfaces:
- aSocketConst, ThreadManagerIF
- class aSocketRCTMSleep
- extends aSocketThreadManager
- implements ThreadManagerIF, aSocketConst
aSocketRCTMSleep is a version of aSocketThreadManager that incorporates
a rate controller: given a target packet-processing rate, it adjusts
its schedule to attempt to match that rate. The controller is based
on adding controlled pauses to the packet-processing loop.
- Author:
- Matt Welsh
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 |
aSocketRCTMSleep
aSocketRCTMSleep(ManagerIF mgr)
makeThread
protected aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)
- Overrides:
makeThread
in class aSocketThreadManager
register
public void register(StageWrapperIF thestage)
- Register a stage with this thread manager.
- Specified by:
register
in interface ThreadManagerIF
deregister
public void deregister(StageWrapperIF stage)
- Deregister a stage with this thread manager.
- Specified by:
deregister
in interface ThreadManagerIF
deregisterAll
public void deregisterAll()
- Deregister all stages from this thread manager.
- Specified by:
deregisterAll
in interface ThreadManagerIF