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

cleanup worker loop

Browse source
This commit is contained in:
Simon Cruanes 2025-07-09 21:00:11 -04:00
parent e09c809a45
commit f53dbe4dda
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/core/worker_loop_.ml
View file

@ -39,8 +39,8 @@ let[@inline] raise_with_bt exn =
let bt = Printexc.get_raw_backtrace () in let bt = Printexc.get_raw_backtrace () in
Printexc.raise_with_backtrace exn bt Printexc.raise_with_backtrace exn bt
let with_handler (type st arg) ~(ops : st ops) (self : st) : let with_handler (type st) ~(ops : st ops) (self : st) : (unit -> unit) -> unit
(unit -> unit) -> unit = =
let current = let current =
Some Some
(fun k -> (fun k ->
@ -145,7 +145,7 @@ module Fine_grained (Args : FINE_GRAINED_ARGS) () = struct
cur_fiber := _dummy_fiber; cur_fiber := _dummy_fiber;
TLS.set k_cur_fiber _dummy_fiber TLS.set k_cur_fiber _dummy_fiber
let setup (type st) ~block_signals () : unit = let setup ~block_signals () : unit =
if !state <> New then invalid_arg "worker_loop.setup: not a new instance"; if !state <> New then invalid_arg "worker_loop.setup: not a new instance";
state := Ready; state := Ready;