Changed NatsBench csv mode to remove confusing message count

Fixes #246
nats-io · Jun 17, 2019 · 74bf92e · 74bf92e
1 parent fd18050
commit 74bf92e
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/examples/java/io/nats/examples/benchmark/Benchmark.java b/src/examples/java/io/nats/examples/benchmark/Benchmark.java
@@ -132,7 +132,7 @@ public final String report() {
     public final String csv() {
         StringBuilder sb = new StringBuilder();
         String header =
-                "#RunID, ClientID, MsgCount, MsgBytes, MsgsPerSec, BytesPerSec, DurationSecs";
+                "#RunID, ClientID, Test Msgs, MsgsPerSec, BytesPerSec, Total Msgs, Total Bytes, DurationSecs";
 
         sb.append(String.format("%s stats: %s\n", name, this));
         sb.append(header); sb.append("\n");
@@ -145,8 +145,10 @@ String csvLines(SampleGroup grp, String prefix) {
         StringBuilder sb = new StringBuilder();
         int j = 0;
         for (Sample stat : grp.getSamples()) {
-            String line = String.format("%s,%s%d,%d,%d,%d,%f,%f", runId, prefix, j++, stat.msgCnt,
-                    stat.msgBytes, stat.rate(), stat.throughput(),
+            String line = String.format("%s,%s%d,%d,%d,%.2f,%d,%d,%.4f", runId,
+                    prefix, j++,
+                    stat.getJobMsgCnt(), stat.rate(), stat.throughput(),
+                    stat.msgCnt, stat.msgBytes, 
                     (double) stat.duration() / 1000000000.0);
                     sb.append(line); sb.append("\n");
         }