diff options
author | jonmv <venstad@gmail.com> | 2024-05-21 10:45:38 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2024-05-21 10:45:38 +0200 |
commit | 7b80287b241677c19ec165c9804b01d0e0ac0c4c (patch) | |
tree | 1c770d772e19b6fd186a2c4f393757211066957b /vespa-feed-client/src/main/java/ai/vespa/feed/client/impl/HttpRequest.java | |
parent | d7954c1b84d26b7f6b429159c3d9b956dc39eaef (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.java | 18 |
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 |