diff options
author | Olli Virtanen <olli.virtanen@oath.com> | 2018-12-19 13:34:15 +0200 |
---|---|---|
committer | Olli Virtanen <olli.virtanen@oath.com> | 2018-12-19 13:34:15 +0200 |
commit | 9fede395bcf3fe1f1af3a228046fcd51b7eee197 (patch) | |
tree | ca4de2923b4ff1105c497d8da3be20716d50c3f0 /container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java | |
parent | 26c6781168f21eb58bb86f1c40babd3a38e03dfd (diff) |
Adaptive load balancing scheduler, coverage calculation fixes
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java index 1ca64be7924..baf401a2536 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java @@ -144,10 +144,10 @@ public class Dispatcher extends AbstractComponent { if (invoker.isPresent()) { query.trace(false, 2, "Dispatching internally to search group ", group.id()); query.getModel().setSearchPath("/" + group.id()); - invoker.get().teardown(() -> loadBalancer.releaseGroup(group)); + invoker.get().teardown((success, time) -> loadBalancer.releaseGroup(group, success, time)); return invoker; } else { - loadBalancer.releaseGroup(group); + loadBalancer.releaseGroup(group, false, 0); if (rejected == null) { rejected = new HashSet<>(); } |