diff options
| author | hozan23 <hozan23@karyontech.net> | 2024-07-15 13:16:01 +0200 |
|---|---|---|
| committer | hozan23 <hozan23@karyontech.net> | 2024-07-15 13:16:01 +0200 |
| commit | e15d3e6fd20b3f87abaad7ddec1c88b0e66419f9 (patch) | |
| tree | 7976f6993e4f6b3646f5bd6954189346d5ffd330 /p2p/src/discovery/mod.rs | |
| parent | 6c65232d741229635151671708556b9af7ef75ac (diff) | |
p2p: Major refactoring of the handshake protocol
Introduce a new protocol InitProtocol which can be used as the core protocol
for initializing a connection with a peer.
Move the handshake logic from the PeerPool module to the protocols directory and
build a handshake protocol that implements InitProtocol trait.
Diffstat (limited to 'p2p/src/discovery/mod.rs')
| -rw-r--r-- | p2p/src/discovery/mod.rs | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/p2p/src/discovery/mod.rs b/p2p/src/discovery/mod.rs index a9d99d6..a81a817 100644 --- a/p2p/src/discovery/mod.rs +++ b/p2p/src/discovery/mod.rs @@ -16,7 +16,8 @@ use karyon_net::{Conn, Endpoint}; use crate::{ config::Config, - conn_queue::{ConnDirection, ConnQueue}, + conn_queue::ConnQueue, + connection::ConnDirection, connector::Connector, listener::Listener, message::NetMsg, @@ -132,15 +133,11 @@ impl Discovery { let resolved_endpoint = self.start_listener(endpoint).await?; - if endpoint.addr()? != resolved_endpoint.addr()? { - info!("Resolved listen endpoint: {resolved_endpoint}"); - self.lookup_service - .set_listen_endpoint(&resolved_endpoint) - .await; - self.refresh_service - .set_listen_endpoint(&resolved_endpoint) - .await; - } + info!("Resolved listen endpoint: {resolved_endpoint}"); + self.lookup_service + .set_listen_endpoint(&resolved_endpoint)?; + self.refresh_service + .set_listen_endpoint(&resolved_endpoint)?; } // Start the lookup service |