summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
diff options
context:
space:
mode:
authorOlli Virtanen <olli.virtanen@oath.com>2018-12-19 13:34:15 +0200
committerOlli Virtanen <olli.virtanen@oath.com>2018-12-19 13:34:15 +0200
commit9fede395bcf3fe1f1af3a228046fcd51b7eee197 (patch)
treeca4de2923b4ff1105c497d8da3be20716d50c3f0 /container-search/src/main/java/com/yahoo/search/dispatch/Dispatcher.java
parent26c6781168f21eb58bb86f1c40babd3a38e03dfd (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.java4
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<>();
}