From a80aaca9940948bca6ed8af91f7af29259242ccd Mon Sep 17 00:00:00 2001 From: ghassmo Date: Fri, 29 Apr 2022 13:55:06 +0300 Subject: [PATCH] net3: acceptor print an info msg once accept a clinet --- src/net3/acceptor.rs | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/src/net3/acceptor.rs b/src/net3/acceptor.rs index 178372ef2..2c9826d3f 100644 --- a/src/net3/acceptor.rs +++ b/src/net3/acceptor.rs @@ -2,7 +2,7 @@ use async_std::{stream::StreamExt, sync::Arc}; use std::net::SocketAddr; use futures_rustls::TlsStream; -use log::error; +use log::{error, info}; use smol::Executor; use url::Url; @@ -92,6 +92,8 @@ impl Acceptor { let result: Result<()> = { let stream = stream?; let peer_addr = peer_addr_to_url(stream.peer_addr()?, "tcp")?; + info!("Accepted client: {}", peer_addr); + let channel = Channel::new(Box::new(stream), peer_addr).await; self.channel_subscriber.notify(Ok(channel)).await; Ok(()) @@ -99,6 +101,7 @@ impl Acceptor { if let Err(err) = result { error!("Error listening for connections: {}", err); + return Err(Error::ServiceStopped) } } } @@ -126,7 +129,7 @@ impl Acceptor { let result: Result<()> = { let stream = stream?; let peer_addr = peer_addr_to_url(stream.peer_addr()?, "tls")?; - + info!("Accepted client: {}", peer_addr); let stream = acceptor.accept(stream).await; if let Err(err) = stream { @@ -143,6 +146,7 @@ impl Acceptor { if let Err(err) = result { error!("Error listening for connections: {}", err); + return Err(Error::ServiceStopped) } } }