YGGverse/aquatic
1
0
Fork 0
mirror of https://github.com/YGGverse/aquatic.git synced 2026-03-31 17:55:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Explicity use IndexMap::swap_remove to silence warnings

Browse source
This commit is contained in:
Joakim Frostegård 2024-02-06 18:34:17 +01:00
parent 0b6a02e1a7
commit e705c03981
4 changed files with 6 additions and 6 deletions
Download patch file Download diff file Expand all files Collapse all files

2
crates/http/src/workers/swarm/storage.rs
View file

@ -433,7 +433,7 @@ impl<I: Ip> LargePeerMap<I> {
} }
fn remove_peer(&mut self, key: &ResponsePeer<I>) -> Option<Peer> { fn remove_peer(&mut self, key: &ResponsePeer<I>) -> Option<Peer> {
let opt_removed_peer = self.peers.remove(key); let opt_removed_peer = self.peers.swap_remove(key);
if let Some(Peer { if let Some(Peer {
is_seeder: true, .. is_seeder: true, ..

2
crates/udp/src/workers/statistics/mod.rs
View file

@ -97,7 +97,7 @@ pub fn run_statistics_worker(
*count -= 1; *count -= 1;
if *count == 0 { if *count == 0 {
peers.remove(&peer_id); peers.swap_remove(&peer_id);
} }
} }
} }

2
crates/udp/src/workers/swarm/storage.rs
View file

@ -407,7 +407,7 @@ impl<I: Ip> LargePeerMap<I> {
} }
fn remove_peer(&mut self, key: &ResponsePeer<I>) -> Option<Peer> { fn remove_peer(&mut self, key: &ResponsePeer<I>) -> Option<Peer> {
let opt_removed_peer = self.peers.remove(key); let opt_removed_peer = self.peers.swap_remove(key);
if let Some(Peer { if let Some(Peer {
is_seeder: true, .. is_seeder: true, ..

6
crates/ws/src/workers/swarm/storage.rs
View file

@ -356,7 +356,7 @@ impl TorrentData {
peer.valid_until = valid_until; peer.valid_until = valid_until;
} }
PeerStatus::Stopped => { PeerStatus::Stopped => {
let peer = entry.remove(); let peer = entry.swap_remove();
if peer.seeder { if peer.seeder {
self.num_seeders -= 1; self.num_seeders -= 1;
@ -477,7 +477,7 @@ impl TorrentData {
if answer_receiver if answer_receiver
.expecting_answers .expecting_answers
.remove(&expecting_answer) .swap_remove(&expecting_answer)
.is_some() .is_some()
{ {
let answer_out_message = AnswerOutMessage { let answer_out_message = AnswerOutMessage {
@ -519,7 +519,7 @@ impl TorrentData {
peer_id: PeerId, peer_id: PeerId,
#[cfg(feature = "metrics")] peer_gauge: &::metrics::Gauge, #[cfg(feature = "metrics")] peer_gauge: &::metrics::Gauge,
) { ) {
if let Some(peer) = self.peers.remove(&peer_id) { if let Some(peer) = self.peers.swap_remove(&peer_id) {
if peer.seeder { if peer.seeder {
self.num_seeders -= 1; self.num_seeders -= 1;
} }