From e022b2b77e3e98f0f444f637f96e74e6a6f990cf Mon Sep 17 00:00:00 2001 From: hozan23 Date: Sat, 25 May 2024 07:15:02 +0200 Subject: p2p: rename connection.rs to conn_queue.rs --- p2p/src/peer_pool.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'p2p/src/peer_pool.rs') 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) { 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. -- cgit v1.2.3