eu.xtreemos.xati.API
Class XExecMng
java.lang.Object
eu.xtreemos.xati.API.XExecMng
public class XExecMng
- extends java.lang.Object
- Author:
- gregor.pipan@xlab.si
Method Summary |
static void |
assignProcessesToJobAtRestart(java.lang.String __jobId,
java.lang.String __procListString)
|
static java.lang.Integer |
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. |
static java.lang.String |
getJobSelf(java.lang.Integer __pid)
Retunr the JobId of the calling process (identified by its pid) |
static java.lang.String |
getJobsResource(java.security.cert.X509Certificate __certificate)
Return the information of the jobs running in this resource
TODO Is that a required feature? |
static 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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
servicename
public static java.lang.String servicename
XExecMng
public XExecMng()
getJobsResource
public static java.lang.String getJobsResource(java.security.cert.X509Certificate __certificate)
throws java.lang.Exception
- 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.
- Returns:
- String with the information of the running jobs
- Throws:
java.lang.Exception
createProcess
public static java.lang.Integer createProcess(java.lang.String __jobId,
java.lang.String __JSDL,
java.lang.String __reservationId,
CommunicationAddress __resource,
java.security.cert.X509Certificate __userCtx)
throws java.lang.Exception
- 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
-
- Returns:
- an Integer to be determined
TODO: Return the resource and pid of the new process
- Throws:
java.lang.Exception
rebuildJobUnit
public static 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)
throws java.lang.Exception
- Parameters:
jobId
- jobMngAddr
-
- Throws:
java.lang.Exception
assignProcessesToJobAtRestart
public static void assignProcessesToJobAtRestart(java.lang.String __jobId,
java.lang.String __procListString)
throws java.lang.Exception
- Throws:
java.lang.Exception
getJobSelf
public static java.lang.String getJobSelf(java.lang.Integer __pid)
throws java.lang.Exception
- Retunr the JobId of the calling process (identified by its pid)
- Parameters:
pid
- of the calling process
- Returns:
- String containg the jobId
- Throws:
java.lang.Exception