gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-03-19 21:04:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make sure we have fanout peers when publish (#6738)

Browse Source 
* Ensure that `fanout_peers` is always non-empty if it's `Some`
This commit is contained in:
Akihito Nakano
2024-12-24 10:38:56 +09:00
committed by GitHub
parent 42c64a2744
commit 7e0cddef32
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
beacon_node/lighthouse_network/gossipsub/src/behaviour.rs
View File

@@ -679,9 +679,15 @@ where
// Gossipsub peers // Gossipsub peers
None => { None => {
tracing::debug!(topic=%topic_hash, "Topic not in the mesh"); tracing::debug!(topic=%topic_hash, "Topic not in the mesh");
// `fanout_peers` is always non-empty if it's `Some`.
let fanout_peers = self
.fanout
.get(&topic_hash)
.map(|peers| if peers.is_empty() { None } else { Some(peers) })
.unwrap_or(None);
// If we have fanout peers add them to the map. // If we have fanout peers add them to the map.
if self.fanout.contains_key(&topic_hash) { if let Some(peers) = fanout_peers {
for peer in self.fanout.get(&topic_hash).expect("Topic must exist") { for peer in peers {
recipient_peers.insert(*peer); recipient_peers.insert(*peer);
} }
} else { } else {