Fix fsevents loop

mirage · May 15, 2024 · 9b83ce7 · 9b83ce7
1 parent 423e860
commit 9b83ce7
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/src/backend.fsevents.ml b/src/backend.fsevents.ml
@@ -19,15 +19,15 @@ let start_runloop dir =
   let stream = Fsevents_lwt.stream watcher in
   let event_stream = Fsevents_lwt.event_stream watcher in
   let _scheduler =
-    Lwt_eio.run_lwt @@ fun () ->
+    Lwt_eio.run_lwt_in_main @@ fun () ->
     Cf_lwt.RunLoop.run_thread (fun runloop ->
         Fsevents.schedule_with_run_loop event_stream runloop run_loop_mode;
         if not (Fsevents.start event_stream) then
           prerr_endline "failed to start FSEvents stream")
   in
   (* FIXME: should probably do something with the scheduler *)
   let stop_scheduler () =
-    (Lwt_eio.run_lwt @@ fun () -> Fsevents_lwt.flush watcher);
+    (Lwt_eio.run_lwt_in_main @@ fun () -> Fsevents_lwt.flush watcher);
     Fsevents_lwt.stop watcher;
     Fsevents_lwt.invalidate watcher;
     Fsevents_lwt.release watcher
@@ -44,7 +44,7 @@ let listen ~sw stream fn =
         fn @@ path)
       stream
   in
-  Core.stoppable ~sw (fun () -> Lwt_eio.run_lwt iter)
+  Core.stoppable ~sw (fun () -> Lwt_eio.run_lwt_in_main iter)
 
 (* Note: we use FSevents to detect any change, and we re-read the full
    tree on every change (so very similar to active polling, but
@@ -64,7 +64,7 @@ let v ~sw =
           events := List.rev t;
           Lwt.return (`File h)
     in
-    let wait_for_changes () = Lwt_eio.run_lwt wait_for_changes in
+    let wait_for_changes () = Lwt_eio.run_lwt_in_main wait_for_changes in
     let unlisten =
       listen ~sw stream (fun path ->
           events := path :: !events;