diff options
author | Jon Bratseth <bratseth@gmail.com> | 2021-02-08 23:52:33 +0100 |
---|---|---|
committer | Jon Bratseth <bratseth@gmail.com> | 2021-02-08 23:52:33 +0100 |
commit | 1e6a8f4ebb958feac3ecac7f7dbbd9818ee0fc30 (patch) | |
tree | bba036864eb44f6c1e98ae04f4bdf8862a2dc4be /node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java | |
parent | b2092944431231d010f33fbffb5f29b5f8623610 (diff) |
Move node operations into a separate class
Diffstat (limited to 'node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java index d9ca0100402..cd381b467d4 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/provisioning/GroupPreparer.java @@ -81,8 +81,8 @@ public class GroupPreparer { } // There were some changes, so re-do the allocation with locks - try (Mutex lock = nodeRepository.lock(application); - Mutex allocationLock = nodeRepository.lockUnallocated()) { + try (Mutex lock = nodeRepository.nodes().lock(application); + Mutex allocationLock = nodeRepository.nodes().lockUnallocated()) { NodeAllocation allocation = prepareAllocation(application, cluster, requestedNodes, surplusActiveNodes, highestIndex, wantedGroups, allocationLock, @@ -109,7 +109,7 @@ public class GroupPreparer { List<Node> hosts = provisionedHosts.stream() .map(ProvisionedHost::generateHost) .collect(Collectors.toList()); - nodeRepository.addNodes(hosts, Agent.application); + nodeRepository.nodes().addNodes(hosts, Agent.application); // Offer the nodes on the newly provisioned hosts, this should be enough to cover the deficit List<NodeCandidate> candidates = provisionedHosts.stream() @@ -124,8 +124,8 @@ public class GroupPreparer { allocation.outOfCapacityDetails()); // Carry out and return allocation - nodeRepository.reserve(allocation.reservableNodes()); - nodeRepository.addDockerNodes(new LockedNodeList(allocation.newNodes(), allocationLock)); + nodeRepository.nodes().reserve(allocation.reservableNodes()); + nodeRepository.nodes().addDockerNodes(new LockedNodeList(allocation.newNodes(), allocationLock)); List<Node> acceptedNodes = allocation.finalNodes(); surplusActiveNodes.removeAll(acceptedNodes); return acceptedNodes; @@ -135,7 +135,7 @@ public class GroupPreparer { private NodeAllocation prepareAllocation(ApplicationId application, ClusterSpec cluster, NodeSpec requestedNodes, List<Node> surplusActiveNodes, MutableInteger highestIndex, int wantedGroups, Mutex allocationLock, String allocateOsRequirement) { - LockedNodeList allNodes = nodeRepository.list(allocationLock); + LockedNodeList allNodes = nodeRepository.nodes().list(allocationLock); NodeAllocation allocation = new NodeAllocation(allNodes, application, cluster, requestedNodes, highestIndex, nodeRepository); NodePrioritizer prioritizer = new NodePrioritizer( |