simon/nanoev
1
0
Fork 0
mirror of https://github.com/c-cube/nanoev.git synced 2025-12-06 11:15:48 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(posix): implement timers

Browse source
This commit is contained in:
Simon Cruanes 2025-05-02 13:48:12 -04:00
parent 03af765e43
commit abd651428d
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 19 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
src/posix/nanoev_posix.ml
View file

@ -98,9 +98,6 @@ type st = {
(** While in [poll()], changes get queued, so we don't invalidate the poll (** While in [poll()], changes get queued, so we don't invalidate the poll
buffer before the syscall returns *) buffer before the syscall returns *)
} }
(* TODO: [Thread.t] field to remember the owner thread, and
thread-safe queue for externally queued tasks.
Only owner thread can call [step]. *)
let[@inline] queue_task_ (self : st) t : unit = let[@inline] queue_task_ (self : st) t : unit =
Sync_queue.push self.queued_tasks t Sync_queue.push self.queued_tasks t
@ -308,12 +305,30 @@ let step (self : st) : unit =
let@ _sp = Trace_.with_span ~__FILE__ ~__LINE__ "nanoev.posix.step" in let@ _sp = Trace_.with_span ~__FILE__ ~__LINE__ "nanoev.posix.step" in
self.owner_thread <- Thread.(id (self ())); self.owner_thread <- Thread.(id (self ()));
let now = now_ns () in
let timeout_ns : int64 = let timeout_ns : int64 =
match next_deadline_ self with match next_deadline_ self with
| None -> 30_000_000_000L | None -> 30_000_000_000L
| Some d -> Int64.max 0L (Int64.sub d (now_ns ())) | Some d -> Int64.max 0L (Int64.sub d now)
in in
(* run timers *)
while
if Heap.is_empty self.timer then
false
else (
let (Timer t) = Heap.peek_min_exn self.timer in
if t.deadline <= now then (
ignore (Heap.pop_min_exn self.timer : timer_ev);
t.f t.x t.y;
true
) else
false
)
do
()
done;
(* process all queued tasks. (* process all queued tasks.
NOTE: race condition: if another thread queues tasks after we do NOTE: race condition: if another thread queues tasks after we do