summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java
diff options
context:
space:
mode:
authorOlli Virtanen <olli.virtanen@oath.com>2018-09-24 14:45:25 +0200
committerOlli Virtanen <olli.virtanen@oath.com>2018-09-24 14:45:25 +0200
commit6002813ae4d7e012409f6d43abe5a83bddc63f06 (patch)
treef7911b8a516172b55ef45692c8f35451cb91e85b /container-search/src/main/java/com/yahoo/search/dispatch/LoadBalancer.java
parent3a18bab028097dec03bac8186d06c23536fda1c0 (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.java5
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();
}