avoid thread blocking

citadel-tech · Feb 17, 2025 · 4ae42b9 · 4ae42b9
1 parent 13b8530
commit 4ae42b9
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/src/maker/server.rs b/src/maker/server.rs
@@ -248,6 +248,13 @@ fn network_bootstrap(maker: Arc<Maker>) -> Result<Option<Child>, MakerError> {
                 }
                 // Reset counter when success
                 i = 0;
+            } else {
+                // Do not block the process thread
+                status_sender
+                    .send(Err(MakerError::General(
+                        "Maximum retry limit reached, avoiding thread blocking",
+                    )))
+                    .unwrap();
             }
             i += 1;
             thread::sleep(HEART_BEAT_INTERVAL);
@@ -256,7 +263,7 @@ fn network_bootstrap(maker: Arc<Maker>) -> Result<Option<Child>, MakerError> {
 
     match status_recv.recv() {
         Ok(status) => {
-            if let Err(e) = status {
+            if let Err(e @ MakerError::UnexpectedMessage { .. }) = status {
                 log::error!("{:?}", e);
                 return Err(e);
             }