seda.sandStorm.lib.aSocket
Class aSocketRCTMSleep

java.lang.Object
  extended by seda.sandStorm.lib.aSocket.aSocketThreadManager
      extended by seda.sandStorm.lib.aSocket.aSocketRCTMSleep
All Implemented Interfaces:
ThreadManagerIF, aSocketConst

 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

Nested Class Summary
protected  class aSocketRCTMSleep.aSocketRCThread
          Internal class representing a single aSocketTM-managed thread.
 
Nested classes/interfaces inherited from class seda.sandStorm.lib.aSocket.aSocketThreadManager
aSocketThreadManager.aSocketThread
 
Field Summary
 
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
 
Constructor Summary
aSocketRCTMSleep(ManagerIF mgr)
           
 
Method Summary
protected  aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)
           
 
Methods inherited from class seda.sandStorm.lib.aSocket.aSocketThreadManager
deregister, deregisterAll, register
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface seda.sandStorm.api.internal.ThreadManagerIF
deregister, deregisterAll, register
 

Constructor Detail

aSocketRCTMSleep

aSocketRCTMSleep(ManagerIF mgr)
Method Detail

makeThread

protected aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)
Overrides:
makeThread in class aSocketThreadManager