diff --git a/crates/librqbit/src/peer_state.rs b/crates/librqbit/src/peer_state.rs index 3e997ed..4e217d6 100644 --- a/crates/librqbit/src/peer_state.rs +++ b/crates/librqbit/src/peer_state.rs @@ -144,14 +144,6 @@ impl PeerState { self.get_live_mut() } - pub fn dead_to_queued(&mut self) -> bool { - if let PeerState::Dead = self { - *self = PeerState::Queued; - return true; - } - false - } - pub fn to_dead(&mut self) -> Option> { match std::mem::replace(self, PeerState::Dead) { PeerState::Live(l) => Some(Some(l)), diff --git a/crates/librqbit/src/torrent_state.rs b/crates/librqbit/src/torrent_state.rs index b70f49b..b9180e8 100644 --- a/crates/librqbit/src/torrent_state.rs +++ b/crates/librqbit/src/torrent_state.rs @@ -137,9 +137,6 @@ impl PeerStates { .flatten() } - pub fn add(&self, addr: SocketAddr) -> Option { - self.add_if_not_seen(addr) - } pub fn mark_peer_dead(&self, handle: PeerHandle) -> Option> { self.with_peer_mut(handle, "mark_peer_dead", |peer| peer.state.to_dead()) .flatten() @@ -810,7 +807,7 @@ impl TorrentState { None => return false, }; - let _ = self.peer_queue_tx.send(addr); + self.peer_queue_tx.send(addr).unwrap(); true }