eu.xtreemos.xosd.services
Class SExecMng

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

public class SExecMng
extends java.lang.Object


Field Summary
private  CommunicationAddress _accesspoint_remoteaddress
           
private  eu.xtreemos.system.eventmachine.queue.Context context
           
static java.lang.String servicename
          AUTOGENERATED CODE
 
Constructor Summary
SExecMng(eu.xtreemos.system.eventmachine.queue.Context context)
           
 
Method Summary
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)
           
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void assignProcessesToJobAtRestart(java.lang.String __jobId, java.lang.String __procListString)
           
 void assignProcessesToJobAtRestart(java.lang.String __jobId, java.lang.String __procListString, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void assignProcessesToJobAtRestart(java.lang.String __jobId, java.lang.String __procListString, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx)
          It is supposed to be "similar" to a fork but in XOS.
 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)
          It is supposed to be "similar" to a fork but in XOS.
 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)
          It is supposed to be "similar" to a fork but in XOS.
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue)
           
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 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 getJobSelf(java.lang.Integer __pid)
          Retunr the JobId of the calling process (identified by its pid)
 void getJobSelf(java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Retunr the JobId of the calling process (identified by its pid)
 void getJobSelf(java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Retunr the JobId of the calling process (identified by its pid)
 void getJobsResource(java.security.cert.X509Certificate __certificate)
          Return the information of the jobs running in this resource TODO Is that a required feature?
 void getJobsResource(java.security.cert.X509Certificate __certificate, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Return the information of the jobs running in this resource TODO Is that a required feature?
 void getJobsResource(java.security.cert.X509Certificate __certificate, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Return the information of the jobs running in this resource TODO Is that a required feature?
 void getProcessList(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __jobUnitID, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __executable, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __kernelCheckpointer, java.lang.String __checkpointVersion, java.lang.String __pidCGroupName, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert)
          get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst
 void getProcessList(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __jobUnitID, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __executable, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __kernelCheckpointer, java.lang.String __checkpointVersion, java.lang.String __pidCGroupName, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst
 void getProcessList(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __jobUnitID, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __executable, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __kernelCheckpointer, java.lang.String __checkpointVersion, java.lang.String __pidCGroupName, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst
 void getProcsInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.lang.String __user)
           
 void getProcsInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.lang.String __user, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getProcsInfo(java.lang.String __jobId, java.lang.Integer __flags, java.lang.Integer __infoLevel, java.util.ArrayList<java.lang.String> __metricsList, java.lang.String __user, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void getProcsJob(java.lang.String __jobId)
           
 void getProcsJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void getProcsJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList)
          This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them.
 void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them.
 void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them.
 void rebuildJobUnit(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __checkpointVersion, CommunicationAddress __jobMngAddr, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __kernelCheckpointer, java.lang.String __jsdlFile, java.lang.String __input, java.lang.String __output, java.lang.String __cmd, java.lang.String __error, java.security.cert.X509Certificate __userCert)
           
 void rebuildJobUnit(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __checkpointVersion, CommunicationAddress __jobMngAddr, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __kernelCheckpointer, java.lang.String __jsdlFile, java.lang.String __input, java.lang.String __output, java.lang.String __cmd, java.lang.String __error, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void rebuildJobUnit(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __checkpointVersion, CommunicationAddress __jobMngAddr, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __kernelCheckpointer, java.lang.String __jsdlFile, java.lang.String __input, java.lang.String __output, java.lang.String __cmd, java.lang.String __error, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void removeBuffers(java.lang.String __jobId)
          To be called from jobMng whenever it's cleaning time.
 void removeBuffers(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          To be called from jobMng whenever it's cleaning time.
 void removeBuffers(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          To be called from jobMng whenever it's cleaning time.
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName)
           
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void removeJobMetrics(java.lang.String __jobId)
          JobUnit scope Removes metrics data, but leaves metadata and buffers.
 void removeJobMetrics(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JobUnit scope Removes metrics data, but leaves metadata and buffers.
 void removeJobMetrics(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JobUnit scope Removes metrics data, but leaves metadata and buffers.
 void removeProcMetrics(java.lang.String __jobId, java.lang.Integer __pid)
          Process scope Removes metrics data, but leaves metadata and buffers.
 void removeProcMetrics(java.lang.String __jobId, java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Process scope Removes metrics data, but leaves metadata and buffers.
 void removeProcMetrics(java.lang.String __jobId, java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Process scope Removes metrics data, but leaves metadata and buffers.
 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 sendEvent(java.lang.String __jobId, java.lang.Integer __signal)
           
 void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.String __value)
           
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.String __value, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.String __value, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void setMonitoringBuffering(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.Boolean __enable, java.lang.String __user)
          TODO update to setMonitorBuffering semantics, if required.
 void setMonitoringBuffering(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.Boolean __enable, java.lang.String __user, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          TODO update to setMonitorBuffering semantics, if required.
 void setMonitoringBuffering(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.Boolean __enable, java.lang.String __user, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          TODO update to setMonitorBuffering semantics, if required.
 void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
           
 void startJob(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx)
          Starts running a job already created
 void startJob(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Starts running a job already created
 void startJob(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Starts running a job already created
 void startProcess(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx)
          Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.
 void startProcess(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.
 void startProcess(java.lang.String __jobId, CommunicationAddress __jobMngAddr, java.lang.String __command, java.lang.Object __params_aux, java.lang.Object __env_aux, java.lang.String __output, java.lang.String __error, java.lang.String __input, java.security.cert.X509Certificate __userCtx, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)
           
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

servicename

public static java.lang.String servicename
AUTOGENERATED CODE


context

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

_accesspoint_remoteaddress

private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail

SExecMng

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

setRemoteaddress

public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)

inheritMetricsCB

public void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList)
This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them. It needs the newly created jobUnit in its context to execute the job afterwards. Should be called in this workflow: startJob/startProcess: new jobUnit? -> inheritMetrics -> JobMng(getMetricsByScope) -> this callback -> execJob

Parameters:
metricsList - an ArrayList of metrics that the job needs to handle.

inheritMetricsCB

public void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them. It needs the newly created jobUnit in its context to execute the job afterwards. Should be called in this workflow: startJob/startProcess: new jobUnit? -> inheritMetrics -> JobMng(getMetricsByScope) -> this callback -> execJob

Parameters:
metricsList - an ArrayList of metrics that the job needs to handle.

inheritMetricsCB

public void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
This method receives a list of metrics from jobMng, stores them in its corresponding structure for the job and sets initial values for some of them. It needs the newly created jobUnit in its context to execute the job afterwards. Should be called in this workflow: startJob/startProcess: new jobUnit? -> inheritMetrics -> JobMng(getMetricsByScope) -> this callback -> execJob

Parameters:
metricsList - an ArrayList of metrics that the job needs to handle.

startJob

public void startJob(java.lang.String __jobId,
                     CommunicationAddress __jobMngAddr,
                     java.lang.String __command,
                     java.lang.Object __params_aux,
                     java.lang.Object __env_aux,
                     java.lang.String __output,
                     java.lang.String __error,
                     java.lang.String __input,
                     java.security.cert.X509Certificate __userCtx)
Starts running a job already created


startJob

public void startJob(java.lang.String __jobId,
                     CommunicationAddress __jobMngAddr,
                     java.lang.String __command,
                     java.lang.Object __params_aux,
                     java.lang.Object __env_aux,
                     java.lang.String __output,
                     java.lang.String __error,
                     java.lang.String __input,
                     java.security.cert.X509Certificate __userCtx,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts running a job already created


startJob

public void startJob(java.lang.String __jobId,
                     CommunicationAddress __jobMngAddr,
                     java.lang.String __command,
                     java.lang.Object __params_aux,
                     java.lang.Object __env_aux,
                     java.lang.String __output,
                     java.lang.String __error,
                     java.lang.String __input,
                     java.security.cert.X509Certificate __userCtx,
                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts running a job already created


startProcess

public void startProcess(java.lang.String __jobId,
                         CommunicationAddress __jobMngAddr,
                         java.lang.String __command,
                         java.lang.Object __params_aux,
                         java.lang.Object __env_aux,
                         java.lang.String __output,
                         java.lang.String __error,
                         java.lang.String __input,
                         java.security.cert.X509Certificate __userCtx)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.


startProcess

public void startProcess(java.lang.String __jobId,
                         CommunicationAddress __jobMngAddr,
                         java.lang.String __command,
                         java.lang.Object __params_aux,
                         java.lang.Object __env_aux,
                         java.lang.String __output,
                         java.lang.String __error,
                         java.lang.String __input,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.


startProcess

public void startProcess(java.lang.String __jobId,
                         CommunicationAddress __jobMngAddr,
                         java.lang.String __command,
                         java.lang.Object __params_aux,
                         java.lang.Object __env_aux,
                         java.lang.String __output,
                         java.lang.String __error,
                         java.lang.String __input,
                         java.security.cert.X509Certificate __userCtx,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Starts a new process, might create a new jobUnit if it's the first one of the job in this resource.


getProcsJob

public void getProcsJob(java.lang.String __jobId)

getProcsJob

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

getProcsJob

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

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)

addJobMetric

public void addJobMetric(java.lang.String __jobId,
                         eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)

updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)

updateJobMetric

public void updateJobMetric(java.lang.String __jobId,
                            eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName)
Parameters:
jobId -
metricName -

removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
Parameters:
jobId -
metricName -

removeJobMetric

public void removeJobMetric(java.lang.String __jobId,
                            java.lang.String __metricName,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Parameters:
jobId -
metricName -

removeJobMetrics

public void removeJobMetrics(java.lang.String __jobId)
JobUnit scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -

removeJobMetrics

public void removeJobMetrics(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
JobUnit scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -

removeJobMetrics

public void removeJobMetrics(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JobUnit scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -

removeProcMetrics

public void removeProcMetrics(java.lang.String __jobId,
                              java.lang.Integer __pid)
Process scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -
pid -

removeProcMetrics

public void removeProcMetrics(java.lang.String __jobId,
                              java.lang.Integer __pid,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
Process scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -
pid -

removeProcMetrics

public void removeProcMetrics(java.lang.String __jobId,
                              java.lang.Integer __pid,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Process scope Removes metrics data, but leaves metadata and buffers.

Parameters:
jobId -
pid -

removeBuffers

public void removeBuffers(java.lang.String __jobId)
To be called from jobMng whenever it's cleaning time. Removes buffers and metadata.

Parameters:
jobId -

removeBuffers

public void removeBuffers(java.lang.String __jobId,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)
To be called from jobMng whenever it's cleaning time. Removes buffers and metadata.

Parameters:
jobId -

removeBuffers

public void removeBuffers(java.lang.String __jobId,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
To be called from jobMng whenever it's cleaning time. Removes buffers and metadata.

Parameters:
jobId -

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           java.lang.Integer __pid,
                           java.lang.String __value)
Parameters:
jobId -
metricName -
pid -
value -

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           java.lang.Integer __pid,
                           java.lang.String __value,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
Parameters:
jobId -
metricName -
pid -
value -

setMetricValue

public void setMetricValue(java.lang.String __jobId,
                           java.lang.String __metricName,
                           java.lang.Integer __pid,
                           java.lang.String __value,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Parameters:
jobId -
metricName -
pid -
value -

setMonitoringBuffering

public void setMonitoringBuffering(java.lang.String __jobId,
                                   java.lang.String __metricName,
                                   java.lang.Integer __pid,
                                   java.lang.Boolean __enable,
                                   java.lang.String __user)
TODO update to setMonitorBuffering semantics, if required.

Parameters:
jobId -
metricName -
pid - should be null if it's not a process scope metric
enable -
user -

setMonitoringBuffering

public void setMonitoringBuffering(java.lang.String __jobId,
                                   java.lang.String __metricName,
                                   java.lang.Integer __pid,
                                   java.lang.Boolean __enable,
                                   java.lang.String __user,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
TODO update to setMonitorBuffering semantics, if required.

Parameters:
jobId -
metricName -
pid - should be null if it's not a process scope metric
enable -
user -

setMonitoringBuffering

public void setMonitoringBuffering(java.lang.String __jobId,
                                   java.lang.String __metricName,
                                   java.lang.Integer __pid,
                                   java.lang.Boolean __enable,
                                   java.lang.String __user,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
TODO update to setMonitorBuffering semantics, if required.

Parameters:
jobId -
metricName -
pid - should be null if it's not a process scope metric
enable -
user -

getProcsInfo

public void getProcsInfo(java.lang.String __jobId,
                         java.lang.Integer __flags,
                         java.lang.Integer __infoLevel,
                         java.util.ArrayList<java.lang.String> __metricsList,
                         java.lang.String __user)

getProcsInfo

public void getProcsInfo(java.lang.String __jobId,
                         java.lang.Integer __flags,
                         java.lang.Integer __infoLevel,
                         java.util.ArrayList<java.lang.String> __metricsList,
                         java.lang.String __user,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback)

getProcsInfo

public void getProcsInfo(java.lang.String __jobId,
                         java.lang.Integer __flags,
                         java.lang.Integer __infoLevel,
                         java.util.ArrayList<java.lang.String> __metricsList,
                         java.lang.String __user,
                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

sendEvent

public void sendEvent(java.lang.String __jobId,
                      java.lang.Integer __signal)

sendEvent

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

sendEvent

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

getJobsResource

public void getJobsResource(java.security.cert.X509Certificate __certificate)
Return the information of the jobs running in this resource TODO Is that a required feature? For now it needs to be run in a core node.


getJobsResource

public void getJobsResource(java.security.cert.X509Certificate __certificate,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
Return the information of the jobs running in this resource TODO Is that a required feature? For now it needs to be run in a core node.


getJobsResource

public void getJobsResource(java.security.cert.X509Certificate __certificate,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Return the information of the jobs running in this resource TODO Is that a required feature? For now it needs to be run in a core node.


getJobInfoCB

public void getJobInfoCB(java.lang.String __info)

getJobInfoCB

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

getJobInfoCB

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

exitJob

public void exitJob(java.lang.String __jobId,
                    java.lang.Integer __exitValue)

exitJob

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

exitJob

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

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx)
It is supposed to be "similar" to a fork but in XOS. If JSDLPath is null we will use the one provided in createJob. If a reservationID is provided it will be used. Otherwise, if resourceID is provided it will be used. Otherwise, the process will be created locally.

Parameters:
jobId -
JSDL -
reservationId -
resource -
userCtx -

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback)
It is supposed to be "similar" to a fork but in XOS. If JSDLPath is null we will use the one provided in createJob. If a reservationID is provided it will be used. Otherwise, if resourceID is provided it will be used. Otherwise, the process will be created locally.

Parameters:
jobId -
JSDL -
reservationId -
resource -
userCtx -

createProcess

public void createProcess(java.lang.String __jobId,
                          java.lang.String __JSDL,
                          java.lang.String __reservationId,
                          CommunicationAddress __resource,
                          java.security.cert.X509Certificate __userCtx,
                          eu.xtreemos.system.communication.bus.CallbackMessage callback,
                          eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
It is supposed to be "similar" to a fork but in XOS. If JSDLPath is null we will use the one provided in createJob. If a reservationID is provided it will be used. Otherwise, if resourceID is provided it will be used. Otherwise, the process will be created locally.

Parameters:
jobId -
JSDL -
reservationId -
resource -
userCtx -

returnCB

public void returnCB(java.lang.Object __obj)

returnCB

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

returnCB

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

returnCBE

public void returnCBE(java.lang.Exception __ex)

returnCBE

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

returnCBE

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

getProcessList

public void getProcessList(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jsdlFile,
                           java.lang.String __jobUnitID,
                           java.util.ArrayList<java.lang.String> __dependentJobs,
                           java.lang.String __executable,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __checkpointVersion,
                           java.lang.String __pidCGroupName,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst


getProcessList

public void getProcessList(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jsdlFile,
                           java.lang.String __jobUnitID,
                           java.util.ArrayList<java.lang.String> __dependentJobs,
                           java.lang.String __executable,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __checkpointVersion,
                           java.lang.String __pidCGroupName,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst


getProcessList

public void getProcessList(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jsdlFile,
                           java.lang.String __jobUnitID,
                           java.util.ArrayList<java.lang.String> __dependentJobs,
                           java.lang.String __executable,
                           CommunicationAddress __jobCpAddr,
                           CommunicationAddress __superJobCpAddr,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __checkpointVersion,
                           java.lang.String __pidCGroupName,
                           java.lang.String __strategy,
                           java.lang.String __options,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
get a process from the job unit - for kernel checkpointer to determine process group it uses for cp/rst


rebuildJobUnit

public void rebuildJobUnit(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jobUnitId,
                           java.lang.String __checkpointVersion,
                           CommunicationAddress __jobMngAddr,
                           java.lang.String __processGroupReferenceId,
                           java.lang.String __processGroupReferenceType,
                           java.lang.String __pidCGroupName,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __jsdlFile,
                           java.lang.String __input,
                           java.lang.String __output,
                           java.lang.String __cmd,
                           java.lang.String __error,
                           java.security.cert.X509Certificate __userCert)
Parameters:
jobId -
jobMngAddr -

rebuildJobUnit

public void rebuildJobUnit(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jobUnitId,
                           java.lang.String __checkpointVersion,
                           CommunicationAddress __jobMngAddr,
                           java.lang.String __processGroupReferenceId,
                           java.lang.String __processGroupReferenceType,
                           java.lang.String __pidCGroupName,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __jsdlFile,
                           java.lang.String __input,
                           java.lang.String __output,
                           java.lang.String __cmd,
                           java.lang.String __error,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
Parameters:
jobId -
jobMngAddr -

rebuildJobUnit

public void rebuildJobUnit(java.lang.String __jobId,
                           java.lang.String __initialJobId,
                           java.lang.String __jobUnitId,
                           java.lang.String __checkpointVersion,
                           CommunicationAddress __jobMngAddr,
                           java.lang.String __processGroupReferenceId,
                           java.lang.String __processGroupReferenceType,
                           java.lang.String __pidCGroupName,
                           java.lang.String __kernelCheckpointer,
                           java.lang.String __jsdlFile,
                           java.lang.String __input,
                           java.lang.String __output,
                           java.lang.String __cmd,
                           java.lang.String __error,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Parameters:
jobId -
jobMngAddr -

assignProcessesToJobAtRestart

public void assignProcessesToJobAtRestart(java.lang.String __jobId,
                                          java.lang.String __procListString)

assignProcessesToJobAtRestart

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

assignProcessesToJobAtRestart

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

getJobSelf

public void getJobSelf(java.lang.Integer __pid)
Retunr the JobId of the calling process (identified by its pid)

Parameters:
pid - of the calling process

getJobSelf

public void getJobSelf(java.lang.Integer __pid,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback)
Retunr the JobId of the calling process (identified by its pid)

Parameters:
pid - of the calling process

getJobSelf

public void getJobSelf(java.lang.Integer __pid,
                       eu.xtreemos.system.communication.bus.CallbackMessage callback,
                       eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Retunr the JobId of the calling process (identified by its pid)

Parameters:
pid - of the calling process