aboutsummaryrefslogtreecommitdiffstats
path: root/vespa_feed_perf
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2019-04-29 08:52:37 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2019-04-29 08:52:37 +0200
commit1ee1a52e9b27c19d7eec8f4ac229e76e82c62fb9 (patch)
treea56e7bcdb93c9f42025c497b3430a9bea717c537 /vespa_feed_perf
parent1f2395a64721868956a11184e73d962aaa394f86 (diff)
Test for failures before printing anything and guard against division by zero.
Diffstat (limited to 'vespa_feed_perf')
-rw-r--r--vespa_feed_perf/src/main/java/com/yahoo/vespa/feed/perf/SimpleFeeder.java6
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) {