seda.sandStorm.lib.aSocket
Class aSocketThreadManager

java.lang.Object
  seda.sandStorm.lib.aSocket.aSocketThreadManager

All Implemented Interfaces:

ThreadManagerIF, aSocketConst

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.

Nested Class Summary

protected class

aSocketThreadManager.aSocketThread Internal class representing a single aSocketTM-managed thread.

Field Summary

private static boolean	DEBUG
private ManagerIF	mgr

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

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

mgr

private ManagerIF mgr

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