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

single system call for signal blocking

Browse source
This commit is contained in:
Simon Cruanes 2025-03-13 15:42:04 -04:00
parent dd88008a0a
commit f0ea8c294d
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 16 additions and 13 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
src/core/worker_loop_.ml
View file

@ -103,9 +103,10 @@ let with_handler ~ops:_ self f = f ()
[@@@endif] [@@@endif]
let worker_loop (type st) ~block_signals ~(ops : st ops) (self : st) : unit = let worker_loop (type st) ~block_signals ~(ops : st ops) (self : st) : unit =
if block_signals then if block_signals then (
List.iter try
(fun signal -> try Sys.set_signal signal Sys.Signal_ignore with _ -> ()) ignore
(Unix.sigprocmask SIG_BLOCK
[ [
Sys.sigterm; Sys.sigterm;
Sys.sigpipe; Sys.sigpipe;
@ -114,8 +115,10 @@ let worker_loop (type st) ~block_signals ~(ops : st ops) (self : st) : unit =
Sys.sigalrm; Sys.sigalrm;
Sys.sigusr1; Sys.sigusr1;
Sys.sigusr2; Sys.sigusr2;
Sys.sigvtalrm; ]
]; : _ list)
with _ -> ()
);
let cur_fiber : fiber ref = ref _dummy_fiber in let cur_fiber : fiber ref = ref _dummy_fiber in
let runner = ops.runner self in let runner = ops.runner self in