From 8164317b1980259fb25d1ce9d7ded934201fd398 Mon Sep 17 00:00:00 2001 From: Maple Date: Sat, 11 Apr 2026 21:59:37 +0200 Subject: [PATCH] fix friends connection --- prudpv0/src/server.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/prudpv0/src/server.rs b/prudpv0/src/server.rs index 4921b3f..34c7647 100644 --- a/prudpv0/src/server.rs +++ b/prudpv0/src/server.rs @@ -6,7 +6,6 @@ use std::{ Arc, LazyLock, Weak, atomic::{AtomicBool, AtomicU32}, }, - thread::sleep, time::Duration, }; @@ -30,7 +29,7 @@ use tokio::{ net::{TcpSocket, UdpSocket}, spawn, sync::{Mutex, RwLock}, - time::Instant, + time::{Instant, sleep}, }; use crate::{ @@ -170,7 +169,7 @@ impl Server { async fn timeout_thread(self: Arc, conn: Weak>) { loop { let Some(conn) = conn.upgrade() else { break }; - sleep(Duration::from_secs(3)); + sleep(Duration::from_secs(3)).await; let mut inner = conn.inner.lock().await; if (Instant::now() - inner.last_action).as_secs() > 5 { @@ -259,6 +258,7 @@ impl Server { }; let pid = ci.get_user_id(); + println!("user with pid {} is connecting", pid); let buf_conn = new_backend_connection(&self.param, addr, pid).await; let Some(buf_conn) = buf_conn else { error!("unable to connect to backend");