diff options
author | Valerij Fredriksen <freva@users.noreply.github.com> | 2022-11-04 15:09:30 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2022-11-04 15:09:30 +0100 |
commit | 1c48ffbdc847a328dbc2b45019628135939c8012 (patch) | |
tree | 21889452f1063047372f9902cb2637adc783423d /node-repository/src/test/java/com/yahoo/vespa/hosted/provision/NodeRepositoryTest.java | |
parent | 86cd5991a15cfd674ddaf57937d8ce4b10f6b6c7 (diff) | |
parent | 67a492188f4cd6482788a38fcfc5a164ac96857d (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.java | 8 |
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"); |