|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.joram.mom.dest.LoadingFactor
Nested Class Summary | |
static class |
LoadingFactor.ConsumerStatus
|
static class |
LoadingFactor.ProducerStatus
|
static class |
LoadingFactor.Status
|
Field Summary | |
boolean |
autoEvalThreshold
automatic eval threshold |
ClusterQueueImpl |
clusterQueueImpl
reference to clusterQueueImpl |
int |
consumThreshold
consumer threshold |
int |
producThreshold
producer threshold |
long |
validityPeriod
validity period |
Constructor Summary | |
LoadingFactor(ClusterQueueImpl clusterQueueImpl,
int producThreshold,
int consumThreshold,
boolean autoEvalThreshold,
long validityPeriod)
|
Method Summary | |
float |
evalRateOfFlow(int pendingMessages,
int pendingRequests)
eval the rate of flow (means). |
void |
factorCheck(java.util.Hashtable clusters,
int pendingMessages,
int pendingRequests)
this method eval the rate of flow and activity. |
float |
getRateOfFlow()
|
boolean |
isOverloaded()
return true if cluster queue is overloaded. |
void |
processGive(AgentId to,
LBCycleLife cycle)
|
void |
setRateOfFlow(float rateOfFlow)
|
void |
setWait()
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public ClusterQueueImpl clusterQueueImpl
public int producThreshold
public int consumThreshold
public boolean autoEvalThreshold
public long validityPeriod
Constructor Detail |
public LoadingFactor(ClusterQueueImpl clusterQueueImpl, int producThreshold, int consumThreshold, boolean autoEvalThreshold, long validityPeriod)
Method Detail |
public void setRateOfFlow(float rateOfFlow)
public float getRateOfFlow()
public void setWait()
public float evalRateOfFlow(int pendingMessages, int pendingRequests)
public void factorCheck(java.util.Hashtable clusters, int pendingMessages, int pendingRequests)
public boolean isOverloaded()
public void processGive(AgentId to, LBCycleLife cycle)
public java.lang.String toString()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |