agentgui.simulationService.agents

Class LoadMeasureAgent

java.lang.Object

jade.core.Agent

agentgui.simulationService.agents.LoadMeasureAgent

All Implemented Interfaces:

jade.core.TimerListener, java.io.Serializable, java.lang.Runnable

public class LoadMeasureAgent
extends jade.core.Agent

This class represents the agent, which monitors the load information of all involved JVM's, container and agents of the platform.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	LoadMeasureAgent.MonitorBehaviour This TickerBehaviour measures, displays (if wanted) and stores the measured load values.

Nested classes/interfaces inherited from class jade.core.Agent

jade.core.Agent.Interrupted

Field Summary

Fields

Modifier and Type	Field and Description
java.util.Vector<java.lang.String>	loadContainer2Display The used (dead or alive) nodes of the system, ordered ascending.
java.util.Hashtable<java.lang.String,java.lang.Float>	loadContainerBenchmarkResults The benchmark value /results in the different container.
java.util.Hashtable<java.lang.String,LoadMerger>	loadJVM4Balancing The currently running JVM's for this platform.
java.util.Hashtable<java.lang.String,LoadMerger>	loadMachines4Balancing The currently running physical machines for this platform.
java.lang.Integer	loadThresholdExceededOverAll The indicator if thresholds exceeded over all.
LoadThresholdLevels	loadThresholdLevels The currently configured threshold levels.

Fields inherited from class jade.core.Agent

AP_ACTIVE, AP_DELETED, AP_IDLE, AP_INITIATED, AP_MAX, AP_MIN, AP_SUSPENDED, AP_WAITING, D_ACTIVE, D_MAX, D_MIN, D_RETIRED, D_SUSPENDED, D_UNKNOWN, MSG_QUEUE_CLASS

Constructor Summary

Constructors

Constructor and Description
LoadMeasureAgent()

Method Summary

Modifier and Type	Method and Description
void	addThreadProtocol(ThreadProtocol tp) Adds a thread protocol to the information of the agent.
DistributionSetup	getDistributionSetup() Returns the DistributionSetup of the current Project if available.
DynamicLoadBalancingBase	getLoadBalancing() Gets the currently use dynamic load balancing algorithm.
java.util.Hashtable<java.lang.String,PlatformLoad>	getLoadContainer() Returns the current PlatformLoad by container name.
LoadAgentMap	getLoadContainerAgentMap() Return the current LoadAgentMap.
java.util.Hashtable<java.lang.String,jade.core.Location>	getLoadContainerLoactions() Returns the current Location information in the different container.
double	getLoadCycleTime() Return the average cycle time of a sequential simulation.
LoadServiceHelper	getLoadServiceHelper() Returns the LoadServiceHelper.
LoadMeasureAgent.MonitorBehaviour	getMonitorBehaviour() Returns the LoadMeasureAgent.MonitorBehaviour.
long	getMonitorBehaviourTickingPeriod() Returns the monitor behaviour ticking period.
Project	getProject() Returns the current Project.
SimulationSetup	getSimulationSetup() Returns the current SimulationSetup if available.
ThreadMonitor	getThreadDialog() Gets the thread dialog.
ThreadInfoStorage	getThreadInfoStorage() Gets the thread info storage.
ThreadMeasureBehaviour	getThreadMeasureBehaviour() Gets the thread measure behaviour.
java.lang.Long	getThreadMeasurementTickingPeriod() Returns the thread measurement ticking period.
ThreadProtocolVector	getThreadProtocolVector() Returns the current ThreadProtocol.
boolean	isDynLoadBalancaingStillActivated()
boolean	isMonitorSaveLoad() Checks if the current LoadAgent has to the save the load information in a file.
void	reStartThreadMeasurement(boolean oneShotBehaviour) (Re-)Starts the thread measurement.
void	setDynLoadBalancaingStillActivated(boolean dynLoadBalancaingStillActivated)
void	setLoadBalancing(DynamicLoadBalancingBase loadBalancing) Sets the instance of the dynamic load balancing algorithm to use.
void	setLoadContainer(java.util.Hashtable<java.lang.String,PlatformLoad> newLoadContainer) Sets the current PlatformLoad by container name.
void	setLoadContainerAgentMap(LoadAgentMap newLoadAgentMap) Return the current LoadAgentMap.
void	setLoadContainerLoactions(java.util.Hashtable<java.lang.String,jade.core.Location> newLoadContainerLocation) Sets the load container loaction's.
void	setLoadCycleTime(double newLoadCycleTime) Sets the average cycle time of a sequential simulation.
void	setMonitorBehaviourTickingPeriod(long monitorBehaviourTickingPeriod) Sets the monitor behaviour ticking period.
void	setMonitorSaveLoad(boolean monitorSaveLoad) Sets the current LoadAgent to save or not save the load information in a file.
void	setThreadDialog(ThreadMonitor threadDialog) Sets the thread dialog.
void	setThreadMeasurementTickingPeriod(long threadMeasurementTickingPeriod) Sets the thread measurement ticking period.
protected void	setup()
protected void	takeDown()

Methods inherited from class jade.core.Agent

addBehaviour, afterClone, afterMove, beforeClone, beforeMove, blockingReceive, blockingReceive, blockingReceive, blockingReceive, changeStateTo, clean, createMessageQueue, doActivate, doClone, doDelete, doMove, doSuspend, doTimeOut, doWait, doWait, doWake, getAgentState, getAID, getAID, getAMS, getArguments, getBehavioursCnt, getBootProperties, getContainerController, getContentManager, getCurQueueSize, getDefaultDF, getExecutedBehavioursCnt, getHap, getHelper, getLocalName, getName, getO2AInterface, getO2AObject, getPostedMessagesCnt, getProperty, getQueueSize, getReceivedMessagesCnt, getState, here, isAlive, isRestarting, join, notifyChangeBehaviourState, notifyRestarted, postMessage, putBack, putO2AObject, receive, receive, registerO2AInterface, removeBehaviour, removeTimer, restartLater, restore, restoreBufferedState, run, send, setArguments, setEnabledO2ACommunication, setGenerateBehaviourEvents, setO2AManager, setQueueSize, waitUntilStarted, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

loadThresholdExceededOverAll

public java.lang.Integer loadThresholdExceededOverAll

The indicator if thresholds exceeded over all.

loadThresholdLevels

public LoadThresholdLevels loadThresholdLevels

The currently configured threshold levels.

loadContainer2Display

public java.util.Vector<java.lang.String> loadContainer2Display

The used (dead or alive) nodes of the system, ordered ascending.

loadContainerBenchmarkResults

public java.util.Hashtable<java.lang.String,java.lang.Float> loadContainerBenchmarkResults

The benchmark value /results in the different container.

loadJVM4Balancing

public java.util.Hashtable<java.lang.String,LoadMerger> loadJVM4Balancing

The currently running JVM's for this platform.

loadMachines4Balancing

public java.util.Hashtable<java.lang.String,LoadMerger> loadMachines4Balancing

The currently running physical machines for this platform.

Constructor Detail

LoadMeasureAgent

public LoadMeasureAgent()

Method Detail

setup

protected void setup()

Overrides:

setup in class jade.core.Agent

takeDown

protected void takeDown()

Overrides:

takeDown in class jade.core.Agent

getMonitorBehaviour

public LoadMeasureAgent.MonitorBehaviour getMonitorBehaviour()

Returns the LoadMeasureAgent.MonitorBehaviour.

Returns:

the monitor behaviour

getMonitorBehaviourTickingPeriod

public long getMonitorBehaviourTickingPeriod()

Returns the monitor behaviour ticking period.

Returns:

the monitorBehaviourTickingPeriod

setMonitorBehaviourTickingPeriod

public void setMonitorBehaviourTickingPeriod(long monitorBehaviourTickingPeriod)

Sets the monitor behaviour ticking period.

Parameters:

monitorBehaviourTickingPeriod - the monitorBehaviourTickingPeriod to set

setLoadBalancing

public void setLoadBalancing(DynamicLoadBalancingBase loadBalancing)

Sets the instance of the dynamic load balancing algorithm to use.

Parameters:

loadBalancing - the new load balancing

getLoadBalancing

public DynamicLoadBalancingBase getLoadBalancing()

Gets the currently use dynamic load balancing algorithm.

Returns:

the loadBalancing

getProject

public Project getProject()

Returns the current Project.

Returns:

the project

getSimulationSetup

public SimulationSetup getSimulationSetup()

Returns the current SimulationSetup if available.

Returns:

the simulation setup

getDistributionSetup

public DistributionSetup getDistributionSetup()

Returns the DistributionSetup of the current Project if available.

Returns:

the distribution setup

getLoadServiceHelper

public LoadServiceHelper getLoadServiceHelper()

Returns the LoadServiceHelper.

Returns:

the load service helper

getLoadCycleTime

public double getLoadCycleTime()

Return the average cycle time of a sequential simulation.

Returns:

the load cycle time

setLoadCycleTime

public void setLoadCycleTime(double newLoadCycleTime)

Sets the average cycle time of a sequential simulation.

Parameters:

newLoadCycleTime - the new load cycle time

getLoadContainerAgentMap

public LoadAgentMap getLoadContainerAgentMap()

Return the current LoadAgentMap.

Returns:

the load container agent map

setLoadContainerAgentMap

public void setLoadContainerAgentMap(LoadAgentMap newLoadAgentMap)

Return the current LoadAgentMap.

Parameters:

newLoadAgentMap - the new load container agent map

getLoadContainer

public java.util.Hashtable<java.lang.String,PlatformLoad> getLoadContainer()

Returns the current PlatformLoad by container name.

Returns:

the load container

setLoadContainer

public void setLoadContainer(java.util.Hashtable<java.lang.String,PlatformLoad> newLoadContainer)

Sets the current PlatformLoad by container name.

Parameters:

newLoadContainer - the new load container

getLoadContainerLoactions

public java.util.Hashtable<java.lang.String,jade.core.Location> getLoadContainerLoactions()

Returns the current Location information in the different container.

Returns:

the load container loaction's

setLoadContainerLoactions

public void setLoadContainerLoactions(java.util.Hashtable<java.lang.String,jade.core.Location> newLoadContainerLocation)

Sets the load container loaction's.

Parameters:

newLoadContainerLocation - the new load container location

isDynLoadBalancaingStillActivated

public boolean isDynLoadBalancaingStillActivated()

setDynLoadBalancaingStillActivated

public void setDynLoadBalancaingStillActivated(boolean dynLoadBalancaingStillActivated)

isMonitorSaveLoad

public boolean isMonitorSaveLoad()

Checks if the current LoadAgent has to the save the load information in a file.

Returns:

the monitorSaveLoad

setMonitorSaveLoad

public void setMonitorSaveLoad(boolean monitorSaveLoad)

Sets the current LoadAgent to save or not save the load information in a file.

Parameters:

monitorSaveLoad - true, if the information should be saved

getThreadMeasureBehaviour

public ThreadMeasureBehaviour getThreadMeasureBehaviour()

Gets the thread measure behaviour.

Returns:

the thread measure behaviour

reStartThreadMeasurement

public void reStartThreadMeasurement(boolean oneShotBehaviour)

(Re-)Starts the thread measurement.

Parameters:

oneShotBehaviour - set true if you want to do a single measurement, otherwise false

setThreadMeasurementTickingPeriod

public void setThreadMeasurementTickingPeriod(long threadMeasurementTickingPeriod)

Sets the thread measurement ticking period.

Parameters:

threadMeasurementTickingPeriod - the new thread measurement ticking period

getThreadMeasurementTickingPeriod

public java.lang.Long getThreadMeasurementTickingPeriod()

Returns the thread measurement ticking period.

Returns:

the thread measurement ticking period

addThreadProtocol

public void addThreadProtocol(ThreadProtocol tp)

Adds a thread protocol to the information of the agent.

Parameters:

tp - the thread protocol

getThreadProtocolVector

public ThreadProtocolVector getThreadProtocolVector()

Returns the current ThreadProtocol.

Returns:

the thread protocol

getThreadInfoStorage

public ThreadInfoStorage getThreadInfoStorage()

Gets the thread info storage.

Returns:

the thread info storage

setThreadDialog

public void setThreadDialog(ThreadMonitor threadDialog)

Sets the thread dialog.

Parameters:

threadDialog - the new thread dialog

getThreadDialog

public ThreadMonitor getThreadDialog()

Gets the thread dialog.

Returns:

the thread dialog