summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorJon Marius Venstad <venstad@gmail.com>2021-06-14 11:20:41 +0200
committerJon Marius Venstad <venstad@gmail.com>2021-06-14 11:20:41 +0200
commitba702a983c529cf6a199b98ce444d1a52f949e5c (patch)
tree6ddf78d2aaa0d0b9b7868a9eae7af0c7ff364d93
parent8f20e002d8518159f36b1788ccd38e00ee0fe866 (diff)
Avoid jumpy clock for latency measurements
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/BenchmarkingCluster.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/BenchmarkingCluster.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/BenchmarkingCluster.java
index 0e9bfe0ef46..840219a6bf1 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/BenchmarkingCluster.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/BenchmarkingCluster.java
@@ -40,14 +40,14 @@ public class BenchmarkingCluster implements Cluster {
@Override
public void dispatch(HttpRequest request, CompletableFuture<HttpResponse> vessel) {
requests.incrementAndGet();
- long startMillis = System.currentTimeMillis();
+ long startNanos = System.nanoTime();
delegate.dispatch(request, vessel);
vessel.whenCompleteAsync((response, thrown) -> {
results++;
if (thrown == null) {
responses++;
responsesByCode[response.code()]++;
- long latency = System.currentTimeMillis() - startMillis;
+ long latency = (System.nanoTime() - startNanos) / 1_000_000;
totalLatencyMillis += latency;
minLatencyMillis = Math.min(minLatencyMillis, latency);
maxLatencyMillis = Math.max(maxLatencyMillis, latency);