From 8f365e32db9ff98ffce581f997090e608fee3995 Mon Sep 17 00:00:00 2001 From: asxalex Date: Tue, 16 Jul 2024 16:21:37 +0800 Subject: [PATCH] changed the register_with_local_peers --- src/network/packet.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/network/packet.rs b/src/network/packet.rs index 2e08704..2d5b124 100644 --- a/src/network/packet.rs +++ b/src/network/packet.rs @@ -258,7 +258,7 @@ pub async fn handle_packet_peer_info( sock.to_string() ); send_register(eee, &sock, &None).await; - register_with_local_peers(eee).await; + // register_with_local_peers(eee).await; } None => { debug!("Rx PEERINFO unknown peer: {}", ip_to_string(&pi.dst_ip)); @@ -795,7 +795,6 @@ pub async fn check_query_peer_info(eee: &Node, dst_ip: u32) { debug!("insert peer {} to pending", ip_to_string(&dst_ip)); println!("insert peer {} to pending", ip_to_string(&dst_ip)); eee.pending_peers.insert_peer(peer.clone()); - register_with_local_peers(eee).await; scan = peer; } Some(s) => { @@ -819,6 +818,7 @@ pub async fn check_query_peer_info(eee: &Node, dst_ip: u32) { .await; */ debug!("sending query for {}", ip_to_string(&dst_ip)); + register_with_local_peers(eee).await; if let Ok(()) = send_query_peer(eee, dst_ip).await { scan.last_sent_query.store(now, Ordering::Relaxed); }