seda.sandStorm.internal
Class ResponseTimeControllerMM1
java.lang.Object
seda.sandStorm.internal.ResponseTimeController
seda.sandStorm.internal.ResponseTimeControllerMM1
- All Implemented Interfaces:
- ResponseTimeControllerIF
public class ResponseTimeControllerMM1
- extends ResponseTimeController
An implementation of ResponseTimeController that models the stage
as an M/M/1 queue.
Method Summary |
void |
adjustThreshold(QueueElementIF[] fetched,
long procTime)
Invoked by the stage's thread manager to adjust admission control
parameters. |
void |
adjustThreshold(QueueElementIF[] fetched,
long startTime,
long endTime,
boolean isFirst,
int numThreads)
|
void |
disable()
Disable the response time controller. |
void |
enable()
Enable the response time controller. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DEBUG
private static final boolean DEBUG
- See Also:
- Constant Field Values
ADJUST_THRESHOLD
private static final boolean ADJUST_THRESHOLD
- See Also:
- Constant Field Values
ADJUST_RATE
private static final boolean ADJUST_RATE
- See Also:
- Constant Field Values
INIT_THRESHOLD
protected static final int INIT_THRESHOLD
- See Also:
- Constant Field Values
MIN_THRESHOLD
protected static final int MIN_THRESHOLD
- See Also:
- Constant Field Values
MAX_THRESHOLD
protected static final int MAX_THRESHOLD
- See Also:
- Constant Field Values
INIT_RATE
private static final double INIT_RATE
- See Also:
- Constant Field Values
INIT_DEPTH
private static final int INIT_DEPTH
- See Also:
- Constant Field Values
MIN_RATE
private static final double MIN_RATE
- See Also:
- Constant Field Values
DEBUG_CAP_RATE
private static final boolean DEBUG_CAP_RATE
- See Also:
- Constant Field Values
DEBUG_RATE
private static final double DEBUG_RATE
- See Also:
- Constant Field Values
MOVING_AVERAGE
private static final boolean MOVING_AVERAGE
- See Also:
- Constant Field Values
MEASUREMENT_SIZE
private static final int MEASUREMENT_SIZE
- See Also:
- Constant Field Values
ESTIMATION_SIZE
private static final int ESTIMATION_SIZE
- See Also:
- Constant Field Values
ESTIMATION_TIME
private static final long ESTIMATION_TIME
- See Also:
- Constant Field Values
SMOOTH_CONST
private static final double SMOOTH_CONST
- See Also:
- Constant Field Values
NINETIETH
private static final int NINETIETH
- See Also:
- Constant Field Values
BIDIRECTIONAL_FILTER
private static final boolean BIDIRECTIONAL_FILTER
- See Also:
- Constant Field Values
SMOOTH_CONST_UP
private static final double SMOOTH_CONST_UP
- See Also:
- Constant Field Values
SMOOTH_CONST_DOWN
private static final double SMOOTH_CONST_DOWN
- See Also:
- Constant Field Values
sinkProxy
private SinkProxy sinkProxy
measurements
private long[] measurements
sortedmeasurements
private long[] sortedmeasurements
curThreshold
private int curThreshold
cur_measurement
private int cur_measurement
curRate
private double curRate
measured_mu
private double measured_mu
measured_lambda
private double measured_lambda
est_ninetiethRT
private double est_ninetiethRT
total_measured_mu
private double total_measured_mu
count_measured_mu
private double count_measured_mu
total_measured_lambda
private double total_measured_lambda
count_measured_lambda
private double count_measured_lambda
total_est_ninetiethRT
private double total_est_ninetiethRT
count_est_ninetiethRT
private double count_est_ninetiethRT
ninetiethRT
private double ninetiethRT
totalNinetiethRT
private double totalNinetiethRT
countNinetiethRT
private int countNinetiethRT
lasttime
private long lasttime
totalProcTime
private long totalProcTime
startProcTime
private long startProcTime
endProcTime
private long endProcTime
numProcessed
private int numProcessed
numReceived
private int numReceived
numEst
private int numEst
avgNumThreads
private double avgNumThreads
totalNumThreads
private int totalNumThreads
countNumThreads
private int countNumThreads
enabled
private boolean enabled
ResponseTimeControllerMM1
public ResponseTimeControllerMM1(ManagerIF mgr,
StageWrapperIF stage)
throws java.lang.IllegalArgumentException
- Throws:
java.lang.IllegalArgumentException
enable
public void enable()
- Description copied from interface:
ResponseTimeControllerIF
- Enable the response time controller.
- Specified by:
enable
in interface ResponseTimeControllerIF
- Specified by:
enable
in class ResponseTimeController
disable
public void disable()
- Description copied from interface:
ResponseTimeControllerIF
- Disable the response time controller.
- Specified by:
disable
in interface ResponseTimeControllerIF
- Specified by:
disable
in class ResponseTimeController
adjustThreshold
public void adjustThreshold(QueueElementIF[] fetched,
long startTime,
long endTime,
boolean isFirst,
int numThreads)
adjustThreshold
public void adjustThreshold(QueueElementIF[] fetched,
long procTime)
- Description copied from interface:
ResponseTimeControllerIF
- Invoked by the stage's thread manager to adjust admission control
parameters.
- Specified by:
adjustThreshold
in interface ResponseTimeControllerIF
- Specified by:
adjustThreshold
in class ResponseTimeController