Cuprate/cuprate
Cuprate/cuprate
1
0
Fork 0
mirror of https://github.com/Cuprate/cuprate.git synced 2025-02-02 03:06:36 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

small changes

Browse source
This commit is contained in:
Boog900 2024-05-13 23:56:00 +01:00
parent e59bb0a1f5
commit 6d3096eb03
No known key found for this signature in database
GPG key ID: 42AB1287CB0041C2
1 changed files with 4 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
p2p/cuprate-p2p/src/client_pool.rs
View file

@ -17,6 +17,7 @@ use tokio::sync::mpsc;
use monero_p2p::{
client::{Client, InternalPeerID},
handles::ConnectionHandle,
ConnectionDirection, NetworkZone,
};
@ -24,7 +25,6 @@ mod disconnect_monitor;
mod drop_guard_client;
pub use drop_guard_client::ClientPoolDropGuard;
use monero_p2p::handles::ConnectionHandle;
/// The client pool, which holds currently connected free peers.
///
@ -33,8 +33,9 @@ pub struct ClientPool<N: NetworkZone> {
/// The connected [`Client`]s.
clients: DashMap<InternalPeerID<N::Addr>, Client<N>>,
/// A set of outbound clients, as these allow accesses/ mutation from different threads
/// a peer ID in here does not mean the peer is definitely in `clients` , if the peer is
/// in both here and `clients` it is defiantly an outbound peer,
/// a peer ID in here does not mean the peer is in `clients` as it could have been removed
/// by another thread. However, if the peer is in both here and `clients` it is defiantly
/// an outbound peer,
outbound_clients: DashSet<InternalPeerID<N::Addr>>,
/// A channel to send new peer ids down to monitor for disconnect.