From fa63a7e9e534d19f92498b2a0b2d645517abffd9 Mon Sep 17 00:00:00 2001
From: Ferdinand Schober <ferdinand.schober@fau.de>
Date: Sat, 21 Sep 2024 15:28:28 +0200
Subject: [PATCH] fix active

---
 src/connect.rs | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/src/connect.rs b/src/connect.rs
index bbbf0a0..3f3a1b4 100644
--- a/src/connect.rs
+++ b/src/connect.rs
@@ -186,7 +186,8 @@ async fn ping_pong(
 ) {
     loop {
         let (buf, len) = ProtoEvent::Ping.into();
-        if let Err(_) = conn.send(&buf[..len]).await {
+        if let Err(e) = conn.send(&buf[..len]).await {
+            log::warn!("send: {e}");
             disconnect(&server, handle, addr, &conns).await;
             break;
         }
@@ -194,6 +195,7 @@ async fn ping_pong(
         tokio::time::sleep(Duration::from_millis(500)).await;
 
         if server.active_addr(handle).is_none() {
+            log::warn!("no active addr");
             disconnect(&server, handle, addr, &conns).await;
         }
     }
@@ -211,11 +213,12 @@ async fn receive_loop(
     while let Ok(_) = conn.recv(&mut buf).await {
         if let Ok(event) = buf.try_into() {
             match event {
-                ProtoEvent::Pong => server.set_active_addr(handle, None),
+                ProtoEvent::Pong => server.set_active_addr(handle, Some(addr)),
                 event => tx.send((handle, event)).expect("channel closed"),
             }
         }
     }
+    log::warn!("recv error");
     disconnect(&server, handle, addr, &conns).await;
 }