org.gridbus.broker.farming.common.dispatchers
Class SSHDispatcher

java.lang.Object
  extended by org.gridbus.broker.farming.common.dispatchers.SSHDispatcher
All Implemented Interfaces:
java.io.Serializable, Dispatcher

public class SSHDispatcher
extends java.lang.Object
implements Dispatcher

Author:
mtc
See Also:
Serialized Form

Constructor Summary
SSHDispatcher(java.lang.String host, java.lang.String stagingDir, java.lang.String workingDir, SimpleCredential cred)
           
 
Method Summary
 boolean detectFile(java.lang.String filename, int timeoutMillis)
          Detects the existence of the remote file.
 java.io.InputStream executeAndGetResult(java.lang.String cmd)
           
 void executeCmd(java.lang.String cmd)
           
 java.lang.String getDispatcherType()
           
 java.lang.String getInputPath()
           
 java.lang.String getStagingDir()
           
 void shutdown()
           
 void stageIn(java.lang.String src, java.lang.String dest)
           
 void stageInData(java.lang.String src, java.lang.String dest)
           
 void stageOut(java.lang.String src, java.lang.String dest)
           
 void stageOutData(java.lang.String src, java.lang.String dest)
           
 java.lang.Object submit(java.lang.String scriptFileName)
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SSHDispatcher

public SSHDispatcher(java.lang.String host,
                     java.lang.String stagingDir,
                     java.lang.String workingDir,
                     SimpleCredential cred)
Parameters:
host -
stagingDir -
cred -
Method Detail

submit

public java.lang.Object submit(java.lang.String scriptFileName)
                        throws java.lang.Exception
Parameters:
scriptFileName -
Returns:
Throws:
java.lang.Exception

stageIn

public void stageIn(java.lang.String src,
                    java.lang.String dest)
             throws java.lang.Exception
Specified by:
stageIn in interface Dispatcher
Parameters:
src - -- local file path
dest - -- remote file path
Throws:
java.lang.Exception
See Also:
Dispatcher.stageIn(java.lang.String, java.lang.String)

stageInData

public void stageInData(java.lang.String src,
                        java.lang.String dest)
                 throws java.lang.Exception
Specified by:
stageInData in interface Dispatcher
Throws:
java.lang.Exception
See Also:
Dispatcher.stageInData(java.lang.String, java.lang.String)

stageOut

public void stageOut(java.lang.String src,
                     java.lang.String dest)
              throws java.lang.Exception
Specified by:
stageOut in interface Dispatcher
Parameters:
src - -- remote file path
dest - -- local file path
Throws:
java.lang.Exception
See Also:
Dispatcher.stageOut(java.lang.String, java.lang.String)

stageOutData

public void stageOutData(java.lang.String src,
                         java.lang.String dest)
                  throws java.lang.Exception
Specified by:
stageOutData in interface Dispatcher
Throws:
java.lang.Exception
See Also:
Dispatcher.stageOutData(java.lang.String, java.lang.String)

executeAndGetResult

public java.io.InputStream executeAndGetResult(java.lang.String cmd)
                                        throws java.lang.Exception
Specified by:
executeAndGetResult in interface Dispatcher
Returns:
Throws:
java.lang.Exception
See Also:
Dispatcher.executeCmd(java.lang.String)

executeCmd

public void executeCmd(java.lang.String cmd)
                throws java.lang.Exception
Specified by:
executeCmd in interface Dispatcher
Throws:
java.lang.Exception

getInputPath

public java.lang.String getInputPath()
Specified by:
getInputPath in interface Dispatcher
Returns:
See Also:
Dispatcher.getInputPath()

getStagingDir

public java.lang.String getStagingDir()
Specified by:
getStagingDir in interface Dispatcher
Returns:
See Also:
Dispatcher.getStagingDir()

detectFile

public boolean detectFile(java.lang.String filename,
                          int timeoutMillis)
Detects the existence of the remote file. Returns true, if the file exists, false otherwise.

Specified by:
detectFile in interface Dispatcher
Parameters:
filename -
timeoutMillis -
Returns:

getDispatcherType

public java.lang.String getDispatcherType()
Specified by:
getDispatcherType in interface Dispatcher
Returns:
See Also:
Dispatcher.getDispatcherType()

shutdown

public void shutdown()
Specified by:
shutdown in interface Dispatcher
See Also:
Dispatcher.shutdown()