agentgui.simulationService

Class LoadService.LoadServiceImpl

java.lang.Object

agentgui.simulationService.LoadService.LoadServiceImpl

All Implemented Interfaces:

LoadServiceHelper, jade.core.ServiceHelper

Enclosing class:

LoadService

public class LoadService.LoadServiceImpl
extends java.lang.Object
implements LoadServiceHelper

Sub-Class to provide interaction between Agents and this Service by using the LoadServiceHelper.

Field Summary

Fields inherited from interface agentgui.simulationService.LoadServiceHelper

SERVICE_NAME

Constructor Summary

Constructors

Constructor and Description
LoadServiceImpl()

Method Summary

Modifier and Type	Method and Description
RemoteContainerConfig	getAutoRemoteContainerConfig() Provides the default remote container configuration.
ClientAvailableMachinesReply	getAvailableMachines() Gets the available machines.
double	getAvgCycleTime() Provides the average cycle time for a simulation.
LoadInformation.NodeDescription	getContainerDescription(java.lang.String containerName) Gets the NodeDescription of a specified container.
java.util.Hashtable<java.lang.String,LoadInformation.NodeDescription>	getContainerDescriptions() Gets the NodeDescription of all involved nodes.
PlatformLoad	getContainerLoad(java.lang.String containerName) Returns the load of a specified container.
java.util.Hashtable<java.lang.String,PlatformLoad>	getContainerLoadHash() Returns the load of all connected container.
jade.core.Location	getContainerLocation(java.lang.String containerName) Gets the container location of a specified container.
java.util.Hashtable<java.lang.String,jade.core.Location>	getContainerLocations() Provides the container locations of all connected container.
java.util.Vector<java.lang.String>	getContainerNames() Returns the list of all available container.
LoadAgentMap	getLoadAgentMap() Returns the current LoadAgentMap.
ClientRemoteContainerReply	getLocalCRCReply() Returns the locally saved ClientRemoteContainerReply.
void	init(jade.core.Agent ag)
void	putAvailableMachines(ClientAvailableMachinesReply availableMachines) Puts the available machines to the load information.
void	putContainerDescription(ClientRemoteContainerReply crcReply) Broadcasts a container description to all involved node, if the ClientRemoteContainerReply is valid.
void	requestAvailableMachines() Requests at the main container for the available machines.
void	requestThreadMeasurements(LoadMeasureAgent loadMeasurementAgent) Requests all involved JVMs to do the thread measurements.
void	setAgentMigration(java.util.Vector<LoadAgentMap.AID_Container> transferAgents) Sets the agent migration.
void	setAndSaveCRCReplyLocal(ClientRemoteContainerReply crcReply) Sets and save the local ClientRemoteContainerReply.
void	setDefaults4RemoteContainerConfig(RemoteContainerConfig remoteContainerConfig) Sets the default remote container configuration.
void	setSimulationCycleStartTimeStamp() Sets System.currentTimeMillis() as an indicator for the start of an new simulations cycle.
void	setThresholdLevels(LoadThresholdLevels thresholdLevels) Sets the threshold levels for all involved container.
boolean	startAgent(java.lang.String nickName, java.lang.String agentClassName, java.lang.Object[] args, java.lang.String containerName) Start an agent on a specified location.
java.lang.String	startNewRemoteContainer() Will start a new remote container.
java.lang.String	startNewRemoteContainer(RemoteContainerConfig remoteConfig) Will start a new remote container.
LoadInformation.Container2Wait4	startNewRemoteContainerStaus(java.lang.String containerName) Returns the current status of the requested new container.

Methods inherited from class java.lang.Object

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

Constructor Detail

LoadServiceImpl

public LoadServiceImpl()

Method Detail

init

public void init(jade.core.Agent ag)

Specified by:

init in interface jade.core.ServiceHelper

startAgent

public boolean startAgent(java.lang.String nickName,
                          java.lang.String agentClassName,
                          java.lang.Object[] args,
                          java.lang.String containerName)
                   throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Start an agent on a specified location.

Specified by:

startAgent in interface LoadServiceHelper

Parameters:

nickName - the local name for the agent

agentClassName - the class of the agent

args - the serializable Object array for the start arguments

containerName - the name of the container, where the agent should start

Returns:

true, if successful

Throws:

jade.core.ServiceException - the service exception

getAutoRemoteContainerConfig

public RemoteContainerConfig getAutoRemoteContainerConfig()
                                                   throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Provides the default remote container configuration.

Specified by:

getAutoRemoteContainerConfig in interface LoadServiceHelper

Returns:

the default remote container configuration

Throws:

jade.core.ServiceException - the service exception

setDefaults4RemoteContainerConfig

public void setDefaults4RemoteContainerConfig(RemoteContainerConfig remoteContainerConfig)
                                       throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Sets the default remote container configuration.

Specified by:

setDefaults4RemoteContainerConfig in interface LoadServiceHelper

Parameters:

remoteContainerConfig - the new default remote container configuration

Throws:

jade.core.ServiceException - the service exception

startNewRemoteContainer

public java.lang.String startNewRemoteContainer()
                                         throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Will start a new remote container.

Specified by:

startNewRemoteContainer in interface LoadServiceHelper

Returns:

the name of the new container

Throws:

jade.core.ServiceException - the service exception

startNewRemoteContainer

public java.lang.String startNewRemoteContainer(RemoteContainerConfig remoteConfig)
                                         throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Will start a new remote container.

Specified by:

startNewRemoteContainer in interface LoadServiceHelper

Parameters:

remoteConfig - the remote container configuration

Returns:

the name of the new container

Throws:

jade.core.ServiceException - the service exception

startNewRemoteContainerStaus

public LoadInformation.Container2Wait4 startNewRemoteContainerStaus(java.lang.String containerName)
                                                             throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the current status of the requested new container.

Specified by:

startNewRemoteContainerStaus in interface LoadServiceHelper

Parameters:

containerName - the new containers name

Returns:

current status of the requested new remote container

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadInformation.Container2Wait4

getLocalCRCReply

public ClientRemoteContainerReply getLocalCRCReply()
                                            throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the locally saved ClientRemoteContainerReply.

Specified by:

getLocalCRCReply in interface LoadServiceHelper

Returns:

the local ClientRemoteContainerReply

Throws:

jade.core.ServiceException - the service exception

setAndSaveCRCReplyLocal

public void setAndSaveCRCReplyLocal(ClientRemoteContainerReply crcReply)
                             throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Sets and save the local ClientRemoteContainerReply.

Specified by:

setAndSaveCRCReplyLocal in interface LoadServiceHelper

Parameters:

crcReply - the ClientRemoteContainerReply to save

Throws:

jade.core.ServiceException - the service exception

putContainerDescription

public void putContainerDescription(ClientRemoteContainerReply crcReply)
                             throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Broadcasts a container description to all involved node, if the ClientRemoteContainerReply is valid.

Specified by:

putContainerDescription in interface LoadServiceHelper

Parameters:

crcReply - the crc reply

Throws:

jade.core.ServiceException - the service exception

getContainerDescriptions

public java.util.Hashtable<java.lang.String,LoadInformation.NodeDescription> getContainerDescriptions()
                                                                                               throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Gets the NodeDescription of all involved nodes.

Specified by:

getContainerDescriptions in interface LoadServiceHelper

Returns:

the container descriptions

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadInformation.NodeDescription

getContainerDescription

public LoadInformation.NodeDescription getContainerDescription(java.lang.String containerName)
                                                        throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Gets the NodeDescription of a specified container.

Specified by:

getContainerDescription in interface LoadServiceHelper

Parameters:

containerName - the container name

Returns:

the container description

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadInformation.NodeDescription

getContainerLocations

public java.util.Hashtable<java.lang.String,jade.core.Location> getContainerLocations()
                                                                               throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Provides the container locations of all connected container.

Specified by:

getContainerLocations in interface LoadServiceHelper

Returns:

the container locations

Throws:

jade.core.ServiceException - the service exception

getContainerLocation

public jade.core.Location getContainerLocation(java.lang.String containerName)
                                        throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Gets the container location of a specified container.

Specified by:

getContainerLocation in interface LoadServiceHelper

Parameters:

containerName - the container name

Returns:

the container location

Throws:

jade.core.ServiceException - the service exception

setThresholdLevels

public void setThresholdLevels(LoadThresholdLevels thresholdLevels)
                        throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Sets the threshold levels for all involved container.

Specified by:

setThresholdLevels in interface LoadServiceHelper

Parameters:

thresholdLevels - the new threshold levels

Throws:

jade.core.ServiceException - the service exception

getContainerLoadHash

public java.util.Hashtable<java.lang.String,PlatformLoad> getContainerLoadHash()
                                                                        throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the load of all connected container.

Specified by:

getContainerLoadHash in interface LoadServiceHelper

Returns:

the container loads

Throws:

jade.core.ServiceException - the service exception

getContainerLoad

public PlatformLoad getContainerLoad(java.lang.String containerName)
                              throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the load of a specified container.

Specified by:

getContainerLoad in interface LoadServiceHelper

Parameters:

containerName - the container name

Returns:

the container load

Throws:

jade.core.ServiceException - the service exception

getContainerNames

public java.util.Vector<java.lang.String> getContainerNames()
                                                     throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the list of all available container.

Specified by:

getContainerNames in interface LoadServiceHelper

Returns:

the container queue

Throws:

jade.core.ServiceException - the service exception

setSimulationCycleStartTimeStamp

public void setSimulationCycleStartTimeStamp()
                                      throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Sets System.currentTimeMillis() as an indicator for the start of an new simulations cycle.

Specified by:

setSimulationCycleStartTimeStamp in interface LoadServiceHelper

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadServiceHelper.getAvgCycleTime()

getAvgCycleTime

public double getAvgCycleTime()
                       throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Provides the average cycle time for a simulation.

Specified by:

getAvgCycleTime in interface LoadServiceHelper

Returns:

the average cycle time fo a simulation

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadServiceHelper.setSimulationCycleStartTimeStamp()

getLoadAgentMap

public LoadAgentMap getLoadAgentMap()
                             throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Returns the current LoadAgentMap.

Specified by:

getLoadAgentMap in interface LoadServiceHelper

Returns:

the current LoadAgentMap

Throws:

jade.core.ServiceException - the service exception

See Also:

LoadAgentMap

setAgentMigration

public void setAgentMigration(java.util.Vector<LoadAgentMap.AID_Container> transferAgents)
                       throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Sets the agent migration.

Specified by:

setAgentMigration in interface LoadServiceHelper

Parameters:

transferAgents - the agents, which has to be migrated

Throws:

jade.core.ServiceException - the service exception

requestThreadMeasurements

public void requestThreadMeasurements(LoadMeasureAgent loadMeasurementAgent)
                               throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Requests all involved JVMs to do the thread measurements.

Specified by:

requestThreadMeasurements in interface LoadServiceHelper

Parameters:

loadMeasurementAgent - the load measure agent

Throws:

jade.core.ServiceException - the service exception

requestAvailableMachines

public void requestAvailableMachines()
                              throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Requests at the main container for the available machines.

Specified by:

requestAvailableMachines in interface LoadServiceHelper

Throws:

jade.core.ServiceException - the service exception

putAvailableMachines

public void putAvailableMachines(ClientAvailableMachinesReply availableMachines)
                          throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Puts the available machines to the load information.

Specified by:

putAvailableMachines in interface LoadServiceHelper

Parameters:

availableMachines - the available machines

Throws:

jade.core.ServiceException - the service exception

getAvailableMachines

public ClientAvailableMachinesReply getAvailableMachines()
                                                  throws jade.core.ServiceException

Description copied from interface: LoadServiceHelper

Gets the available machines.

Specified by:

getAvailableMachines in interface LoadServiceHelper

Returns:

the available machines

Throws:

jade.core.ServiceException - the service exception