From 326c54d5566d21b438a99b46db468d90e6e2c1f0 Mon Sep 17 00:00:00 2001
From: Sachandhan Ganesh <sachan.ganesh@gmail.com>
Date: Fri, 15 Jan 2021 12:37:41 -0800
Subject: [PATCH] add more debug stmts to tcp server

---
 src/tcp/server.rs | 6 ++++++
 src/tls/server.rs | 2 +-
 2 files changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/tcp/server.rs b/src/tcp/server.rs
index 43fd1de..136c3f1 100644
--- a/src/tcp/server.rs
+++ b/src/tcp/server.rs
@@ -29,8 +29,14 @@ impl Stream for TcpServer {
 
     fn poll_next(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Option<Self::Item>> {
         if let Some(Ok(conn)) = futures::executor::block_on(self.listener.incoming().next()) {
+            debug!(
+                "Received connection attempt from {}",
+                conn.peer_addr()
+                    .expect("Peer address could not be retrieved")
+            );
             Poll::Ready(Some(Connection::from(conn)))
         } else {
+            debug!("Shutting TCP server down at {}", self.local_addrs);
             Poll::Ready(None)
         }
     }
diff --git a/src/tls/server.rs b/src/tls/server.rs
index 64e44c9..70a7423 100644
--- a/src/tls/server.rs
+++ b/src/tls/server.rs
@@ -46,7 +46,7 @@ impl Stream for TlsServer {
             debug!("Received connection attempt from {}", peer_addr);
 
             if let Ok(tls_stream) = futures::executor::block_on(self.acceptor.accept(tcp_stream)) {
-                debug!("Established TLS connection from {}", peer_addr);
+                debug!("Completed TLS handshake with {}", peer_addr);
                 Poll::Ready(Some(Connection::from(TlsConnectionMetadata::Server {
                     local_addr,
                     peer_addr,
-- 
2.44.0