org.gridbus.broker.services.compute
Class PosixJobWrapper

java.lang.Object
  extended by org.gridbus.broker.common.JobWrapper
      extended by org.gridbus.broker.services.compute.PosixJobWrapper
Direct Known Subclasses:
SimJobWrapper

public abstract class PosixJobWrapper
extends JobWrapper

This is a model class for submitting jobs to various middleware.

Author:
Srikumar Venugopal (srikumar@cs.mu.oz.au)

Field Summary
protected static java.lang.String errorActionScript
           
protected static java.lang.String errorCheckScript
           
protected static java.lang.String errorCodeScript
           
protected static java.lang.String errorScript
           
protected static java.lang.String execErrMsgScript
           
protected static java.lang.String execMsgScript
           
protected static java.lang.String linkScript
           
protected static java.lang.String mvScript
           
protected static java.lang.String permScript
           
protected static java.lang.String successScript
           
 
Fields inherited from class org.gridbus.broker.common.JobWrapper
AGENT_JAR, COMMIT_TIMEOUT, EOL, PROXY_FILE, QUOTE, SUBMISSION_TIMEOUT
 
Constructor Summary
PosixJobWrapper()
           
 
Method Summary
protected  void cleanUp(Job job)
           
protected  java.lang.String generateGlobusCopyScript(java.lang.String src, java.lang.String dest)
           
protected  java.lang.String generateSGetScript(java.lang.String src, java.lang.String dest)
           
protected  java.lang.String generateSPutScript(java.lang.String src, java.lang.String dest)
           
protected  java.lang.String getAgentInitScript(Job job)
           
protected  java.lang.String getCleanUpScript(java.lang.String remoteWorkingDir)
           
protected  java.lang.String getEnvScript(Job job)
           
protected  java.lang.String getInitScript(Job job)
           
protected  java.lang.String getLocalShellFilename(Job job)
           
protected  java.lang.String getShellFilename(Job job)
           
protected  java.lang.String wrapSshToHeadNode(java.lang.String remoteWorkingDir, java.lang.String source)
          This is used to wrap up your command so that it will ssh to the head node of a cluster and execute your command from there.
 
Methods inherited from class org.gridbus.broker.common.JobWrapper
commit, execute, execute, executeJob, executeJob, getFileOnStagingServer, getUniqueId, jobNeedsRemoteData, stageIn, stageOut, stageOut, terminate
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

permScript

protected static final java.lang.String permScript
See Also:
Constant Field Values

execMsgScript

protected static final java.lang.String execMsgScript
See Also:
Constant Field Values

execErrMsgScript

protected static final java.lang.String execErrMsgScript
See Also:
Constant Field Values

mvScript

protected static final java.lang.String mvScript
See Also:
Constant Field Values

errorCodeScript

protected static final java.lang.String errorCodeScript
See Also:
Constant Field Values

errorCheckScript

protected static final java.lang.String errorCheckScript
See Also:
Constant Field Values

errorActionScript

protected static final java.lang.String errorActionScript
See Also:
Constant Field Values

errorScript

protected static final java.lang.String errorScript
See Also:
Constant Field Values

successScript

protected static final java.lang.String successScript
See Also:
Constant Field Values

linkScript

protected static final java.lang.String linkScript
See Also:
Constant Field Values
Constructor Detail

PosixJobWrapper

public PosixJobWrapper()
Method Detail

getInitScript

protected java.lang.String getInitScript(Job job)

getEnvScript

protected java.lang.String getEnvScript(Job job)

getAgentInitScript

protected java.lang.String getAgentInitScript(Job job)

getCleanUpScript

protected java.lang.String getCleanUpScript(java.lang.String remoteWorkingDir)

generateSGetScript

protected java.lang.String generateSGetScript(java.lang.String src,
                                              java.lang.String dest)
                                       throws java.lang.Exception
Throws:
java.lang.Exception

generateSPutScript

protected java.lang.String generateSPutScript(java.lang.String src,
                                              java.lang.String dest)
                                       throws java.lang.Exception
Throws:
java.lang.Exception

generateGlobusCopyScript

protected java.lang.String generateGlobusCopyScript(java.lang.String src,
                                                    java.lang.String dest)
                                             throws java.lang.Exception
Throws:
java.lang.Exception

wrapSshToHeadNode

protected java.lang.String wrapSshToHeadNode(java.lang.String remoteWorkingDir,
                                             java.lang.String source)
This is used to wrap up your command so that it will ssh to the head node of a cluster and execute your command from there.

Parameters:
source -
Returns:
ssh tunnel script

getShellFilename

protected java.lang.String getShellFilename(Job job)

getLocalShellFilename

protected java.lang.String getLocalShellFilename(Job job)

cleanUp

protected void cleanUp(Job job)
                throws java.lang.Exception
Specified by:
cleanUp in class JobWrapper
Throws:
java.lang.Exception

Copyright © The University of Melbourne. 2006