alterwain/Frida
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Changes to be committed:

Browse Source 
modified:   src/server.rs
This commit is contained in:
Michael Wain 2024-08-24 02:44:33 +03:00
parent 9181519ab0
commit 267a861ebb
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/server.rs
View File

@ -45,20 +45,20 @@ pub async fn server_mode(server_config: ServerConfiguration) {
}); });
let keepalive_sec = server_config.interface.keepalive.clone(); let keepalive_sec = server_config.interface.keepalive.clone();
// let send2hnd_cl = send2hnd.clone(); let send2hnd_cl = send2hnd.clone();
// let addrs_lcl = addresses.clone(); let addrs_lcl = addresses.clone();
if keepalive_sec > 0 { if keepalive_sec > 0 {
tokio::spawn(async move { tokio::spawn(async move {
let mut now = std::time::Instant::now(); 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 { loop {
if now.elapsed() < kps { continue; } if now.elapsed() < kps { continue; }
now = std::time::Instant::now(); now = std::time::Instant::now();
// let mut mmp = addrs_lcl.lock().await; let mut mmp = addrs_lcl.lock().await;
// mmp.values().for_each(|p| { mmp.values().for_each(|p| {
//let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr)); let _ = send2hnd_cl.send((UDPKeepAlive{}.serialize(), p.addr));
// }); });
// drop(mmp); drop(mmp);
} }
}); });
} }