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

Bump seen counters

Browse source
This commit is contained in:
Igor Katson 2023-12-06 00:26:52 +00:00
parent fd17ddc46b
commit 91873ed287
No known key found for this signature in database
GPG key ID: B4EC22B66D61A3F5
1 changed files with 3 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -91,7 +91,7 @@ use crate::{
}, },
session::CheckedIncomingConnection, session::CheckedIncomingConnection,
spawn_utils::spawn, spawn_utils::spawn,
torrent_state::peer::Peer, torrent_state::{peer::Peer, utils::atomic_inc},
tracker_comms::{TrackerError, TrackerRequest, TrackerRequestEvent, TrackerResponse}, tracker_comms::{TrackerError, TrackerRequest, TrackerRequestEvent, TrackerResponse},
type_aliases::{PeerHandle, BF}, type_aliases::{PeerHandle, BF},
}; };
@ -394,6 +394,7 @@ impl TorrentStateLive {
peer.stats.counters.clone() peer.stats.counters.clone()
} }
Entry::Vacant(vac) => { Entry::Vacant(vac) => {
atomic_inc(&self.peers.stats.seen);
let peer = Peer::new_live_for_incoming_connection( let peer = Peer::new_live_for_incoming_connection(
Id20(checked_peer.handshake.peer_id), Id20(checked_peer.handshake.peer_id),
tx.clone(), tx.clone(),
@ -404,9 +405,7 @@ impl TorrentStateLive {
counters counters
} }
}; };
counters atomic_inc(&counters.incoming_connections);
.incoming_connections
.fetch_add(1, Ordering::Relaxed);
self.spawn( self.spawn(
"incoming peer", "incoming peer",