diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-08-23 07:06:03 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-08-23 07:06:03 +0200 |
commit | 8bba638ca93da728b9604ec828ae0457514c5bc6 (patch) | |
tree | 8faa7379b9cb744d78e2cf7ce087ce3baa966c6b /container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java | |
parent | b409eb7c17d06744954a64495e4c6d0e21638dd5 (diff) | |
parent | 81575e0b094f78b790fd18f70eb625bd99eafcbc (diff) |
Merge pull request #23738 from vespa-engine/balder/implement-decay-over-timev8.41.3
- Refactor to allow for different decay method.
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java b/container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java index 9da89c6bfd8..77496114df1 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java @@ -16,13 +16,13 @@ public abstract class CloseableInvoker implements Closeable { protected abstract void release(); - private BiConsumer<Boolean, Duration> teardown = null; + private BiConsumer<Boolean, RequestDuration> teardown = null; private boolean success = false; - private long startTime = 0; + private RequestDuration duration; - public void teardown(BiConsumer<Boolean, Duration> teardown) { + public void teardown(BiConsumer<Boolean, RequestDuration> teardown) { this.teardown = teardown; - this.startTime = System.nanoTime(); + this.duration = new RequestDuration(); } protected void setFinalStatus(boolean success) { @@ -32,7 +32,7 @@ public abstract class CloseableInvoker implements Closeable { @Override public final void close() { if (teardown != null) { - teardown.accept(success, Duration.ofNanos(System.nanoTime() - startTime)); + teardown.accept(success, duration.complete()); teardown = null; } release(); |