Showing
2 changed files
with
5 additions
and
5 deletions
| ... | @@ -49,7 +49,6 @@ public final class SimpleNettyClient { | ... | @@ -49,7 +49,6 @@ public final class SimpleNettyClient { |
| 49 | } | 49 | } |
| 50 | 50 | ||
| 51 | Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender"); | 51 | Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender"); |
| 52 | - Timer sendAndReceiveTimer = metrics.createTimer(component, feature, "SendAndReceive"); | ||
| 53 | 52 | ||
| 54 | for (int i = 0; i < iterations; i++) { | 53 | for (int i = 0; i < iterations; i++) { |
| 55 | Timer.Context context = sendAsyncTimer.time(); | 54 | Timer.Context context = sendAsyncTimer.time(); |
| ... | @@ -57,6 +56,7 @@ public final class SimpleNettyClient { | ... | @@ -57,6 +56,7 @@ public final class SimpleNettyClient { |
| 57 | context.stop(); | 56 | context.stop(); |
| 58 | } | 57 | } |
| 59 | 58 | ||
| 59 | + Timer sendAndReceiveTimer = metrics.createTimer(component, feature, "SendAndReceive"); | ||
| 60 | for (int i = 0; i < iterations; i++) { | 60 | for (int i = 0; i < iterations; i++) { |
| 61 | Timer.Context context = sendAndReceiveTimer.time(); | 61 | Timer.Context context = sendAndReceiveTimer.time(); |
| 62 | Response response = messaging | 62 | Response response = messaging | ... | ... |
| ... | @@ -14,9 +14,9 @@ import org.onlab.onos.cli.AbstractShellCommand; | ... | @@ -14,9 +14,9 @@ import org.onlab.onos.cli.AbstractShellCommand; |
| 14 | public class SimpleNettyClientCommand extends AbstractShellCommand { | 14 | public class SimpleNettyClientCommand extends AbstractShellCommand { |
| 15 | 15 | ||
| 16 | //FIXME: replace these arguments with proper ones needed for the test. | 16 | //FIXME: replace these arguments with proper ones needed for the test. |
| 17 | - @Argument(index = 0, name = "serverIp", description = "Server IP address", | 17 | + @Argument(index = 0, name = "hostname", description = "Server Hostname", |
| 18 | required = false, multiValued = false) | 18 | required = false, multiValued = false) |
| 19 | - String serverIp = "127.0.0.1"; | 19 | + String host = "localhost"; |
| 20 | 20 | ||
| 21 | @Argument(index = 3, name = "port", description = "Port", | 21 | @Argument(index = 3, name = "port", description = "Port", |
| 22 | required = false, multiValued = false) | 22 | required = false, multiValued = false) |
| ... | @@ -28,12 +28,12 @@ public class SimpleNettyClientCommand extends AbstractShellCommand { | ... | @@ -28,12 +28,12 @@ public class SimpleNettyClientCommand extends AbstractShellCommand { |
| 28 | 28 | ||
| 29 | @Argument(index = 2, name = "messageCount", description = "Message count", | 29 | @Argument(index = 2, name = "messageCount", description = "Message count", |
| 30 | required = false, multiValued = false) | 30 | required = false, multiValued = false) |
| 31 | - String messageCount = "100000"; | 31 | + String messageCount = "5000000"; |
| 32 | 32 | ||
| 33 | @Override | 33 | @Override |
| 34 | protected void execute() { | 34 | protected void execute() { |
| 35 | try { | 35 | try { |
| 36 | - startStandalone(new String[]{serverIp, port, warmup, messageCount}); | 36 | + startStandalone(new String[]{host, port, warmup, messageCount}); |
| 37 | } catch (Exception e) { | 37 | } catch (Exception e) { |
| 38 | error("Unable to start client %s", e); | 38 | error("Unable to start client %s", e); |
| 39 | } | 39 | } | ... | ... |
-
Please register or login to post a comment