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

fix build on < 5.0

Browse source
This commit is contained in:
Simon Cruanes 2023-08-29 14:21:24 -04:00
parent c4bbec092a
commit 0345b65fb4
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/d_pool_.ml
View file

@ -14,7 +14,7 @@ type worker_state = {
(** Array of (optional) workers. (** Array of (optional) workers.
Workers are started/stop on demand. *) Workers are started/stop on demand. *)
let domains_ : (worker_state option * unit Domain_.t option) Lock.t array = let domains_ : (worker_state option * Domain_.t option) Lock.t array =
(* number of domains we spawn. Note that we spawn n-1 domains (* number of domains we spawn. Note that we spawn n-1 domains
because there already is the main domain running. *) because there already is the main domain running. *)
let n = max 1 (Domain_.recommended_number () - 1) in let n = max 1 (Domain_.recommended_number () - 1) in
@ -65,7 +65,7 @@ let work_ idx (st : worker_state) : unit =
let is_alive = let is_alive =
Lock.update_map domains_.(idx) (function Lock.update_map domains_.(idx) (function
| None, _ -> assert false | None, _ -> assert false
| Some (_st'), dom -> | Some _st', dom ->
assert (st == _st'); assert (st == _st');
if Atomic_.get st.th_count > 0 then if Atomic_.get st.th_count > 0 then
@ -91,7 +91,7 @@ let run_on (i : int) (f : unit -> unit) : unit =
Atomic_.incr w.th_count; Atomic_.incr w.th_count;
st, w st, w
| None, _dom -> | None, _dom ->
Option.iter Domain.join _dom; Option.iter Domain_.join _dom;
let w = { th_count = Atomic_.make 1; q = Bb_queue.create () } in let w = { th_count = Atomic_.make 1; q = Bb_queue.create () } in
let worker : domain = Domain_.spawn (fun () -> work_ i w) in let worker : domain = Domain_.spawn (fun () -> work_ i w) in
(Some w, Some worker), w) (Some w, Some worker), w)