Async unix debugging

.gitmodules

@@ -39,3 +39,6 @@
 [submodule "src/external/capnp-ocaml"]
 	path = src/external/capnp-ocaml
 	url = https://github.com/o1-labs/capnp-ocaml.git
+[submodule "src/external/async_unix"]
+	path = src/external/async_unix
+	url = https://github.com/nholland94/async_unix.git

src/external/dune

@@ -1 +1 @@
-(dirs :standard \ async_kernel)
+(dirs :standard \ async_kernel async_unix)

src/lib/child_processes/child_processes.ml

@@ -168,7 +168,10 @@ let reader_to_strict_pipe reader output_type =
     | `Chunks ->
         Reader.pipe reader
     | `Lines ->
-        Reader.lines reader
+        (* Reader.lines reader *)
+        Async_unix.Reader.lines
+          ~trace:({ Reader.trace = O1trace.time_execution' } : Reader.trace_f)
+          reader
   in
   Strict_pipe.Reader.of_linear_pipe { pipe; has_reader = false }
 

src/libp2p_ipc/libp2p_ipc.ml

@@ -678,12 +678,13 @@ let rec stream_messages frag_stream w =
 let read_incoming_messages reader =
   let r, w = Strict_pipe.create Strict_pipe.Synchronous in
   let fragment_stream = Fragment_stream.create () in
-  O1trace.time_execution "ipc_stream_messages" (fun () -> don't_wait_for (stream_messages fragment_stream w)) ;
+  O1trace.time_execution "ipc_stream_messages" (fun () ->
+      don't_wait_for (stream_messages fragment_stream w)) ;
   O1trace.time_execution "ipc_adding_fragments" (fun () ->
-    don't_wait_for
-      (Strict_pipe.Reader.iter_without_pushback reader ~f:(fun fragment ->
-           Fragment_stream.add_fragment fragment_stream
-             (Stdlib.Bytes.unsafe_of_string fragment)))) ;
+      don't_wait_for
+        (Strict_pipe.Reader.iter_without_pushback reader ~f:(fun fragment ->
+             Fragment_stream.add_fragment fragment_stream
+               (Stdlib.Bytes.unsafe_of_string fragment)))) ;
   r
 
 let write_outgoing_message writer msg =