summaryrefslogtreecommitdiffstats
path: root/node-repository
diff options
context:
space:
mode:
authorMartin Polden <mpolden@mpolden.no>2022-05-03 13:04:00 +0200
committerMartin Polden <mpolden@mpolden.no>2022-05-04 09:16:42 +0200
commit4ab204a2c98815c2ddec06f78a122f3e6b4b7baf (patch)
treeec85609e6426feeee07ae20e756bb840c1d9eb37 /node-repository
parentd2603bf71d4ba888a07cc08a30b4d63c46ee4eef (diff)
Re-order parameters
Diffstat (limited to 'node-repository')
-rw-r--r--node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java18
1 files changed, 8 insertions, 10 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java
index 1b0c7602f82..ef2d5bb798d 100644
--- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java
+++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java
@@ -72,23 +72,21 @@ public class FailedExpirer extends NodeRepositoryMaintainer {
.nodeType(NodeType.tenant, NodeType.host)
.asList());
- recycleIf(remainingNodes,
- node -> node.allocation().isEmpty(),
+ recycleIf(node -> node.allocation().isEmpty(), remainingNodes, allNodes);
+ recycleIf(node -> !node.allocation().get().membership().cluster().isStateful() &&
+ node.history().hasEventBefore(History.Event.Type.failed, clock().instant().minus(statelessExpiry)),
+ remainingNodes,
allNodes);
- recycleIf(remainingNodes,
- node -> !node.allocation().get().membership().cluster().isStateful() &&
- node.history().hasEventBefore(History.Event.Type.failed, clock().instant().minus(statelessExpiry)),
- allNodes);
- recycleIf(remainingNodes,
- node -> node.allocation().get().membership().cluster().isStateful() &&
+ recycleIf(node -> node.allocation().get().membership().cluster().isStateful() &&
node.history().hasEventBefore(History.Event.Type.failed, clock().instant().minus(statefulExpiry)),
+ remainingNodes,
allNodes);
return 1.0;
}
/** Recycle the nodes matching condition, and remove those nodes from the nodes list. */
- private void recycleIf(List<Node> failedNodes, Predicate<Node> recycleCondition, NodeList allNodes) {
- List<Node> nodesToRecycle = failedNodes.stream().filter(recycleCondition).collect(Collectors.toList());
+ private void recycleIf(Predicate<Node> condition, List<Node> failedNodes, NodeList allNodes) {
+ List<Node> nodesToRecycle = failedNodes.stream().filter(condition).collect(Collectors.toList());
failedNodes.removeAll(nodesToRecycle);
recycle(nodesToRecycle, allNodes);
}