summaryrefslogtreecommitdiffstats
path: root/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java
diff options
context:
space:
mode:
authorValerij Fredriksen <freva@users.noreply.github.com>2022-11-04 15:09:30 +0100
committerGitHub <noreply@github.com>2022-11-04 15:09:30 +0100
commit1c48ffbdc847a328dbc2b45019628135939c8012 (patch)
tree21889452f1063047372f9902cb2637adc783423d /node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java
parent86cd5991a15cfd674ddaf57937d8ce4b10f6b6c7 (diff)
parent67a492188f4cd6482788a38fcfc5a164ac96857d (diff)
Merge pull request #24747 from vespa-engine/freva/fix-locking
Read the node after taking the lock when moving to ready
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java8
1 files changed, 4 insertions, 4 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java
index b338527b0fd..0a179babc10 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java
@@ -60,7 +60,7 @@ public class NodeRepositoryTest {
// Expected
}
- tester.nodeRepository().nodes().setReady("host1", Agent.system, getClass().getSimpleName());
+ tester.nodeRepository().nodes().setReady(tester.nodeRepository().nodes().lockAndGetRequired("host1"), Agent.system, getClass().getSimpleName());
tester.nodeRepository().nodes().removeRecursively("host1");
}
@@ -85,8 +85,8 @@ public class NodeRepositoryTest {
@Test
public void fail_readying_with_hard_fail() {
NodeRepositoryTester tester = new NodeRepositoryTester();
- tester.addHost("host1", "host1", "default", NodeType.tenant);
- tester.addHost("host2", "host2", "default", NodeType.tenant);
+ tester.addHost("host1", "host1", "default", NodeType.host);
+ tester.addHost("host2", "host2", "default", NodeType.host);
Node node2 = tester.nodeRepository().nodes().node("host2").orElseThrow();
var reportsBuilder = new Reports.Builder(node2.reports());
@@ -133,7 +133,7 @@ public class NodeRepositoryTest {
// Now node10 is in provisioned, set node11 to failed and node12 to ready, and it should be OK to delete host1
tester.nodeRepository().nodes().fail("node11", Agent.system, getClass().getSimpleName());
- tester.nodeRepository().nodes().setReady("node12", Agent.system, getClass().getSimpleName());
+ tester.nodeRepository().nodes().setReady(tester.nodeRepository().nodes().lockAndGetRequired("node12"), Agent.system, getClass().getSimpleName());
tester.nodeRepository().nodes().removeRecursively("node12"); // Remove one of the children first instead
assertEquals(4, tester.nodeRepository().nodes().list().size());
tester.nodeRepository().nodes().removeRecursively("host1");