summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorJon Bratseth <bratseth@oath.com>2020-01-17 15:13:18 +0100
committerGitHub <noreply@github.com>2020-01-17 15:13:18 +0100
commit1b6f9a1a9b2b5fabd933e952f315752b0ae5113f (patch)
tree33104f7269e91d9298d3a29b8940b7b43e377290 /node-repository
parentd595db5ce5faa3654de52d049b1358d9fd72bee4 (diff)
parent0b6988204a030ac07557c41053258617288a46a0 (diff)
Merge pull request #11837 from vespa-engine/bratseth/dont-allow-wrong-serviceport-take-2
Bratseth/dont allow wrong serviceport take 2
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRebooter.java6
1 files changed, 2 insertions, 4 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRebooter.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRebooter.java
index a54287ed082..d1e15c78a47 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRebooter.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRebooter.java
@@ -41,7 +41,7 @@ public class NodeRebooter extends Maintainer {
@Override
protected void maintain() {
- // Reboot candidates: Nodes in long-term states, which we know can safely orchestrate a reboot
+ // Reboot candidates: Nodes in long-term states, where we know we can safely orchestrate a reboot
List<Node> nodesToReboot = nodeRepository().getNodes(Node.State.active, Node.State.ready).stream()
.filter(node -> node.flavor().getType() != Flavor.Type.DOCKER_CONTAINER)
.filter(this::shouldReboot)
@@ -66,13 +66,11 @@ public class NodeRebooter extends Maintainer {
if (overdue.isEmpty()) // should never happen as all !docker-container should have provisioned timestamp
return random.nextDouble() < interval().getSeconds() / (double) rebootInterval.getSeconds();
- if (overdue.get().isNegative())
- return false;
+ if (overdue.get().isNegative()) return false;
// Use a probability such that each maintain() schedules the same number of reboots,
// as long as 0 <= overdue <= rebootInterval, with the last maintain() in that interval
// naturally scheduling the remaining with probability 1.
-
int configServers = nodeRepository().database().cluster().size();
long secondsRemaining = Math.max(0, rebootInterval.getSeconds() - overdue.get().getSeconds());
double runsRemaining = configServers * secondsRemaining / (double) interval().getSeconds();