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

fix build

Browse source
This commit is contained in:
Simon Cruanes 2024-02-10 01:00:07 -05:00
parent 0605ef4a1e
commit e0f5b5bbcb
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
4 changed files with 10 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
src/core/suspend_.ml
View file

@ -1,5 +1,3 @@
module A = Atomic_
type suspension = unit Exn_bt.result -> unit type suspension = unit Exn_bt.result -> unit
type task = unit -> unit type task = unit -> unit

12
src/lwt/IO.ml
View file

@ -11,12 +11,12 @@ let rec read fd buf i len : int =
Moonpool.Private.Suspend_.suspend Moonpool.Private.Suspend_.suspend
{ {
handle = handle =
(fun ~ls ~run:_ ~resume sus -> (fun ~run:_ ~resume sus ->
Perform_action_in_lwt.schedule Perform_action_in_lwt.schedule
@@ Action.Wait_readable @@ Action.Wait_readable
( fd, ( fd,
fun cancel -> fun cancel ->
resume ~ls sus @@ Ok (); resume sus @@ Ok ();
Lwt_engine.stop_event cancel )); Lwt_engine.stop_event cancel ));
}; };
read fd buf i len read fd buf i len
@ -33,12 +33,12 @@ let rec write_once fd buf i len : int =
Moonpool.Private.Suspend_.suspend Moonpool.Private.Suspend_.suspend
{ {
handle = handle =
(fun ~ls ~run:_ ~resume sus -> (fun ~run:_ ~resume sus ->
Perform_action_in_lwt.schedule Perform_action_in_lwt.schedule
@@ Action.Wait_writable @@ Action.Wait_writable
( fd, ( fd,
fun cancel -> fun cancel ->
resume ~ls sus @@ Ok (); resume sus @@ Ok ();
Lwt_engine.stop_event cancel )); Lwt_engine.stop_event cancel ));
}; };
write_once fd buf i len write_once fd buf i len
@ -60,12 +60,12 @@ let sleep_s (f : float) : unit =
Moonpool.Private.Suspend_.suspend Moonpool.Private.Suspend_.suspend
{ {
handle = handle =
(fun ~ls ~run:_ ~resume sus -> (fun ~run:_ ~resume sus ->
Perform_action_in_lwt.schedule Perform_action_in_lwt.schedule
@@ Action.Sleep @@ Action.Sleep
( f, ( f,
false, false,
fun cancel -> fun cancel ->
resume ~ls sus @@ Ok (); resume sus @@ Ok ();
Lwt_engine.stop_event cancel )); Lwt_engine.stop_event cancel ));
} }

4
src/lwt/base.ml
View file

@ -107,8 +107,8 @@ let await_lwt (fut : _ Lwt.t) =
M.Private.Suspend_.suspend M.Private.Suspend_.suspend
{ {
handle = handle =
(fun ~ls ~run:_ ~resume sus -> (fun ~run:_ ~resume sus ->
let on_lwt_done _ = resume ~ls sus @@ Ok () in let on_lwt_done _ = resume sus @@ Ok () in
Perform_action_in_lwt.( Perform_action_in_lwt.(
schedule Action.(On_termination (fut, on_lwt_done)))); schedule Action.(On_termination (fut, on_lwt_done))));
}; };

4
src/lwt/moonpool_lwt.ml
View file

@ -48,12 +48,12 @@ module TCP_client = struct
Moonpool.Private.Suspend_.suspend Moonpool.Private.Suspend_.suspend
{ {
handle = handle =
(fun ~ls ~run:_ ~resume sus -> (fun ~run:_ ~resume sus ->
Perform_action_in_lwt.schedule Perform_action_in_lwt.schedule
@@ Action.Wait_writable @@ Action.Wait_writable
( sock, ( sock,
fun ev -> fun ev ->
resume ~ls sus @@ Ok (); resume sus @@ Ok ();
Lwt_engine.stop_event ev )); Lwt_engine.stop_event ev ));
}; };
true true