RemoteSubProcessExecutor

Class Overview

Runs a simulation on a remote machine via ssh. Note this implementation may not work in all situations. We assume the following:

• ssh and rsync commands available on the path of the local machine (and usable from a Process)
• Passwordless login from the above commands to the remote machine.
• Write access to the specified working directory in order to transfer classpath dependencies.
• java command available on the path of the remote machine (and usable from ssh).
• The remote machine has access to the database via the settings specified in db.properties

Summary

[Expand] Inherited Fields
From class uk.ac.imperial.presage2.core.cli.run.SubProcessExecutor protected int MAX_PROCESSES protected final String[] customArgs protected final int gcThreads protected Logger logger protected Timer processMonitor protected List<Process> running protected final String xms protected final String xmx

[Expand] Inherited Methods
From class uk.ac.imperial.presage2.core.cli.run.SubProcessExecutor abstract ProcessBuilder createProcess(long simId) Create a ProcessBuilder which will spawn a Process to run the given simulation.@return boolean enableLogs() Returns whether this executor will log output to file. void enableLogs(boolean saveLogs) Enable or disable saving of execution logs to file. String getClasspath() List<String> getJvmArgs() Get the list of arguments which should be passed to the java executable for the vm. String getLogsDirectory() Get directory to which execution log will be written. int maxConcurrent() Get the maximum number of simultaneously executing simulations this executor can handle. synchronized void run(long simId) Submits a simulation to be run on this executor. int running() Get the number of simulations this executor is currently running. void setLogsDirectory(String logsDir) Set directory to which execution logs will be written.
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait() final void wait(long arg0) final void wait(long arg0, int arg1)
From interface uk.ac.imperial.presage2.core.cli.run.SimulationExecutor abstract boolean enableLogs() Returns whether this executor will log output to file. abstract void enableLogs(boolean saveLogs) Enable or disable saving of execution logs to file. abstract String getLogsDirectory() Get directory to which execution log will be written. abstract int maxConcurrent() Get the maximum number of simultaneously executing simulations this executor can handle. abstract void run(long simId) Submits a simulation to be run on this executor. abstract int running() Get the number of simulations this executor is currently running. abstract void setLogsDirectory(String logsDir) Set directory to which execution logs will be written.