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:23:50 +03:00
parent 0bf8981ab1
commit 9181519ab0
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/server.rs
View File

@ -46,7 +46,7 @@ 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();
@ -54,11 +54,11 @@ pub async fn server_mode(server_config: ServerConfiguration) {
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);
} }
}); });
} }