eu.xtreemos.xosd.services
Class SJobMng

java.lang.Object
  extended by eu.xtreemos.xosd.services.SJobMng

public class SJobMng
extends java.lang.Object


Field Summary
private  CommunicationAddress _accesspoint_remoteaddress
           
private  eu.xtreemos.system.eventmachine.queue.Context context
           
static java.lang.String servicename
          AUTOGENERATED CODE
 
Constructor Summary
SJobMng(eu.xtreemos.system.eventmachine.queue.Context context)
           
 
Method Summary
 void addDependence(java.lang.String __FromJobId, java.lang.String __toJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx)
          This function adds a new job dependence.
 void addDependence(java.lang.String __FromJobId, java.lang.String __toJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          This function adds a new job dependence.
 void addDependence(java.lang.String __FromJobId, java.lang.String __toJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          This function adds a new job dependence.
 void addDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
           
 void addDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void addDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void addDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
           
 void addDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void addDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx)
          Adds a new user defined metric to the job.
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Adds a new user defined metric to the job.
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Adds a new user defined metric to the job.
 void chgUID(java.lang.String __jobId, java.security.cert.X509Certificate __oldUserCtx, java.security.cert.X509Certificate __newUserCtx)
          Changes the UID associated to a jobId
 void chgUID(java.lang.String __jobId, java.security.cert.X509Certificate __oldUserCtx, java.security.cert.X509Certificate __newUserCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Changes the UID associated to a jobId
 void chgUID(java.lang.String __jobId, java.security.cert.X509Certificate __oldUserCtx, java.security.cert.X509Certificate __newUserCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Changes the UID associated to a jobId
 void cleanMonitoring(java.lang.String __jobId)
          This method is called from CronDaemon some time after job's death to clean metrics' data structures.
 void cleanMonitoring(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          This method is called from CronDaemon some time after job's death to clean metrics' data structures.
 void cleanMonitoring(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          This method is called from CronDaemon some time after job's death to clean metrics' data structures.
 void completeJobCreationCB(java.lang.Object __result)
          Completes Job Creation (all directories filled)
 void completeJobCreationCB(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Completes Job Creation (all directories filled)
 void completeJobCreationCB(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Completes Job Creation (all directories filled)
 void completeJobCreationCBE(java.lang.Object __result)
          Callback for failure on JobCreation
 void completeJobCreationCBE(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback for failure on JobCreation
 void completeJobCreationCBE(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback for failure on JobCreation
 void createJob(java.lang.String __jsdlFile, java.lang.Boolean __startJob, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx)
          Creates a job in the AEM based on the JSDL description.
 void createJob(java.lang.String __jsdlFile, java.lang.Boolean __startJob, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Creates a job in the AEM based on the JSDL description.
 void createJob(java.lang.String __jsdlFile, java.lang.Boolean __startJob, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Creates a job in the AEM based on the JSDL description.
 void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx)
          Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID.
 void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID.
 void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID.
 void deleteDependence(java.lang.String __FromJobId, java.lang.String __ToJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx)
          Deletes an existing dependence between two specific jobs
 void deleteDependence(java.lang.String __FromJobId, java.lang.String __ToJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Deletes an existing dependence between two specific jobs
 void deleteDependence(java.lang.String __FromJobId, java.lang.String __ToJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Deletes an existing dependence between two specific jobs
 void deleteDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
           
 void deleteDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void deleteDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void deleteDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
           
 void deleteDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void deleteDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void execJob(CommunicationAddress __addrResource)
          Executes the job in the resource specified
 void execJob(CommunicationAddress __addrResource, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Executes the job in the resource specified
 void execJob(CommunicationAddress __addrResource, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Executes the job in the resource specified
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, java.security.cert.X509Certificate __userCtx)
          The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided.
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided.
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided.
 void fillReservationCB(java.lang.Boolean __value)
          Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB...
 void fillReservationCB(java.lang.Boolean __value, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB...
 void fillReservationCB(java.lang.Boolean __value, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB...
 void fillReservationCBE(java.lang.Object __value)
          Callback for error on fillReservation
 void fillReservationCBE(java.lang.Object __value, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback for error on fillReservation
 void fillReservationCBE(java.lang.Object __value, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback for error on fillReservation
 void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list)
          Callback where I get a list of candidates.
 void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get a list of candidates.
 void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get a list of candidates.
 void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
          Callback where I get information from a resource, and select one with the specified scheduling method.
 void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get information from a resource, and select one with the specified scheduling method.
 void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get information from a resource, and select one with the specified scheduling method.
 void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
          Callback where I get information from a resource (if it fails)
 void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get information from a resource (if it fails)
 void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get information from a resource (if it fails)
 void getJobId(CommunicationAddress __resourceId, java.lang.Integer __pid, java.security.cert.X509Certificate __userCtx)
          Returns the jobID corresponding to a
 void getJobId(CommunicationAddress __resourceId, java.lang.Integer __pid, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns the jobID corresponding to a
 void getJobId(CommunicationAddress __resourceId, java.lang.Integer __pid, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns the jobID corresponding to a
 void getJobIdCB(java.lang.String __jobId)
           
 void getJobIdCB(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getJobIdCB(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx)
          TODO: To be eventually deprecated.
 void getJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          TODO: To be eventually deprecated.
 void getJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          TODO: To be eventually deprecated.
 void getJobInfoCB(java.lang.String __info)
           
 void getJobInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getJobInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getJobInfoCBE(java.lang.Object __info)
           
 void getJobInfoCBE(java.lang.Object __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getJobInfoCBE(java.lang.Object __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList)
          range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected
 void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected
 void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected
 void getJobMetrics(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx)
          Returns the list of available metrics for a specific job, both system and user defined.
 void getJobMetrics(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns the list of available metrics for a specific job, both system and user defined.
 void getJobMetrics(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns the list of available metrics for a specific job, both system and user defined.
 void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metrics, java.security.cert.X509Certificate __userCtx)
          Returns the monitoring information of the requested jobs.
 void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metrics, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns the monitoring information of the requested jobs.
 void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metrics, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns the monitoring information of the requested jobs.
 void getJobsUser(java.lang.String __userId, java.security.cert.X509Certificate __userCtx)
          Returns all the jobIDs of the jobs belonging to the given user
 void getJobsUser(java.lang.String __userId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns all the jobIDs of the jobs belonging to the given user
 void getJobsUser(java.lang.String __userId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns all the jobIDs of the jobs belonging to the given user
 void getJobsUserCB(java.lang.Object __obj)
           
 void getJobsUserCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getJobsUserCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getListOfDependences(java.lang.String __jobID, java.lang.String __tag, java.lang.Integer __levels, java.lang.Integer __direction, java.security.cert.X509Certificate __userCtx)
          Returns the list of jobs that have a dependence FROM jobID or TO jobID.
 void getListOfDependences(java.lang.String __jobID, java.lang.String __tag, java.lang.Integer __levels, java.lang.Integer __direction, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns the list of jobs that have a dependence FROM jobID or TO jobID.
 void getListOfDependences(java.lang.String __jobID, java.lang.String __tag, java.lang.Integer __levels, java.lang.Integer __direction, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns the list of jobs that have a dependence FROM jobID or TO jobID.
 void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList)
           
 void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getMetricsByScope(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricScope __scope)
          AUTOGENERATED CODE
 void getMetricsByScope(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricScope __scope, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getMetricsByScope(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricScope __scope, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getProcessInfoCB(java.lang.String __info)
           
 void getProcessInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getProcessInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getProcessInfoCBE(java.lang.Exception __info)
           
 void getProcessInfoCBE(java.lang.Exception __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getProcessInfoCBE(java.lang.Exception __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getReservationID(java.lang.String __reservationID)
          Callback where I get reservationID and go to the createJob
 void getReservationID(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get reservationID and go to the createJob
 void getReservationID(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get reservationID and go to the createJob
 void getReservationIDFromJobIDCB(java.lang.String __reservationID)
          Callback where I get reservationID from a JobID and go to the runjob or createProcess
 void getReservationIDFromJobIDCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get reservationID from a JobID and go to the runjob or createProcess
 void getReservationIDFromJobIDCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get reservationID from a JobID and go to the runjob or createProcess
 void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list)
          Callback where I get the list of resources inside reservation.
 void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get the list of resources inside reservation.
 void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get the list of resources inside reservation.
 void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list)
          Callback where I get the list of resources inside reservation to execute a process.
 void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback where I get the list of resources inside reservation to execute a process.
 void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback where I get the list of resources inside reservation to execute a process.
 void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources)
           
 void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources)
          Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation
 void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation
 void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation
 void getRIDForProcStatusCB(java.lang.String __reservationID)
          Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.
 void getRIDForProcStatusCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.
 void getRIDForProcStatusCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.
 void getSingleJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx)
          This method is called from getJobsInfo or another jobMng via redirect.
 void getSingleJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          This method is called from getJobsInfo or another jobMng via redirect.
 void getSingleJobInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          This method is called from getJobsInfo or another jobMng via redirect.
 void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __cert)
          identify job manager address of each job
 void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __cert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          identify job manager address of each job
 void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __cert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          identify job manager address of each job
 void jobControl(java.lang.String __jobId, java.lang.Integer __ctrOp, java.security.cert.X509Certificate __userCtx)
          Apply the operation Control to the specific jobId
 void jobControl(java.lang.String __jobId, java.lang.Integer __ctrOp, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Apply the operation Control to the specific jobId
 void jobControl(java.lang.String __jobId, java.lang.Integer __ctrOp, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Apply the operation Control to the specific jobId
 void jobFinished(java.lang.String __jobId, java.lang.Integer __exitStatus, CommunicationAddress __execMng)
           
 void jobFinished(java.lang.String __jobId, java.lang.Integer __exitStatus, CommunicationAddress __execMng, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void jobFinished(java.lang.String __jobId, java.lang.Integer __exitStatus, CommunicationAddress __execMng, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void jobMonitoringControl(java.lang.String __jobId, java.lang.Integer __op, java.lang.String __level, java.security.cert.X509Certificate __userCtx)
          Update the characteristics of the monitorization of a job.
 void jobMonitoringControl(java.lang.String __jobId, java.lang.Integer __op, java.lang.String __level, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Update the characteristics of the monitorization of a job.
 void jobMonitoringControl(java.lang.String __jobId, java.lang.Integer __op, java.lang.String __level, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Update the characteristics of the monitorization of a job.
 void jobRunning(java.lang.String __jobId)
           
 void jobRunning(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void jobRunning(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void jobWait(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx)
          Blocks the calling process until the job indicated finishes
 void jobWait(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Blocks the calling process until the job indicated finishes
 void jobWait(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Blocks the calling process until the job indicated finishes
 void lockCheckpoint(java.lang.String __jobId, java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.util.ArrayList<java.lang.String> __dependentJobs)
          lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name
 void lockCheckpoint(java.lang.String __jobId, java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.util.ArrayList<java.lang.String> __dependentJobs, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name
 void lockCheckpoint(java.lang.String __jobId, java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.util.ArrayList<java.lang.String> __dependentJobs, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name
 void lockRestart(java.lang.String __jobId)
           
 void lockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void lockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void recreateJob(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFileContent, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.util.ArrayList<CommunicationAddress> __jobResourceList, java.security.cert.X509Certificate __userCert)
          set up structures that represent a job in AEM at restart
 void recreateJob(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFileContent, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.util.ArrayList<CommunicationAddress> __jobResourceList, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          set up structures that represent a job in AEM at restart
 void recreateJob(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFileContent, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.util.ArrayList<CommunicationAddress> __jobResourceList, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          set up structures that represent a job in AEM at restart
 void redirectFunctionCB(CommunicationAddress __addrJob)
           
 void redirectFunctionCB(CommunicationAddress __addrJob, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void redirectFunctionCB(CommunicationAddress __addrJob, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, java.security.cert.X509Certificate __userCtx)
          Removes a user defined metric from the job.
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Removes a user defined metric from the job.
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Removes a user defined metric from the job.
 void returnCB(java.lang.Object __obj)
           
 void returnCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void returnCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void returnCBE(java.lang.Exception __ex)
           
 void returnCBE(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void returnCBE(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void runJob(java.lang.String __jobId, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx)
          Starts the scheduling process of a previously created job.
 void runJob(java.lang.String __jobId, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Starts the scheduling process of a previously created job.
 void runJob(java.lang.String __jobId, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Starts the scheduling process of a previously created job.
 void runJobRes(java.lang.String __jobId, java.lang.String __reservationID, CommunicationAddress __resourceID, java.security.cert.X509Certificate __userCtx)
          Starts the scheduling process of a previously created job.
 void runJobRes(java.lang.String __jobId, java.lang.String __reservationID, CommunicationAddress __resourceID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Starts the scheduling process of a previously created job.
 void runJobRes(java.lang.String __jobId, java.lang.String __reservationID, CommunicationAddress __resourceID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Starts the scheduling process of a previously created job.
 void selectResource(java.util.ArrayList<CommunicationAddress> __list, java.lang.Integer __schedule)
          Returns a resource from a list of resources
 void selectResource(java.util.ArrayList<CommunicationAddress> __list, java.lang.Integer __schedule, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Returns a resource from a list of resources
 void selectResource(java.util.ArrayList<CommunicationAddress> __list, java.lang.Integer __schedule, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Returns a resource from a list of resources
 void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, java.lang.Integer __operation, java.util.ArrayList<java.lang.String> __list, java.security.cert.X509Certificate __userCtx)
          Sends an event to a job
 void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, java.lang.Integer __operation, java.util.ArrayList<java.lang.String> __list, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Sends an event to a job
 void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, java.lang.Integer __operation, java.util.ArrayList<java.lang.String> __list, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Sends an event to a job
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.String __value, java.security.cert.X509Certificate __userCtx)
          Sets the value of a Metric.
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.String __value, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Sets the value of a Metric.
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.String __value, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Sets the value of a Metric.
 void setMonitorBuffering(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.Integer __flags, java.security.cert.X509Certificate __userCtx)
          Switches on and off buffering for the specified metric.
 void setMonitorBuffering(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.Integer __flags, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Switches on and off buffering for the specified metric.
 void setMonitorBuffering(java.lang.String __jobId, java.lang.String __metricName, CommunicationAddress __resourceID, java.lang.Integer __pid, java.lang.Integer __flags, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Switches on and off buffering for the specified metric.
 void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
           
 void unlockCheckpoint(java.lang.String __jobId)
           
 void unlockCheckpoint(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void unlockCheckpoint(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void unlockRestart(java.lang.String __jobId)
           
 void unlockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void unlockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void updateJobHints(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx)
          Modifies the hints passed in createJob function
 void updateJobHints(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Modifies the hints passed in createJob function
 void updateJobHints(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Modifies the hints passed in createJob function
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx)
          Not defined yet
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Not defined yet
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Not defined yet
 void updateJobRequirements(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx)
          Modifies the requirements passed in createJob function.
 void updateJobRequirements(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Modifies the requirements passed in createJob function.
 void updateJobRequirements(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Modifies the requirements passed in createJob function.
 void verifyPolicyHandler(ResourceMatching __rmList)
          Starts job using the first resource from rmList.
 void verifyPolicyHandler(ResourceMatching __rmList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Starts job using the first resource from rmList.
 void verifyPolicyHandler(ResourceMatching __rmList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Starts job using the first resource from rmList.
 void waitForEvent(java.lang.String __jobId, java.lang.Integer __event, java.security.cert.X509Certificate __userCtx)
          Blocks the calling process until "event" is received.
 void waitForEvent(java.lang.String __jobId, java.lang.Integer __event, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Blocks the calling process until "event" is received.
 void waitForEvent(java.lang.String __jobId, java.lang.Integer __event, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Blocks the calling process until "event" is received.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

servicename

public static java.lang.String servicename
AUTOGENERATED CODE


context

private eu.xtreemos.system.eventmachine.queue.Context context

_accesspoint_remoteaddress

private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail

SJobMng

public SJobMng(eu.xtreemos.system.eventmachine.queue.Context context)
Method Detail

setRemoteaddress

public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)

getMetricsByScope

public void getMetricsByScope(java.lang.String __jobId,
                              eu.xtreemos.xosd.utilities.metrics.MetricScope __scope)
AUTOGENERATED CODE


getMetricsByScope

public void getMetricsByScope(java.lang.String __jobId,
                              eu.xtreemos.xosd.utilities.metrics.MetricScope __scope,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)

getMetricsByScope

public void getMetricsByScope(java.lang.String __jobId,
                              eu.xtreemos.xosd.utilities.metrics.MetricScope __scope,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getReservationID

public void getReservationID(java.lang.String __reservationID)
Callback where I get reservationID and go to the createJob


getReservationID

public void getReservationID(java.lang.String __reservationID,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get reservationID and go to the createJob


getReservationID

public void getReservationID(java.lang.String __reservationID,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get reservationID and go to the createJob


getReservationIDFromJobIDCB

public void getReservationIDFromJobIDCB(java.lang.String __reservationID)
Callback where I get reservationID from a JobID and go to the runjob or createProcess


getReservationIDFromJobIDCB

public void getReservationIDFromJobIDCB(java.lang.String __reservationID,
                                        eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get reservationID from a JobID and go to the runjob or createProcess


getReservationIDFromJobIDCB

public void getReservationIDFromJobIDCB(java.lang.String __reservationID,
                                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get reservationID from a JobID and go to the runjob or createProcess


getResourcesFromReservationIDCB

public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources)
Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation


getResourcesFromReservationIDCB

public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources,
                                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation


getResourcesFromReservationIDCB

public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources,
                                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback to get the list of resources of the reservationID In case we don't have any resource in the reservation call getResources from ResMng and fill up the reservation


fillReservationCB

public void fillReservationCB(java.lang.Boolean __value)
Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB... Remember than Time constrained resources should be acquired with createReservation method...


fillReservationCB

public void fillReservationCB(java.lang.Boolean __value,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB... Remember than Time constrained resources should be acquired with createReservation method...


fillReservationCB

public void fillReservationCB(java.lang.Boolean __value,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback to fill up a reservation (infinite and shared), calls to getAllResourcesCB... Remember than Time constrained resources should be acquired with createReservation method...


fillReservationCBE

public void fillReservationCBE(java.lang.Object __value)
Callback for error on fillReservation


fillReservationCBE

public void fillReservationCBE(java.lang.Object __value,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback for error on fillReservation


fillReservationCBE

public void fillReservationCBE(java.lang.Object __value,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback for error on fillReservation


getRIDForProcStatusCB

public void getRIDForProcStatusCB(java.lang.String __reservationID)
Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.


getRIDForProcStatusCB

public void getRIDForProcStatusCB(java.lang.String __reservationID,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.


getRIDForProcStatusCB

public void getRIDForProcStatusCB(java.lang.String __reservationID,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback to get the reservationID of a job to enable procStatus buffering for each resource it has reserved.


getResForProcStatusCB

public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources)

getResForProcStatusCB

public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback)

getResForProcStatusCB

public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

completeJobCreationCB

public void completeJobCreationCB(java.lang.Object __result)
Completes Job Creation (all directories filled)


completeJobCreationCB

public void completeJobCreationCB(java.lang.Object __result,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback)
Completes Job Creation (all directories filled)


completeJobCreationCB

public void completeJobCreationCB(java.lang.Object __result,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Completes Job Creation (all directories filled)


completeJobCreationCBE

public void completeJobCreationCBE(java.lang.Object __result)
Callback for failure on JobCreation


completeJobCreationCBE

public void completeJobCreationCBE(java.lang.Object __result,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback for failure on JobCreation


completeJobCreationCBE

public void completeJobCreationCBE(java.lang.Object __result,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback for failure on JobCreation


createJob

public void createJob(java.lang.String __jsdlFile,
                      java.lang.Boolean __startJob,
                      java.lang.String __reservationID,
                      java.security.cert.X509Certificate __userCtx)
Creates a job in the AEM based on the JSDL description. The job can be automatically scheduled or just created, depending on the value of startJob. If a reservationId is provided, the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started when the job will be scheduled based on resource requirements and scheduling hints. If calls to VOPS are enabled, policy enforcement gets into the picture. XOSDCONSOLE annotation denotes that this method becomes a part of XConsole project and therefore be available to user usage and scripts.

Parameters:
jsdlFile - is the job description of the job to be created in JSDL format (content not path to jsdl file)
startJob - true if we want to run job now, false just to create it without running
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

createJob

public void createJob(java.lang.String __jsdlFile,
                      java.lang.Boolean __startJob,
                      java.lang.String __reservationID,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback)
Creates a job in the AEM based on the JSDL description. The job can be automatically scheduled or just created, depending on the value of startJob. If a reservationId is provided, the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started when the job will be scheduled based on resource requirements and scheduling hints. If calls to VOPS are enabled, policy enforcement gets into the picture. XOSDCONSOLE annotation denotes that this method becomes a part of XConsole project and therefore be available to user usage and scripts.

Parameters:
jsdlFile - is the job description of the job to be created in JSDL format (content not path to jsdl file)
startJob - true if we want to run job now, false just to create it without running
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

createJob

public void createJob(java.lang.String __jsdlFile,
                      java.lang.Boolean __startJob,
                      java.lang.String __reservationID,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback,
                      eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Creates a job in the AEM based on the JSDL description. The job can be automatically scheduled or just created, depending on the value of startJob. If a reservationId is provided, the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started when the job will be scheduled based on resource requirements and scheduling hints. If calls to VOPS are enabled, policy enforcement gets into the picture. XOSDCONSOLE annotation denotes that this method becomes a part of XConsole project and therefore be available to user usage and scripts.

Parameters:
jsdlFile - is the job description of the job to be created in JSDL format (content not path to jsdl file)
startJob - true if we want to run job now, false just to create it without running
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

runJob

public void runJob(java.lang.String __jobId,
                   java.lang.String __reservationID,
                   java.security.cert.X509Certificate __userCtx)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. If a resevationID is provided the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

runJob

public void runJob(java.lang.String __jobId,
                   java.lang.String __reservationID,
                   java.security.cert.X509Certificate __userCtx,
                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. If a resevationID is provided the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

runJob

public void runJob(java.lang.String __jobId,
                   java.lang.String __reservationID,
                   java.security.cert.X509Certificate __userCtx,
                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. If a resevationID is provided the job will be scheduled on that reservation. Otherwise, a negotiation/reservation process will be started.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
userCtx - the user certificate.

runJobRes

public void runJobRes(java.lang.String __jobId,
                      java.lang.String __reservationID,
                      CommunicationAddress __resourceID,
                      java.security.cert.X509Certificate __userCtx)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. It will get a ResourceID, (that should be valid in the ReservationID provided), and run the job on those resource.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
resourceID - of the resource that will run the job (if possible)
userCtx - the user certificate.

runJobRes

public void runJobRes(java.lang.String __jobId,
                      java.lang.String __reservationID,
                      CommunicationAddress __resourceID,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. It will get a ResourceID, (that should be valid in the ReservationID provided), and run the job on those resource.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
resourceID - of the resource that will run the job (if possible)
userCtx - the user certificate.

runJobRes

public void runJobRes(java.lang.String __jobId,
                      java.lang.String __reservationID,
                      CommunicationAddress __resourceID,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback,
                      eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts the scheduling process of a previously created job. JobId must be a valid jobId in the system. It will get a ResourceID, (that should be valid in the ReservationID provided), and run the job on those resource.

Parameters:
jobId - of the job to be started
reservationID - The previously created reservation were the job will run
resourceID - of the resource that will run the job (if possible)
userCtx - the user certificate.

getInfoResourcesCB

public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
Callback where I get information from a resource, and select one with the specified scheduling method.


getInfoResourcesCB

public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get information from a resource, and select one with the specified scheduling method.


getInfoResourcesCB

public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get information from a resource, and select one with the specified scheduling method.


getInfoResourcesCBE

public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
Callback where I get information from a resource (if it fails)


getInfoResourcesCBE

public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get information from a resource (if it fails)


getInfoResourcesCBE

public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get information from a resource (if it fails)


getAllResourcesCB

public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list)
Callback where I get a list of candidates.

Parameters:
list - of candidates.

getAllResourcesCB

public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get a list of candidates.

Parameters:
list - of candidates.

getAllResourcesCB

public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get a list of candidates.

Parameters:
list - of candidates.

getReservationResourcesCB

public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list)
Callback where I get the list of resources inside reservation. TODO: is that really used as a callback?

Parameters:
list - of candidates.

getReservationResourcesCB

public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list,
                                      eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get the list of resources inside reservation. TODO: is that really used as a callback?

Parameters:
list - of candidates.

getReservationResourcesCB

public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list,
                                      eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                      eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get the list of resources inside reservation. TODO: is that really used as a callback?

Parameters:
list - of candidates.

getReservationResourcesProcessCB

public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list)
Callback where I get the list of resources inside reservation to execute a process.

Parameters:
list - of candidates.

getReservationResourcesProcessCB

public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list,
                                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
Callback where I get the list of resources inside reservation to execute a process.

Parameters:
list - of candidates.

getReservationResourcesProcessCB

public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list,
                                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Callback where I get the list of resources inside reservation to execute a process.

Parameters:
list - of candidates.

selectResource

public void selectResource(java.util.ArrayList<CommunicationAddress> __list,
                           java.lang.Integer __schedule)
Returns a resource from a list of resources

Parameters:
list - list of suitable resources.
schedule - type of schedule applied (0: RANDOM (only available)) 1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)

selectResource

public void selectResource(java.util.ArrayList<CommunicationAddress> __list,
                           java.lang.Integer __schedule,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns a resource from a list of resources

Parameters:
list - list of suitable resources.
schedule - type of schedule applied (0: RANDOM (only available)) 1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)

selectResource

public void selectResource(java.util.ArrayList<CommunicationAddress> __list,
                           java.lang.Integer __schedule,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns a resource from a list of resources

Parameters:
list - list of suitable resources.
schedule - type of schedule applied (0: RANDOM (only available)) 1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)

execJob

public void execJob(CommunicationAddress __addrResource)
Executes the job in the resource specified


execJob

public void execJob(CommunicationAddress __addrResource,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback)
Executes the job in the resource specified


execJob

public void execJob(CommunicationAddress __addrResource,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Executes the job in the resource specified


verifyPolicyHandler

public void verifyPolicyHandler(ResourceMatching __rmList)
Starts job using the first resource from rmList.

Parameters:
rmList - list of suitable resources.

verifyPolicyHandler

public void verifyPolicyHandler(ResourceMatching __rmList,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts job using the first resource from rmList.

Parameters:
rmList - list of suitable resources.

verifyPolicyHandler

public void verifyPolicyHandler(ResourceMatching __rmList,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts job using the first resource from rmList.

Parameters:
rmList - list of suitable resources.

jobControl

public void jobControl(java.lang.String __jobId,
                       java.lang.Integer __ctrOp,
                       java.security.cert.X509Certificate __userCtx)
Apply the operation Control to the specific jobId

Parameters:
jobId - of the job to apply the operation
ctrOp - possible values: 0: SUSPENDJOB 1: RESUMEJOB 2: CANCEL JOB
userCtx - the user certificate

jobControl

public void jobControl(java.lang.String __jobId,
                       java.lang.Integer __ctrOp,
                       java.security.cert.X509Certificate __userCtx,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback)
Apply the operation Control to the specific jobId

Parameters:
jobId - of the job to apply the operation
ctrOp - possible values: 0: SUSPENDJOB 1: RESUMEJOB 2: CANCEL JOB
userCtx - the user certificate

jobControl

public void jobControl(java.lang.String __jobId,
                       java.lang.Integer __ctrOp,
                       java.security.cert.X509Certificate __userCtx,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback,
                       eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Apply the operation Control to the specific jobId

Parameters:
jobId - of the job to apply the operation
ctrOp - possible values: 0: SUSPENDJOB 1: RESUMEJOB 2: CANCEL JOB
userCtx - the user certificate

exitJob

public void exitJob(java.lang.String __jobId,
                    java.lang.Integer __exitValue,
                    java.security.cert.X509Certificate __userCtx)
The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided. If the process calling exitJob is part of the job this function never returns.

Parameters:
jobId - identifying the job to exit
exitValue - the exit code the job will finish with
userCtx - the user certificate

exitJob

public void exitJob(java.lang.String __jobId,
                    java.lang.Integer __exitValue,
                    java.security.cert.X509Certificate __userCtx,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback)
The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided. If the process calling exitJob is part of the job this function never returns.

Parameters:
jobId - identifying the job to exit
exitValue - the exit code the job will finish with
userCtx - the user certificate

exitJob

public void exitJob(java.lang.String __jobId,
                    java.lang.Integer __exitValue,
                    java.security.cert.X509Certificate __userCtx,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
The job identified by the jobId is finished immediately (all the processes of the job) with the exit code provided. If the process calling exitJob is part of the job this function never returns.

Parameters:
jobId - identifying the job to exit
exitValue - the exit code the job will finish with
userCtx - the user certificate

getJobsInfo

public void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds,
                        java.lang.Integer __flags,
                        java.lang.Integer __infoLevel,
                        java.util.ArrayList<java.lang.String> __metrics,
                        java.security.cert.X509Certificate __userCtx)
Returns the monitoring information of the requested jobs. Any user of the VO can access monitoring data of the job, but if he is not the owner, access will be restricted to unbuffered system metrics.

Parameters:
jobId - an ArrayList of String which is the list of requested jobs.
flags - an Integer used as a mask to define the metrics to return. TypeOfInfo enum class has the values of each type. P.e. TypeOfInfo.BASIC.val(). Several flags might be combined as logical OR operands. Values and description:

BASIC: Job identification, status and times

JOB_DEFINITION: The JSDL

RESOURCES_ALLOCATED: ReservationIDs

RESOURCES_CONSUMED: Extended information about resources (to be implemented)

USER_METRICS: Metrics added by the user with the addJobMetric method

infoLevel - an Integer defining the sources of information allowed in the operation. InfoLevel enum class should be used to get the right values. P.e. InfoLevel.PROCESS.val(). Values and description:

JOB: it communicates only with the jobMng.

PROCESS: it communicates both with jobMng and exec- or resMng.

KERNEL: it communicates with every needed service and also considers special kernel metrics (to be implemented)

metrics - a list of metrics to obtain, additional to the flags
userCtx - the X509Certificate Object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Incorrect list of metrics 4) Not a valid XtreemOS certificate

getJobsInfo

public void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds,
                        java.lang.Integer __flags,
                        java.lang.Integer __infoLevel,
                        java.util.ArrayList<java.lang.String> __metrics,
                        java.security.cert.X509Certificate __userCtx,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the monitoring information of the requested jobs. Any user of the VO can access monitoring data of the job, but if he is not the owner, access will be restricted to unbuffered system metrics.

Parameters:
jobId - an ArrayList of String which is the list of requested jobs.
flags - an Integer used as a mask to define the metrics to return. TypeOfInfo enum class has the values of each type. P.e. TypeOfInfo.BASIC.val(). Several flags might be combined as logical OR operands. Values and description:

BASIC: Job identification, status and times

JOB_DEFINITION: The JSDL

RESOURCES_ALLOCATED: ReservationIDs

RESOURCES_CONSUMED: Extended information about resources (to be implemented)

USER_METRICS: Metrics added by the user with the addJobMetric method

infoLevel - an Integer defining the sources of information allowed in the operation. InfoLevel enum class should be used to get the right values. P.e. InfoLevel.PROCESS.val(). Values and description:

JOB: it communicates only with the jobMng.

PROCESS: it communicates both with jobMng and exec- or resMng.

KERNEL: it communicates with every needed service and also considers special kernel metrics (to be implemented)

metrics - a list of metrics to obtain, additional to the flags
userCtx - the X509Certificate Object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Incorrect list of metrics 4) Not a valid XtreemOS certificate

getJobsInfo

public void getJobsInfo(java.util.ArrayList<java.lang.String> __jobIds,
                        java.lang.Integer __flags,
                        java.lang.Integer __infoLevel,
                        java.util.ArrayList<java.lang.String> __metrics,
                        java.security.cert.X509Certificate __userCtx,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the monitoring information of the requested jobs. Any user of the VO can access monitoring data of the job, but if he is not the owner, access will be restricted to unbuffered system metrics.

Parameters:
jobId - an ArrayList of String which is the list of requested jobs.
flags - an Integer used as a mask to define the metrics to return. TypeOfInfo enum class has the values of each type. P.e. TypeOfInfo.BASIC.val(). Several flags might be combined as logical OR operands. Values and description:

BASIC: Job identification, status and times

JOB_DEFINITION: The JSDL

RESOURCES_ALLOCATED: ReservationIDs

RESOURCES_CONSUMED: Extended information about resources (to be implemented)

USER_METRICS: Metrics added by the user with the addJobMetric method

infoLevel - an Integer defining the sources of information allowed in the operation. InfoLevel enum class should be used to get the right values. P.e. InfoLevel.PROCESS.val(). Values and description:

JOB: it communicates only with the jobMng.

PROCESS: it communicates both with jobMng and exec- or resMng.

KERNEL: it communicates with every needed service and also considers special kernel metrics (to be implemented)

metrics - a list of metrics to obtain, additional to the flags
userCtx - the X509Certificate Object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Incorrect list of metrics 4) Not a valid XtreemOS certificate

getJobInfoCB

public void getJobInfoCB(java.lang.String __info)

getJobInfoCB

public void getJobInfoCB(java.lang.String __info,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)

getJobInfoCB

public void getJobInfoCB(java.lang.String __info,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getJobInfoCBE

public void getJobInfoCBE(java.lang.Object __info)

getJobInfoCBE

public void getJobInfoCBE(java.lang.Object __info,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)

getJobInfoCBE

public void getJobInfoCBE(java.lang.Object __info,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getJobInfo

public void getJobInfo(java.lang.String __jobId,
                       java.lang.Integer __flags,
                       java.lang.Integer __infoLevel,
                       java.util.ArrayList<java.lang.String> __metricsList,
                       java.security.cert.X509Certificate __userCtx)
TODO: To be eventually deprecated. It's not in the monitoring deliverable

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getJobInfo

public void getJobInfo(java.lang.String __jobId,
                       java.lang.Integer __flags,
                       java.lang.Integer __infoLevel,
                       java.util.ArrayList<java.lang.String> __metricsList,
                       java.security.cert.X509Certificate __userCtx,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback)
TODO: To be eventually deprecated. It's not in the monitoring deliverable

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getJobInfo

public void getJobInfo(java.lang.String __jobId,
                       java.lang.Integer __flags,
                       java.lang.Integer __infoLevel,
                       java.util.ArrayList<java.lang.String> __metricsList,
                       java.security.cert.X509Certificate __userCtx,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback,
                       eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
TODO: To be eventually deprecated. It's not in the monitoring deliverable

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getSingleJobInfo

public void getSingleJobInfo(java.lang.String __jobId,
                             java.lang.Integer __flags,
                             java.lang.Integer __infoLevel,
                             java.util.ArrayList<java.lang.String> __metricsList,
                             java.security.cert.X509Certificate __userCtx)
This method is called from getJobsInfo or another jobMng via redirect.

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getSingleJobInfo

public void getSingleJobInfo(java.lang.String __jobId,
                             java.lang.Integer __flags,
                             java.lang.Integer __infoLevel,
                             java.util.ArrayList<java.lang.String> __metricsList,
                             java.security.cert.X509Certificate __userCtx,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
This method is called from getJobsInfo or another jobMng via redirect.

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getSingleJobInfo

public void getSingleJobInfo(java.lang.String __jobId,
                             java.lang.Integer __flags,
                             java.lang.Integer __infoLevel,
                             java.util.ArrayList<java.lang.String> __metricsList,
                             java.security.cert.X509Certificate __userCtx,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This method is called from getJobsInfo or another jobMng via redirect.

Parameters:
jobId -
flags -
infoLevel -
metricsList -
userCtx -
Throws:
java.lang.Exception
See Also:
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)

getJobIdCB

public void getJobIdCB(java.lang.String __jobId)

getJobIdCB

public void getJobIdCB(java.lang.String __jobId,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback)

getJobIdCB

public void getJobIdCB(java.lang.String __jobId,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback,
                       eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getJobId

public void getJobId(CommunicationAddress __resourceId,
                     java.lang.Integer __pid,
                     java.security.cert.X509Certificate __userCtx)
Returns the jobID corresponding to a

Parameters:
resourceId - the CommunicationAddress of the resource where the process is assigned
pid - an Integer with the process identifier local to that resource
userCtx - an X509Certificate object with the user certificate
Throws:
java.lang.Exception - when either of these happens: 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) No jobID associated with the requested

getJobId

public void getJobId(CommunicationAddress __resourceId,
                     java.lang.Integer __pid,
                     java.security.cert.X509Certificate __userCtx,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the jobID corresponding to a

Parameters:
resourceId - the CommunicationAddress of the resource where the process is assigned
pid - an Integer with the process identifier local to that resource
userCtx - an X509Certificate object with the user certificate
Throws:
java.lang.Exception - when either of these happens: 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) No jobID associated with the requested

getJobId

public void getJobId(CommunicationAddress __resourceId,
                     java.lang.Integer __pid,
                     java.security.cert.X509Certificate __userCtx,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the jobID corresponding to a

Parameters:
resourceId - the CommunicationAddress of the resource where the process is assigned
pid - an Integer with the process identifier local to that resource
userCtx - an X509Certificate object with the user certificate
Throws:
java.lang.Exception - when either of these happens: 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) No jobID associated with the requested

getJobsUser

public void getJobsUser(java.lang.String __userId,
                        java.security.cert.X509Certificate __userCtx)
Returns all the jobIDs of the jobs belonging to the given user

Parameters:
userId - a String identifying the user we want to obtain the jobs from
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate

getJobsUser

public void getJobsUser(java.lang.String __userId,
                        java.security.cert.X509Certificate __userCtx,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns all the jobIDs of the jobs belonging to the given user

Parameters:
userId - a String identifying the user we want to obtain the jobs from
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate

getJobsUser

public void getJobsUser(java.lang.String __userId,
                        java.security.cert.X509Certificate __userCtx,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns all the jobIDs of the jobs belonging to the given user

Parameters:
userId - a String identifying the user we want to obtain the jobs from
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate

getJobsUserCB

public void getJobsUserCB(java.lang.Object __obj)

getJobsUserCB

public void getJobsUserCB(java.lang.Object __obj,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)

getJobsUserCB

public void getJobsUserCB(java.lang.Object __obj,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

sendEvent

public void sendEvent(java.lang.String __jobId,
                      java.lang.Integer __signal,
                      java.lang.Integer __operation,
                      java.util.ArrayList<java.lang.String> __list,
                      java.security.cert.X509Certificate __userCtx)
Sends an event to a job

Parameters:
signal - number to be sent
operation - can be: 0: ALL 1: MASTER 2: SPECIFYED in list 3: EXCEPT in list
jobId - identifying the job we are going to send the signal to
list -
userCtx - the user certificate TODO: Now we send always the signal to all the processes of the job, use the operation and list parameters

sendEvent

public void sendEvent(java.lang.String __jobId,
                      java.lang.Integer __signal,
                      java.lang.Integer __operation,
                      java.util.ArrayList<java.lang.String> __list,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback)
Sends an event to a job

Parameters:
signal - number to be sent
operation - can be: 0: ALL 1: MASTER 2: SPECIFYED in list 3: EXCEPT in list
jobId - identifying the job we are going to send the signal to
list -
userCtx - the user certificate TODO: Now we send always the signal to all the processes of the job, use the operation and list parameters

sendEvent

public void sendEvent(java.lang.String __jobId,
                      java.lang.Integer __signal,
                      java.lang.Integer __operation,
                      java.util.ArrayList<java.lang.String> __list,
                      java.security.cert.X509Certificate __userCtx,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback,
                      eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Sends an event to a job

Parameters:
signal - number to be sent
operation - can be: 0: ALL 1: MASTER 2: SPECIFYED in list 3: EXCEPT in list
jobId - identifying the job we are going to send the signal to
list -
userCtx - the user certificate TODO: Now we send always the signal to all the processes of the job, use the operation and list parameters

jobWait

public void jobWait(java.lang.String __jobId,
                    java.security.cert.X509Certificate __userCtx)
Blocks the calling process until the job indicated finishes

Parameters:
jobId - identifying the job the calling process is waiting for

jobWait

public void jobWait(java.lang.String __jobId,
                    java.security.cert.X509Certificate __userCtx,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback)
Blocks the calling process until the job indicated finishes

Parameters:
jobId - identifying the job the calling process is waiting for

jobWait

public void jobWait(java.lang.String __jobId,
                    java.security.cert.X509Certificate __userCtx,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Blocks the calling process until the job indicated finishes

Parameters:
jobId - identifying the job the calling process is waiting for

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. Resource can be used to force the execution on the resource, (only if it's inside the reservationID). Finally JSDL can be specified to change executable and parameters of the process Priority: Reservation > resource > JSDL > job JSDLInfo

Parameters:
jobId -
JSDL, - JSDL content
reservationId -
resource -
userCtx -
Throws:
java.lang.Exception

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. Resource can be used to force the execution on the resource, (only if it's inside the reservationID). Finally JSDL can be specified to change executable and parameters of the process Priority: Reservation > resource > JSDL > job JSDLInfo

Parameters:
jobId -
JSDL, - JSDL content
reservationId -
resource -
userCtx -
Throws:
java.lang.Exception

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Creates a new Process inside the specified JobID In order to increase performance, user can specify the ReservationID. Resource can be used to force the execution on the resource, (only if it's inside the reservationID). Finally JSDL can be specified to change executable and parameters of the process Priority: Reservation > resource > JSDL > job JSDLInfo

Parameters:
jobId -
JSDL, - JSDL content
reservationId -
resource -
userCtx -
Throws:
java.lang.Exception

getProcessInfoCB

public void getProcessInfoCB(java.lang.String __info)

getProcessInfoCB

public void getProcessInfoCB(java.lang.String __info,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)

getProcessInfoCB

public void getProcessInfoCB(java.lang.String __info,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

getProcessInfoCBE

public void getProcessInfoCBE(java.lang.Exception __info)

getProcessInfoCBE

public void getProcessInfoCBE(java.lang.Exception __info,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)

getProcessInfoCBE

public void getProcessInfoCBE(java.lang.Exception __info,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

jobFinished

public void jobFinished(java.lang.String __jobId,
                        java.lang.Integer __exitStatus,
                        CommunicationAddress __execMng)

jobFinished

public void jobFinished(java.lang.String __jobId,
                        java.lang.Integer __exitStatus,
                        CommunicationAddress __execMng,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback)

jobFinished

public void jobFinished(java.lang.String __jobId,
                        java.lang.Integer __exitStatus,
                        CommunicationAddress __execMng,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

cleanMonitoring

public void cleanMonitoring(java.lang.String __jobId)
This method is called from CronDaemon some time after job's death to clean metrics' data structures. Every resource manager of a resource where the job has run is cleaned and also every exec manager of a resource where buffering was enabled and never disabled. Job is also retired from Job Directory and Job Manager.

Parameters:
jobId -

cleanMonitoring

public void cleanMonitoring(java.lang.String __jobId,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
This method is called from CronDaemon some time after job's death to clean metrics' data structures. Every resource manager of a resource where the job has run is cleaned and also every exec manager of a resource where buffering was enabled and never disabled. Job is also retired from Job Directory and Job Manager.

Parameters:
jobId -

cleanMonitoring

public void cleanMonitoring(java.lang.String __jobId,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This method is called from CronDaemon some time after job's death to clean metrics' data structures. Every resource manager of a resource where the job has run is cleaned and also every exec manager of a resource where buffering was enabled and never disabled. Job is also retired from Job Directory and Job Manager.

Parameters:
jobId -

jobRunning

public void jobRunning(java.lang.String __jobId)

jobRunning

public void jobRunning(java.lang.String __jobId,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback)

jobRunning

public void jobRunning(java.lang.String __jobId,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback,
                       eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

redirectFunctionCB

public void redirectFunctionCB(CommunicationAddress __addrJob)
Throws:
java.lang.Exception - if 1) Incorrect jobId

redirectFunctionCB

public void redirectFunctionCB(CommunicationAddress __addrJob,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)
Throws:
java.lang.Exception - if 1) Incorrect jobId

redirectFunctionCB

public void redirectFunctionCB(CommunicationAddress __addrJob,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Throws:
java.lang.Exception - if 1) Incorrect jobId

addDependenceUp

public void addDependenceUp(java.lang.String __jobId,
                            java.lang.String __FromJobId,
                            java.lang.String __tag,
                            java.security.cert.X509Certificate __userCtx)

addDependenceUp

public void addDependenceUp(java.lang.String __jobId,
                            java.lang.String __FromJobId,
                            java.lang.String __tag,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)

addDependenceUp

public void addDependenceUp(java.lang.String __jobId,
                            java.lang.String __FromJobId,
                            java.lang.String __tag,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

addDependenceDown

public void addDependenceDown(java.lang.String __jobId,
                              java.lang.String __toJobId,
                              java.lang.String __tag,
                              java.security.cert.X509Certificate __userCtx)

addDependenceDown

public void addDependenceDown(java.lang.String __jobId,
                              java.lang.String __toJobId,
                              java.lang.String __tag,
                              java.security.cert.X509Certificate __userCtx,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)

addDependenceDown

public void addDependenceDown(java.lang.String __jobId,
                              java.lang.String __toJobId,
                              java.lang.String __tag,
                              java.security.cert.X509Certificate __userCtx,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

deleteDependenceUp

public void deleteDependenceUp(java.lang.String __jobId,
                               java.lang.String __FromJobId,
                               java.lang.String __tag,
                               java.security.cert.X509Certificate __userCtx)

deleteDependenceUp

public void deleteDependenceUp(java.lang.String __jobId,
                               java.lang.String __FromJobId,
                               java.lang.String __tag,
                               java.security.cert.X509Certificate __userCtx,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)

deleteDependenceUp

public void deleteDependenceUp(java.lang.String __jobId,
                               java.lang.String __FromJobId,
                               java.lang.String __tag,
                               java.security.cert.X509Certificate __userCtx,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

deleteDependenceDown

public void deleteDependenceDown(java.lang.String __jobId,
                                 java.lang.String __toJobId,
                                 java.lang.String __tag,
                                 java.security.cert.X509Certificate __userCtx)

deleteDependenceDown

public void deleteDependenceDown(java.lang.String __jobId,
                                 java.lang.String __toJobId,
                                 java.lang.String __tag,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)

deleteDependenceDown

public void deleteDependenceDown(java.lang.String __jobId,
                                 java.lang.String __toJobId,
                                 java.lang.String __tag,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

addDependence

public void addDependence(java.lang.String __FromJobId,
                          java.lang.String __toJobId,
                          java.lang.String __TAG,
                          java.security.cert.X509Certificate __userCtx)
This function adds a new job dependence. If we think on an arrow, it will go from FromJobId to ToJobID. We support sets of dependencies identified by TAG, to be able to use them for different purposes. The AEM won't interpret these TAGS, just group dependencies of jobs based on them. AEM won't check cycles in job dependencies. It is user/job responsibility

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

addDependence

public void addDependence(java.lang.String __FromJobId,
                          java.lang.String __toJobId,
                          java.lang.String __TAG,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)
This function adds a new job dependence. If we think on an arrow, it will go from FromJobId to ToJobID. We support sets of dependencies identified by TAG, to be able to use them for different purposes. The AEM won't interpret these TAGS, just group dependencies of jobs based on them. AEM won't check cycles in job dependencies. It is user/job responsibility

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

addDependence

public void addDependence(java.lang.String __FromJobId,
                          java.lang.String __toJobId,
                          java.lang.String __TAG,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This function adds a new job dependence. If we think on an arrow, it will go from FromJobId to ToJobID. We support sets of dependencies identified by TAG, to be able to use them for different purposes. The AEM won't interpret these TAGS, just group dependencies of jobs based on them. AEM won't check cycles in job dependencies. It is user/job responsibility

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

deleteDependence

public void deleteDependence(java.lang.String __FromJobId,
                             java.lang.String __ToJobId,
                             java.lang.String __TAG,
                             java.security.cert.X509Certificate __userCtx)
Deletes an existing dependence between two specific jobs

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

deleteDependence

public void deleteDependence(java.lang.String __FromJobId,
                             java.lang.String __ToJobId,
                             java.lang.String __TAG,
                             java.security.cert.X509Certificate __userCtx,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
Deletes an existing dependence between two specific jobs

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

deleteDependence

public void deleteDependence(java.lang.String __FromJobId,
                             java.lang.String __ToJobId,
                             java.lang.String __TAG,
                             java.security.cert.X509Certificate __userCtx,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Deletes an existing dependence between two specific jobs

Parameters:
FromJobId - the job from which tojobId depends
toJobId - the job that depends on fromJobId
TAG - is a name to identify a set of dependencies.
userCtx - the user certificate

getListOfDependences

public void getListOfDependences(java.lang.String __jobID,
                                 java.lang.String __tag,
                                 java.lang.Integer __levels,
                                 java.lang.Integer __direction,
                                 java.security.cert.X509Certificate __userCtx)
Returns the list of jobs that have a dependence FROM jobID or TO jobID.

Parameters:
jobID - the starting job to get the related jobs
tag - is a name to identify a set of dependencies.
levels - 1 or ALL (0) (TBD)
direction - can be: 0: FROM (up) 1: TO (down)
userCtx - the user certificate

getListOfDependences

public void getListOfDependences(java.lang.String __jobID,
                                 java.lang.String __tag,
                                 java.lang.Integer __levels,
                                 java.lang.Integer __direction,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the list of jobs that have a dependence FROM jobID or TO jobID.

Parameters:
jobID - the starting job to get the related jobs
tag - is a name to identify a set of dependencies.
levels - 1 or ALL (0) (TBD)
direction - can be: 0: FROM (up) 1: TO (down)
userCtx - the user certificate

getListOfDependences

public void getListOfDependences(java.lang.String __jobID,
                                 java.lang.String __tag,
                                 java.lang.Integer __levels,
                                 java.lang.Integer __direction,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the list of jobs that have a dependence FROM jobID or TO jobID.

Parameters:
jobID - the starting job to get the related jobs
tag - is a name to identify a set of dependencies.
levels - 1 or ALL (0) (TBD)
direction - can be: 0: FROM (up) 1: TO (down)
userCtx - the user certificate

getListOfDependencesCB

public void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList)

getListOfDependencesCB

public void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)

getListOfDependencesCB

public void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

updateJobHints

public void updateJobHints(java.lang.String __jobId,
                           java.lang.Integer __operation,
                           java.lang.String __requirements,
                           java.lang.Boolean __wait,
                           java.security.cert.X509Certificate __userCtx)
Modifies the hints passed in createJob function

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: MIGRATION_REQ 1: SCHEDULING_REQ
requirements - identifying the job to change the requirements of
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

updateJobHints

public void updateJobHints(java.lang.String __jobId,
                           java.lang.Integer __operation,
                           java.lang.String __requirements,
                           java.lang.Boolean __wait,
                           java.security.cert.X509Certificate __userCtx,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
Modifies the hints passed in createJob function

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: MIGRATION_REQ 1: SCHEDULING_REQ
requirements - identifying the job to change the requirements of
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

updateJobHints

public void updateJobHints(java.lang.String __jobId,
                           java.lang.Integer __operation,
                           java.lang.String __requirements,
                           java.lang.Boolean __wait,
                           java.security.cert.X509Certificate __userCtx,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Modifies the hints passed in createJob function

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: MIGRATION_REQ 1: SCHEDULING_REQ
requirements - identifying the job to change the requirements of
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

getJobMetrics

public void getJobMetrics(java.lang.String __jobId,
                          java.security.cert.X509Certificate __userCtx)
Returns the list of available metrics for a specific job, both system and user defined.

Parameters:
jobId - a String identifying the job to get the metrics from, if the jobId is null the generic list of metrics is returned
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) Incorrect jobId

getJobMetrics

public void getJobMetrics(java.lang.String __jobId,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)
Returns the list of available metrics for a specific job, both system and user defined.

Parameters:
jobId - a String identifying the job to get the metrics from, if the jobId is null the generic list of metrics is returned
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) Incorrect jobId

getJobMetrics

public void getJobMetrics(java.lang.String __jobId,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Returns the list of available metrics for a specific job, both system and user defined.

Parameters:
jobId - a String identifying the job to get the metrics from, if the jobId is null the generic list of metrics is returned
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Not a valid XtreemOS certificate 2) Invalid User in the Certificate 3) Incorrect jobId

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           CommunicationAddress __resourceID,
                           java.lang.Integer __pid,
                           java.lang.String __value,
                           java.security.cert.X509Certificate __userCtx)
Sets the value of a Metric. A metric will be an user-defined attribute of the job. Not all the attributes can be set, for instance the user time or the status are set by the system, not by the user.

Parameters:
jobId - a String identifying the job, the metric is associated to.
metricName - is a String with the name of the metric to be set.
value - a String with the value to be set to the metric. It's a string, but it will be parsed according to the metric type. If it's time type, the string must be in jiffies format.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to set value on a system metric

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           CommunicationAddress __resourceID,
                           java.lang.Integer __pid,
                           java.lang.String __value,
                           java.security.cert.X509Certificate __userCtx,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
Sets the value of a Metric. A metric will be an user-defined attribute of the job. Not all the attributes can be set, for instance the user time or the status are set by the system, not by the user.

Parameters:
jobId - a String identifying the job, the metric is associated to.
metricName - is a String with the name of the metric to be set.
value - a String with the value to be set to the metric. It's a string, but it will be parsed according to the metric type. If it's time type, the string must be in jiffies format.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to set value on a system metric

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           CommunicationAddress __resourceID,
                           java.lang.Integer __pid,
                           java.lang.String __value,
                           java.security.cert.X509Certificate __userCtx,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Sets the value of a Metric. A metric will be an user-defined attribute of the job. Not all the attributes can be set, for instance the user time or the status are set by the system, not by the user.

Parameters:
jobId - a String identifying the job, the metric is associated to.
metricName - is a String with the name of the metric to be set.
value - a String with the value to be set to the metric. It's a string, but it will be parsed according to the metric type. If it's time type, the string must be in jiffies format.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to set value on a system metric

setMonitorBuffering

public void setMonitorBuffering(java.lang.String __jobId,
                                java.lang.String __metricName,
                                CommunicationAddress __resourceID,
                                java.lang.Integer __pid,
                                java.lang.Integer __flags,
                                java.security.cert.X509Certificate __userCtx)
Switches on and off buffering for the specified metric. With buffering on, multiple values of a metric are returned, and its timestamps represent the time when the value was changed. Only metrics defined as "bufferable" on creation can be buffered.

Parameters:
jobId - a String identifying the job whose metric is about to get buffered. Its worth noticing that buffering is not applied to the whole job but to the smallest part of it according to the scope.
metricName - a String with the name of the metric.
resourceID - the CommunicationAddress of the resource where the buffering is to be applied. Used only if the scope of the metric is resource, jobUnit or process.
pid - Integer with the process ID of the process where the buffering is to be applied. Used only if the scope of the metric is process.
flags - an Integer mask with options to aggregate several metrics, tag buffers and enable or disable buffering. Use flags |= TypeOfInfo.ENABLE.val() to enable buffering flags |= ~TypeOfInfo.ENABLE.val() to disable buffering TODO: add support for metric aggregations, if required.
userCtx - a X509Certificate object with the user certificate.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Metric cannot provide buffering capabilities

setMonitorBuffering

public void setMonitorBuffering(java.lang.String __jobId,
                                java.lang.String __metricName,
                                CommunicationAddress __resourceID,
                                java.lang.Integer __pid,
                                java.lang.Integer __flags,
                                java.security.cert.X509Certificate __userCtx,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)
Switches on and off buffering for the specified metric. With buffering on, multiple values of a metric are returned, and its timestamps represent the time when the value was changed. Only metrics defined as "bufferable" on creation can be buffered.

Parameters:
jobId - a String identifying the job whose metric is about to get buffered. Its worth noticing that buffering is not applied to the whole job but to the smallest part of it according to the scope.
metricName - a String with the name of the metric.
resourceID - the CommunicationAddress of the resource where the buffering is to be applied. Used only if the scope of the metric is resource, jobUnit or process.
pid - Integer with the process ID of the process where the buffering is to be applied. Used only if the scope of the metric is process.
flags - an Integer mask with options to aggregate several metrics, tag buffers and enable or disable buffering. Use flags |= TypeOfInfo.ENABLE.val() to enable buffering flags |= ~TypeOfInfo.ENABLE.val() to disable buffering TODO: add support for metric aggregations, if required.
userCtx - a X509Certificate object with the user certificate.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Metric cannot provide buffering capabilities

setMonitorBuffering

public void setMonitorBuffering(java.lang.String __jobId,
                                java.lang.String __metricName,
                                CommunicationAddress __resourceID,
                                java.lang.Integer __pid,
                                java.lang.Integer __flags,
                                java.security.cert.X509Certificate __userCtx,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Switches on and off buffering for the specified metric. With buffering on, multiple values of a metric are returned, and its timestamps represent the time when the value was changed. Only metrics defined as "bufferable" on creation can be buffered.

Parameters:
jobId - a String identifying the job whose metric is about to get buffered. Its worth noticing that buffering is not applied to the whole job but to the smallest part of it according to the scope.
metricName - a String with the name of the metric.
resourceID - the CommunicationAddress of the resource where the buffering is to be applied. Used only if the scope of the metric is resource, jobUnit or process.
pid - Integer with the process ID of the process where the buffering is to be applied. Used only if the scope of the metric is process.
flags - an Integer mask with options to aggregate several metrics, tag buffers and enable or disable buffering. Use flags |= TypeOfInfo.ENABLE.val() to enable buffering flags |= ~TypeOfInfo.ENABLE.val() to disable buffering TODO: add support for metric aggregations, if required.
userCtx - a X509Certificate object with the user certificate.
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Metric cannot provide buffering capabilities

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                         java.security.cert.X509Certificate __userCtx)
Adds a new user defined metric to the job. Afterwards, user might give values to it through the setMetricValue interface and get them with getJobInfo. Metrics are checked for correctness before insertion. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to add the metric to
metric - a MetricsDesc object with the metric to be added
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric already exists 5) Incorrect metric description

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)
Adds a new user defined metric to the job. Afterwards, user might give values to it through the setMetricValue interface and get them with getJobInfo. Metrics are checked for correctness before insertion. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to add the metric to
metric - a MetricsDesc object with the metric to be added
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric already exists 5) Incorrect metric description

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Adds a new user defined metric to the job. Afterwards, user might give values to it through the setMetricValue interface and get them with getJobInfo. Metrics are checked for correctness before insertion. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to add the metric to
metric - a MetricsDesc object with the metric to be added
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric already exists 5) Incorrect metric description

updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                            java.security.cert.X509Certificate __userCtx)
Not defined yet


updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
Not defined yet


updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Not defined yet


removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName,
                            java.security.cert.X509Certificate __userCtx)
Removes a user defined metric from the job. Data associated to the metric is also erased. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to remove the metric from
metricName - a String with the name of the metric to be removed
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to remove a system metric

removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
Removes a user defined metric from the job. Data associated to the metric is also erased. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to remove the metric from
metricName - a String with the name of the metric to be removed
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to remove a system metric

removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName,
                            java.security.cert.X509Certificate __userCtx,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Removes a user defined metric from the job. Data associated to the metric is also erased. It might communicate with other services and XOSDs if needed.

Parameters:
jobId - a String identifying the job to remove the metric from
metricName - a String with the name of the metric to be removed
userCtx - a X509Certificate object with the user certificate
Throws:
java.lang.Exception - if 1) Incorrect jobId 2) Invalid User in the Certificate 3) Not a valid XtreemOS certificate 4) Metric doesn't exist 5) Trying to remove a system metric

chgUID

public void chgUID(java.lang.String __jobId,
                   java.security.cert.X509Certificate __oldUserCtx,
                   java.security.cert.X509Certificate __newUserCtx)
Changes the UID associated to a jobId

Parameters:
jobId - identifying the job whose user will change
oldUserCtx - the certificate of the current user
newUserCtx - the new certificate to be used

chgUID

public void chgUID(java.lang.String __jobId,
                   java.security.cert.X509Certificate __oldUserCtx,
                   java.security.cert.X509Certificate __newUserCtx,
                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
Changes the UID associated to a jobId

Parameters:
jobId - identifying the job whose user will change
oldUserCtx - the certificate of the current user
newUserCtx - the new certificate to be used

chgUID

public void chgUID(java.lang.String __jobId,
                   java.security.cert.X509Certificate __oldUserCtx,
                   java.security.cert.X509Certificate __newUserCtx,
                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Changes the UID associated to a jobId

Parameters:
jobId - identifying the job whose user will change
oldUserCtx - the certificate of the current user
newUserCtx - the new certificate to be used

updateJobRequirements

public void updateJobRequirements(java.lang.String __jobId,
                                  java.lang.Integer __operation,
                                  java.lang.String __requirements,
                                  java.lang.Boolean __wait,
                                  java.security.cert.X509Certificate __userCtx)
Modifies the requirements passed in createJob function.

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: ADD_RESOURCES 1: RELEASE_RESOURCES 2: EXTEND_RESOURCES
requirements - in a JSDL format specifying the new requirements
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

updateJobRequirements

public void updateJobRequirements(java.lang.String __jobId,
                                  java.lang.Integer __operation,
                                  java.lang.String __requirements,
                                  java.lang.Boolean __wait,
                                  java.security.cert.X509Certificate __userCtx,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback)
Modifies the requirements passed in createJob function.

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: ADD_RESOURCES 1: RELEASE_RESOURCES 2: EXTEND_RESOURCES
requirements - in a JSDL format specifying the new requirements
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

updateJobRequirements

public void updateJobRequirements(java.lang.String __jobId,
                                  java.lang.Integer __operation,
                                  java.lang.String __requirements,
                                  java.lang.Boolean __wait,
                                  java.security.cert.X509Certificate __userCtx,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Modifies the requirements passed in createJob function.

Parameters:
jobId - identifying the job to change the requirements of
operation - can be: 0: ADD_RESOURCES 1: RELEASE_RESOURCES 2: EXTEND_RESOURCES
requirements - in a JSDL format specifying the new requirements
wait - if the call is synchronous or asynchronous
userCtx - the user certificate

jobMonitoringControl

public void jobMonitoringControl(java.lang.String __jobId,
                                 java.lang.Integer __op,
                                 java.lang.String __level,
                                 java.security.cert.X509Certificate __userCtx)
Update the characteristics of the monitorization of a job. It allows to start We can use start,stop to enable/disable all the callbacks with one XOS call. It is still pending to decide if we are going to use start/stop to automatically call external start/stop functions

Parameters:
jobId -
op - can be: 0:START 1:STOP 2:CHANGE_LEVEL
level - the new monitoring level in case op is set to CHANGE. Can be: High, medium or Low
userCtx - the user certificate

jobMonitoringControl

public void jobMonitoringControl(java.lang.String __jobId,
                                 java.lang.Integer __op,
                                 java.lang.String __level,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)
Update the characteristics of the monitorization of a job. It allows to start We can use start,stop to enable/disable all the callbacks with one XOS call. It is still pending to decide if we are going to use start/stop to automatically call external start/stop functions

Parameters:
jobId -
op - can be: 0:START 1:STOP 2:CHANGE_LEVEL
level - the new monitoring level in case op is set to CHANGE. Can be: High, medium or Low
userCtx - the user certificate

jobMonitoringControl

public void jobMonitoringControl(java.lang.String __jobId,
                                 java.lang.Integer __op,
                                 java.lang.String __level,
                                 java.security.cert.X509Certificate __userCtx,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Update the characteristics of the monitorization of a job. It allows to start We can use start,stop to enable/disable all the callbacks with one XOS call. It is still pending to decide if we are going to use start/stop to automatically call external start/stop functions

Parameters:
jobId -
op - can be: 0:START 1:STOP 2:CHANGE_LEVEL
level - the new monitoring level in case op is set to CHANGE. Can be: High, medium or Low
userCtx - the user certificate

waitForEvent

public void waitForEvent(java.lang.String __jobId,
                         java.lang.Integer __event,
                         java.security.cert.X509Certificate __userCtx)
Blocks the calling process until "event" is received.

Parameters:
jobId -
event - the event the process is waiting for
userCtx - the user certificate

waitForEvent

public void waitForEvent(java.lang.String __jobId,
                         java.lang.Integer __event,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)
Blocks the calling process until "event" is received.

Parameters:
jobId -
event - the event the process is waiting for
userCtx - the user certificate

waitForEvent

public void waitForEvent(java.lang.String __jobId,
                         java.lang.Integer __event,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Blocks the calling process until "event" is received.

Parameters:
jobId -
event - the event the process is waiting for
userCtx - the user certificate

identifyJobManagers

public void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs,
                                java.lang.String __initialJobId,
                                java.lang.String __strategy,
                                java.lang.String __options,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __cert)
identify job manager address of each job


identifyJobManagers

public void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs,
                                java.lang.String __initialJobId,
                                java.lang.String __strategy,
                                java.lang.String __options,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __cert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)
identify job manager address of each job


identifyJobManagers

public void identifyJobManagers(java.util.ArrayList<java.lang.String> __dependentJobs,
                                java.lang.String __initialJobId,
                                java.lang.String __strategy,
                                java.lang.String __options,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __cert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
identify job manager address of each job


getJobManagerAddressesCB

public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected

Parameters:
addrJob -
Throws:
java.lang.Exception

getJobManagerAddressesCB

public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected

Parameters:
addrJob -
Throws:
java.lang.Exception

getJobManagerAddressesCB

public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
range addresses equals range dependent jobs save job manager addresses, BARRIER: contact super job cp after all job manger addresses have been collected

Parameters:
addrJob -
Throws:
java.lang.Exception

lockCheckpoint

public void lockCheckpoint(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.security.cert.X509Certificate __userCert,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.util.ArrayList<java.lang.String> __dependentJobs)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name


lockCheckpoint

public void lockCheckpoint(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.security.cert.X509Certificate __userCert,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.util.ArrayList<java.lang.String> __dependentJobs,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name


lockCheckpoint

public void lockCheckpoint(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.security.cert.X509Certificate __userCert,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.util.ArrayList<java.lang.String> __dependentJobs,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
lock a checkpoint action - private member jobslist needed piggyback jsdl file and executable name


unlockCheckpoint

public void unlockCheckpoint(java.lang.String __jobId)

unlockCheckpoint

public void unlockCheckpoint(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)

unlockCheckpoint

public void unlockCheckpoint(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

lockRestart

public void lockRestart(java.lang.String __jobId)

lockRestart

public void lockRestart(java.lang.String __jobId,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback)

lockRestart

public void lockRestart(java.lang.String __jobId,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

unlockRestart

public void unlockRestart(java.lang.String __jobId)

unlockRestart

public void unlockRestart(java.lang.String __jobId,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)

unlockRestart

public void unlockRestart(java.lang.String __jobId,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

recreateJob

public void recreateJob(java.lang.String __jobId,
                        java.lang.String __initialJobId,
                        java.lang.String __jsdlFileContent,
                        java.lang.String __checkpointVersion,
                        CommunicationAddress __superJobCpAddr,
                        java.util.ArrayList<CommunicationAddress> __jobResourceList,
                        java.security.cert.X509Certificate __userCert)
set up structures that represent a job in AEM at restart


recreateJob

public void recreateJob(java.lang.String __jobId,
                        java.lang.String __initialJobId,
                        java.lang.String __jsdlFileContent,
                        java.lang.String __checkpointVersion,
                        CommunicationAddress __superJobCpAddr,
                        java.util.ArrayList<CommunicationAddress> __jobResourceList,
                        java.security.cert.X509Certificate __userCert,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback)
set up structures that represent a job in AEM at restart


recreateJob

public void recreateJob(java.lang.String __jobId,
                        java.lang.String __initialJobId,
                        java.lang.String __jsdlFileContent,
                        java.lang.String __checkpointVersion,
                        CommunicationAddress __superJobCpAddr,
                        java.util.ArrayList<CommunicationAddress> __jobResourceList,
                        java.security.cert.X509Certificate __userCert,
                        eu.xtreemos.system.communication.bus.CallbackMessage callback,
                        eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
set up structures that represent a job in AEM at restart


returnCB

public void returnCB(java.lang.Object __obj)

returnCB

public void returnCB(java.lang.Object __obj,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback)

returnCB

public void returnCB(java.lang.Object __obj,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

returnCBE

public void returnCBE(java.lang.Exception __ex)

returnCBE

public void returnCBE(java.lang.Exception __ex,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback)

returnCBE

public void returnCBE(java.lang.Exception __ex,
                      eu.xtreemos.system.communication.bus.CallbackMessage callback,
                      eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)