diff options
author | Martin Polden <mpolden@mpolden.no> | 2022-05-03 13:04:00 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2022-05-04 09:16:42 +0200 |
commit | 4ab204a2c98815c2ddec06f78a122f3e6b4b7baf (patch) | |
tree | ec85609e6426feeee07ae20e756bb840c1d9eb37 /node-repository | |
parent | d2603bf71d4ba888a07cc08a30b4d63c46ee4eef (diff) |
Re-order parameters
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/FailedExpirer.java | 18 |
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); } |