TheLanc3/lan-mouse
1
0
Fork 0
mirror of https://github.com/feschber/lan-mouse.git synced 2026-04-09 23:01:27 +03:00
Code Issues Packages Projects Releases Wiki Activity

fix active

Browse Source
This commit is contained in:
Ferdinand Schober
2024-09-21 15:28:28 +02:00
parent f825f3be53
commit fa63a7e9e5
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/connect.rs
View File

@@ -186,7 +186,8 @@ async fn ping_pong(
) { ) {
loop { loop {
let (buf, len) = ProtoEvent::Ping.into(); 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; disconnect(&server, handle, addr, &conns).await;
break; break;
} }
@@ -194,6 +195,7 @@ async fn ping_pong(
tokio::time::sleep(Duration::from_millis(500)).await; tokio::time::sleep(Duration::from_millis(500)).await;
if server.active_addr(handle).is_none() { if server.active_addr(handle).is_none() {
log::warn!("no active addr");
disconnect(&server, handle, addr, &conns).await; disconnect(&server, handle, addr, &conns).await;
} }
} }
@@ -211,11 +213,12 @@ async fn receive_loop(
while let Ok(_) = conn.recv(&mut buf).await { while let Ok(_) = conn.recv(&mut buf).await {
if let Ok(event) = buf.try_into() { if let Ok(event) = buf.try_into() {
match event { 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"), event => tx.send((handle, event)).expect("channel closed"),
} }
} }
} }
log::warn!("recv error");
disconnect(&server, handle, addr, &conns).await; disconnect(&server, handle, addr, &conns).await;
} }