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

wanted to match on network unreachable, but it turns out its unstable

Browse source
This commit is contained in:
Igor Katson 2023-11-20 16:03:07 +00:00
parent 6f93fed360
commit 6d12227f35
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 11 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

18
crates/librqbit/src/torrent_state.rs
View file

@ -866,13 +866,16 @@ impl PeerHandler {
} }
}; };
if error.is_none() { let _error = match error {
debug!("peer died without errors, not re-queueing"); Some(e) => e,
pe.value_mut().state.set(PeerState::NotNeeded, pstats); None => {
return; debug!("peer died without errors, not re-queueing");
} else { pe.value_mut().state.set(PeerState::NotNeeded, pstats);
self.counters.errors.fetch_add(1, Ordering::Relaxed); return;
} }
};
self.counters.errors.fetch_add(1, Ordering::Relaxed);
if self.state.is_finished() { if self.state.is_finished() {
debug!("torrent finished, not re-queueing"); debug!("torrent finished, not re-queueing");
@ -881,6 +884,7 @@ impl PeerHandler {
} }
pe.value_mut().state.set(PeerState::Dead, pstats); pe.value_mut().state.set(PeerState::Dead, pstats);
let backoff = pe.value_mut().stats.backoff.next_backoff(); let backoff = pe.value_mut().stats.backoff.next_backoff();
// Prevent deadlocks. // Prevent deadlocks.