rename

paradigmxyz · Aug 22, 2024 · 839b791 · 839b791
1 parent 2d5eef4
commit 839b791
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/crates/net/network-api/src/lib.rs b/crates/net/network-api/src/lib.rs
@@ -184,7 +184,7 @@ pub trait Peers: PeersInfo {
     /// Disconnect an existing connection to the given peer using the provided reason
     fn disconnect_peer_with_reason(&self, peer: PeerId, reason: DisconnectReason);
 
-    /// Connect to the given peer. NOTE: if the maximum number out outbound sessions is reached, 
+    /// Connect to the given peer. NOTE: if the maximum number out outbound sessions is reached,
     /// this won't do anything. See `reth_network::SessionManager::dial_outbound`.
     fn reconnect_peer(&self, addr: SocketAddr, peer: PeerId);
 

diff --git a/crates/net/network/src/manager.rs b/crates/net/network/src/manager.rs
@@ -588,7 +588,7 @@ impl NetworkManager {
             NetworkHandleMessage::DisconnectPeer(peer_id, reason) => {
                 self.swarm.sessions_mut().disconnect(peer_id, reason);
             }
-            NetworkHandleMessage::ReConnect(socket_addr, peer_id) => {
+            NetworkHandleMessage::Connect(socket_addr, peer_id) => {
                 self.swarm.sessions_mut().dial_outbound(socket_addr, peer_id);
             }
             NetworkHandleMessage::SetNetworkState(net_state) => {

diff --git a/crates/net/network/src/network.rs b/crates/net/network/src/network.rs
@@ -304,7 +304,7 @@ impl Peers for NetworkHandle {
     /// Sends a message to the [`NetworkManager`](crate::NetworkManager) to reconnect to the given
     /// peer.
     fn reconnect_peer(&self, addr: SocketAddr, peer: PeerId) {
-        self.send_message(NetworkHandleMessage::ReConnect(addr, peer))
+        self.send_message(NetworkHandleMessage::Connect(addr, peer))
     }
 
     /// Send a reputation change for the given peer.
@@ -487,6 +487,6 @@ pub(crate) enum NetworkHandleMessage {
     DiscoveryListener(UnboundedSender<DiscoveryEvent>),
     /// Adds an additional `RlpxSubProtocol`.
     AddRlpxSubProtocol(RlpxSubProtocol),
-    /// Reconnect to the given peer.
-    ReConnect(SocketAddr, PeerId),
+    /// Connect to the given peer.
+    Connect(SocketAddr, PeerId),
 }