diff options
author | Arne H Juul <arnej@yahoo-inc.com> | 2016-10-12 11:36:31 +0200 |
---|---|---|
committer | Arne H Juul <arnej@yahoo-inc.com> | 2016-10-12 11:38:16 +0200 |
commit | f659fe7e796e3c02c3886e04be6a8164d42cf464 (patch) | |
tree | 2e63b0e4c6adca44f8de37482d5f9de805c7cb23 /container-search | |
parent | aa1c878712ef38d3c2b55bce1c68bce8f1f3a245 (diff) |
minor cosmetic style changes
Diffstat (limited to 'container-search')
-rw-r--r-- | container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java b/container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java index 1555e7c5058..b6ee70802d8 100644 --- a/container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java +++ b/container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java @@ -83,20 +83,20 @@ public class SearchCluster implements NodeManager<SearchCluster.Node> { ImmutableMap.Builder<Integer, Group> groupsBuilder = new ImmutableMap.Builder<>(); for (Map.Entry<Integer, List<Node>> group : nodes.stream().collect(Collectors.groupingBy(Node::group)).entrySet()) groupsBuilder.put(group.getKey(), new Group(group.getKey(), group.getValue())); - groups = groupsBuilder.build(); + this.groups = groupsBuilder.build(); // Index nodes by host ImmutableMultimap.Builder<String, Node> nodesByHostBuilder = new ImmutableMultimap.Builder<>(); for (Node node : nodes) nodesByHostBuilder.put(node.hostname(), node); - nodesByHost = nodesByHostBuilder.build(); + this.nodesByHost = nodesByHostBuilder.build(); this.directDispatchTarget = findDirectDispatchTarget(HostName.getLocalhost(), size, containerClusterSize, nodesByHost, groups); // Set up monitoring of the fs4 interface of the nodes // We can switch to monitoring the rpc interface instead when we move the query phase to rpc - clusterMonitor = new ClusterMonitor<>(this); + this.clusterMonitor = new ClusterMonitor<>(this); for (Node node : nodes) { // cluster monitor will only call working() when the // node transitions from down to up, so we need to @@ -192,12 +192,12 @@ public class SearchCluster implements NodeManager<SearchCluster.Node> { private void updateSufficientCoverage(Group group, boolean sufficientCoverage) { // update VIP status if we direct dispatch to this group and coverage status changed if (usesDirectDispatchTo(group) && sufficientCoverage != group.hasSufficientCoverage()) { - if (sufficientCoverage) + if (sufficientCoverage) { vipStatus.addToRotation(this); - else + } else { vipStatus.removeFromRotation(this); + } } - group.setHasSufficientCoverage(sufficientCoverage); } |