fix: user same logger throughout net module

riot/lib/io.ml

@@ -130,6 +130,7 @@ module Reader = struct
 
   let read : type src. src t -> buf:Buffer.t -> (int, [> `Closed ]) result =
    fun (Reader ((module R), src)) ~buf ->
+    Logger.trace (fun f -> f " IO.Reader.read");
     match R.read src ~buf with
     | Ok len -> Ok len
     | Error `Eof -> Ok 0

riot/lib/net.ml

@@ -41,10 +41,6 @@ end
 module Socket = struct
   include Runtime.Net.Socket
 
-  module Logger = Logger.Make (struct
-    let namespace = [ "riot"; "net"; "socket" ]
-  end)
-
   type listen_opts = {
     reuse_addr : bool;
     reuse_port : bool;
@@ -108,6 +104,7 @@ module Socket = struct
   let controlling_process _socket ~new_owner:_ = Ok ()
 
   let rec receive ?(timeout = Infinity) ~buf socket =
+    Logger.trace (fun f -> f "Riot.Net.Socket.receive");
     match Low_level.readv socket [| Io.Buffer.as_cstruct buf |] with
     | exception Fd.(Already_closed _) -> Error `Closed
     | `Abort reason -> Error (`Unix_error reason)

riot/riot.ml

@@ -7,7 +7,7 @@ let shutdown () =
   Scheduler.Pool.shutdown pool
 
 let run ?(rnd = Random.State.make_self_init ())
-    ?(workers = max 0 (Stdlib.Domain.recommended_domain_count () - 1)) main =
+    ?(workers = Int.max 0 (Stdlib.Domain.recommended_domain_count () - 1)) main =
   Log.debug (fun f -> f "Initializing Riot runtime...");
   Printexc.record_backtrace true;
   Pid.reset ();

test/io_reader_large_test.ml

@@ -33,7 +33,7 @@ let test_with_buffer capacity =
 let () =
   Riot.run @@ fun () ->
   let _ = Logger.start () |> Result.get_ok in
-  Logger.set_log_level (Some Trace);
+  Logger.set_log_level (Some Info);
   (* smallest buffer that will work than the target and the source*)
   test_with_buffer 4;
   (* smallest than the target and the source*)