diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-29 08:52:37 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2019-04-29 08:52:37 +0200 |
commit | 1ee1a52e9b27c19d7eec8f4ac229e76e82c62fb9 (patch) | |
tree | a56e7bcdb93c9f42025c497b3430a9bea717c537 | |
parent | 1f2395a64721868956a11184e73d962aaa394f86 (diff) |
Test for failures before printing anything and guard against division by zero.
-rw-r--r-- | vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java index 70bb2c78ce7..32e883f171a 100644 --- a/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java +++ b/vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java @@ -386,10 +386,10 @@ public class SimpleFeeder implements ReplyHandler { while (failure.get() == null && numReplies.get() < numMessagesSent) { Thread.sleep(100); } - printReport(out); if (failure.get() != null) { throw failure.get(); } + printReport(out); return this; } @@ -448,9 +448,9 @@ public class SimpleFeeder implements ReplyHandler { out.println("# Time used, num ok, num error, min latency, max latency, average latency"); } - private void printReport(PrintStream out) { + private synchronized void printReport(PrintStream out) { out.format("%10d, %12d, %11d, %11d, %11d\n", System.currentTimeMillis() - startTime, - numReplies.get(), minLatency, maxLatency, sumLatency / numReplies.get()); + numReplies.get(), minLatency, maxLatency, sumLatency / Long.max(1, numReplies.get())); } private static String formatErrors(Reply reply) { |