|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objecteu.xtreemos.xosd.services.SCRJobMng
public class SCRJobMng
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 |
---|
public static java.lang.String servicename
private eu.xtreemos.system.eventmachine.queue.Context context
private CommunicationAddress _accesspoint_remoteaddress
Constructor Detail |
---|
public SCRJobMng(eu.xtreemos.system.eventmachine.queue.Context context)
Method Detail |
---|
public void setRemoteaddress(CommunicationAddress _accesspoint_remoteaddress)
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)
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)
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)
public void stopJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
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)
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)
public void checkpointJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
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)
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)
public void resumeJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
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)
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)
public void rebuildJobComplete(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, CommunicationAddress __jucAddr, java.lang.Integer __ret)
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)
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)
public void resumeJobCompleteRST(java.lang.String __jobId, java.lang.String __initialJobId, java.lang.String __jobUnitId, java.lang.Integer __ret)
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)
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)
public void checkpointJobInit(java.lang.String __jobId, java.lang.Integer __resolveJobDependencies, java.lang.String __modeType, java.lang.String __options, java.security.cert.X509Certificate __userCert)
jobId
- signed
- XOSCertificatepublic 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)
jobId
- signed
- XOSCertificatepublic 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)
jobId
- signed
- XOSCertificatepublic void getDependentJobs(java.lang.String __jobId)
public void getDependentJobs(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void getDependentJobs(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
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)
jobId
- userCert
- jobID_jobMng_List
- - know communication address of each involved job (checkpointer)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)
jobId
- userCert
- jobID_jobMng_List
- - know communication address of each involved job (checkpointer)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)
jobId
- userCert
- jobID_jobMng_List
- - know communication address of each involved job (checkpointer)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)
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)
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)
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)
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)
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)
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)
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)
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)
public void proceedWithStopping(java.lang.String __jobId, java.lang.String __initialJobId)
public void proceedWithStopping(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList)
jobList
- public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList, eu.xtreemos.system.communication.bus.CallbackMessage callback)
jobList
- public void createJobMetaData(java.util.ArrayList<java.lang.String> __jobList, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
jobList
- public void stopJob(java.lang.String __jobId, java.lang.String __initialJobId)
public void stopJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void proceedWithCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId)
public void proceedWithCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void checkpointJob(java.lang.String __jobId, java.lang.String __initialJobId)
public void checkpointJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void proceedWithResuming(java.lang.String __jobId, java.lang.String __initialJobId)
public void proceedWithResuming(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void resumeJob(java.lang.String __jobId)
public void resumeJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void resumeJob(java.lang.String __jobId, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void terminateSingleMultiJobCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId)
public void terminateSingleMultiJobCheckpointing(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
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)
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)
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)
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)
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)
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)
public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void matchUnitsBiggerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list)
public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void matchUnitsEqualNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void proceedWithRestart(java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert)
public void proceedWithRestart(java.lang.String __initialJobId, java.security.cert.X509Certificate __userCert, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list)
public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void matchUnitsSmallerNodesCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret)
public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void returnFromCheckDestinationNodeCB(java.lang.Integer __ret, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list)
public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback)
public void dynamicMatchingCB(java.util.ArrayList<CommunicationAddress> __list, eu.xtreemos.system.communication.bus.CallbackMessage callback, eu.xtreemos.system.communication.bus.CallbackMessage exceptionCallback)
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)
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)
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)
public void proceedWithRebuilding(java.lang.String __jobId, java.lang.String __initialJobId)
public void proceedWithRebuilding(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void rebuildJob(java.lang.String __jobId, java.lang.String __initialJobId)
public void rebuildJob(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void proceedWithResumingRST(java.lang.String __jobId, java.lang.String __initialJobId)
public void proceedWithResumingRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void resumeJobRST(java.lang.String __jobId, java.lang.String __initialJobId)
public void resumeJobRST(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
public void terminateSingleMultiJobRestart(java.lang.String __jobId, java.lang.String __initialJobId)
public void terminateSingleMultiJobRestart(java.lang.String __jobId, java.lang.String __initialJobId, eu.xtreemos.system.communication.bus.CallbackMessage callback)
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)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |