hongshaorou/rustdesk
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

also check --server in loop

Browse Source
This commit is contained in:
rustdesk 2024-06-19 21:29:54 +08:00
parent 77f1c7e74c
commit 0bf9de8256
1 changed files with 20 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/platform/macos.rs
View File

@ -514,27 +514,31 @@ pub fn start_os_service() {
if server.is_none() { if server.is_none() {
server = get_server_start_time(&mut sys, &path); server = get_server_start_time(&mut sys, &path);
} }
if let Some((start_time, pid)) = server { let Some((start_time, pid)) = server else {
if my_start_time <= start_time + 1 { log::error!(
log::error!( "Agent not started yet, please restart --server first to make delegate work",
);
std::process::exit(-1);
};
if my_start_time <= start_time + 1 {
log::error!(
"Agent start later, {my_start_time} vs {start_time}, please start --server first to make delegate work", "Agent start later, {my_start_time} vs {start_time}, please start --server first to make delegate work",
); );
std::process::exit(-1); std::process::exit(-1);
} }
// only refresh this pid and check if valid, no need to refresh all processes since refreshing all is expensive, about 10ms on my machine // only refresh this pid and check if valid, no need to refresh all processes since refreshing all is expensive, about 10ms on my machine
if !sys.refresh_process_specifics(pid, ProcessRefreshKind::new()) { if !sys.refresh_process_specifics(pid, ProcessRefreshKind::new()) {
server = None; server = None;
continue; continue;
} }
if let Some(p) = sys.process(pid.into()) { if let Some(p) = sys.process(pid.into()) {
if let Some(p) = get_server_start_time_of(p, &path) { if let Some(p) = get_server_start_time_of(p, &path) {
server = Some((p, pid)); server = Some((p, pid));
} else {
server = None;
}
} else { } else {
server = None; server = None;
} }
} else {
server = None;
} }
}); });