summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorArne H Juul <arnej@yahoo-inc.com>2016-10-12 11:36:31 +0200
committerArne H Juul <arnej@yahoo-inc.com>2016-10-12 11:38:16 +0200
commitf659fe7e796e3c02c3886e04be6a8164d42cf464 (patch)
tree2e63b0e4c6adca44f8de37482d5f9de805c7cb23 /container-search
parentaa1c878712ef38d3c2b55bce1c68bce8f1f3a245 (diff)
minor cosmetic style changes
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/search/dispatch/SearchCluster.java12
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);
}