|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.xtreemos.xosd.services.SJobMng
public class SJobMng
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 |
---|
public static java.lang.String servicename
private eu.xtreemos.system.eventmachine.queue.Context context
private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail |
---|
public SJobMng(eu.xtreemos.system.eventmachine.queue.Context context)
Method Detail |
---|
public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
public void getMetricsByScope(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricScope __scope)
public void getMetricsByScope(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricScope __scope, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void getReservationID(java.lang.String __reservationID)
public void getReservationID(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getReservationID(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getReservationIDFromJobIDCB(java.lang.String __reservationID)
public void getReservationIDFromJobIDCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getReservationIDFromJobIDCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources)
public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getResourcesFromReservationIDCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void fillReservationCB(java.lang.Boolean __value)
public void fillReservationCB(java.lang.Boolean __value, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void fillReservationCB(java.lang.Boolean __value, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void fillReservationCBE(java.lang.Object __value)
public void fillReservationCBE(java.lang.Object __value, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void fillReservationCBE(java.lang.Object __value, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getRIDForProcStatusCB(java.lang.String __reservationID)
public void getRIDForProcStatusCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getRIDForProcStatusCB(java.lang.String __reservationID, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources)
public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getResForProcStatusCB(java.util.ArrayList<ReservationSlot> __resources, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void completeJobCreationCB(java.lang.Object __result)
public void completeJobCreationCB(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void completeJobCreationCB(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void completeJobCreationCBE(java.lang.Object __result)
public void completeJobCreationCBE(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void completeJobCreationCBE(java.lang.Object __result, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void createJob(java.lang.String __jsdlFile, java.lang.Boolean __startJob, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx)
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 runningreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.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)
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 runningreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.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)
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 runningreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.public void runJob(java.lang.String __jobId, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.public void runJob(java.lang.String __jobId, java.lang.String __reservationID, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.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)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runuserCtx
- the user certificate.public void runJobRes(java.lang.String __jobId, java.lang.String __reservationID, CommunicationAddress __resourceID, java.security.cert.X509Certificate __userCtx)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runresourceID
- of the resource that will run the job (if possible)userCtx
- the user certificate.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)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runresourceID
- of the resource that will run the job (if possible)userCtx
- the user certificate.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)
jobId
- of the job to be startedreservationID
- The previously created reservation were the job will runresourceID
- of the resource that will run the job (if possible)userCtx
- the user certificate.public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getInfoResourcesCB(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR)
public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getInfoResourcesCBE(java.util.ArrayList<ResourceDescriptorRecord> __RDR, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list)
list
- of candidates.public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
list
- of candidates.public void getAllResourcesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
list
- of candidates.public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list)
list
- of candidates.public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
list
- of candidates.public void getReservationResourcesCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
list
- of candidates.public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list)
list
- of candidates.public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
list
- of candidates.public void getReservationResourcesProcessCB(java.util.ArrayList<ReservationSlot> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
list
- of candidates.public void selectResource(java.util.ArrayList<CommunicationAddress> __list, java.lang.Integer __schedule)
list
- list of suitable resources.schedule
- type of schedule applied (0: RANDOM (only available))
1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)public void selectResource(java.util.ArrayList<CommunicationAddress> __list, java.lang.Integer __schedule, eu.xtreemos.system.communication.bus.CallbackMessage callback)
list
- list of suitable resources.schedule
- type of schedule applied (0: RANDOM (only available))
1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)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)
list
- list of suitable resources.schedule
- type of schedule applied (0: RANDOM (only available))
1: Less USED (Calls resMng getResourceDescriptor and eventually calls ExecMng)public void execJob(CommunicationAddress __addrResource)
public void execJob(CommunicationAddress __addrResource, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void execJob(CommunicationAddress __addrResource, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void verifyPolicyHandler(ResourceMatching __rmList)
rmList
- list of suitable resources.public void verifyPolicyHandler(ResourceMatching __rmList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
rmList
- list of suitable resources.public void verifyPolicyHandler(ResourceMatching __rmList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
rmList
- list of suitable resources.public void jobControl(java.lang.String __jobId, java.lang.Integer __ctrOp, java.security.cert.X509Certificate __userCtx)
jobId
- of the job to apply the operationctrOp
- possible values:
0: SUSPENDJOB
1: RESUMEJOB
2: CANCEL JOBuserCtx
- the user certificatepublic void jobControl(java.lang.String __jobId, java.lang.Integer __ctrOp, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- of the job to apply the operationctrOp
- possible values:
0: SUSPENDJOB
1: RESUMEJOB
2: CANCEL JOBuserCtx
- the user certificatepublic 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)
jobId
- of the job to apply the operationctrOp
- possible values:
0: SUSPENDJOB
1: RESUMEJOB
2: CANCEL JOBuserCtx
- the user certificatepublic void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, java.security.cert.X509Certificate __userCtx)
jobId
- identifying the job to exitexitValue
- the exit code the job will finish withuserCtx
- the user certificatepublic void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- identifying the job to exitexitValue
- the exit code the job will finish withuserCtx
- the user certificatepublic 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)
jobId
- identifying the job to exitexitValue
- the exit code the job will finish withuserCtx
- the user certificatepublic 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)
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 flagsuserCtx
- the X509Certificate Object with the user certificate
java.lang.Exception
- if
1) Incorrect jobId
2) Invalid User in the Certificate
3) Incorrect list of metrics
4) Not a valid XtreemOS certificatepublic 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)
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 flagsuserCtx
- the X509Certificate Object with the user certificate
java.lang.Exception
- if
1) Incorrect jobId
2) Invalid User in the Certificate
3) Incorrect list of metrics
4) Not a valid XtreemOS certificatepublic 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)
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 flagsuserCtx
- the X509Certificate Object with the user certificate
java.lang.Exception
- if
1) Incorrect jobId
2) Invalid User in the Certificate
3) Incorrect list of metrics
4) Not a valid XtreemOS certificatepublic void getJobInfoCB(java.lang.String __info)
public void getJobInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getJobInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getJobInfoCBE(java.lang.Object __info)
public void getJobInfoCBE(java.lang.Object __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getJobInfoCBE(java.lang.Object __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
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)
jobId
- flags
- infoLevel
- metricsList
- userCtx
-
java.lang.Exception
getJobsInfo(ArrayList, Integer, Integer, ArrayList, X509Certificate)
public void getJobIdCB(java.lang.String __jobId)
public void getJobIdCB(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getJobIdCB(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getJobId(CommunicationAddress __resourceId, java.lang.Integer __pid, java.security.cert.X509Certificate __userCtx)
resourceId
- the CommunicationAddress of the resource where the process is assignedpid
- an Integer with the process identifier local to that resourceuserCtx
- an X509Certificate object with the user certificate
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 public void getJobId(CommunicationAddress __resourceId, java.lang.Integer __pid, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
resourceId
- the CommunicationAddress of the resource where the process is assignedpid
- an Integer with the process identifier local to that resourceuserCtx
- an X509Certificate object with the user certificate
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 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)
resourceId
- the CommunicationAddress of the resource where the process is assignedpid
- an Integer with the process identifier local to that resourceuserCtx
- an X509Certificate object with the user certificate
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 public void getJobsUser(java.lang.String __userId, java.security.cert.X509Certificate __userCtx)
userId
- a String identifying the user we want to obtain the jobs fromuserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificatepublic void getJobsUser(java.lang.String __userId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
userId
- a String identifying the user we want to obtain the jobs fromuserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificatepublic 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)
userId
- a String identifying the user we want to obtain the jobs fromuserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificatepublic void getJobsUserCB(java.lang.Object __obj)
public void getJobsUserCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getJobsUserCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
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)
signal
- number to be sentoperation
- can be:
0: ALL
1: MASTER
2: SPECIFYED in list
3: EXCEPT in listjobId
- identifying the job we are going to send the signal tolist
- userCtx
- the user certificate
TODO: Now we send always the signal to all the processes of the job, use the operation and list parameterspublic 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)
signal
- number to be sentoperation
- can be:
0: ALL
1: MASTER
2: SPECIFYED in list
3: EXCEPT in listjobId
- identifying the job we are going to send the signal tolist
- userCtx
- the user certificate
TODO: Now we send always the signal to all the processes of the job, use the operation and list parameterspublic 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)
signal
- number to be sentoperation
- can be:
0: ALL
1: MASTER
2: SPECIFYED in list
3: EXCEPT in listjobId
- identifying the job we are going to send the signal tolist
- userCtx
- the user certificate
TODO: Now we send always the signal to all the processes of the job, use the operation and list parameterspublic void jobWait(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx)
jobId
- identifying the job the calling process is waiting forpublic void jobWait(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- identifying the job the calling process is waiting forpublic 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)
jobId
- identifying the job the calling process is waiting forpublic void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx)
jobId
- JSDL,
- JSDL contentreservationId
- resource
- userCtx
-
java.lang.Exception
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)
jobId
- JSDL,
- JSDL contentreservationId
- resource
- userCtx
-
java.lang.Exception
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)
jobId
- JSDL,
- JSDL contentreservationId
- resource
- userCtx
-
java.lang.Exception
public void getProcessInfoCB(java.lang.String __info)
public void getProcessInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getProcessInfoCB(java.lang.String __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void getProcessInfoCBE(java.lang.Exception __info)
public void getProcessInfoCBE(java.lang.Exception __info, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getProcessInfoCBE(java.lang.Exception __info, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void jobFinished(java.lang.String __jobId, java.lang.Integer __exitStatus, CommunicationAddress __execMng)
public void jobFinished(java.lang.String __jobId, java.lang.Integer __exitStatus, CommunicationAddress __execMng, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void cleanMonitoring(java.lang.String __jobId)
jobId
- public void cleanMonitoring(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- public void cleanMonitoring(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
jobId
- public void jobRunning(java.lang.String __jobId)
public void jobRunning(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void jobRunning(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void redirectFunctionCB(CommunicationAddress __addrJob)
java.lang.Exception
- if
1) Incorrect jobIdpublic void redirectFunctionCB(CommunicationAddress __addrJob, eu.xtreemos.system.communication.bus.CallbackMessage callback)
java.lang.Exception
- if
1) Incorrect jobIdpublic void redirectFunctionCB(CommunicationAddress __addrJob, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
java.lang.Exception
- if
1) Incorrect jobIdpublic void addDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
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)
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)
public void addDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
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)
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)
public void deleteDependenceUp(java.lang.String __jobId, java.lang.String __FromJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
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)
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)
public void deleteDependenceDown(java.lang.String __jobId, java.lang.String __toJobId, java.lang.String __tag, java.security.cert.X509Certificate __userCtx)
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)
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)
public void addDependence(java.lang.String __FromJobId, java.lang.String __toJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic 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)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic 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)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic void deleteDependence(java.lang.String __FromJobId, java.lang.String __ToJobId, java.lang.String __TAG, java.security.cert.X509Certificate __userCtx)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic 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)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic 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)
FromJobId
- the job from which tojobId dependstoJobId
- the job that depends on fromJobIdTAG
- is a name to identify a set of dependencies.userCtx
- the user certificatepublic void getListOfDependences(java.lang.String __jobID, java.lang.String __tag, java.lang.Integer __levels, java.lang.Integer __direction, java.security.cert.X509Certificate __userCtx)
jobID
- the starting job to get the related jobstag
- 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 certificatepublic 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)
jobID
- the starting job to get the related jobstag
- 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 certificatepublic 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)
jobID
- the starting job to get the related jobstag
- 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 certificatepublic void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList)
public void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getListOfDependencesCB(java.util.ArrayList<java.lang.String> __depList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void updateJobHints(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: MIGRATION_REQ
1: SCHEDULING_REQrequirements
- identifying the job to change the requirements ofwait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic 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)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: MIGRATION_REQ
1: SCHEDULING_REQrequirements
- identifying the job to change the requirements ofwait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic 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)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: MIGRATION_REQ
1: SCHEDULING_REQrequirements
- identifying the job to change the requirements ofwait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic void getJobMetrics(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx)
jobId
- a String identifying the job to get the metrics from,
if the jobId is null the generic list of metrics is returneduserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificate
2) Invalid User in the Certificate
3) Incorrect jobIdpublic void getJobMetrics(java.lang.String __jobId, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- a String identifying the job to get the metrics from,
if the jobId is null the generic list of metrics is returneduserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificate
2) Invalid User in the Certificate
3) Incorrect jobIdpublic 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)
jobId
- a String identifying the job to get the metrics from,
if the jobId is null the generic list of metrics is returneduserCtx
- a X509Certificate object with the user certificate
java.lang.Exception
- if
1) Not a valid XtreemOS certificate
2) Invalid User in the Certificate
3) Incorrect jobIdpublic 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)
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.
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 metricpublic 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)
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.
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 metricpublic 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)
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.
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 metricpublic 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)
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.
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 capabilitiespublic 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)
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.
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 capabilitiespublic 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)
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.
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 capabilitiespublic void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx)
jobId
- a String identifying the job to add the metric tometric
- a MetricsDesc object with the metric to be addeduserCtx
- a X509Certificate object with the user certificate
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 descriptionpublic 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)
jobId
- a String identifying the job to add the metric tometric
- a MetricsDesc object with the metric to be addeduserCtx
- a X509Certificate object with the user certificate
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 descriptionpublic 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)
jobId
- a String identifying the job to add the metric tometric
- a MetricsDesc object with the metric to be addeduserCtx
- a X509Certificate object with the user certificate
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 descriptionpublic void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, java.security.cert.X509Certificate __userCtx)
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)
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)
public void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, java.security.cert.X509Certificate __userCtx)
jobId
- a String identifying the job to remove the metric frommetricName
- a String with the name of the metric to be removeduserCtx
- a X509Certificate object with the user certificate
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 metricpublic void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- a String identifying the job to remove the metric frommetricName
- a String with the name of the metric to be removeduserCtx
- a X509Certificate object with the user certificate
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 metricpublic 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)
jobId
- a String identifying the job to remove the metric frommetricName
- a String with the name of the metric to be removeduserCtx
- a X509Certificate object with the user certificate
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 metricpublic void chgUID(java.lang.String __jobId, java.security.cert.X509Certificate __oldUserCtx, java.security.cert.X509Certificate __newUserCtx)
jobId
- identifying the job whose user will changeoldUserCtx
- the certificate of the current usernewUserCtx
- the new certificate to be usedpublic void chgUID(java.lang.String __jobId, java.security.cert.X509Certificate __oldUserCtx, java.security.cert.X509Certificate __newUserCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- identifying the job whose user will changeoldUserCtx
- the certificate of the current usernewUserCtx
- the new certificate to be usedpublic 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)
jobId
- identifying the job whose user will changeoldUserCtx
- the certificate of the current usernewUserCtx
- the new certificate to be usedpublic void updateJobRequirements(java.lang.String __jobId, java.lang.Integer __operation, java.lang.String __requirements, java.lang.Boolean __wait, java.security.cert.X509Certificate __userCtx)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: ADD_RESOURCES
1: RELEASE_RESOURCES
2: EXTEND_RESOURCESrequirements
- in a JSDL format specifying the new requirementswait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic 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)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: ADD_RESOURCES
1: RELEASE_RESOURCES
2: EXTEND_RESOURCESrequirements
- in a JSDL format specifying the new requirementswait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic 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)
jobId
- identifying the job to change the requirements ofoperation
- can be:
0: ADD_RESOURCES
1: RELEASE_RESOURCES
2: EXTEND_RESOURCESrequirements
- in a JSDL format specifying the new requirementswait
- if the call is synchronous or asynchronoususerCtx
- the user certificatepublic void jobMonitoringControl(java.lang.String __jobId, java.lang.Integer __op, java.lang.String __level, java.security.cert.X509Certificate __userCtx)
jobId
- op
- can be:
0:START
1:STOP
2:CHANGE_LEVELlevel
- the new monitoring level in case op is set to CHANGE.
Can be: High, medium or LowuserCtx
- the user certificatepublic 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)
jobId
- op
- can be:
0:START
1:STOP
2:CHANGE_LEVELlevel
- the new monitoring level in case op is set to CHANGE.
Can be: High, medium or LowuserCtx
- the user certificatepublic 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)
jobId
- op
- can be:
0:START
1:STOP
2:CHANGE_LEVELlevel
- the new monitoring level in case op is set to CHANGE.
Can be: High, medium or LowuserCtx
- the user certificatepublic void waitForEvent(java.lang.String __jobId, java.lang.Integer __event, java.security.cert.X509Certificate __userCtx)
jobId
- event
- the event the process is waiting foruserCtx
- the user certificatepublic void waitForEvent(java.lang.String __jobId, java.lang.Integer __event, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- event
- the event the process is waiting foruserCtx
- the user certificatepublic 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)
jobId
- event
- the event the process is waiting foruserCtx
- the user certificatepublic 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)
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)
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)
public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList)
addrJob
-
java.lang.Exception
public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
addrJob
-
java.lang.Exception
public void getJobManagerAddressesCB(java.util.ArrayList<CommunicationAddress> __addrJobList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
addrJob
-
java.lang.Exception
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)
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)
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)
public void unlockCheckpoint(java.lang.String __jobId)
public void unlockCheckpoint(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void unlockCheckpoint(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void lockRestart(java.lang.String __jobId)
public void lockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void lockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void unlockRestart(java.lang.String __jobId)
public void unlockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void unlockRestart(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
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)
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)
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)
public void returnCB(java.lang.Object __obj)
public void returnCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void returnCB(java.lang.Object __obj, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void returnCBE(java.lang.Exception __ex)
public void returnCBE(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void returnCBE(java.lang.Exception __ex, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |