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

remove use of 5.1 only function

Browse source
This commit is contained in:
Simon Cruanes 2024-03-21 17:01:42 -04:00
parent 8e6340846a
commit ba1876f957
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
1 changed files with 8 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
test/lwt/hash_client.ml
View file

@ -31,18 +31,6 @@ let main ~port ~runner ~ext ~dir ~n_conn () : unit Lwt.t =
()
else if Str_tbl.mem seen file then
()
else if Sys.is_regular_file file then
if ext <> "" && Filename.extension file <> ext then
()
else (
Str_tbl.add seen file ();
M_lwt.run_in_lwt_and_await (fun () -> Lwt_io.write_line oc file);
let res =
M_lwt.run_in_lwt_and_await (fun () -> Lwt_io.read_line ic)
in
let@ () = M.Lock.with_ lock_stdout in
Printf.printf "%s\n%!" res
)
else if Sys.is_directory file then (
let _sp =
Trace.enter_manual_sub_span ~parent:_sp ~__FILE__ ~__LINE__ "walk-dir"
@ -53,6 +41,14 @@ let main ~port ~runner ~ext ~dir ~n_conn () : unit Lwt.t =
let d = Sys.readdir file in
Array.sort String.compare d;
Array.iter (fun sub -> walk (Filename.concat file sub)) d
) else if ext <> "" && Filename.extension file <> ext then
()
else (
Str_tbl.add seen file ();
M_lwt.run_in_lwt_and_await (fun () -> Lwt_io.write_line oc file);
let res = M_lwt.run_in_lwt_and_await (fun () -> Lwt_io.read_line ic) in
let@ () = M.Lock.with_ lock_stdout in
Printf.printf "%s\n%!" res
)
in
walk dir;