diff options
| author | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-15 15:05:19 +0100 |
|---|---|---|
| committer | Olli Virtanen <olli.virtanen@oath.com> | 2019-01-15 15:05:19 +0100 |
| commit | 9c03d3d5620c1ce2da81ba45518381df423eb2d1 (patch) | |
| tree | 5604289f8201e3f7b561f63f128c3f242de44023 /container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java | |
| parent | bb9a8be9b26191ef6887b352ab11f64bd75cda6b (diff) | |
uselocalnode support and fix to coverage estimation
Diffstat (limited to 'container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java')
| -rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java index 01cbc5cd307..146c62f0a16 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/searchcluster/Group.java @@ -44,6 +44,16 @@ public class Group { hasSufficientCoverage.lazySet(sufficientCoverage); } + public int workingNodes() { + int nodesUp = 0; + for (Node node : nodes) { + if (node.isWorking()) { + nodesUp++; + } + } + return nodesUp; + } + void aggregateActiveDocuments() { long activeDocumentsInGroup = 0; for (Node node : nodes) { |