blob: b59ff38e9d43e4267e4b0c2ef61aaeb69cad1fdb [file] [log] [blame]
pankajf49b45e2014-10-07 14:24:22 -07001package org.onlab.onos.foo;
2
3import static org.onlab.onos.foo.SimpleNettyClient.startStandalone;
pankaj9fc87592014-10-10 15:40:43 -07004import static org.onlab.onos.foo.SimpleNettyClient.stop;
pankajf49b45e2014-10-07 14:24:22 -07005
6import org.apache.karaf.shell.commands.Argument;
7import org.apache.karaf.shell.commands.Command;
8import org.onlab.onos.cli.AbstractShellCommand;
9
10/**
11 * Test Netty client performance.
12 */
13@Command(scope = "onos", name = "simple-netty-client",
pankaj5364ca92014-10-09 14:11:58 -070014 description = "Starts simple Netty client")
pankajf49b45e2014-10-07 14:24:22 -070015public class SimpleNettyClientCommand extends AbstractShellCommand {
16
pankajea0acef2014-10-07 15:01:47 -070017 //FIXME: replace these arguments with proper ones needed for the test.
pankajf0f80b22014-10-07 18:37:32 -070018 @Argument(index = 0, name = "hostname", description = "Server Hostname",
pankajf49b45e2014-10-07 14:24:22 -070019 required = false, multiValued = false)
pankaj28c35642014-10-08 16:42:36 -070020 String hostname = "localhost";
pankajf49b45e2014-10-07 14:24:22 -070021
pankaj31b8eab2014-10-08 18:14:08 -070022 @Argument(index = 1, name = "port", description = "Port",
pankajf49b45e2014-10-07 14:24:22 -070023 required = false, multiValued = false)
pankaj13373b52014-10-07 18:26:07 -070024 String port = "8081";
25
pankaj31b8eab2014-10-08 18:14:08 -070026 @Argument(index = 2, name = "warmupCount", description = "Warm-up count",
pankaj13373b52014-10-07 18:26:07 -070027 required = false, multiValued = false)
pankaj6245a7a2014-10-10 17:50:55 -070028 String warmupCount = "1000";
pankajf49b45e2014-10-07 14:24:22 -070029
pankaj31b8eab2014-10-08 18:14:08 -070030 @Argument(index = 3, name = "messageCount", description = "Message count",
pankajf49b45e2014-10-07 14:24:22 -070031 required = false, multiValued = false)
pankaj9fc87592014-10-10 15:40:43 -070032 String messageCount = "1000000";
pankajf49b45e2014-10-07 14:24:22 -070033
34 @Override
35 protected void execute() {
36 try {
pankaj28c35642014-10-08 16:42:36 -070037 startStandalone(new String[]{hostname, port, warmupCount, messageCount});
pankajf49b45e2014-10-07 14:24:22 -070038 } catch (Exception e) {
39 error("Unable to start client %s", e);
40 }
pankaj9fc87592014-10-10 15:40:43 -070041 stop();
pankajf49b45e2014-10-07 14:24:22 -070042 }
pankajf49b45e2014-10-07 14:24:22 -070043}