aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHarald Musum <musum@yahooinc.com>2023-04-18 13:41:13 +0200
committerHarald Musum <musum@yahooinc.com>2023-04-18 13:41:13 +0200
commitf737089811b3140a999606bb23ad65ca9e65443b (patch)
tree28aeeba5a841b4ea21dad877c27a8d18d6c8fc8c
parent63750359c99fb968814fcfd6d2e0aea0ff2ec74f (diff)
Rename and fix logic
-rw-r--r--clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeChecker.java24
1 files changed, 12 insertions, 12 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeChecker.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeChecker.java
index b98974cf27f..ca5cca062ae 100644
--- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeChecker.java
+++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeChecker.java
@@ -316,21 +316,21 @@ public class NodeStateChangeChecker {
sortSetIntoList(groupsWithNodesWantedStateNotUp)));
}
- Set<Integer> retiredOrNotUpGroups = retiredOrNotUpGroups(clusterState);
- int numberOfGroupsToConsider = retiredOrNotUpGroups.size();
+ Set<Integer> retiredAndNotUpGroups = groupsWithNotRetiredAndNotUp(clusterState);
+ int numberOfGroupsToConsider = retiredAndNotUpGroups.size();
// Subtract one group if node is in a group with nodes already retired or not up, since number of such groups wil
// not increase if we allow node to go down
- if (aGroupContainsNode(retiredOrNotUpGroups, node)) {
- numberOfGroupsToConsider = retiredOrNotUpGroups.size() - 1;
+ if (aGroupContainsNode(retiredAndNotUpGroups, node)) {
+ numberOfGroupsToConsider = retiredAndNotUpGroups.size() - 1;
}
if (numberOfGroupsToConsider < maxNumberOfGroupsAllowedToBeDown) {
- log.log(FINE, "Allow, retiredOrNotUpGroups=" + retiredOrNotUpGroups);
+ log.log(FINE, "Allow, retiredAndNotUpGroups=" + retiredAndNotUpGroups);
return Optional.of(allowSettingOfWantedState());
}
return Optional.of(createDisallowed(String.format("At most %d groups can have wanted state: %s",
maxNumberOfGroupsAllowedToBeDown,
- sortSetIntoList(retiredOrNotUpGroups))));
+ sortSetIntoList(retiredAndNotUpGroups))));
} else {
// Return a disallow-result if there is another node with a wanted state
var otherNodeHasWantedState = otherNodeHasWantedState(nodeInfo);
@@ -560,13 +560,13 @@ public class NodeStateChangeChecker {
.collect(Collectors.toSet());
}
- // groups with at least one node with the same state & description
- private Set<Integer> retiredOrNotUpGroups(ClusterState clusterState) {
+ // groups with at least one node in state (not retired AND not up)
+ private Set<Integer> groupsWithNotRetiredAndNotUp(ClusterState clusterState) {
return clusterInfo.getAllNodeInfos().stream()
- .filter(nodeInfo -> (nodeInfo.getUserWantedState().getState() == RETIRED
- || nodeInfo.getUserWantedState().getState() != UP
- || clusterState.getNodeState(nodeInfo.getNode()).getState() == RETIRED
- || clusterState.getNodeState(nodeInfo.getNode()).getState() != UP))
+ .filter(nodeInfo -> (nodeInfo.getUserWantedState().getState() != RETIRED
+ && nodeInfo.getUserWantedState().getState() != UP)
+ || (clusterState.getNodeState(nodeInfo.getNode()).getState() != RETIRED
+ && clusterState.getNodeState(nodeInfo.getNode()).getState() != UP))
.map(NodeInfo::getGroup)
.filter(Objects::nonNull)
.filter(Group::isLeafGroup)