diff options
author | Olli Virtanen <olli.virtanen@oath.com> | 2018-09-24 14:45:25 +0200 |
---|---|---|
committer | Olli Virtanen <olli.virtanen@oath.com> | 2018-09-24 14:45:25 +0200 |
commit | 6002813ae4d7e012409f6d43abe5a83bddc63f06 (patch) | |
tree | f7911b8a516172b55ef45692c8f35451cb91e85b /container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java | |
parent | 3a18bab028097dec03bac8186d06c23536fda1c0 (diff) |
Multiple node java dispatch support
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java b/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java index 269d16fd24d..455696c16b1 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java @@ -26,17 +26,14 @@ public class LoadBalancer { private static final CompoundName QUERY_NODE_GROUP_AFFINITY = new CompoundName("dispatch.group.affinity"); - private final boolean isInternallyDispatchable; private final List<GroupSchedule> scoreboard; private int needle = 0; public LoadBalancer(SearchCluster searchCluster) { if (searchCluster == null) { - this.isInternallyDispatchable = false; this.scoreboard = null; return; } - this.isInternallyDispatchable = (searchCluster.groupSize() == 1); this.scoreboard = new ArrayList<>(searchCluster.groups().size()); for (Group group : searchCluster.groups().values()) { @@ -53,7 +50,7 @@ public class LoadBalancer { * @return The node group to target, or <i>empty</i> if the internal dispatch logic cannot be used */ public Optional<Group> takeGroupForQuery(Query query) { - if (!isInternallyDispatchable) { + if (scoreboard == null) { return Optional.empty(); } |