diff options
| author | tv <tv@krebsco.de> | 2026-10-28 17:35:35 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-28 17:35:35 +0100 |
| commit | 21c3f5b47f35b3ebbd00addfd369cf8f81d56a48 (patch) | |
| tree | 8e9f1f22072826efb762ca58dd42286401fb51e8 /src/swarm/peer/handshake.rs | |
| parent | 9d0218e158f146b2b0cb30ccbd2a63854dc5098d (diff) | |
track unlisted members
Diffstat (limited to 'src/swarm/peer/handshake.rs')
| -rw-r--r-- | src/swarm/peer/handshake.rs | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/swarm/peer/handshake.rs b/src/swarm/peer/handshake.rs index fbebfc6..3e8fbf4 100644 --- a/src/swarm/peer/handshake.rs +++ b/src/swarm/peer/handshake.rs @@ -375,6 +375,8 @@ pub(super) async fn establish_peer( peer_state.standing = Standing::Member { swarm_id: swarm_id.clone(), }; + // A member our list may lack yet: a neighbour then (`topology::refresh`). + state.topology_changed.notify_one(); } // Stop our retries and sync from a clean slate. A new handshake from the peer always |
