File tree Expand file tree Collapse file tree 3 files changed +15
-17
lines changed
Expand file tree Collapse file tree 3 files changed +15
-17
lines changed Original file line number Diff line number Diff line change 1- open ! Moonpool
2-
31let ( let @ ) = ( @@ )
4- let runner = Fifo_pool. create ~num_threads: 1 ()
52
63let () =
4+ let @ runner = Moonpool_fib. main in
75 T_fibers.Fib. run1 ~runner () ;
8- T_fibers.Fib. run2 ~runner () ;
9-
6+ T_fibers.Fib. run2 ~runner ()
Original file line number Diff line number Diff line change @@ -19,15 +19,17 @@ let () =
1919 assert (r = 13 )
2020
2121let () =
22- Printf. eprintf " PART 2\n %!" ;
23- try
24- let _r =
25- M_lwt. lwt_main @@ fun runner ->
26- let fib = F. spawn_top ~on: runner (fun () -> failwith " oops" ) in
27- F. await fib
28- in
22+ (* run multiple times to make sure cleanup is correct *)
23+ for _i = 1 to 10 do
24+ try
25+ let _r =
26+ M_lwt. lwt_main @@ fun runner ->
27+ let fib = F. spawn_top ~on: runner (fun () -> failwith " oops" ) in
28+ F. await fib
29+ in
2930
30- assert false
31- with Failure msg ->
32- (* Printf.eprintf "got %S\n%!" msg; *)
33- assert (msg = " oops" )
31+ assert false
32+ with Failure msg ->
33+ (* Printf.eprintf "got %S\n%!" msg; *)
34+ assert (msg = " oops" )
35+ done
Original file line number Diff line number Diff line change 1- module M = Moonpool
21module M_lwt = Moonpool_lwt
32module Trace = Trace_core
43
You can’t perform that action at this time.
0 commit comments