aboutsummaryrefslogtreecommitdiffstats
path: root/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2024-05-21 10:45:38 +0200
committerjonmv <venstad@gmail.com>2024-05-21 10:45:38 +0200
commit7b80287b241677c19ec165c9804b01d0e0ac0c4c (patch)
tree1c770d772e19b6fd186a2c4f393757211066957b /vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java
parentd7954c1b84d26b7f6b429159c3d9b956dc39eaef (diff)
Nano time, and add timeout in timeout message
Diffstat (limited to 'vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java')
-rw-r--r--vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java18
1 files changed, 12 insertions, 6 deletions
diff --git a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java
index a75c56c9368..fdd35b74c35 100644
--- a/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java
+++ b/vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java
@@ -12,16 +12,18 @@ class HttpRequest {
private final String path;
private final Map<String, Supplier<String>> headers;
private final byte[] body;
- private final long deadlineMillis;
- private final LongSupplier clock;
+ private final Duration timeout;
+ private final long deadlineNanos;
+ private final LongSupplier nanoClock;
- public HttpRequest(String method, String path, Map<String, Supplier<String>> headers, byte[] body, Duration timeout, LongSupplier clock) {
+ public HttpRequest(String method, String path, Map<String, Supplier<String>> headers, byte[] body, Duration timeout, LongSupplier nanoClock) {
this.method = method;
this.path = path;
this.headers = headers;
this.body = body;
- this.deadlineMillis = clock.getAsLong() + timeout.toMillis();
- this.clock = clock;
+ this.deadlineNanos = nanoClock.getAsLong() + timeout.toNanos();
+ this.timeout = timeout;
+ this.nanoClock = nanoClock;
}
public String method() {
@@ -41,7 +43,11 @@ class HttpRequest {
}
public Duration timeLeft() {
- return Duration.ofMillis(deadlineMillis - clock.getAsLong());
+ return Duration.ofNanos(deadlineNanos - nanoClock.getAsLong());
+ }
+
+ public Duration timeout() {
+ return timeout;
}
@Override