leyoda/rqbit
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Merge pull request #233 from izderadicka/pex2

Browse source 
In PEX we should also look at dropped peers
This commit is contained in:
Igor Katson 2024-09-13 09:01:54 +01:00 • committed by GitHub
commit 88c8e51ab8
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 11 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

20
crates/librqbit/src/torrent_state/live/mod.rs
View file

@ -1687,14 +1687,16 @@ impl PeerHandler {
B: AsRef<[u8]> + std::fmt::Debug, B: AsRef<[u8]> + std::fmt::Debug,
{ {
// TODO: this is just first attempt at pex - will need more sophistication on adding peers - BEP 40, check number of live, seen peers ... // TODO: this is just first attempt at pex - will need more sophistication on adding peers - BEP 40, check number of live, seen peers ...
msg.added_peers().for_each(|peer| { msg.dropped_peers()
self.state .chain(msg.added_peers())
.add_peer_if_not_seen(peer.addr) .for_each(|peer| {
.map_err(|error| { self.state
warn!(?peer, ?error, "failed to add peer"); .add_peer_if_not_seen(peer.addr)
error .map_err(|error| {
}) warn!(?peer, ?error, "failed to add peer");
.ok(); error
}); })
.ok();
});
} }
} }