agents.executionmanagementagent.ExecutionManagementAgentImpl Class Reference

Inherits agents.executionmanagementagent.ExecutionManagementAgent.

Inheritance diagram for agents.executionmanagementagent.ExecutionManagementAgentImpl:

[legend]Collaboration diagram for agents.executionmanagementagent.ExecutionManagementAgentImpl:[legend]List of all members.

Public Member Functions
	ExecutionManagementAgentImpl ()
synchronized void	registerAgent (ExecutionInfo execInfo)
synchronized boolean	changeAgentHost (String appExecId, String newHost)
ExecutionInfo[]	getAgentList (String host)
void	recoverHost (String host)
synchronized void	killApplication (String appExecId)
boolean	appInitiatedNotification (String execId, Iterator inputFiles)
boolean	appFinishedNotification (String appExecutionId, Iterator outputFiles)
FileStruct	getInputFile (AsctRequestId id, String name)
FileStruct	getOutputFile (AsctRequestId id, String name)
void	acceptedExecutionRequestNotification (ApplicationData app, String userName)
void	refusedExecutionRequestNotification (AsctRequestId id)
boolean	migrateExecutionNotification (String appExecutionId, String newHost)
boolean	removeExecResults (AsctRequestId id)
boolean	updateAgent (ExecutionInfo einfo)
ApplicationParam	getApplicationParam (AsctRequestId id)
ApplicationStateInfo[]	getApplicationsStateInfo (String user)
Protected Member Functions
void	setup ()
Private Member Functions
void	removeDirectory (File directory)
void	saveToFile (File directory, String fileName, byte b[]) throws Exception
Private Attributes
Codec	codec = new LEAPCodec()
Ontology	ontology = MAGOntology.getInstance()
DBManager	dbman

---

Detailed Description

Author:

gilberto

TODO To change the template for this generated type comment go to Window - Preferences - Java - Code Style - Code Templates

---

Constructor & Destructor Documentation

agents.executionmanagementagent.ExecutionManagementAgentImpl.ExecutionManagementAgentImpl (   )

---

Member Function Documentation

void agents.executionmanagementagent.ExecutionManagementAgentImpl.acceptedExecutionRequestNotification (  ApplicationData  app, String  userName )

This method store that the application's request was accepted. Parameters: app  - Application's Data that sended. user  - User that sended the application. Implements agents.executionmanagementagent.ExecutionManagementAgent.

boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.appFinishedNotification (  String  appExecutionId, Iterator  outputFiles )

This method notify the ExecutionManagementAgent after, which the MagAgent will finished the applicaiton. Parameters: id  - identify the application. outputFiles  - OutputFiles about application. Implements agents.executionmanagementagent.ExecutionManagementAgent.

boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.appInitiatedNotification (  String  execId, Iterator  inputFiles )

This method notify the ExecutionManagementAgent before, which the MagAgent will running the applicaiton. Parameters: id  - identify the application. inputFiles  - InputFiles about application. Implements agents.executionmanagementagent.ExecutionManagementAgent.

synchronized boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.changeAgentHost (  String  appExecId, String  newHost )

This method changes the location (host) where the agent is running on. Parameters: appExecId  -identify the application. newHost  - New host's name where the application will be running. Implements agents.executionmanagementagent.ExecutionManagementAgent.

ExecutionInfo [] agents.executionmanagementagent.ExecutionManagementAgentImpl.getAgentList (  String  host  )

This method retrieves the list of agents that is running on specified host. Returns: informations about all agents running in a host Implements agents.executionmanagementagent.ExecutionManagementAgent.

ApplicationParam agents.executionmanagementagent.ExecutionManagementAgentImpl.getApplicationParam (  AsctRequestId  id  )

This method return Application's Param. Parameters: id  - identify the application. Returns: ApplicationParam. Implements agents.executionmanagementagent.ExecutionManagementAgent.

ApplicationStateInfo [] agents.executionmanagementagent.ExecutionManagementAgentImpl.getApplicationsStateInfo (  String  user  )

This method return the Application's State. Parameters: user  - User that sended the application. Implements agents.executionmanagementagent.ExecutionManagementAgent.

FileStruct agents.executionmanagementagent.ExecutionManagementAgentImpl.getInputFile (  AsctRequestId  id, String  name )

This method return one InputFile. Parameters: id-  identify the application. name  - InputFile's name. Returns: FileStruct. Implements agents.executionmanagementagent.ExecutionManagementAgent.

FileStruct agents.executionmanagementagent.ExecutionManagementAgentImpl.getOutputFile (  AsctRequestId  id, String  name )

This method return one OutputFile. Parameters: id-  identify the application. name  - OutputFile's name. Returns: FileStruct. Implements agents.executionmanagementagent.ExecutionManagementAgent.

synchronized void agents.executionmanagementagent.ExecutionManagementAgentImpl.killApplication (  String  appExecId  )

This method kill the application. Parameters: appExecId  - Applications's Identify. Implements agents.executionmanagementagent.ExecutionManagementAgent.

boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.migrateExecutionNotification (  String  appExecutionId, String  newHost )

This method store the info that the application, was migrated. Parameters: id  - identify the application. newHost  - host's name where the application will be running. Implements agents.executionmanagementagent.ExecutionManagementAgent.

void agents.executionmanagementagent.ExecutionManagementAgentImpl.recoverHost (  String  host  )

This method recover all process that were running on specified host. Parameters: host  - Host's name. Implements agents.executionmanagementagent.ExecutionManagementAgent.

void agents.executionmanagementagent.ExecutionManagementAgentImpl.refusedExecutionRequestNotification (  AsctRequestId  id  )

This method store the info that the application, was refused. Parameters: id  - identify the application. Implements agents.executionmanagementagent.ExecutionManagementAgent.

synchronized void agents.executionmanagementagent.ExecutionManagementAgentImpl.registerAgent (  ExecutionInfo  execInfo  )

Method responsible for register an agent in the agent map. Parameters: ainfo  - Application's Data . Implements agents.executionmanagementagent.ExecutionManagementAgent.

void agents.executionmanagementagent.ExecutionManagementAgentImpl.removeDirectory (  File  directory  )  [private]

boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.removeExecResults (  AsctRequestId  id  )

This method removes the pertaining results to the application Parameters: id  - identify the application. Returns: true, if success; or else, false. Implements agents.executionmanagementagent.ExecutionManagementAgent.

void agents.executionmanagementagent.ExecutionManagementAgentImpl.saveToFile (  File  directory, String  fileName, byte  b[] )  throws Exception [private]

Saves a serialized bytecode on filesystem Parameters: directory  - directory where to put the file fileName  - the name of the file to be saved b  - a serialized object Exceptions: Exception  case any error occurs

void agents.executionmanagementagent.ExecutionManagementAgentImpl.setup (   )  [protected]

boolean agents.executionmanagementagent.ExecutionManagementAgentImpl.updateAgent (  ExecutionInfo  einfo  )

This method update Agent's status and Application's info. Parameters: ainfo  - Application's Data . Implements agents.executionmanagementagent.ExecutionManagementAgent.

---

Member Data Documentation

Codec agents.executionmanagementagent.ExecutionManagementAgentImpl.codec = new LEAPCodec() [private]

DBManager agents.executionmanagementagent.ExecutionManagementAgentImpl.dbman [private]

Ontology agents.executionmanagementagent.ExecutionManagementAgentImpl.ontology = MAGOntology.getInstance() [private]

---

The documentation for this class was generated from the following file:

• ExecutionManagementAgentImpl.java

---