From a2a0e3d306997b3d58e918a48ea3638bf4591777 Mon Sep 17 00:00:00 2001 From: Simon Cruanes Date: Mon, 24 Jun 2024 12:11:44 -0400 Subject: [PATCH] wip --- src/unix/ev_loop.ml | 7 ------- test/unix/echo_server.ml | 4 ++-- 2 files changed, 2 insertions(+), 9 deletions(-) diff --git a/src/unix/ev_loop.ml b/src/unix/ev_loop.ml index d8e85263..274b3508 100644 --- a/src/unix/ev_loop.ml +++ b/src/unix/ev_loop.ml @@ -209,18 +209,11 @@ module Ev_loop = struct let reads, writes = IO_tbl.prepare_select self.io_tbl in A.set self.in_blocking_section true; 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 Unix.select (self.pipe_read :: reads) writes [] delay in 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; IO_tbl.handle_ready ~ignore_read:self.pipe_read self.io_tbl reads writes; diff --git a/test/unix/echo_server.ml b/test/unix/echo_server.ml index 12683bb0..d3b56450 100644 --- a/test/unix/echo_server.ml +++ b/test/unix/echo_server.ml @@ -10,8 +10,6 @@ let main ~port ~j () : unit = let@ _main_runner = MU.main in Trace.set_thread_name "main"; - Printf.printf "IN MAIN\n%!"; - Trace.message "foo1"; let@ server = 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)); Printf.printf "listening on %s\n%!" (MU.Sockaddr.show @@ MU.TCP_server.endpoint server); + + Trace.message "awaiting server"; MU.TCP_server.await server; ()