commit 1a444e9c9c302c145bd11058d785ac7b7396056c
author pankaj <pankaj@onlab.us> Tue Oct 07 17:38:44 2014 -0700
committer pankaj <pankaj@onlab.us> Tue Oct 07 17:38:44 2014 -0700
tree 70da2a8cd11f30701552084e5e58ce3384204599
parent 366ce8b168b4b8eb7706d6a4a3b55751cc91c2e0

Run the test longer for realistic measurements

apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyClient.java

diff --git a/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyClient.java b/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyClient.java
index caf3e08..348b75a 100644
--- a/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyClient.java
+++ b/apps/foo/src/main/java/org/onlab/onos/foo/SimpleNettyClient.java
@@ -38,7 +38,7 @@
         MetricsComponent component = metrics.registerComponent("NettyMessaging");
         Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender");
 
-        final int warmup = 100;
+        final int warmup = 1000000;
         for (int i = 0; i < warmup; i++) {
             messaging.sendAsync(new Endpoint("localhost", 8081), "simple", "Hello World".getBytes());
             Response response = messaging
@@ -46,13 +46,12 @@
                             "Hello World".getBytes());
         }
 
-        final int iterations = 10000;
+        final int iterations = 1000000000;
         for (int i = 0; i < iterations; i++) {
             Timer.Context context = sendAsyncTimer.time();
             messaging.sendAsync(new Endpoint("localhost", 8081), "simple", "Hello World".getBytes());
             context.stop();
         }
-        metrics.registerMetric(component, feature, "AsyncTimer", sendAsyncTimer);
 
         Timer sendAndReceiveTimer = metrics.createTimer(component, feature, "SendAndReceive");
 
@@ -64,7 +63,6 @@
             // System.out.println("Got back:" + new String(response.get(2, TimeUnit.SECONDS)));
             context.stop();
         }
-        metrics.registerMetric(component, feature, "PingPong", sendAndReceiveTimer);
     }
 
     public static class TestNettyMessagingService extends NettyMessagingService {