seda.sandStorm.lib.aSocket
Class aSocketRCTMSleep

java.lang.Object
  extended byseda.sandStorm.lib.aSocket.aSocketThreadManager
      extended byseda.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

Nested Class Summary
protected  class aSocketRCTMSleep.aSocketRCThread
          Internal class representing a single aSocketTM-managed thread.
protected  class aSocketThreadManager.aSocketThread
          Internal class representing a single aSocketTM-managed thread.
 
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
(package private) aSocketRCTMSleep(ManagerIF mgr)
           
 
Method Summary
 void deregister(StageWrapperIF stage)
          Deregister a stage with this thread manager.
 void deregisterAll()
          Deregister all stages from this thread manager.
protected  aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)
           
 void register(StageWrapperIF thestage)
          Register a stage with this thread manager.
 
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

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