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

wip

Browse source
This commit is contained in:
Simon Cruanes 2024-06-24 12:11:44 -04:00
parent a19106d74e
commit a2a0e3d306
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
2 changed files with 2 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

7
src/unix/ev_loop.ml
View file

@ -209,18 +209,11 @@ module Ev_loop = struct
let reads, writes = IO_tbl.prepare_select self.io_tbl in let reads, writes = IO_tbl.prepare_select self.io_tbl in
A.set self.in_blocking_section true; A.set self.in_blocking_section true;
let reads, writes, _ = let reads, writes, _ =
Tracing_.message
(Printf.sprintf "select: %d read (+selfpipe), %d writes"
(List.length reads) (List.length writes));
let@ _sp = Tracing_.with_span "moonpool-unix.evloop.select" in let@ _sp = Tracing_.with_span "moonpool-unix.evloop.select" in
Unix.select (self.pipe_read :: reads) writes [] delay Unix.select (self.pipe_read :: reads) writes [] delay
in in
A.set self.in_blocking_section false; A.set self.in_blocking_section false;
Tracing_.message
(Printf.sprintf "select: %d read ready, %d writes ready"
(List.length reads) (List.length writes));
drain_pipe_ self; drain_pipe_ self;
IO_tbl.handle_ready ~ignore_read:self.pipe_read self.io_tbl reads writes; IO_tbl.handle_ready ~ignore_read:self.pipe_read self.io_tbl reads writes;

4
test/unix/echo_server.ml
View file

@ -10,8 +10,6 @@ let main ~port ~j () : unit =
let@ _main_runner = MU.main in let@ _main_runner = MU.main in
Trace.set_thread_name "main"; Trace.set_thread_name "main";
Printf.printf "IN MAIN\n%!";
Trace.message "foo1";
let@ server = let@ server =
MU.TCP_server.with_server ~runner (MU.Sockaddr.any port) MU.TCP_server.with_server ~runner (MU.Sockaddr.any port)
@ -41,6 +39,8 @@ let main ~port ~j () : unit =
(MU.Sockaddr.show @@ MU.TCP_server.endpoint server)); (MU.Sockaddr.show @@ MU.TCP_server.endpoint server));
Printf.printf "listening on %s\n%!" Printf.printf "listening on %s\n%!"
(MU.Sockaddr.show @@ MU.TCP_server.endpoint server); (MU.Sockaddr.show @@ MU.TCP_server.endpoint server);
Trace.message "awaiting server";
MU.TCP_server.await server; MU.TCP_server.await server;
() ()