org.objectweb.proactive.core.process.globus
Class GlobusProcess

java.lang.Object
  extended byorg.objectweb.proactive.core.process.AbstractUniversalProcess
      extended byorg.objectweb.proactive.core.process.AbstractExternalProcess
          extended byorg.objectweb.proactive.core.process.AbstractExternalProcessDecorator
              extended byorg.objectweb.proactive.core.process.globus.GlobusProcess
All Implemented Interfaces:
ExternalProcess, ExternalProcessDecorator, java.io.Serializable, UniversalProcess

public class GlobusProcess
extends AbstractExternalProcessDecorator

Globus Process implementation. This implementation works only for ProActive deployment, and not to submit single commands

Since:
ProActive 3.0
Version:
2.0, 2005/09/20
Author:
ProActive Team
See Also:
Serialized Form

Nested Class Summary
 
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 count
           
protected  JVMProcessImpl jvmProcess
           
protected  java.lang.String maxTime
           
protected  java.lang.String queue
           
protected  java.lang.String stderr
           
protected  java.lang.String stdout
           
 
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, FILE_TRANSFER_DEFAULT_PROTOCOL, fileTransferLogger, inputMessageLogger, IS_WINDOWS_SYSTEM, NO_COMPOSITION, 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, COPY_FILE_AND_APPEND_COMMAND, GIVE_COMMAND_AS_PARAMETER, SEND_TO_OUTPUT_STREAM_COMPOSITION
 
Fields inherited from interface org.objectweb.proactive.core.process.UniversalProcess
logger, UNKNOWN_NODE_NUMBER
 
Constructor Summary
GlobusProcess()
          Creates a new instance of GlobusProcess
GlobusProcess(JVMProcess process)
          Creates a new instance of GlobusProcess.
 
Method Summary
protected  java.lang.String buildEnvironmentCommand()
           
 java.lang.String getCount()
          Returns the count.
 UniversalProcess getFinalProcess()
          Returns the last process of the chain
 java.lang.String getMaxTime()
           
 int getNodeNumber()
          Returns the number of nodes targeted
 java.lang.String getProcessId()
          Returns the id of the process
 java.lang.String getQueue()
           
 java.lang.String getStderr()
           
 java.lang.String getStdout()
           
protected  java.lang.String internalBuildCommand()
           
protected  void internalStartProcess(java.lang.String rslCommand)
           
static void main(java.lang.String[] args)
           
 void setCount(java.lang.String count)
          Sets the count.
 void setMaxTime(java.lang.String maxTime)
           
 void setQueue(java.lang.String queue)
           
 void setStderr(java.lang.String stderr)
           
 void setStdout(java.lang.String stdout)
           
 
Methods inherited from class org.objectweb.proactive.core.process.AbstractExternalProcessDecorator
buildCommand, getCompositionType, getTargetProcess, handleCopyFile, handleOutput, setCompositionType, setTargetProcess, toString
 
Methods inherited from class org.objectweb.proactive.core.process.AbstractExternalProcess
buildUnixEnvironmentCommand, buildWindowsEnvironmentCommand, closeStream, getErrorMessageLogger, getFileTransferDefaultCopyProtocol, getFileTransferWorkShopDeploy, getFileTransferWorkShopRetrieve, getInputMessageLogger, getOutputMessageSink, handleError, handleInput, handleProcess, internalFileTransferDefaultProtocol, internalStartFileTransfer, internalStopProcess, internalWaitFor, setErrorMessageLogger, setInputMessageLogger, setOutputMessageSink
 
Methods inherited from class org.objectweb.proactive.core.process.AbstractUniversalProcess
checkStarted, getCommand, getCommandPath, getEnvironment, getHostname, getUsername, isFinished, isHierarchical, isStarted, pushProcessAttributes, setCommandPath, setEnvironment, setHostname, setUsername, startFileTransfer, 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, getFileTransferWorkShopDeploy, getFileTransferWorkShopRetrieve, getInputMessageLogger, getOutputMessageSink, setErrorMessageLogger, setInputMessageLogger, setOutputMessageSink
 
Methods inherited from interface org.objectweb.proactive.core.process.UniversalProcess
getCommand, getCommandPath, getEnvironment, getHostname, getUsername, isFinished, isHierarchical, isStarted, setCommandPath, setEnvironment, setHostname, setUsername, startFileTransfer, startProcess, stopProcess, waitFor
 

Field Detail

jvmProcess

protected JVMProcessImpl jvmProcess

count

protected java.lang.String count

stderr

protected java.lang.String stderr

stdout

protected java.lang.String stdout

queue

protected java.lang.String queue

maxTime

protected java.lang.String maxTime
Constructor Detail

GlobusProcess

public GlobusProcess()
Creates a new instance of GlobusProcess


GlobusProcess

public GlobusProcess(JVMProcess process)
Creates a new instance of GlobusProcess. The process given as parameter represents the target process

Method Detail

internalBuildCommand

protected java.lang.String internalBuildCommand()
Specified by:
internalBuildCommand in class AbstractExternalProcessDecorator

main

public static void main(java.lang.String[] args)

internalStartProcess

protected void internalStartProcess(java.lang.String rslCommand)
                             throws java.io.IOException
Overrides:
internalStartProcess in class AbstractExternalProcessDecorator
Throws:
java.io.IOException

buildEnvironmentCommand

protected java.lang.String buildEnvironmentCommand()
Overrides:
buildEnvironmentCommand in class AbstractExternalProcess

getCount

public java.lang.String getCount()
Returns the count.

Returns:
String

setCount

public void setCount(java.lang.String count)
Sets the count.

Parameters:
count - The count to set

getProcessId

public java.lang.String getProcessId()
Description copied from interface: UniversalProcess
Returns the id of the process

Returns:
the id of the process. This id is just the first letters of the process class, to be able to identify the sequence of processes used
See Also:
UniversalProcess.getProcessId()

getNodeNumber

public int getNodeNumber()
Description copied from interface: UniversalProcess
Returns the number of nodes targeted

Returns:
the number of nodes targeted. Represents the number of nodes expected to use when starting this process. If this number cannot be known, waiting for all available nodes for example, UNKNOWN_NODE_NUMBER is returned.
See Also:
UniversalProcess.getNodeNumber()

getFinalProcess

public UniversalProcess getFinalProcess()
Description copied from interface: UniversalProcess
Returns the last process of the chain

Returns:
the last process of the chain
See Also:
UniversalProcess.getFinalProcess()

getStderr

public java.lang.String getStderr()
Returns:
Returns the stderr.

setStderr

public void setStderr(java.lang.String stderr)
Parameters:
stderr - The stderr to set.

getStdout

public java.lang.String getStdout()
Returns:
Returns the stdout.

setStdout

public void setStdout(java.lang.String stdout)
Parameters:
stdout - The stdout to set.

getQueue

public java.lang.String getQueue()
Returns:
Returns the queue.

setQueue

public void setQueue(java.lang.String queue)
Parameters:
queue - The queue to set.

getMaxTime

public java.lang.String getMaxTime()

setMaxTime

public void setMaxTime(java.lang.String maxTime)


Copyright 2001-2005 INRIA All Rights Reserved.