+2 -2

lib_eio/core/dla.ml lib_eio/utils/dla.ml

reviewed

··· 7 7 | _ -> () 8 8 and await () = 9 9 if Atomic.get state != `Released then 10 10 - Suspend.enter "domain-local-await" @@ fun ctx enqueue -> 10 10 + Eio.Private.Suspend.enter "domain-local-await" @@ fun ctx enqueue -> 11 11 let awaiting = `Awaiting enqueue in 12 12 if Atomic.compare_and_set state `Init awaiting then ( 13 13 - Cancel.Fiber_context.set_cancel_fn ctx (fun ex -> 13 13 + Eio.Private.Fiber_context.set_cancel_fn ctx (fun ex -> 14 14 if Atomic.compare_and_set state awaiting `Released then ( 15 15 enqueue (Error ex) 16 16 )

+1 -1

lib_eio/core/dune

reviewed

··· 1 1 (library 2 2 (name eio__core) 3 3 (public_name eio.core) 4 4 - (libraries hmap lwt-dllist fmt optint domain-local-await eio.runtime_events)) 4 4 + (libraries hmap lwt-dllist fmt optint eio.runtime_events))

-2

lib_eio/core/eio__core.ml

reviewed

··· 19 19 | Fork = Fiber.Fork 20 20 | Get_context = Cancel.Get_context 21 21 end 22 22 - 23 23 - module Dla = Dla 24 22 end

-4

lib_eio/core/eio__core.mli

reviewed

··· 782 782 val v : t 783 783 (** Backends should use this for {!Eio.Stdenv.debug}. *) 784 784 end 785 785 - 786 786 - module Dla : sig 787 787 - val prepare_for_await : unit -> Domain_local_await.t 788 788 - end 789 785 end

+1 -1

lib_eio/mock/backend.ml

reviewed

··· 105 105 let result = ref None in 106 106 let `Exit_scheduler = 107 107 Domain_local_await.using 108 108 - ~prepare_for_await:Eio.Private.Dla.prepare_for_await 108 108 + ~prepare_for_await:Eio_utils.Dla.prepare_for_await 109 109 ~while_running:(fun () -> 110 110 fork ~new_fiber (fun () -> result := Some (main stdenv))) in 111 111 match !result with

+1

lib_eio/utils/dla.mli

reviewed

··· 1 1 + val prepare_for_await : unit -> Domain_local_await.t

+1 -1

lib_eio/utils/dune

reviewed

··· 1 1 (library 2 2 (name eio_utils) 3 3 (public_name eio.utils) 4 4 - (libraries eio psq fmt optint)) 4 4 + (libraries eio psq fmt optint domain-local-await))

+1

lib_eio/utils/eio_utils.ml

reviewed

··· 5 5 module Lf_queue = Lf_queue 6 6 module Suspended = Suspended 7 7 module Zzz = Zzz 8 8 + module Dla = Dla

+1 -1

lib_eio_linux/sched.ml

reviewed

··· 460 460 let `Exit_scheduler = 461 461 let new_fiber = Fiber_context.make_root () in 462 462 Domain_local_await.using 463 463 - ~prepare_for_await:Eio.Private.Dla.prepare_for_await 463 463 + ~prepare_for_await:Eio_utils.Dla.prepare_for_await 464 464 ~while_running:(fun () -> 465 465 fork ~new_fiber (fun () -> 466 466 Switch.run_protected ~name:"eio_linux" (fun sw ->

+1 -1

lib_eio_posix/sched.ml

reviewed

··· 379 379 let `Exit_scheduler = 380 380 let new_fiber = Fiber_context.make_root () in 381 381 Domain_local_await.using 382 382 - ~prepare_for_await:Eio.Private.Dla.prepare_for_await 382 382 + ~prepare_for_await:Eio_utils.Dla.prepare_for_await 383 383 ~while_running:(fun () -> 384 384 fork ~new_fiber (fun () -> 385 385 Eio_unix.Private.Thread_pool.run t.thread_pool @@ fun () ->

+1 -1

lib_eio_windows/sched.ml

reviewed

··· 370 370 let `Exit_scheduler = 371 371 let new_fiber = Fiber_context.make_root () in 372 372 Domain_local_await.using 373 373 - ~prepare_for_await:Eio.Private.Dla.prepare_for_await 373 373 + ~prepare_for_await:Eio_utils.Dla.prepare_for_await 374 374 ~while_running:(fun () -> 375 375 fork ~new_fiber (fun () -> 376 376 Eio_unix.Private.Thread_pool.run t.thread_pool @@ fun () ->