diff options
| author | jonmv <venstad@gmail.com> | 2023-06-23 14:53:08 +0200 |
|---|---|---|
| committer | jonmv <venstad@gmail.com> | 2023-06-23 14:53:08 +0200 |
| commit | ba8a1a777a6240186cdc952135e5abb477fc9e39 (patch) | |
| tree | f4b35546f0caccee97b3a8269abd769d89613795 | |
| parent | 695d4d5bc12ccdf06caf4c17770817d32da27169 (diff) | |
Re-read all potential children
| -rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/node/Nodes.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/node/Nodes.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/node/Nodes.java index fb718cc8d77..a6d017cd275 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/node/Nodes.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/node/Nodes.java @@ -916,7 +916,7 @@ public class Nodes { mutexes = lockAndGetAll(nodes, timeout); unallocatedLock = timeout.map(db::lockInactive).orElseGet(db::lockInactive); RecursiveNodeMutexes recursive = new RecursiveNodeMutexes(hostname, mutexes, unallocatedLock); - Set<Node> freshChildren = recursive.children.stream().map(NodeMutex::node).collect(Collectors.toSet()); + Set<Node> freshChildren = list().childrenOf(hostname).asSet(); Optional<Node> freshNode = recursive.parent.map(NodeMutex::node); if (children.equals(freshChildren) && node.equals(freshNode)) { // No new nodes have appeared, and none will now, so we have a consistent snapshot. |