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

fix test

Browse source
This commit is contained in:
Simon Cruanes 2025-09-05 12:58:09 -04:00
parent 44edf60836
commit bf649f5348
No known key found for this signature in database
GPG key ID: EBFFF6F283F3A2B4
3 changed files with 6 additions and 1942 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
test/fiber/lib/fls.ml
View file

@ -1,4 +1,3 @@
open! Moonpool open! Moonpool
module A = Atomic module A = Atomic
module F = Moonpool_fib.Fiber module F = Moonpool_fib.Fiber
@ -160,7 +159,7 @@ let run ~pool ~pool_name () =
let fibs = let fibs =
List.init 8 (fun idx -> F.spawn_top ~on:pool (fun () -> top idx)) List.init 8 (fun idx -> F.spawn_top ~on:pool (fun () -> top idx))
in in
List.iter F.wait_block_exn fibs; List.iter F.await fibs;
Printf.printf "tracing complete\n"; Printf.printf "tracing complete\n";
Printf.printf "spans:\n"; Printf.printf "spans:\n";

1934
test/lwt/fibers/t_fls.expected
View file

File diff suppressed because it is too large Load diff

9
test/lwt/fibers/t_fls.ml
View file

@ -1,11 +1,8 @@
open! Moonpool module M_lwt = Moonpool_lwt
let ( let@ ) = ( @@ ) let ( let@ ) = ( @@ )
let () = let () =
(let@ pool = Ws_pool.with_ () in (let@ runner = M_lwt.lwt_main in
T_fibers.Fls.run ~pool ~pool_name:"ws_pool" ()); T_fibers.Fls.run ~pool:runner ~pool_name:"lwt" ());
(let@ pool = Fifo_pool.with_ () in
T_fibers.Fls.run ~pool ~pool_name:"fifo_pool" ());
() ()