Don't try to stop the runloop until it's definitely running

notify-rs · Nov 22, 2017 · 0ce9169 · 0ce9169
1 parent 9956260
commit 0ce9169
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/src/fsevent.rs b/src/fsevent.rs
@@ -85,6 +85,10 @@ struct StreamContextInfo {
     recursive_info: HashMap<PathBuf, bool>,
 }
 
+extern "C" {
+    pub fn CFRunLoopIsWaiting(runloop: cf::CFRunLoopRef) -> bool;
+}
+
 impl FsEventWatcher {
     #[inline]
     fn is_running(&self) -> bool {
@@ -99,6 +103,11 @@ impl FsEventWatcher {
         if let Some(runloop) = self.runloop {
             unsafe {
                 let runloop = runloop as *mut libc::c_void;
+
+                while !CFRunLoopIsWaiting(runloop) {
+                    thread::yield_now();
+                }
+
                 cf::CFRunLoopStop(runloop);
             }
         }