seda.sandStorm.lib.aSocket
Class aSocketRCTMSleep

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

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

private static boolean	DEBUG
private static int	INITIAL_SLEEPFREQ
private static int	INITIAL_SLEEPTIME
private static int	MAX_AGGREGATION
private double	targetRate

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

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

INITIAL_SLEEPTIME

private static final int INITIAL_SLEEPTIME

See Also:

Constant Field Values

INITIAL_SLEEPFREQ

private static final int INITIAL_SLEEPFREQ

See Also:

Constant Field Values

MAX_AGGREGATION

private static final int MAX_AGGREGATION

See Also:

Constant Field Values

targetRate

private double targetRate

Constructor Detail

aSocketRCTMSleep

aSocketRCTMSleep(ManagerIF mgr)

Method Detail

makeThread

protected aSocketThreadManager.aSocketThread makeThread(aSocketStageWrapper wrapper)

Overrides:

makeThread in class aSocketThreadManager