diff --git a/src/server.rs b/src/server.rs index 6a8af5b..6fa8d92 100644 --- a/src/server.rs +++ b/src/server.rs @@ -45,20 +45,20 @@ pub async fn server_mode(server_config: ServerConfiguration) { }); let keepalive_sec = server_config.interface.keepalive.clone(); - // let send2hnd_cl = send2hnd.clone(); - // let addrs_lcl = addresses.clone(); + let send2hnd_cl = send2hnd.clone(); + let addrs_lcl = addresses.clone(); if keepalive_sec > 0 { tokio::spawn(async move { let mut now = std::time::Instant::now(); - let kps = std::time::Duration::from_secs(keepalive_sec.clone().into()); + let kps = std::time::Duration::from_secs(5); loop { if now.elapsed() < kps { continue; } now = std::time::Instant::now(); - // let mut mmp = addrs_lcl.lock().await; - // mmp.values().for_each(|p| { - //let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr)); - // }); - // drop(mmp); + let mut mmp = addrs_lcl.lock().await; + mmp.values().for_each(|p| { + let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr)); + }); + drop(mmp); } }); }