seda.sandStorm.lib.aSocket
Class aSocketThreadManager

java.lang.Object
  extended byseda.sandStorm.lib.aSocket.aSocketThreadManager
All Implemented Interfaces:
aSocketConst, ThreadManagerIF
Direct Known Subclasses:
aSocketRCTMSleep

class aSocketThreadManager
extends java.lang.Object
implements ThreadManagerIF, aSocketConst

aSocketThreadManager provides a thread manager for the aSocket layer: one thread for each of the read, write, and listen stages.

Author:
Matt Welsh

Nested Class Summary
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) aSocketThreadManager(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
 

Constructor Detail

aSocketThreadManager

aSocketThreadManager(ManagerIF mgr)
Method Detail

makeThread

protected aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)

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