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