org.processmining.scientificexperiments

Class SSHExperiments

java.lang.Object

org.processmining.scientificexperiments.SSHExperiments

All Implemented Interfaces:

ExperimentInterface

public class SSHExperiments
extends java.lang.Object
implements ExperimentInterface

Field Summary

Fields

Modifier and Type	Field and Description
static java.text.SimpleDateFormat	consoleTimeFormatter

Constructor Summary

Constructors

Constructor and Description
SSHExperiments()

Method Summary

Methods

Modifier and Type	Method and Description
protected static void	copyLogFiles(java.lang.String user, java.lang.String password, java.lang.String[] servers, java.lang.String serverLogDir, java.lang.String localLogDir)
static int	executeCommand(com.sshtools.j2ssh.session.SessionChannelClient session, java.lang.String command, java.io.PrintStream out)
protected static void	executeTopOnAllNodes(java.lang.String user, java.lang.String password, java.lang.String[] servers)
protected static void	killWork(java.lang.String user, java.lang.String password, java.lang.String server)
protected static void	killWork(java.lang.String user, java.lang.String password, java.lang.String[] servers, boolean exitAfterwards)
void	runExperiment(ServerParam serverParam, ExperimentParam experimentParam)
static com.sshtools.j2ssh.SshClient	setupSSHClient(java.lang.String user, java.lang.String password, java.lang.String gridHost, java.lang.Object lock)
static void	startWorkCommands(ServerParam serverParam, ExperimentParam experimentParam, java.lang.String date, boolean copyLogsToLocal, boolean killExistingWork) Starts the provided work (in the list of different parameter strings, one string per experiment) on the set list of nodes

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

consoleTimeFormatter

public static final java.text.SimpleDateFormat consoleTimeFormatter

Constructor Detail

SSHExperiments

public SSHExperiments()

Method Detail

runExperiment

public void runExperiment(ServerParam serverParam,
                 ExperimentParam experimentParam)

Specified by:

runExperiment in interface ExperimentInterface

startWorkCommands

public static void startWorkCommands(ServerParam serverParam,
                     ExperimentParam experimentParam,
                     java.lang.String date,
                     boolean copyLogsToLocal,
                     boolean killExistingWork)

Starts the provided work (in the list of different parameter strings, one string per experiment) on the set list of nodes

Parameters:

user -

password -

date -

parameters -

copyLogsToLocal - if true copies the remote log files to the local log dir

setupSSHClient

public static com.sshtools.j2ssh.SshClient setupSSHClient(java.lang.String user,
                                          java.lang.String password,
                                          java.lang.String gridHost,
                                          java.lang.Object lock)
                                                   throws java.io.IOException

Throws:

java.io.IOException

executeCommand

public static final int executeCommand(com.sshtools.j2ssh.session.SessionChannelClient session,
                 java.lang.String command,
                 java.io.PrintStream out)
                                throws java.io.IOException,
                                       com.sshtools.j2ssh.util.InvalidStateException,
                                       java.lang.InterruptedException

Throws:

java.io.IOException

com.sshtools.j2ssh.util.InvalidStateException

java.lang.InterruptedException

killWork

protected static void killWork(java.lang.String user,
            java.lang.String password,
            java.lang.String[] servers,
            boolean exitAfterwards)

killWork

protected static void killWork(java.lang.String user,
            java.lang.String password,
            java.lang.String server)

executeTopOnAllNodes

protected static void executeTopOnAllNodes(java.lang.String user,
                        java.lang.String password,
                        java.lang.String[] servers)

copyLogFiles

protected static void copyLogFiles(java.lang.String user,
                java.lang.String password,
                java.lang.String[] servers,
                java.lang.String serverLogDir,
                java.lang.String localLogDir)