diff options
author | Jon Bratseth <bratseth@vespa.ai> | 2023-07-12 11:33:38 +0200 |
---|---|---|
committer | Jon Bratseth <bratseth@vespa.ai> | 2023-07-12 11:33:38 +0200 |
commit | 8daf09b502135f120e2f1fab23b86de597cac982 (patch) | |
tree | d08b1814c135a1d397d6409b486b4aedb8f8ab70 | |
parent | 963d0f7efa2949ab35c1a2e552114a16fdc24ab2 (diff) |
Simplify
3 files changed, 22 insertions, 22 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/LoadBalancerProvisioner.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/LoadBalancerProvisioner.java index 10aae94a986..5a35ed1cc42 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/LoadBalancerProvisioner.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/LoadBalancerProvisioner.java @@ -88,12 +88,12 @@ public class LoadBalancerProvisioner { * <p> * Calling this for irrelevant node or cluster types is a no-op. */ - public void prepare(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes) { - if (!shouldProvision(application, requestedNodes.type(), cluster.type())) return; + public void prepare(ApplicationId application, ClusterSpec cluster, NodeSpec requested) { + if (!shouldProvision(application, requested.type(), cluster.type())) return; try (var lock = db.lock(application)) { ClusterSpec.Id clusterId = effectiveId(cluster); LoadBalancerId loadBalancerId = requireNonClashing(new LoadBalancerId(application, clusterId)); - prepare(loadBalancerId, cluster.zoneEndpoint(), requestedNodes.cloudAccount()); + prepare(loadBalancerId, cluster.zoneEndpoint(), requested.cloudAccount()); } } diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java index 3c33897af57..4ac90753ed1 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/NodePrioritizer.java @@ -33,7 +33,7 @@ public class NodePrioritizer { private final LockedNodeList allNodes; private final HostCapacity capacity; private final HostResourcesCalculator calculator; - private final NodeSpec requestedNodes; + private final NodeSpec requested; private final ApplicationId application; private final ClusterSpec clusterSpec; private final NameResolver nameResolver; @@ -51,7 +51,7 @@ public class NodePrioritizer { this.allNodes = allNodes; this.calculator = hostResourcesCalculator; this.capacity = new HostCapacity(this.allNodes, hostResourcesCalculator); - this.requestedNodes = nodeSpec; + this.requested = nodeSpec; this.clusterSpec = clusterSpec; this.application = application; this.dynamicProvisioning = dynamicProvisioning; @@ -70,7 +70,7 @@ public class NodePrioritizer { .stream()) .distinct() .count(); - this.topologyChange = currentGroups != requestedNodes.groups(); + this.topologyChange = currentGroups != requested.groups(); this.currentClusterSize = (int) nonRetiredNodesInCluster.state(Node.State.active).stream().count(); @@ -116,7 +116,7 @@ public class NodePrioritizer { /** Add a node on each host with enough capacity for the requested flavor */ private void addCandidatesOnExistingHosts() { - if (requestedNodes.resources().isEmpty()) return; + if (requested.resources().isEmpty()) return; for (Node host : allNodes) { if ( ! nodes.canAllocateTenantNodeTo(host, dynamicProvisioning)) continue; @@ -126,10 +126,10 @@ public class NodePrioritizer { if (host.exclusiveToApplicationId().isPresent() && ! fitsPerfectly(host)) continue; if ( ! host.exclusiveToClusterType().map(clusterSpec.type()::equals).orElse(true)) continue; if (spareHosts.contains(host) && !canAllocateToSpareHosts) continue; - if ( ! capacity.hasCapacity(host, requestedNodes.resources().get())) continue; + if ( ! capacity.hasCapacity(host, requested.resources().get())) continue; if ( ! allNodes.childrenOf(host).owner(application).cluster(clusterSpec.id()).isEmpty()) continue; - candidates.add(NodeCandidate.createNewChild(requestedNodes.resources().get(), + candidates.add(NodeCandidate.createNewChild(requested.resources().get(), capacity.availableCapacityOf(host), host, spareHosts.contains(host), @@ -140,14 +140,14 @@ public class NodePrioritizer { } private boolean fitsPerfectly(Node host) { - return calculator.advertisedResourcesOf(host.flavor()).compatibleWith(requestedNodes.resources().get()); + return calculator.advertisedResourcesOf(host.flavor()).compatibleWith(requested.resources().get()); } /** Add existing nodes allocated to the application */ private void addApplicationNodes() { EnumSet<Node.State> legalStates = EnumSet.of(Node.State.active, Node.State.inactive, Node.State.reserved); allNodes.stream() - .filter(node -> node.type() == requestedNodes.type()) + .filter(node -> node.type() == requested.type()) .filter(node -> legalStates.contains(node.state())) .filter(node -> node.allocation().isPresent()) .filter(node -> node.allocation().get().owner().equals(application)) @@ -160,7 +160,7 @@ public class NodePrioritizer { /** Add nodes already provisioned, but not allocated to any application */ private void addReadyNodes() { allNodes.stream() - .filter(node -> node.type() == requestedNodes.type()) + .filter(node -> node.type() == requested.type()) .filter(node -> node.state() == Node.State.ready) .map(node -> candidateFrom(node, false)) .filter(n -> !n.violatesSpares || canAllocateToSpareHosts) @@ -179,11 +179,11 @@ public class NodePrioritizer { isSurplus, false, parent.exclusiveToApplicationId().isEmpty() - && requestedNodes.canResize(node.resources(), - capacity.unusedCapacityOf(parent), - clusterSpec.type(), - topologyChange, - currentClusterSize)); + && requested.canResize(node.resources(), + capacity.unusedCapacityOf(parent), + clusterSpec.type(), + topologyChange, + currentClusterSize)); } else { return NodeCandidate.createStandalone(node, isSurplus, false); } @@ -196,7 +196,7 @@ public class NodePrioritizer { .orElse(nodesInCluster); int failedNodesInGroup = nodesInGroup.failing().size() + nodesInGroup.state(Node.State.failed).size(); if (failedNodesInGroup == 0) return false; - return ! requestedNodes.fulfilledBy(nodesInGroup.size() - failedNodesInGroup); + return ! requested.fulfilledBy(nodesInGroup.size() - failedNodesInGroup); } /** diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java index 55e9a9349db..8975dda8e60 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/Preparer.java @@ -147,20 +147,20 @@ public class Preparer { } } - private NodeAllocation prepareAllocation(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes, + private NodeAllocation prepareAllocation(ApplicationId application, ClusterSpec cluster, NodeSpec requested, Supplier<Integer> nextIndex, LockedNodeList allNodes) { - NodeAllocation allocation = new NodeAllocation(allNodes, application, cluster, requestedNodes, nextIndex, nodeRepository); + NodeAllocation allocation = new NodeAllocation(allNodes, application, cluster, requested, nextIndex, nodeRepository); NodePrioritizer prioritizer = new NodePrioritizer(allNodes, application, cluster, - requestedNodes, + requested, nodeRepository.zone().cloud().dynamicProvisioning(), nodeRepository.nameResolver(), nodeRepository.nodes(), nodeRepository.resourcesCalculator(), nodeRepository.spareCount(), - requestedNodes.cloudAccount().isExclave(nodeRepository.zone())); + requested.cloudAccount().isExclave(nodeRepository.zone())); allocation.offer(prioritizer.collect()); return allocation; } |