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

Logging

Browse source
This commit is contained in:
Ivan 2024-10-23 13:42:52 +02:00 • committed by Igor Katson
parent 1fa05837fb
commit 42d184ff6b
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 2 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -905,7 +905,7 @@ impl TorrentStateLive {
// and addrs_closed_to_sent are only filtered addresses from sent_peers_live // and addrs_closed_to_sent are only filtered addresses from sent_peers_live
if !addrs_live_to_sent.is_empty() || !addrs_closed_to_sent.is_empty() { if !addrs_live_to_sent.is_empty() || !addrs_closed_to_sent.is_empty() {
debug!(peer=?peer_addr, "sending PEX with {} live ({:?})and {} closed peers", addrs_live_to_sent.len(), addrs_live_to_sent,addrs_closed_to_sent.len()); debug!("sending PEX with {} live ({:?})and {} closed peers", addrs_live_to_sent.len(), addrs_live_to_sent,addrs_closed_to_sent.len());
let pex_msg = let pex_msg =
extended::ut_pex::UtPex::from_addrs(&addrs_live_to_sent, &addrs_closed_to_sent); extended::ut_pex::UtPex::from_addrs(&addrs_live_to_sent, &addrs_closed_to_sent);
let ext_msg = extended::ExtendedMessage::UtPex(pex_msg); let ext_msg = extended::ExtendedMessage::UtPex(pex_msg);
@ -1859,6 +1859,7 @@ 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 ...
debug!("received PEX message with {} added peers and {} dropped peers", msg.added_peers().count(), msg.dropped_peers().count());
msg.dropped_peers() msg.dropped_peers()
.chain(msg.added_peers()) .chain(msg.added_peers())
.for_each(|peer| { .for_each(|peer| {