Added small code snippet to run load test via XBaya.
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/366ada03 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/366ada03 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/366ada03 Branch: refs/heads/master Commit: 366ada03275079931d7c898cbbfe66c3409729d1 Parents: ad44956 Author: shamrath <[email protected]> Authored: Mon Mar 2 16:05:26 2015 -0500 Committer: shamrath <[email protected]> Committed: Mon Mar 2 16:05:26 2015 -0500 ---------------------------------------------------------------------- .../experiment/WorkflowInterpreterLaunchWindow.java | 16 ++++++++++++++++ 1 file changed, 16 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/366ada03/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/ui/experiment/WorkflowInterpreterLaunchWindow.java ---------------------------------------------------------------------- diff --git a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/ui/experiment/WorkflowInterpreterLaunchWindow.java b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/ui/experiment/WorkflowInterpreterLaunchWindow.java index c542aa7..c0c6b45 100644 --- a/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/ui/experiment/WorkflowInterpreterLaunchWindow.java +++ b/modules/xbaya-gui/src/main/java/org/apache/airavata/xbaya/ui/experiment/WorkflowInterpreterLaunchWindow.java @@ -353,6 +353,22 @@ public class WorkflowInterpreterLaunchWindow { }else { throw new RuntimeException("Resource scheduling failed, target computer resource host name is not defined"); } +/* +// code snippet for load test. + for (int i = 0; i < 20; i++) { + experiment.setName(instanceName + "_" + i); + + experiment.setExperimentID(airavataClient.createExperiment(experiment)); + + try { + this.engine.getMonitor().subscribe(experiment.getExperimentID()); + this.engine.getMonitor().fireStartMonitoring(workflow.getName()); + } catch (MonitorException e) { + logger.error("Error while subscribing with experiment Id : " + experiment.getExperimentID(), e); + } + airavataClient.launchExperiment(experiment.getExperimentID(), "testToken"); + + }*/ experiment.setExperimentID(airavataClient.createExperiment(experiment));
