recompute neighbours whenever topology changes

1 files changed, 7 insertions, 0 deletions

diff --git a/src/swarm/sync.rs b/src/swarm/sync.rs
index 93af6f7..d4503bb 100644
--- a/src/swarm/sync.rs
+++ b/src/swarm/sync.rs
@@ -608,6 +608,13 @@ pub(crate) async fn run_change_publisher(state: AppState) {
             warn!(path = ?path, "Concurrent writes produced a conflict");
         }
 
+        if paths
+            .iter()
+            .any(|path| crate::swarm::topology::affects_neighbours(path))
+        {
+            state.topology_changed.notify_one();
+        }
+
         // Fails only when nobody is subscribed.
         let _ = state.change_events.send(Arc::new(ChangeSet { paths }));
     }