diff --git a/Cargo.toml b/Cargo.toml index 87218fb..8dd4ae4 100644 --- a/Cargo.toml +++ b/Cargo.toml @@ -8,7 +8,7 @@ members = [ ] [workspace.dependencies] -p2p = { package = "atm0s-small-p2p", version = "0.1.0" } +p2p = { package = "atm0s-small-p2p", version = "0.2.0" } protocol = { path = "crates/protocol", package = "atm0s-reverse-proxy-protocol", version = "0.3.0" } protocol-ed25519 = { path = "crates/protocol_ed25519", package = "atm0s-reverse-proxy-protocol-ed25519", version = "0.1.4" } @@ -36,7 +36,7 @@ url = "2.5" base64 = "0.22" local-ip-address = "0.6" derive_more = "1.0" -thiserror = "1.0" +thiserror = "2.0" anyhow = "1.0" parking_lot = "0.12" futures = "0.3" diff --git a/bin/relayer/src/lib.rs b/bin/relayer/src/lib.rs index 8545673..e404814 100644 --- a/bin/relayer/src/lib.rs +++ b/bin/relayer/src/lib.rs @@ -122,7 +122,7 @@ where let mut sdn_alias = AliasService::new(sdn.create_service(ALIAS_SERVICE.into())); let sdn_alias_requester = sdn_alias.requester(); - tokio::spawn(async move { while sdn_alias.recv().await.is_ok() {} }); + tokio::spawn(async move { while sdn_alias.run_loop().await.is_ok() {} }); let sdn_proxy_service = sdn.create_service(PROXY_TO_AGENT_SERVICE.into()); let sdn_tunnel_service = sdn.create_service(TUNNEL_TO_CLUSTER_SERVICE.into()); let tunnel_service_ctx = TunnelServiceCtx {