diff options
author | hozan23 <hozan23@karyontech.net> | 2024-05-25 07:15:02 +0200 |
---|---|---|
committer | hozan23 <hozan23@karyontech.net> | 2024-05-25 07:15:02 +0200 |
commit | e022b2b77e3e98f0f444f637f96e74e6a6f990cf (patch) | |
tree | 1d599938f8d97eaa9a6cbdc8ff83eefeae966201 /p2p/src/peer_pool.rs | |
parent | 998568ab76cc8ba36fe47d5fca17bcc997aa391c (diff) |
p2p: rename connection.rs to conn_queue.rs
Diffstat (limited to 'p2p/src/peer_pool.rs')
-rw-r--r-- | p2p/src/peer_pool.rs | 8 |
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. |