eu.xtreemos.xosd.services
Class SCRJobMng

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

public class SCRJobMng
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
SCRJobMng(eu.xtreemos.system.eventmachine.queue.Context context)
           
 
Method Summary
 void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId, java.util.ArrayList<java.lang.String> __jobId_jobMng_List, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert)
          SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs
 void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId, java.util.ArrayList<java.lang.String> __jobId_jobMng_List, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs
 void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId, java.util.ArrayList<java.lang.String> __jobId_jobMng_List, java.util.ArrayList<java.lang.String> __dependentJobs, 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)
          SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs
 void checkpointJob(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void checkpointJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void checkpointJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void checkpointJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
          JC - each JUC returns to its JC
 void checkpointJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JC - each JUC returns to its JC
 void checkpointJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JC - each JUC returns to its JC
 void checkpointJobInit(java.lang.String __jobId, java.lang.Integer __resolveJobDependencies, java.lang.String __modeType, java.lang.String __options, java.security.cert.X509Certificate __userCert)
          INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer
 void checkpointJobInit(java.lang.String __jobId, java.lang.Integer __resolveJobDependencies, java.lang.String __modeType, java.lang.String __options, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer
 void checkpointJobInit(java.lang.String __jobId, java.lang.Integer __resolveJobDependencies, java.lang.String __modeType, java.lang.String __options, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer
 void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList)
          SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt
 void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt
 void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt
 void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list)
           
 void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void envPreparationComplete(java.lang.String __jobId, java.lang.String __jobUnitId, java.lang.String __jsdlFile, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __oldMetaData, java.lang.String __newMetaData, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __executable, java.lang.String __kernelCheckpointer, java.lang.String __jobUnitCpVersion, java.lang.String __pidCGroupName, CommunicationAddress __jucAddress, java.lang.String __options, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert)
          JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed
 void envPreparationComplete(java.lang.String __jobId, java.lang.String __jobUnitId, java.lang.String __jsdlFile, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __oldMetaData, java.lang.String __newMetaData, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __executable, java.lang.String __kernelCheckpointer, java.lang.String __jobUnitCpVersion, java.lang.String __pidCGroupName, CommunicationAddress __jucAddress, java.lang.String __options, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed
 void envPreparationComplete(java.lang.String __jobId, java.lang.String __jobUnitId, java.lang.String __jsdlFile, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __initialJobId, java.lang.String __oldMetaData, java.lang.String __newMetaData, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, java.lang.String __executable, java.lang.String __kernelCheckpointer, java.lang.String __jobUnitCpVersion, java.lang.String __pidCGroupName, CommunicationAddress __jucAddress, java.lang.String __options, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed
 void getDependentJobs(java.lang.String __jobId)
          TODO - refer to JobMng getDependentcies
 void getDependentJobs(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          TODO - refer to JobMng getDependentcies
 void getDependentJobs(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          TODO - refer to JobMng getDependentcies
 void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
          BEST SERVICE!
 void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          BEST SERVICE!
 void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          BEST SERVICE!
 void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list)
          UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst
 void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst
 void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst
 void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
          UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst
 void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst
 void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst
 void prepResReallocation(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.lang.String __desiredRestartDestination, java.lang.String __mode, java.security.cert.X509Certificate __userCert)
           
 void prepResReallocation(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.lang.String __desiredRestartDestination, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void prepResReallocation(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.lang.String __desiredRestartDestination, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void proceedWithCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void proceedWithCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void proceedWithCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void proceedWithRebuilding(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void proceedWithRebuilding(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void proceedWithRebuilding(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void proceedWithRestart(java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert)
           
 void proceedWithRestart(java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void proceedWithRestart(java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void proceedWithResuming(java.lang.String __jobId, java.lang.String __initialJobId)
          vvvvvvvvvvvvvvvvvvvvvvvvvvvv
 void proceedWithResuming(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          vvvvvvvvvvvvvvvvvvvvvvvvvvvv
 void proceedWithResuming(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          vvvvvvvvvvvvvvvvvvvvvvvvvvvv
 void proceedWithResumingRST(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void proceedWithResumingRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void proceedWithResumingRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void proceedWithStopping(java.lang.String __jobId, java.lang.String __initialJobId)
          Super JC job (!)
 void proceedWithStopping(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          Super JC job (!)
 void proceedWithStopping(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          Super JC job (!)
 void readRestartMetaData(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.lang.String __jobUnitAddresses, java.security.cert.X509Certificate __userCert)
           
 void readRestartMetaData(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.lang.String __jobUnitAddresses, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void readRestartMetaData(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __checkpointVersion, CommunicationAddress __superJobCpAddr, java.lang.String __jobUnitAddresses, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void rebuildJob(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void rebuildJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void rebuildJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void rebuildJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, CommunicationAddress __jucAddr, java.lang.Integer __ret)
           
 void rebuildJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, CommunicationAddress __jucAddr, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void rebuildJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, CommunicationAddress __jucAddr, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void restartJobInit(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.util.ArrayList<java.lang.String> __ip, java.util.ArrayList<java.lang.String> __port, java.lang.String __mode, java.security.cert.X509Certificate __userCert)
          RESTART ********************************* / /* put ip- and port-details into required format for further computation
 void restartJobInit(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.util.ArrayList<java.lang.String> __ip, java.util.ArrayList<java.lang.String> __port, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          RESTART ********************************* / /* put ip- and port-details into required format for further computation
 void restartJobInit(java.lang.String __jobId, java.lang.String __checkpointVersion, java.lang.Integer __restartDependentJobs, java.util.ArrayList<java.lang.String> __ip, java.util.ArrayList<java.lang.String> __port, java.lang.String __mode, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          RESTART ********************************* / /* put ip- and port-details into required format for further computation
 void resumeJob(java.lang.String __jobId)
           
 void resumeJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void resumeJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void resumeJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
          JC each JUC returns to its JC
 void resumeJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JC each JUC returns to its JC
 void resumeJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JC each JUC returns to its JC
 void resumeJobCompleteRST(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
           
 void resumeJobCompleteRST(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void resumeJobCompleteRST(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void resumeJobRST(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void resumeJobRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void resumeJobRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void returnFromCheckDestinationNodeCB(java.lang.Integer __ret)
           
 void returnFromCheckDestinationNodeCB(java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void returnFromCheckDestinationNodeCB(java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void returnFromGetProcessList(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, CommunicationAddress __jobUnitAddr, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, 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.lang.Integer __ret, java.security.cert.X509Certificate __userCert)
           
 void returnFromGetProcessList(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, CommunicationAddress __jobUnitAddr, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, 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.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void returnFromGetProcessList(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, CommunicationAddress __jobUnitAddr, java.lang.String __processList, java.lang.String __processGroupReferenceId, java.lang.String __processGroupReferenceType, 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.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void returnFromJobLocking(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __executable, java.util.ArrayList<CommunicationAddress> __jobUnitAddresses, CommunicationAddress __superJobCpAddr, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert)
          JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer
 void returnFromJobLocking(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __executable, java.util.ArrayList<CommunicationAddress> __jobUnitAddresses, CommunicationAddress __superJobCpAddr, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer
 void returnFromJobLocking(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jsdlFile, java.lang.String __executable, java.util.ArrayList<CommunicationAddress> __jobUnitAddresses, CommunicationAddress __superJobCpAddr, java.util.ArrayList<java.lang.String> __dependentJobs, java.lang.String __strategy, java.lang.String __options, java.lang.String __mode, java.lang.Integer __ret, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer
 void returnFromSelectCheckpointer(java.lang.String __initialJobId, java.lang.String __jobId, java.lang.Integer __jobUnitId, java.lang.String __jsdlFile, java.lang.String __executable, java.lang.String __kernelCheckpointer, 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)
           
 void returnFromSelectCheckpointer(java.lang.String __initialJobId, java.lang.String __jobId, java.lang.Integer __jobUnitId, java.lang.String __jsdlFile, java.lang.String __executable, java.lang.String __kernelCheckpointer, 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, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void returnFromSelectCheckpointer(java.lang.String __initialJobId, java.lang.String __jobId, java.lang.Integer __jobUnitId, java.lang.String __jsdlFile, java.lang.String __executable, java.lang.String __kernelCheckpointer, 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, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
           
 void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
           
 void stopJob(java.lang.String __jobId, java.lang.String __initialJobId)
          each JC stops a jobs job units mJUC
 void stopJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          each JC stops a jobs job units mJUC
 void stopJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          each JC stops a jobs job units mJUC
 void stopJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
          JC - each JUC returns to its JC
 void stopJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          JC - each JUC returns to its JC
 void stopJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          JC - each JUC returns to its JC
 void terminateSingleMultiJobCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId)
          SJC each JC returns to its super JC
 void terminateSingleMultiJobCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
          SJC each JC returns to its super JC
 void terminateSingleMultiJobCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
          SJC each JC returns to its super JC
 void terminateSingleMultiJobRestart(java.lang.String __jobId, java.lang.String __initialJobId)
           
 void terminateSingleMultiJobRestart(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
           
 void terminateSingleMultiJobRestart(java.lang.String __jobId, java.lang.String __initialJobId, 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

SCRJobMng

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

setRemoteaddress

public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)

envPreparationComplete

public void envPreparationComplete(java.lang.String __jobId,
                                   java.lang.String __jobUnitId,
                                   java.lang.String __jsdlFile,
                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                   java.lang.String __initialJobId,
                                   java.lang.String __oldMetaData,
                                   java.lang.String __newMetaData,
                                   java.lang.String __processList,
                                   java.lang.String __processGroupReferenceId,
                                   java.lang.String __processGroupReferenceType,
                                   java.lang.String __executable,
                                   java.lang.String __kernelCheckpointer,
                                   java.lang.String __jobUnitCpVersion,
                                   java.lang.String __pidCGroupName,
                                   CommunicationAddress __jucAddress,
                                   java.lang.String __options,
                                   java.lang.Integer __ret,
                                   java.security.cert.X509Certificate __userCert)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed


envPreparationComplete

public void envPreparationComplete(java.lang.String __jobId,
                                   java.lang.String __jobUnitId,
                                   java.lang.String __jsdlFile,
                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                   java.lang.String __initialJobId,
                                   java.lang.String __oldMetaData,
                                   java.lang.String __newMetaData,
                                   java.lang.String __processList,
                                   java.lang.String __processGroupReferenceId,
                                   java.lang.String __processGroupReferenceType,
                                   java.lang.String __executable,
                                   java.lang.String __kernelCheckpointer,
                                   java.lang.String __jobUnitCpVersion,
                                   java.lang.String __pidCGroupName,
                                   CommunicationAddress __jucAddress,
                                   java.lang.String __options,
                                   java.lang.Integer __ret,
                                   java.security.cert.X509Certificate __userCert,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed


envPreparationComplete

public void envPreparationComplete(java.lang.String __jobId,
                                   java.lang.String __jobUnitId,
                                   java.lang.String __jsdlFile,
                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                   java.lang.String __initialJobId,
                                   java.lang.String __oldMetaData,
                                   java.lang.String __newMetaData,
                                   java.lang.String __processList,
                                   java.lang.String __processGroupReferenceId,
                                   java.lang.String __processGroupReferenceType,
                                   java.lang.String __executable,
                                   java.lang.String __kernelCheckpointer,
                                   java.lang.String __jobUnitCpVersion,
                                   java.lang.String __pidCGroupName,
                                   CommunicationAddress __jucAddress,
                                   java.lang.String __options,
                                   java.lang.Integer __ret,
                                   java.security.cert.X509Certificate __userCert,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JC (each JUC returns to its JC) write meta data job unit barrier mJUC needed


stopJobComplete

public void stopJobComplete(java.lang.String __jobId,
                            java.lang.String __initialJobId,
                            java.lang.String __jobUnitId,
                            java.lang.Integer __ret)
JC - each JUC returns to its JC


stopJobComplete

public void stopJobComplete(java.lang.String __jobId,
                            java.lang.String __initialJobId,
                            java.lang.String __jobUnitId,
                            java.lang.Integer __ret,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback)
JC - each JUC returns to its JC


stopJobComplete

public void stopJobComplete(java.lang.String __jobId,
                            java.lang.String __initialJobId,
                            java.lang.String __jobUnitId,
                            java.lang.Integer __ret,
                            eu.xtreemos.system.communication.bus.CallbackMessage callback,
                            eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JC - each JUC returns to its JC


checkpointJobComplete

public void checkpointJobComplete(java.lang.String __jobId,
                                  java.lang.String __initialJobId,
                                  java.lang.String __jobUnitId,
                                  java.lang.Integer __ret)
JC - each JUC returns to its JC


checkpointJobComplete

public void checkpointJobComplete(java.lang.String __jobId,
                                  java.lang.String __initialJobId,
                                  java.lang.String __jobUnitId,
                                  java.lang.Integer __ret,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback)
JC - each JUC returns to its JC


checkpointJobComplete

public void checkpointJobComplete(java.lang.String __jobId,
                                  java.lang.String __initialJobId,
                                  java.lang.String __jobUnitId,
                                  java.lang.Integer __ret,
                                  eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                  eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JC - each JUC returns to its JC


resumeJobComplete

public void resumeJobComplete(java.lang.String __jobId,
                              java.lang.String __initialJobId,
                              java.lang.String __jobUnitId,
                              java.lang.Integer __ret)
JC each JUC returns to its JC


resumeJobComplete

public void resumeJobComplete(java.lang.String __jobId,
                              java.lang.String __initialJobId,
                              java.lang.String __jobUnitId,
                              java.lang.Integer __ret,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
JC each JUC returns to its JC


resumeJobComplete

public void resumeJobComplete(java.lang.String __jobId,
                              java.lang.String __initialJobId,
                              java.lang.String __jobUnitId,
                              java.lang.Integer __ret,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JC each JUC returns to its JC


rebuildJobComplete

public void rebuildJobComplete(java.lang.String __jobId,
                               java.lang.String __initialJobId,
                               java.lang.String __jobUnitId,
                               CommunicationAddress __jucAddr,
                               java.lang.Integer __ret)

rebuildJobComplete

public void rebuildJobComplete(java.lang.String __jobId,
                               java.lang.String __initialJobId,
                               java.lang.String __jobUnitId,
                               CommunicationAddress __jucAddr,
                               java.lang.Integer __ret,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)

rebuildJobComplete

public void rebuildJobComplete(java.lang.String __jobId,
                               java.lang.String __initialJobId,
                               java.lang.String __jobUnitId,
                               CommunicationAddress __jucAddr,
                               java.lang.Integer __ret,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

resumeJobCompleteRST

public void resumeJobCompleteRST(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jobUnitId,
                                 java.lang.Integer __ret)

resumeJobCompleteRST

public void resumeJobCompleteRST(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jobUnitId,
                                 java.lang.Integer __ret,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)

resumeJobCompleteRST

public void resumeJobCompleteRST(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jobUnitId,
                                 java.lang.Integer __ret,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

checkpointJobInit

public void checkpointJobInit(java.lang.String __jobId,
                              java.lang.Integer __resolveJobDependencies,
                              java.lang.String __modeType,
                              java.lang.String __options,
                              java.security.cert.X509Certificate __userCert)
INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer

Parameters:
jobId -
signed - XOSCertificate

checkpointJobInit

public void checkpointJobInit(java.lang.String __jobId,
                              java.lang.Integer __resolveJobDependencies,
                              java.lang.String __modeType,
                              java.lang.String __options,
                              java.security.cert.X509Certificate __userCert,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer

Parameters:
jobId -
signed - XOSCertificate

checkpointJobInit

public void checkpointJobInit(java.lang.String __jobId,
                              java.lang.Integer __resolveJobDependencies,
                              java.lang.String __modeType,
                              java.lang.String __options,
                              java.security.cert.X509Certificate __userCert,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
INITIAL CP CMD TYPED IN ON ANY MACHINE entry point for single/multi-job checkpointing - redirection to super job checkpointer grid node in the next step first job detects job dependencies: 1. from jdsl listed dependencies [NOW], 2. queries dependency monitor service (based on connector) [LATER] ATTENTION job manager/checkpointer of job (referenced by passed jobId) becomes SUPER JOB CHECKPOINTER => coordinate all other involved job checkpointer

Parameters:
jobId -
signed - XOSCertificate

getDependentJobs

public void getDependentJobs(java.lang.String __jobId)
TODO - refer to JobMng getDependentcies


getDependentJobs

public void getDependentJobs(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback)
TODO - refer to JobMng getDependentcies


getDependentJobs

public void getDependentJobs(java.lang.String __jobId,
                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
TODO - refer to JobMng getDependentcies


checkpointFromSuperJobCheckpointerNode

public void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId,
                                                   java.util.ArrayList<java.lang.String> __jobId_jobMng_List,
                                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                                   java.lang.String __strategy,
                                                   java.lang.String __options,
                                                   java.lang.String __mode,
                                                   java.security.cert.X509Certificate __userCert)
SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs

Parameters:
jobId -
userCert -
jobID_jobMng_List - - know communication address of each involved job (checkpointer)

checkpointFromSuperJobCheckpointerNode

public void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId,
                                                   java.util.ArrayList<java.lang.String> __jobId_jobMng_List,
                                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                                   java.lang.String __strategy,
                                                   java.lang.String __options,
                                                   java.lang.String __mode,
                                                   java.security.cert.X509Certificate __userCert,
                                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs

Parameters:
jobId -
userCert -
jobID_jobMng_List - - know communication address of each involved job (checkpointer)

checkpointFromSuperJobCheckpointerNode

public void checkpointFromSuperJobCheckpointerNode(java.lang.String __initialJobId,
                                                   java.util.ArrayList<java.lang.String> __jobId_jobMng_List,
                                                   java.util.ArrayList<java.lang.String> __dependentJobs,
                                                   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)
SUPER JOB CHECKPOINTER (SJC) ( redirection to SJC grid node done) coordinate all dependent job checkpointer from super job checkpointer local/super job checkpointer-owned hashtable saves meta-data of involved jobs - keep track with checkpoint workflow for all involved jobs

Parameters:
jobId -
userCert -
jobID_jobMng_List - - know communication address of each involved job (checkpointer)

returnFromJobLocking

public void returnFromJobLocking(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jsdlFile,
                                 java.lang.String __executable,
                                 java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
                                 CommunicationAddress __superJobCpAddr,
                                 java.util.ArrayList<java.lang.String> __dependentJobs,
                                 java.lang.String __strategy,
                                 java.lang.String __options,
                                 java.lang.String __mode,
                                 java.lang.Integer __ret,
                                 java.security.cert.X509Certificate __userCert)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer


returnFromJobLocking

public void returnFromJobLocking(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jsdlFile,
                                 java.lang.String __executable,
                                 java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
                                 CommunicationAddress __superJobCpAddr,
                                 java.util.ArrayList<java.lang.String> __dependentJobs,
                                 java.lang.String __strategy,
                                 java.lang.String __options,
                                 java.lang.String __mode,
                                 java.lang.Integer __ret,
                                 java.security.cert.X509Certificate __userCert,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer


returnFromJobLocking

public void returnFromJobLocking(java.lang.String __jobId,
                                 java.lang.String __initialJobId,
                                 java.lang.String __jsdlFile,
                                 java.lang.String __executable,
                                 java.util.ArrayList<CommunicationAddress> __jobUnitAddresses,
                                 CommunicationAddress __superJobCpAddr,
                                 java.util.ArrayList<java.lang.String> __dependentJobs,
                                 java.lang.String __strategy,
                                 java.lang.String __options,
                                 java.lang.String __mode,
                                 java.lang.Integer __ret,
                                 java.security.cert.X509Certificate __userCert,
                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
JOB CHECKPOINTER (JC) know job units mJUC entry (job-unit address and state ) select appropriate kernel checkpointer


returnFromSelectCheckpointer

public void returnFromSelectCheckpointer(java.lang.String __initialJobId,
                                         java.lang.String __jobId,
                                         java.lang.Integer __jobUnitId,
                                         java.lang.String __jsdlFile,
                                         java.lang.String __executable,
                                         java.lang.String __kernelCheckpointer,
                                         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)

returnFromSelectCheckpointer

public void returnFromSelectCheckpointer(java.lang.String __initialJobId,
                                         java.lang.String __jobId,
                                         java.lang.Integer __jobUnitId,
                                         java.lang.String __jsdlFile,
                                         java.lang.String __executable,
                                         java.lang.String __kernelCheckpointer,
                                         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,
                                         eu.xtreemos.system.communication.bus.CallbackMessage callback)

returnFromSelectCheckpointer

public void returnFromSelectCheckpointer(java.lang.String __initialJobId,
                                         java.lang.String __jobId,
                                         java.lang.Integer __jobUnitId,
                                         java.lang.String __jsdlFile,
                                         java.lang.String __executable,
                                         java.lang.String __kernelCheckpointer,
                                         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,
                                         eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                         eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

returnFromGetProcessList

public void returnFromGetProcessList(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,
                                     CommunicationAddress __jobUnitAddr,
                                     java.lang.String __processList,
                                     java.lang.String __processGroupReferenceId,
                                     java.lang.String __processGroupReferenceType,
                                     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.lang.Integer __ret,
                                     java.security.cert.X509Certificate __userCert)

returnFromGetProcessList

public void returnFromGetProcessList(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,
                                     CommunicationAddress __jobUnitAddr,
                                     java.lang.String __processList,
                                     java.lang.String __processGroupReferenceId,
                                     java.lang.String __processGroupReferenceType,
                                     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.lang.Integer __ret,
                                     java.security.cert.X509Certificate __userCert,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback)

returnFromGetProcessList

public void returnFromGetProcessList(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,
                                     CommunicationAddress __jobUnitAddr,
                                     java.lang.String __processList,
                                     java.lang.String __processGroupReferenceId,
                                     java.lang.String __processGroupReferenceType,
                                     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.lang.Integer __ret,
                                     java.security.cert.X509Certificate __userCert,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

proceedWithStopping

public void proceedWithStopping(java.lang.String __jobId,
                                java.lang.String __initialJobId)
Super JC job (!) barrier mJC


proceedWithStopping

public void proceedWithStopping(java.lang.String __jobId,
                                java.lang.String __initialJobId,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)
Super JC job (!) barrier mJC


proceedWithStopping

public void proceedWithStopping(java.lang.String __jobId,
                                java.lang.String __initialJobId,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
Super JC job (!) barrier mJC


createJobMetaData

public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList)
SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt

Parameters:
jobList -

createJobMetaData

public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)
SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt

Parameters:
jobList -

createJobMetaData

public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
SJC - per job following meta data are saved: its job units and their latest version, dependent jobs and their latest version save under /xtreemfs/jobId/jobId.txt

Parameters:
jobList -

stopJob

public void stopJob(java.lang.String __jobId,
                    java.lang.String __initialJobId)
each JC stops a jobs job units mJUC


stopJob

public void stopJob(java.lang.String __jobId,
                    java.lang.String __initialJobId,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback)
each JC stops a jobs job units mJUC


stopJob

public void stopJob(java.lang.String __jobId,
                    java.lang.String __initialJobId,
                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
each JC stops a jobs job units mJUC


proceedWithCheckpointing

public void proceedWithCheckpointing(java.lang.String __jobId,
                                     java.lang.String __initialJobId)

proceedWithCheckpointing

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

proceedWithCheckpointing

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

checkpointJob

public void checkpointJob(java.lang.String __jobId,
                          java.lang.String __initialJobId)

checkpointJob

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

checkpointJob

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

proceedWithResuming

public void proceedWithResuming(java.lang.String __jobId,
                                java.lang.String __initialJobId)
vvvvvvvvvvvvvvvvvvvvvvvvvvvv


proceedWithResuming

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


proceedWithResuming

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


resumeJob

public void resumeJob(java.lang.String __jobId)

resumeJob

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

resumeJob

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

terminateSingleMultiJobCheckpointing

public void terminateSingleMultiJobCheckpointing(java.lang.String __jobId,
                                                 java.lang.String __initialJobId)
SJC each JC returns to its super JC


terminateSingleMultiJobCheckpointing

public void terminateSingleMultiJobCheckpointing(java.lang.String __jobId,
                                                 java.lang.String __initialJobId,
                                                 eu.xtreemos.system.communication.bus.CallbackMessage callback)
SJC each JC returns to its super JC


terminateSingleMultiJobCheckpointing

public void terminateSingleMultiJobCheckpointing(java.lang.String __jobId,
                                                 java.lang.String __initialJobId,
                                                 eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                                 eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
SJC each JC returns to its super JC


restartJobInit

public void restartJobInit(java.lang.String __jobId,
                           java.lang.String __checkpointVersion,
                           java.lang.Integer __restartDependentJobs,
                           java.util.ArrayList<java.lang.String> __ip,
                           java.util.ArrayList<java.lang.String> __port,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert)
RESTART ********************************* / /* put ip- and port-details into required format for further computation


restartJobInit

public void restartJobInit(java.lang.String __jobId,
                           java.lang.String __checkpointVersion,
                           java.lang.Integer __restartDependentJobs,
                           java.util.ArrayList<java.lang.String> __ip,
                           java.util.ArrayList<java.lang.String> __port,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback)
RESTART ********************************* / /* put ip- and port-details into required format for further computation


restartJobInit

public void restartJobInit(java.lang.String __jobId,
                           java.lang.String __checkpointVersion,
                           java.lang.Integer __restartDependentJobs,
                           java.util.ArrayList<java.lang.String> __ip,
                           java.util.ArrayList<java.lang.String> __port,
                           java.lang.String __mode,
                           java.security.cert.X509Certificate __userCert,
                           eu.xtreemos.system.communication.bus.CallbackMessage callback,
                           eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
RESTART ********************************* / /* put ip- and port-details into required format for further computation


prepResReallocation

public void prepResReallocation(java.lang.String __jobId,
                                java.lang.String __checkpointVersion,
                                java.lang.Integer __restartDependentJobs,
                                java.lang.String __desiredRestartDestination,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __userCert)

prepResReallocation

public void prepResReallocation(java.lang.String __jobId,
                                java.lang.String __checkpointVersion,
                                java.lang.Integer __restartDependentJobs,
                                java.lang.String __desiredRestartDestination,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __userCert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)

prepResReallocation

public void prepResReallocation(java.lang.String __jobId,
                                java.lang.String __checkpointVersion,
                                java.lang.Integer __restartDependentJobs,
                                java.lang.String __desiredRestartDestination,
                                java.lang.String __mode,
                                java.security.cert.X509Certificate __userCert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

matchUnitsBiggerNodesCB

public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
BEST SERVICE! - used! FEATURE: find matching nodes by regarding kernel checkpointer and potential resource(PID,IPC) conflicts, DRAWBACK: unknown number of repeatedly called 'getResources' (worst case: it will never stop => upper limit)


matchUnitsBiggerNodesCB

public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                    eu.xtreemos.system.communication.bus.CallbackMessage callback)
BEST SERVICE! - used! FEATURE: find matching nodes by regarding kernel checkpointer and potential resource(PID,IPC) conflicts, DRAWBACK: unknown number of repeatedly called 'getResources' (worst case: it will never stop => upper limit)


matchUnitsBiggerNodesCB

public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                    eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                    eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
BEST SERVICE! - used! FEATURE: find matching nodes by regarding kernel checkpointer and potential resource(PID,IPC) conflicts, DRAWBACK: unknown number of repeatedly called 'getResources' (worst case: it will never stop => upper limit)


matchUnitsEqualNodesCB

public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst


matchUnitsEqualNodesCB

public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst


matchUnitsEqualNodesCB

public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                   eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                   eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
UNREALISITC - not used FEATURE: no additional getResource call => increased scalability with nodes and job units DRAWBACK: no check against suitable kernel checkpointer, no checak against resource conflicts (worst case: abort restart restart due to incompatible nodes) no support for heterogeneous cp/rst


proceedWithRestart

public void proceedWithRestart(java.lang.String __initialJobId,
                               java.security.cert.X509Certificate __userCert)

proceedWithRestart

public void proceedWithRestart(java.lang.String __initialJobId,
                               java.security.cert.X509Certificate __userCert,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback)

proceedWithRestart

public void proceedWithRestart(java.lang.String __initialJobId,
                               java.security.cert.X509Certificate __userCert,
                               eu.xtreemos.system.communication.bus.CallbackMessage callback,
                               eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

matchUnitsSmallerNodesCB

public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst


matchUnitsSmallerNodesCB

public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst


matchUnitsSmallerNodesCB

public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list,
                                     eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                     eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
UNREALISTIC - not used FEATURE no additional getResources call, if conflict (no suitable kernel checkpoitner, resource conflict) treat it using remaining nodes of initial getResources call (reasonable scalability) DRAWBACK: potential resource and kernel checkpointer conflicts, if remaining nodes do not match (worst case: abort restart due to incompatible nodes) no support for heterogenous cp/rst


returnFromCheckDestinationNodeCB

public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret)

returnFromCheckDestinationNodeCB

public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret,
                                             eu.xtreemos.system.communication.bus.CallbackMessage callback)

returnFromCheckDestinationNodeCB

public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret,
                                             eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                             eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

dynamicMatchingCB

public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list)

dynamicMatchingCB

public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback)

dynamicMatchingCB

public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list,
                              eu.xtreemos.system.communication.bus.CallbackMessage callback,
                              eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

readRestartMetaData

public void readRestartMetaData(java.lang.String __jobId,
                                java.lang.String __initialJobId,
                                java.lang.String __checkpointVersion,
                                CommunicationAddress __superJobCpAddr,
                                java.lang.String __jobUnitAddresses,
                                java.security.cert.X509Certificate __userCert)

readRestartMetaData

public void readRestartMetaData(java.lang.String __jobId,
                                java.lang.String __initialJobId,
                                java.lang.String __checkpointVersion,
                                CommunicationAddress __superJobCpAddr,
                                java.lang.String __jobUnitAddresses,
                                java.security.cert.X509Certificate __userCert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback)

readRestartMetaData

public void readRestartMetaData(java.lang.String __jobId,
                                java.lang.String __initialJobId,
                                java.lang.String __checkpointVersion,
                                CommunicationAddress __superJobCpAddr,
                                java.lang.String __jobUnitAddresses,
                                java.security.cert.X509Certificate __userCert,
                                eu.xtreemos.system.communication.bus.CallbackMessage callback,
                                eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)

proceedWithRebuilding

public void proceedWithRebuilding(java.lang.String __jobId,
                                  java.lang.String __initialJobId)

proceedWithRebuilding

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

proceedWithRebuilding

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

rebuildJob

public void rebuildJob(java.lang.String __jobId,
                       java.lang.String __initialJobId)

rebuildJob

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

rebuildJob

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

proceedWithResumingRST

public void proceedWithResumingRST(java.lang.String __jobId,
                                   java.lang.String __initialJobId)

proceedWithResumingRST

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

proceedWithResumingRST

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

resumeJobRST

public void resumeJobRST(java.lang.String __jobId,
                         java.lang.String __initialJobId)

resumeJobRST

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

resumeJobRST

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

terminateSingleMultiJobRestart

public void terminateSingleMultiJobRestart(java.lang.String __jobId,
                                           java.lang.String __initialJobId)

terminateSingleMultiJobRestart

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

terminateSingleMultiJobRestart

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