reduce logging

@@ -14,6 +14,6 @@ public class NettyLoggingHandler implements MessageHandler {
 
 
     @Override
     @Override
     public void handle(Message message) {
     public void handle(Message message) {
-        log.info("Received message. Payload has {} bytes", message.payload().length);
+        //log.info("Received message. Payload has {} bytes", message.payload().length);
     }
     }
 }
 }

@@ -10,11 +10,16 @@ import org.onlab.metrics.MetricsManager;
 import org.onlab.netty.Endpoint;
 import org.onlab.netty.Endpoint;
 import org.onlab.netty.NettyMessagingService;
 import org.onlab.netty.NettyMessagingService;
 import org.onlab.netty.Response;
 import org.onlab.netty.Response;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 
 import com.codahale.metrics.Timer;
 import com.codahale.metrics.Timer;
 
 
 // FIXME: Should be move out to test or app
 // FIXME: Should be move out to test or app
 public final class SimpleNettyClient {
 public final class SimpleNettyClient {
+
+private static Logger log = LoggerFactory.getLogger(SimpleNettyClient.class);
+
         private SimpleNettyClient() {
         private SimpleNettyClient() {
     }
     }
 
 
@@ -40,6 +45,7 @@ public final class SimpleNettyClient {
         metrics.activate();
         metrics.activate();
         MetricsFeature feature = new MetricsFeature("latency");
         MetricsFeature feature = new MetricsFeature("latency");
         MetricsComponent component = metrics.registerComponent("NettyMessaging");
         MetricsComponent component = metrics.registerComponent("NettyMessaging");
+        log.info("warmup....");
 
 
         for (int i = 0; i < warmup; i++) {
         for (int i = 0; i < warmup; i++) {
             messaging.sendAsync(new Endpoint(host, port), "simple", "Hello World".getBytes());
             messaging.sendAsync(new Endpoint(host, port), "simple", "Hello World".getBytes());
@@ -48,6 +54,7 @@ public final class SimpleNettyClient {
                             "Hello World".getBytes());
                             "Hello World".getBytes());
         }
         }
 
 
+        log.info("measuring async sender");
         Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender");
         Timer sendAsyncTimer = metrics.createTimer(component, feature, "AsyncSender");
 
 
         for (int i = 0; i < iterations; i++) {
         for (int i = 0; i < iterations; i++) {

@@ -28,7 +28,7 @@ public class SimpleNettyClientCommand extends AbstractShellCommand {
 
 
     @Argument(index = 2, name = "messageCount", description = "Message count",
     @Argument(index = 2, name = "messageCount", description = "Message count",
             required = false, multiValued = false)
             required = false, multiValued = false)
-    String messageCount = "5000000";
+    String messageCount = "100000";
 
 
     @Override
     @Override
     protected void execute() {
     protected void execute() {

@@ -11,6 +11,7 @@ import org.apache.felix.scr.annotations.Deactivate;
 import org.slf4j.Logger;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.slf4j.LoggerFactory;
 
 
+import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Counter;
 import com.codahale.metrics.Counter;
 import com.codahale.metrics.Gauge;
 import com.codahale.metrics.Gauge;
 import com.codahale.metrics.Histogram;
 import com.codahale.metrics.Histogram;
@@ -18,7 +19,6 @@ import com.codahale.metrics.Meter;
 import com.codahale.metrics.Metric;
 import com.codahale.metrics.Metric;
 import com.codahale.metrics.MetricFilter;
 import com.codahale.metrics.MetricFilter;
 import com.codahale.metrics.MetricRegistry;
 import com.codahale.metrics.MetricRegistry;
-import com.codahale.metrics.Slf4jReporter;
 import com.codahale.metrics.Timer;
 import com.codahale.metrics.Timer;
 
 
 /**
 /**
@@ -70,16 +70,20 @@ public final class MetricsManager implements MetricsService {
     /**
     /**
      * Default Reporter for this metrics manager.
      * Default Reporter for this metrics manager.
      */
      */
-    private final Slf4jReporter reporter;
+    //private final Slf4jReporter reporter;
+    private final ConsoleReporter reporter;
 
 
     public MetricsManager() {
     public MetricsManager() {
         this.metricsRegistry = new MetricRegistry();
         this.metricsRegistry = new MetricRegistry();
-        this.reporter = Slf4jReporter.forRegistry(this.metricsRegistry)
-                .outputTo(log)
+//        this.reporter = Slf4jReporter.forRegistry(this.metricsRegistry)
+//                .outputTo(log)
+//                .convertRatesTo(TimeUnit.SECONDS)
+//                .convertDurationsTo(TimeUnit.NANOSECONDS)
+//                .build();
+        this.reporter = ConsoleReporter.forRegistry(this.metricsRegistry)
                 .convertRatesTo(TimeUnit.SECONDS)
                 .convertRatesTo(TimeUnit.SECONDS)
                 .convertDurationsTo(TimeUnit.NANOSECONDS)
                 .convertDurationsTo(TimeUnit.NANOSECONDS)
                 .build();
                 .build();
-        reporter.start(1, TimeUnit.MINUTES);
     }
     }
 
 
     @Activate
     @Activate