aboutsummaryrefslogtreecommitdiff
path: root/p2p/src/peer_pool.rs
diff options
context:
space:
mode:
authorhozan23 <hozan23@karyontech.net>2024-05-25 07:15:02 +0200
committerhozan23 <hozan23@karyontech.net>2024-05-25 07:15:02 +0200
commite022b2b77e3e98f0f444f637f96e74e6a6f990cf (patch)
tree1d599938f8d97eaa9a6cbdc8ff83eefeae966201 /p2p/src/peer_pool.rs
parent998568ab76cc8ba36fe47d5fca17bcc997aa391c (diff)
p2p: rename connection.rs to conn_queue.rs
Diffstat (limited to 'p2p/src/peer_pool.rs')
-rw-r--r--p2p/src/peer_pool.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/p2p/src/peer_pool.rs b/p2p/src/peer_pool.rs
index 07bb73d..79fd4b4 100644
--- a/p2p/src/peer_pool.rs
+++ b/p2p/src/peer_pool.rs
@@ -21,7 +21,7 @@ use karyon_net::Conn;
use crate::{
config::Config,
- connection::{ConnDirection, ConnQueue},
+ conn_queue::{ConnDirection, ConnQueue},
message::{get_msg_payload, NetMsg, NetMsgCmd, VerAckMsg, VerMsg},
monitor::{Monitor, PeerPoolEvent},
peer::{ArcPeer, Peer, PeerID},
@@ -99,11 +99,11 @@ impl PeerPool {
/// Listens to a new connection from the connection queue
pub async fn listen_loop(self: Arc<Self>) {
loop {
- let new_conn = self.conn_queue.next().await;
- let signal = new_conn.disconnect_signal;
+ let conn = self.conn_queue.next().await;
+ let signal = conn.disconnect_signal;
let result = self
- .new_peer(new_conn.conn, &new_conn.direction, signal.clone())
+ .new_peer(conn.conn, &conn.direction, signal.clone())
.await;
// Only send a disconnect signal if there is an error when adding a peer.