startup: Add spinloop until daemon is ready

.direnv/flake-profile

@@ -1 +1 @@
-flake-profile-10-link
+flake-profile-11-link

.direnv/flake-profile-11-link

@@ -0,0 +1 @@
+/nix/store/51yb1yhqssknlmxvvscvj0cqbvs0z915-nix-shell-env

Cargo.toml

@@ -7,7 +7,7 @@ repository = "https://github.com/Xetibo/ReSet"
 license = "GPL-3.0-or-later"
 
 [dependencies]
-reset_daemon = "1.5.0"
+reset_daemon = "2.1.0"
 re_set-lib = "5.2.1"
 # re_set-lib = { git = "https://github.com/Xetibo/ReSet-Lib" }
 adw = { version = "0.6.0", package = "libadwaita", features = ["v1_4"] }

flake.nix

@@ -37,6 +37,8 @@
               # (rust-bin.selectLatestNightlyWith
               # (toolchain: toolchain.default))
               rust-bin.nightly."2024-05-10".default
+              rust-analyzer
+              clippy
             ];
           };
 

src/main.rs

@@ -1,3 +1,6 @@
+use std::hint::{self};
+use std::sync::atomic::AtomicBool;
+use std::sync::Arc;
 use std::thread;
 use std::time::Duration;
 
@@ -71,8 +74,12 @@ async fn daemon_check() {
         let res: Result<(), Error> = proxy.method_call(BASE, "RegisterClient", ("ReSet",));
         res
     });
+    let ready = Arc::new(AtomicBool::new(false));
     let res = handle.join();
     if res.unwrap().is_err() {
-        run_daemon().await;
+        run_daemon(Some(ready.clone())).await;
+    }
+    while !ready.load(std::sync::atomic::Ordering::SeqCst) {
+        hint::spin_loop();
     }
 }