diff options
Diffstat (limited to 'node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java index a8929cf9d22..1684ebbb38f 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/Expirer.java @@ -40,7 +40,7 @@ public abstract class Expirer extends NodeRepositoryMaintainer { @Override protected double maintain() { - NodeList expired = nodeRepository().nodes().list(fromState).matching(this::isExpired); + NodeList expired = getExpiredNodes(); if ( ! expired.isEmpty()) { log.info(fromState + " expirer found " + expired.size() + " expired nodes: " + expired); @@ -51,6 +51,10 @@ public abstract class Expirer extends NodeRepositoryMaintainer { return 1.0; } + protected NodeList getExpiredNodes() { + return nodeRepository().nodes().list(fromState).matching(this::isExpired); + } + protected boolean isExpired(Node node) { return isExpired(node, expiryTime); } |