aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java
diff options
context:
space:
mode:
authorjonmv <venstad@gmail.com>2023-06-22 13:09:11 +0200
committerjonmv <venstad@gmail.com>2023-06-22 13:09:11 +0200
commitef5e845ff28a088591809d0794b6975655b948b2 (patch)
treee8566e468cf93c2bf8836c9601bbbbb018fd9c71 /node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java
parent66d358b94cb172515eece49a953ef60ce5dd4413 (diff)
Require locked node list in some more APIs
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java5
1 files changed, 3 insertions, 2 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java
index 66d4b67c7c2..e1e183c9362 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/HostCapacityMaintainerTest.java
@@ -27,6 +27,7 @@ import com.yahoo.test.ManualClock;
import com.yahoo.vespa.flags.InMemoryFlagSource;
import com.yahoo.vespa.flags.PermanentFlags;
import com.yahoo.vespa.flags.custom.ClusterCapacity;
+import com.yahoo.vespa.hosted.provision.LockedNodeList;
import com.yahoo.vespa.hosted.provision.Node;
import com.yahoo.vespa.hosted.provision.Node.State;
import com.yahoo.vespa.hosted.provision.NodeList;
@@ -722,7 +723,7 @@ public class HostCapacityMaintainerTest {
createNode("host4", Optional.empty(), NodeType.host, Node.State.provisioned, null),
createNode("host4-1", Optional.of("host4"), NodeType.tenant, Node.State.reserved, tenantApp),
createNode("host4-2", Optional.of("host4"), NodeType.tenant, Node.State.reserved, tenantApp))
- .forEach(node -> nodeRepository.database().addNodesInState(List.of(node), node.state(), Agent.system));
+ .forEach(node -> nodeRepository.database().addNodesInState(new LockedNodeList(List.of(node), () -> { }), node.state(), Agent.system));
return this;
}
@@ -744,7 +745,7 @@ public class HostCapacityMaintainerTest {
private Node addNode(String hostname, Optional<String> parentHostname, NodeType nodeType, Node.State state, ApplicationId application, Duration hostTTL) {
Node node = createNode(hostname, parentHostname, nodeType, state, application, hostTTL);
- return nodeRepository.database().addNodesInState(List.of(node), node.state(), Agent.system).get(0);
+ return nodeRepository.database().addNodesInState(new LockedNodeList(List.of(node), () -> { }), node.state(), Agent.system).get(0);
}
private Node createNode(String hostname, Optional<String> parentHostname, NodeType nodeType,