|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.objectweb.proactive.core.process.AbstractUniversalProcess
org.objectweb.proactive.core.process.AbstractExternalProcess
org.objectweb.proactive.core.process.AbstractExternalProcessDecorator
org.objectweb.proactive.core.process.gridengine.GridEngineSubProcess
The GridEngineSubProcess class is able to start any class, of the ProActive library, on a cluster managed by Sun Grid Engine protocol. An istance of this class can be coupled for instance with RLoginProcess or SSHProcess classes in order to log into the cluster's front end with rlogin or ssh and then to run a job with LSFBSubProcess.
For instance:
.............. GridEngineSubProcess sge = new GridEngineSubProcess(new SimpleExternalProcess("ls -lsa")); SSHProcess ssh = new RLoginProcess(sge, false); ssh.setHostname("cluster_front_end_name"); ssh.startProcess(); ...............Anyway it is strongly advised to use XML Deployment files to run such processes
Nested Class Summary | |
class |
GridEngineSubProcess.ParserMessageLogger
Implementation of a MessageLogger that look for the jobID of the launched job |
Nested classes inherited from class org.objectweb.proactive.core.process.AbstractExternalProcessDecorator |
AbstractExternalProcessDecorator.CompositeMessageLogger, AbstractExternalProcessDecorator.CompositeMessageSink |
Nested classes inherited from class org.objectweb.proactive.core.process.AbstractExternalProcess |
AbstractExternalProcess.NullMessageLogger, AbstractExternalProcess.ProcessInputHandler, AbstractExternalProcess.ProcessOutputHandler, AbstractExternalProcess.SimpleMessageSink, AbstractExternalProcess.StandardOutputMessageLogger |
Field Summary | |
protected java.lang.String |
bookingDuration
|
protected static java.lang.String |
DEFAULT_BOOKING_DURATION
|
protected static java.lang.String |
DEFAULT_HOSTS_NUMBER
|
protected static java.lang.String |
DEFAULT_PARALLEL_ENVIRONMENT
|
static java.lang.String |
DEFAULT_QSUBPATH
|
protected java.lang.String |
hostList
|
protected java.lang.String |
hostNumber
|
protected java.lang.String |
interactive
|
protected int |
jobID
|
protected java.lang.String |
outputFile
|
protected java.lang.String |
parallelEnvironment
|
protected java.lang.String |
queueName
|
protected java.lang.String |
scriptLocation
|
Fields inherited from class org.objectweb.proactive.core.process.AbstractExternalProcessDecorator |
targetProcess |
Fields inherited from class org.objectweb.proactive.core.process.AbstractExternalProcess |
clogger, closeStream, errorMessageLogger, externalProcess, inputMessageLogger, IS_WINDOWS_SYSTEM, outputMessageSink |
Fields inherited from class org.objectweb.proactive.core.process.AbstractUniversalProcess |
certificateLocation, command, command_path, DEFAULT_HOSTNAME, DEFAULT_USERNAME, environment, hostname, isFinished, isStarted, LOCALHOST, privateKeyLocation, securityFile, username |
Fields inherited from interface org.objectweb.proactive.core.process.ExternalProcessDecorator |
APPEND_TO_COMMAND_COMPOSITION, GIVE_COMMAND_AS_PARAMETER, SEND_TO_OUTPUT_STREAM_COMPOSITION |
Fields inherited from interface org.objectweb.proactive.core.process.UniversalProcess |
logger |
Constructor Summary | |
GridEngineSubProcess()
|
|
GridEngineSubProcess(ExternalProcess targetProcess)
|
Method Summary | |
protected java.lang.String |
buildCommand()
|
protected java.lang.StringBuffer |
buildResourceString()
|
UniversalProcess |
getFinalProcess()
Returns the last process of the chain |
java.lang.String |
getHostList()
Returns the hostList value of this process. |
java.lang.String |
getHostsNumber()
Returns the number of nodes requested when running the job |
int |
getNodeNumber()
Returns the number of nodes targeted |
java.lang.String |
getParallelEnvironment()
Returns the parallel environmemnt for this GridEngineSubProcess |
java.lang.String |
getProcessId()
Returns the id of the process |
protected java.lang.String |
internalBuildCommand()
|
protected java.lang.String |
parseHostname(java.lang.String message)
|
void |
setBookingDuration(java.lang.String d)
Set the booking duration of the cluster's nodes. |
void |
setErrorMessageLogger(MessageLogger errorMessageLogger)
sets the MessageLogger handling the error stream of the process |
void |
setHostList(java.lang.String hostList)
Sets the value of the hostList parameter with the given value Not yet included in the sge command |
void |
setHostsNumber(java.lang.String hostNumber)
Sets the number of nodes requested when running the job |
void |
setInteractive(java.lang.String interactive)
Allows to launch this GridEngineSubProcess with -I (interactive option) Not yet included in the sge command |
void |
setOutputFile(java.lang.String string)
Set the output file to be passed to sge Not yet included in the sge command |
void |
setOutputMessageSink(MessageSink outputMessageSink)
sets the MessageSink handling the output stream of the process |
void |
setParallelEnvironment(java.lang.String p)
Sets the parallel environmemnt for this GridEngineSubProcess |
void |
setQueueName(java.lang.String queueName)
Sets the value of the queue where the job will be launched. |
void |
setScriptLocation(java.lang.String location)
Sets the location of the script on the remote host |
Methods inherited from class org.objectweb.proactive.core.process.AbstractExternalProcessDecorator |
getCompositionType, getTargetProcess, handleOutput, internalStartProcess, setCompositionType, setTargetProcess, toString |
Methods inherited from class org.objectweb.proactive.core.process.AbstractExternalProcess |
buildEnvironmentCommand, buildUnixEnvironmentCommand, buildWindowsEnvironmentCommand, closeStream, getErrorMessageLogger, getInputMessageLogger, getOutputMessageSink, handleError, handleInput, handleProcess, internalStopProcess, internalWaitFor, setInputMessageLogger |
Methods inherited from class org.objectweb.proactive.core.process.AbstractUniversalProcess |
checkStarted, getCommand, getCommandPath, getEnvironment, getHostname, getUsername, isFinished, isStarted, setCommandPath, setEnvironment, setHostname, setUsername, startProcess, stopProcess, toString, waitFor |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.objectweb.proactive.core.process.ExternalProcess |
closeStream, getErrorMessageLogger, getInputMessageLogger, getOutputMessageSink, setInputMessageLogger |
Methods inherited from interface org.objectweb.proactive.core.process.UniversalProcess |
getCommand, getCommandPath, getEnvironment, getHostname, getUsername, isFinished, isStarted, setCommandPath, setEnvironment, setHostname, setUsername, startProcess, stopProcess, waitFor |
Field Detail |
public static final java.lang.String DEFAULT_QSUBPATH
protected static final java.lang.String DEFAULT_HOSTS_NUMBER
protected static final java.lang.String DEFAULT_PARALLEL_ENVIRONMENT
protected static final java.lang.String DEFAULT_BOOKING_DURATION
protected java.lang.String hostNumber
protected java.lang.String parallelEnvironment
protected java.lang.String bookingDuration
protected java.lang.String scriptLocation
protected java.lang.String interactive
protected java.lang.String outputFile
protected int jobID
protected java.lang.String queueName
protected java.lang.String hostList
Constructor Detail |
public GridEngineSubProcess()
public GridEngineSubProcess(ExternalProcess targetProcess)
Method Detail |
public void setErrorMessageLogger(MessageLogger errorMessageLogger)
ExternalProcess
setErrorMessageLogger
in interface ExternalProcess
setErrorMessageLogger
in class AbstractExternalProcess
public void setOutputMessageSink(MessageSink outputMessageSink)
ExternalProcess
setOutputMessageSink
in interface ExternalProcess
setOutputMessageSink
in class AbstractExternalProcess
public void setBookingDuration(java.lang.String d)
d
- durationpublic java.lang.String getHostsNumber()
public void setHostsNumber(java.lang.String hostNumber)
hostNumber
- the number of nodes requested when running the jobpublic java.lang.String getProcessId()
UniversalProcess
UniversalProcess.getProcessId()
public int getNodeNumber()
UniversalProcess
UniversalProcess.getNodeNumber()
public UniversalProcess getFinalProcess()
UniversalProcess
UniversalProcess.getFinalProcess()
public void setScriptLocation(java.lang.String location)
location
- public void setParallelEnvironment(java.lang.String p)
p
- the parallel environmemnt to usepublic java.lang.String getParallelEnvironment()
public void setHostList(java.lang.String hostList)
hostList
- public java.lang.String getHostList()
public void setInteractive(java.lang.String interactive)
interactive
- true for -I option false otherwisepublic void setOutputFile(java.lang.String string)
string
- public void setQueueName(java.lang.String queueName)
queueName
- protected java.lang.String parseHostname(java.lang.String message)
protected java.lang.String internalBuildCommand()
internalBuildCommand
in class AbstractExternalProcessDecorator
protected java.lang.String buildCommand()
buildCommand
in class AbstractExternalProcessDecorator
protected java.lang.StringBuffer buildResourceString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |