fluencelabs/rust-libp2p
1
0
Fork 0
mirror of https://github.com/fluencelabs/rust-libp2p synced 2025-05-28 18:21:20 +00:00
Code Issues Projects Releases Wiki Activity

protocols/gossipsub: Emit gossip of all non empty topics (#2481)

Browse Source 
Co-authored-by: Max Inden <mail@max-inden.de>
This commit is contained in:
Divma 2022-02-07 14:00:46 -05:00 committed by GitHub
parent ab7ed43b4a
commit 78f5981856
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
protocols/gossipsub/CHANGELOG.md
View File

@ -6,7 +6,10 @@
- Move from `open-metrics-client` to `prometheus-client` (see [PR 2442]). - Move from `open-metrics-client` to `prometheus-client` (see [PR 2442]).
- Emit gossip of all non empty topics (see [PR 2481]).
[PR 2442]: https://github.com/libp2p/rust-libp2p/pull/2442 [PR 2442]: https://github.com/libp2p/rust-libp2p/pull/2442
[PR 2481]: https://github.com/libp2p/rust-libp2p/pull/2481
# 0.35.0 [2022-01-27] # 0.35.0 [2022-01-27]

2
protocols/gossipsub/src/behaviour.rs
View File

@ -2508,7 +2508,7 @@ where
for (topic_hash, peers) in self.mesh.iter().chain(self.fanout.iter()) { for (topic_hash, peers) in self.mesh.iter().chain(self.fanout.iter()) {
let mut message_ids = self.mcache.get_gossip_message_ids(topic_hash); let mut message_ids = self.mcache.get_gossip_message_ids(topic_hash);
if message_ids.is_empty() { if message_ids.is_empty() {
return; continue;
} }
// if we are emitting more than GossipSubMaxIHaveLength message_ids, truncate the list // if we are emitting more than GossipSubMaxIHaveLength message_ids, truncate the list