Changes to be committed:
modified: src/server.rs
This commit is contained in:
parent
26d819f626
commit
3c85631626
@ -46,18 +46,18 @@ pub async fn server_mode(server_config: ServerConfiguration) {
|
|||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
let keepalive_sec = server_config.interface.keepalive;
|
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 {
|
||||||
loop {
|
loop {
|
||||||
thread::sleep(time::Duration::from_secs(keepalive_sec.into()));
|
thread::sleep(time::Duration::from_secs(keepalive_sec.into()));
|
||||||
let mp = addrs_lcl.lock().await;
|
let mmp = addrs_lcl.lock().await;
|
||||||
mp.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(mp);
|
drop(mmp);
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
Loading…
x
Reference in New Issue
Block a user