diff options
author | jonmv <venstad@gmail.com> | 2023-07-11 12:07:55 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2023-07-13 10:30:49 +0200 |
commit | 9a81c2221bfd201e4614e5146aa58251db30c914 (patch) | |
tree | 05989e0a352d269e08f2bada9a4a3aacbf1c0368 /container-search/src/main/java/com/yahoo/search/dispatch/CloseableInvoker.java | |
parent | bb006b94caafd982c633a2830f1eb9a63d24fc0c (diff) |
Add skeleton for delaying search invoker RPC resource shutdown
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 | 7 |
1 files changed, 5 insertions, 2 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 77496114df1..558b734be51 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 @@ -21,8 +21,11 @@ public abstract class CloseableInvoker implements Closeable { private RequestDuration duration; public void teardown(BiConsumer<Boolean, RequestDuration> teardown) { - this.teardown = teardown; - this.duration = new RequestDuration(); + this.teardown = this.teardown == null ? teardown : (success, duration) -> { + this.teardown.accept(success, duration); + teardown.accept(success, duration); + }; + this.duration = this.duration == null ? new RequestDuration() : this.duration; } protected void setFinalStatus(boolean success) { |