|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.xtreemos.xosd.services.SExecMng
public class SExecMng
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 |
---|
public static java.lang.String servicename
private eu.xtreemos.system.eventmachine.queue.Context context
private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail |
---|
public SExecMng(eu.xtreemos.system.eventmachine.queue.Context context)
Method Detail |
---|
public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
public void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList)
metricsList
- an ArrayList of metrics that the job needs to
handle.public void inheritMetricsCB(java.util.ArrayList<eu.xtreemos.xosd.utilities.metrics.MetricsDesc> __metricsList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
metricsList
- an ArrayList of metrics that the job needs to
handle.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)
metricsList
- an ArrayList of metrics that the job needs to
handle.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)
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)
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)
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)
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)
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)
public void getProcsJob(java.lang.String __jobId)
public void getProcsJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getProcsJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)
public void addJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric)
public void updateJobMetric(java.lang.String __jobId, eu.xtreemos.xosd.utilities.metrics.MetricsDesc __metric, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName)
jobId
- metricName
- public void removeJobMetric(java.lang.String __jobId, java.lang.String __metricName, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- metricName
- 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)
jobId
- metricName
- public void removeJobMetrics(java.lang.String __jobId)
jobId
- public void removeJobMetrics(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- public void removeJobMetrics(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
jobId
- public void removeProcMetrics(java.lang.String __jobId, java.lang.Integer __pid)
jobId
- pid
- public void removeProcMetrics(java.lang.String __jobId, java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- pid
- 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)
jobId
- pid
- public void removeBuffers(java.lang.String __jobId)
jobId
- public void removeBuffers(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobId
- public void removeBuffers(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
jobId
- public void setMetricValue(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.String __value)
jobId
- metricName
- pid
- value
- 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)
jobId
- metricName
- pid
- value
- 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)
jobId
- metricName
- pid
- value
- public void setMonitoringBuffering(java.lang.String __jobId, java.lang.String __metricName, java.lang.Integer __pid, java.lang.Boolean __enable, java.lang.String __user)
jobId
- metricName
- pid
- should be null if it's not a process scope metricenable
- user
- 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)
jobId
- metricName
- pid
- should be null if it's not a process scope metricenable
- user
- 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)
jobId
- metricName
- pid
- should be null if it's not a process scope metricenable
- user
- 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)
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)
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)
public void sendEvent(java.lang.String __jobId, java.lang.Integer __signal)
public void sendEvent(java.lang.String __jobId, java.lang.Integer __signal, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void getJobsResource(java.security.cert.X509Certificate __certificate)
public void getJobsResource(java.security.cert.X509Certificate __certificate, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getJobsResource(java.security.cert.X509Certificate __certificate, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public 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 exitJob(java.lang.String __jobId, java.lang.Integer __exitValue)
public void exitJob(java.lang.String __jobId, java.lang.Integer __exitValue, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void createProcess(java.lang.String __jobId, java.lang.String __JSDL, java.lang.String __reservationId, CommunicationAddress __resource, java.security.cert.X509Certificate __userCtx)
jobId
- JSDL
- reservationId
- resource
- userCtx
- 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
- reservationId
- resource
- userCtx
- 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
- reservationId
- resource
- userCtx
- 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)
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)
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)
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)
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)
jobId
- jobMngAddr
- 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)
jobId
- jobMngAddr
- 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)
jobId
- jobMngAddr
- public void assignProcessesToJobAtRestart(java.lang.String __jobId, java.lang.String __procListString)
public void assignProcessesToJobAtRestart(java.lang.String __jobId, java.lang.String __procListString, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void getJobSelf(java.lang.Integer __pid)
pid
- of the calling processpublic void getJobSelf(java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback)
pid
- of the calling processpublic void getJobSelf(java.lang.Integer __pid, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
pid
- of the calling process
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |