eu.xtreemos.xati.API
Class XCRExecMng

java.lang.Object
  extended by eu.xtreemos.xati.API.XCRExecMng

public class XCRExecMng
extends java.lang.Object

Author:
gregor.pipan@xlab.si

Field Summary
static java.lang.String servicename
           
 
Constructor Summary
XCRExecMng()
           
 
Method Summary
static java.lang.Integer checkpointJobUnit(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __processList, java.lang.String __executable, java.lang.String __options, java.lang.String __cpImageVersion, java.lang.String __checkpointPath, CommunicationAddress __jobCpAddr)
           
static void continueRebuildJobUnit(java.lang.String __jobId, java.lang.String __jobUnitId, java.lang.String __initialJobId, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __checkpointVersion, 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, CommunicationAddress __jobCpAddr)
           
static java.lang.Integer enableProcessPageFaultMonitoring(java.lang.Integer __pid)
           
static java.lang.Integer prepareJobUnit(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 __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __kernelCheckpointer, java.lang.String __pidCGroupName, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert)
           
static java.lang.Integer resumeJobUnitCP(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __processList, java.lang.String __executableName, java.lang.String __cpImageVersion, CommunicationAddress __jobCpAddr)
           
static void resumeJobUnitRST(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __checkpointVersion, java.lang.String __jobUnitId, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __processList, CommunicationAddress __jobCpAddr, java.lang.String __userCert)
           
static java.lang.Integer selectCheckpointer(java.lang.String __initialJobId, java.lang.String __jobId, java.lang.Integer __jobUnitId, java.lang.String __jsdlFile, java.lang.String __executable, java.lang.Integer __kernelCheckpointerId, java.lang.String __preferredKernelCheckpointer, CommunicationAddress __jobUnitCpAddr, CommunicationAddress __jobCpAddr, CommunicationAddress __superJobCpAddr, java.lang.String __lastCheckpointVersion, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.util.ArrayList<java.lang.String> __dependentJobs, java.security.cert.X509Certificate __userCert)
          select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!!
static java.lang.Integer stopJobUnit(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __pidCGroupName, java.lang.String __processList, java.lang.String __executable, java.lang.String __cpImageVersion, CommunicationAddress __jcAddr)
           
 
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
Constructor Detail

XCRExecMng

public XCRExecMng()
Method Detail

selectCheckpointer

public static java.lang.Integer selectCheckpointer(java.lang.String __initialJobId,
                                                   java.lang.String __jobId,
                                                   java.lang.Integer __jobUnitId,
                                                   java.lang.String __jsdlFile,
                                                   java.lang.String __executable,
                                                   java.lang.Integer __kernelCheckpointerId,
                                                   java.lang.String __preferredKernelCheckpointer,
                                                   CommunicationAddress __jobUnitCpAddr,
                                                   CommunicationAddress __jobCpAddr,
                                                   CommunicationAddress __superJobCpAddr,
                                                   java.lang.String __lastCheckpointVersion,
                                                   java.lang.String __strategy,
                                                   java.lang.String __options,
                                                   java.lang.String __mode,
                                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                                   java.security.cert.X509Certificate __userCert)
                                            throws java.lang.Exception
select on each grid node kernel checkpointer bound to node, no job-unit checkpointer matching yet!!

Parameters:
kernel - checkpointer Id
Throws:
java.lang.Exception

prepareJobUnit

public static java.lang.Integer prepareJobUnit(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 __processList,
                                               java.lang.String __processGroupReferenceId,
                                               java.lang.String __processGroupReferenceType,
                                               java.lang.String __kernelCheckpointer,
                                               java.lang.String __pidCGroupName,
                                               java.lang.String __strategy,
                                               java.lang.String __options,
                                               java.lang.String __mode,
                                               java.security.cert.X509Certificate __userCert)
                                        throws java.lang.Exception
Throws:
java.lang.Exception

stopJobUnit

public static java.lang.Integer stopJobUnit(java.lang.String __jobId,
                                            java.lang.String __initialJobId,
                                            java.lang.String __jobUnitId,
                                            java.lang.String __processGroupReferenceId,
                                            java.lang.String __processGroupReferenceType,
                                            java.lang.String __pidCGroupName,
                                            java.lang.String __processList,
                                            java.lang.String __executable,
                                            java.lang.String __cpImageVersion,
                                            CommunicationAddress __jcAddr)
                                     throws java.lang.Exception
Parameters:
jobId -
Throws:
java.lang.Exception

checkpointJobUnit

public static java.lang.Integer checkpointJobUnit(java.lang.String __jobId,
                                                  java.lang.String __initialJobId,
                                                  java.lang.String __jobUnitId,
                                                  java.lang.String __processGroupReferenceId,
                                                  java.lang.String __processGroupReferenceType,
                                                  java.lang.String __pidCGroupName,
                                                  java.lang.String __processList,
                                                  java.lang.String __executable,
                                                  java.lang.String __options,
                                                  java.lang.String __cpImageVersion,
                                                  java.lang.String __checkpointPath,
                                                  CommunicationAddress __jobCpAddr)
                                           throws java.lang.Exception
Parameters:
-
Throws:
java.lang.Exception

resumeJobUnitCP

public static java.lang.Integer resumeJobUnitCP(java.lang.String __jobId,
                                                java.lang.String __initialJobId,
                                                java.lang.String __jobUnitId,
                                                java.lang.String __processGroupReferenceId,
                                                java.lang.String __processGroupReferenceType,
                                                java.lang.String __pidCGroupName,
                                                java.lang.String __processList,
                                                java.lang.String __executableName,
                                                java.lang.String __cpImageVersion,
                                                CommunicationAddress __jobCpAddr)
                                         throws java.lang.Exception
Throws:
java.lang.Exception

continueRebuildJobUnit

public static void continueRebuildJobUnit(java.lang.String __jobId,
                                          java.lang.String __jobUnitId,
                                          java.lang.String __initialJobId,
                                          java.lang.String __processGroupReferenceId,
                                          java.lang.String __processGroupReferenceType,
                                          java.lang.String __pidCGroupName,
                                          java.lang.String __checkpointVersion,
                                          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,
                                          CommunicationAddress __jobCpAddr)
                                   throws java.lang.Exception
Throws:
java.lang.Exception

resumeJobUnitRST

public static void resumeJobUnitRST(java.lang.String __jobId,
                                    java.lang.String __initialJobId,
                                    java.lang.String __checkpointVersion,
                                    java.lang.String __jobUnitId,
                                    java.lang.String __processGroupReferenceId,
                                    java.lang.String __processGroupReferenceType,
                                    java.lang.String __pidCGroupName,
                                    java.lang.String __processList,
                                    CommunicationAddress __jobCpAddr,
                                    java.lang.String __userCert)
                             throws java.lang.Exception
Parameters:
cpImageVersion -
cpImageIdentifier - - provide kernel checkpointer to rebuild (file path to image, image name, ...)
Throws:
java.lang.Exception

enableProcessPageFaultMonitoring

public static java.lang.Integer enableProcessPageFaultMonitoring(java.lang.Integer __pid)
                                                          throws java.lang.Exception
Throws:
java.lang.Exception