Review poll timer logic for scheduled callbacks

gi0baro · Jan 30, 2025 · b6ab444 · b6ab444
1 parent d90d02b
commit b6ab444
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/event_loop.rs b/src/event_loop.rs
@@ -110,7 +110,7 @@ impl EventLoop {
                 if let Some(timer) = guard_sched.peek() {
                     let tick = Instant::now().duration_since(self.epoch).as_micros();
                     if timer.when > tick {
-                        let dt = ((timer.when - tick) / 1000) as u64;
+                        let dt = (timer.when - tick) as u64;
                         sched_time = Some(dt);
                     }
                 }
@@ -128,7 +128,7 @@ impl EventLoop {
                     if sched_time.is_none() {
                         self.idle.store(true, atomic::Ordering::Release);
                     }
-                    let res = io.poll(&mut state.events, sched_time.map(Duration::from_millis));
+                    let res = io.poll(&mut state.events, sched_time.map(Duration::from_micros));
                     if let Err(ref err) = res {
                         if err.kind() == std::io::ErrorKind::Interrupted {
                             // if we got an interrupt, we retry ready events (as we might need to process signals)

diff --git a/tests/handles/test_handles.py b/tests/handles/test_handles.py
@@ -27,7 +27,7 @@ def stop():
         loop.stop()
 
     loop.call_later(0.001, cb, 2)
-    loop.call_later(1.0, stop)
+    loop.call_later(0.1, stop)
     loop.call_soon(cb, 1)
     loop.run_forever()
     assert calls == [1, 2]