From cb163011573e91426e4a48f86e29ac387a725146 Mon Sep 17 00:00:00 2001
From: Jussi Saurio <jussi.saurio@gmail.com>
Date: Sat, 12 Jul 2025 10:24:49 +0300
Subject: [PATCH] sim: return LimboError::Busy when busy, instead of looping
 forever

---
 simulator/generation/plan.rs  | 14 +++++++++++---
 simulator/runner/execution.rs |  4 +++-
 2 files changed, 14 insertions(+), 4 deletions(-)

diff --git a/simulator/generation/plan.rs b/simulator/generation/plan.rs
index fa5ba86c0..60e4a7da6 100644
--- a/simulator/generation/plan.rs
+++ b/simulator/generation/plan.rs
@@ -446,7 +446,9 @@ impl Interaction {
                     StepResult::Done => {
                         break;
                     }
-                    StepResult::Busy => {}
+                    StepResult::Busy => {
+                        return Err(turso_core::LimboError::Busy);
+                    }
                 }
             }
 
@@ -579,7 +581,10 @@ impl Interaction {
                     StepResult::Done => {
                         break;
                     }
-                    StepResult::Interrupt | StepResult::Busy => {}
+                    StepResult::Busy => {
+                        return Err(turso_core::LimboError::Busy);
+                    }
+                    StepResult::Interrupt => {}
                 }
             }
 
@@ -646,7 +651,10 @@ impl Interaction {
                     StepResult::Done => {
                         break;
                     }
-                    StepResult::Interrupt | StepResult::Busy => {}
+                    StepResult::Busy => {
+                        return Err(turso_core::LimboError::Busy);
+                    }
+                    StepResult::Interrupt => {}
                 }
             }
 
diff --git a/simulator/runner/execution.rs b/simulator/runner/execution.rs
index 6b4442a57..ef87e25bc 100644
--- a/simulator/runner/execution.rs
+++ b/simulator/runner/execution.rs
@@ -268,7 +268,9 @@ fn limbo_integrity_check(conn: &Arc<Connection>) -> Result<()> {
             StepResult::Done => {
                 break;
             }
-            StepResult::Busy => {}
+            StepResult::Busy => {
+                return Err(LimboError::Busy);
+            }
         }
     }