diff options
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java')
-rw-r--r-- | node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java | 15 |
1 files changed, 4 insertions, 11 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java index 96236b5fb84..5e8d22275af 100644 --- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java +++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/CapacityCheckerTester.java @@ -25,6 +25,7 @@ import com.yahoo.vespa.curator.mock.MockCurator; import com.yahoo.vespa.flags.InMemoryFlagSource; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeRepository; +import com.yahoo.vespa.hosted.provision.node.Agent; import com.yahoo.vespa.hosted.provision.node.IP; import com.yahoo.vespa.hosted.provision.provisioning.FlavorConfigBuilder; import com.yahoo.vespa.hosted.provision.testutils.MockNameResolver; @@ -175,14 +176,13 @@ public class CapacityCheckerTester { void createNodes(int childrenPerHost, int numDistinctChildren, List<NodeResources> childResources, int numHosts, NodeResources hostExcessCapacity, int hostExcessIps, int numEmptyHosts, NodeResources emptyHostExcessCapacity, int emptyHostExcessIps) { - cleanRepository(); List<NodeModel> possibleChildren = createDistinctChildren(numDistinctChildren, childResources); List<Node> nodes = new ArrayList<>(); nodes.addAll(createHostsWithChildren(childrenPerHost, possibleChildren, numHosts, hostExcessCapacity, hostExcessIps)); nodes.addAll(createEmptyHosts(numHosts, numEmptyHosts, emptyHostExcessCapacity, emptyHostExcessIps)); - nodeRepository.addNodes(nodes); + nodeRepository.addNodes(nodes, Agent.system); updateCapacityChecker(); } @@ -275,7 +275,7 @@ public class CapacityCheckerTester { } } - public void restoreNodeRepositoryFromJsonFile(Path path) throws IOException { + public void populateNodeRepositoryFromJsonFile(Path path) throws IOException { byte[] jsonData = Files.readAllBytes(path); ObjectMapper om = new ObjectMapper(); @@ -289,15 +289,8 @@ public class CapacityCheckerTester { nodes.add(createNodeFromModel(nmod)); } - nodeRepository.addNodes(nodes); + nodeRepository.addNodes(nodes, Agent.system); updateCapacityChecker(); } - void cleanRepository() { - nodeRepository.getNodes(NodeType.host).forEach(n -> nodeRepository.removeRecursively(n, true)); - nodeRepository.getNodes().forEach(n -> nodeRepository.removeRecursively(n, true)); - if (nodeRepository.getNodes().size() != 0) { - throw new IllegalStateException("Cleaning repository didn't remove all nodes! [" + nodeRepository.getNodes().size() + "]"); - } - } } |