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

remove debug mesages

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

6
src/unix/async_io.ml
View file

@ -196,7 +196,9 @@ module TCP_server = struct
loop () loop ()
in in
if can_start then ( if can_start then
let@ _sp = Tracing_.with_span "moonpool-unix.tcp-server.run" in
let sock = let sock =
try try
let sock = let sock =
@ -213,6 +215,7 @@ module TCP_server = struct
Fut.fulfill_idempotent promise @@ Error (Exn_bt.make e bt); Fut.fulfill_idempotent promise @@ Error (Exn_bt.make e bt);
Printexc.raise_with_backtrace e bt Printexc.raise_with_backtrace e bt
in in
while A.get st = Running do while A.get st = Running do
let client_sock, client_addr = accept_ sock in let client_sock, client_addr = accept_ sock in
let client_fd = Fd.create client_sock in let client_fd = Fd.create client_sock in
@ -237,7 +240,6 @@ module TCP_server = struct
in in
() ()
done done
)
end end
let create ?(after_init = ignore) ?listen ?buf_pool ?buf_size ~runner let create ?(after_init = ignore) ?listen ?buf_pool ?buf_size ~runner

1
src/unix/ev_loop.ml
View file

@ -207,6 +207,7 @@ 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, _ =
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;