aboutsummaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2022-08-23 07:06:03 +0200
committerGitHub <noreply@github.com>2022-08-23 07:06:03 +0200
commit8bba638ca93da728b9604ec828ae0457514c5bc6 (patch)
tree8faa7379b9cb744d78e2cf7ce087ce3baa966c6b /container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java
parentb409eb7c17d06744954a64495e4c6d0e21638dd5 (diff)
parent81575e0b094f78b790fd18f70eb625bd99eafcbc (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.java10
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();