mirror/rustdesk
1
0
Fork 0
mirror of https://github.com/rustdesk/rustdesk.git synced 2024-12-04 11:59:18 +08:00
Code Issues Actions 3 Packages Projects Releases Wiki Activity

reset onlinestatus after test rendezvous servers

Browse Source
This commit is contained in:
rustdesk 2023-06-27 22:24:08 +08:00
parent 56eac7294c
commit 8709b6bc93
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/common.rs
View File

@ -668,11 +668,13 @@ pub async fn get_nat_type(ms_timeout: u64) -> i32 {
crate::ipc::get_nat_type(ms_timeout).await crate::ipc::get_nat_type(ms_timeout).await
} }
// #[cfg(any(target_os = "android", target_os = "ios", feature = "cli"))] // used for client to test which server is faster in case stop-servic=Y
#[tokio::main(flavor = "current_thread")] #[tokio::main(flavor = "current_thread")]
async fn test_rendezvous_server_() { async fn test_rendezvous_server_() {
let servers = Config::get_rendezvous_servers(); let servers = Config::get_rendezvous_servers();
Config::reset_online(); if servers.len() <= 1 {
return;
}
let mut futs = Vec::new(); let mut futs = Vec::new();
for host in servers { for host in servers {
futs.push(tokio::spawn(async move { futs.push(tokio::spawn(async move {
@ -692,6 +694,7 @@ async fn test_rendezvous_server_() {
})); }));
} }
join_all(futs).await; join_all(futs).await;
Config::reset_online();
} }
// #[cfg(any(target_os = "android", target_os = "ios", feature = "cli"))] // #[cfg(any(target_os = "android", target_os = "ios", feature = "cli"))]