diff --git a/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/AbstractLoadGeneratorStarter.java b/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/AbstractLoadGeneratorStarter.java index eae035b9..6fc74729 100644 --- a/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/AbstractLoadGeneratorStarter.java +++ b/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/AbstractLoadGeneratorStarter.java @@ -33,7 +33,6 @@ import org.mortbay.jetty.load.generator.HTTPClientTransportBuilder; import org.mortbay.jetty.load.generator.LoadGenerator; import org.mortbay.jetty.load.generator.Resource; -import org.mortbay.jetty.load.generator.listeners.responsetime.TimePerPathListener; import java.io.InputStream; import java.io.Reader; @@ -41,10 +40,7 @@ import java.nio.file.Path; import java.nio.file.Paths; import java.util.concurrent.CompletableFuture; -import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; -import java.util.concurrent.TimeUnit; -import java.util.concurrent.TimeoutException; /** * @@ -85,11 +81,6 @@ public void run() .warmupIterationsPerThread( starterArgs.getWarmupNumber() ) // .scheme( starterArgs.getScheme() ); // - if (starterArgs.getThreads() > 0) - { - loadGeneratorBuilder.threads( starterArgs.getThreads() ); - } - if ( starterArgs.getMaxRequestsQueued() > 0 ) { loadGeneratorBuilder.maxRequestsQueued( starterArgs.getMaxRequestsQueued() ); @@ -100,7 +91,10 @@ public void run() loadGeneratorBuilder.executor( getExecutorService() ); } - boolean runFor = false; + if ( starterArgs.getThreads() > 0 ) + { + loadGeneratorBuilder.threads( starterArgs.getThreads() ); + } if ( starterArgs.getRunningTime() > 0 ) { diff --git a/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/LoadGeneratorStarterArgs.java b/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/LoadGeneratorStarterArgs.java index eb2e1f0e..17484293 100644 --- a/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/LoadGeneratorStarterArgs.java +++ b/jetty-load-generator-starter/src/main/java/org/mortbay/jetty/load/generator/starter/LoadGeneratorStarterArgs.java @@ -49,9 +49,6 @@ public class LoadGeneratorStarterArgs @Parameter( names = { "--users", "-u" }, description = "Simulated users number" ) private int users = 1; - @Parameter( names = { "--threads" }, description = "Threads number" ) - private int threads = 0; - @Parameter( names = { "--transaction-rate", "-tr" }, description = "Transaction rate / second" ) private int transactionRate = 1; @@ -61,6 +58,9 @@ public class LoadGeneratorStarterArgs @Parameter( names = { "--selectors", "-s" }, description = "HttpClientTransport selectors" ) private int selectors = 1; + @Parameter( names = { "--threads" }, description = "LoadGenerator threads" ) + private int threads = 0; + @Parameter( names = { "--running-time", "-rt" }, description = "Running Time" ) private long runningTime = 1; @@ -376,8 +376,8 @@ public String toString() { return "LoadGeneratorStarterArgs{" + "profileXmlPath='" + profileXmlPath + '\'' + ", profileJsonPath='" + profileJsonPath + '\'' + ", profileGroovyPath='" + profileGroovyPath + '\'' + ", host='" + host + '\'' - + ", port=" + port + ", users=" + users + ", threads=" + threads + ", transactionRate=" + transactionRate - + ", transport='" + transport + '\'' + ", selectors=" + selectors + ", runningTime=" + runningTime + + ", port=" + port + ", users=" + users + ", transactionRate=" + transactionRate + ", transport='" + + transport + '\'' + ", selectors=" + selectors + ", threads=" + threads + ", runningTime=" + runningTime + ", runningTimeUnit='" + runningTimeUnit + '\'' + ", runIteration=" + runIteration + ", reportHost='" + reportHost + '\'' + ", scheme='" + scheme + '\'' + ", reportPort=" + reportPort + ", notInterrupt=" + notInterrupt + ", statsFile='" + statsFile + '\'' + ", params=" + params + ", help=" + help