Change to use Picos instead of DLT and DLA

bench/bench_mvar.ml

@@ -11,6 +11,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
   let n_msgs_to_add = Atomic.make n_msgs |> Multicore_magic.copy_as_padded in
 
   let init _ = () in
+  let wrap _ () action = Scheduler.run action in
   let work i () =
     if i < n_adders then
       if blocking_add then
@@ -79,7 +80,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
       (format "taker" blocking_take n_takers)
   in
 
-  Times.record ~budgetf ~n_domains ~init ~work ~after ()
+  Times.record ~budgetf ~n_domains ~init ~wrap ~work ~after ()
   |> Times.to_thruput_metrics ~n:n_msgs ~singular:"message" ~config
 
 let run_suite ~budgetf =

bench/bench_queue.ml

@@ -29,6 +29,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
     Atomic.set n_msgs_to_take n_msgs;
     Atomic.set n_msgs_to_add n_msgs
   in
+  let wrap _ () action = Scheduler.run action in
   let work i () =
     if i < n_adders then
       let rec work () =
@@ -79,7 +80,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
       (format "taker" blocking_take n_takers)
   in
 
-  Times.record ~budgetf ~n_domains ~init ~work ()
+  Times.record ~budgetf ~n_domains ~init ~wrap ~work ()
   |> Times.to_thruput_metrics ~n:n_msgs ~singular:"message" ~config
 
 let run_suite ~budgetf =

bench/bench_stack.ml

@@ -29,6 +29,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
     Atomic.set n_msgs_to_take n_msgs;
     Atomic.set n_msgs_to_add n_msgs
   in
+  let wrap _ () action = Scheduler.run action in
   let work i () =
     if i < n_adders then
       let rec work () =
@@ -79,7 +80,7 @@ let run_one ~budgetf ?(n_adders = 2) ?(blocking_add = false) ?(n_takers = 2)
       (format "taker" blocking_take n_takers)
   in
 
-  Times.record ~budgetf ~n_domains ~init ~work ()
+  Times.record ~budgetf ~n_domains ~init ~wrap ~work ()
   |> Times.to_thruput_metrics ~n:n_msgs ~singular:"message" ~config
 
 let run_suite ~budgetf =

bench/dune

@@ -14,6 +14,7 @@ let () =
  (action
   (run %{test} -brief))
  (libraries
+  scheduler
   kcas_data
   multicore-bench
   backoff

doc/dune

@@ -1,8 +1,8 @@
-(mdx
- (package kcas_data)
- (deps
-  (package kcas)
-  (package kcas_data))
- (enabled_if
-  (>= %{ocaml_version} 5.0.0))
- (files gkmz-with-read-only-cmp-ops.md scheduler-interop.md))
+;(mdx
+; (package kcas_data)
+; (deps
+;  (package kcas)
+;  (package kcas_data))
+; (enabled_if
+;  (>= %{ocaml_version} 5.0.0))
+; (files gkmz-with-read-only-cmp-ops.md scheduler-interop.md))

dune

@@ -1,7 +1,7 @@
-(mdx
- (package kcas_data)
- (deps
-  (package kcas)
-  (package kcas_data))
- (libraries domain_shims)
- (files README.md))
+;(mdx
+; (package kcas_data)
+; (deps
+;  (package kcas)
+;  (package kcas_data))
+; (libraries domain_shims)
+; (files README.md))

dune-project

@@ -34,10 +34,8 @@
    (>= 4.13.0))
   (backoff
    (>= 0.1.0))
-  (domain-local-await
-   (>= 1.0.1))
-  (domain-local-timeout
-   (>= 1.0.1))
+  (picos
+   (>= 0.5.0))
   (multicore-magic
    (>= 2.3.0))
   (domain_shims
@@ -84,9 +82,9 @@
    (and
     (>= 0.1.0)
     :with-test))
-  (domain-local-await
+  (picos
    (and
-    (>= 1.0.1)
+    (>= 0.5.0)
     :with-test))
   (domain_shims
    (and

kcas.opam

@@ -19,8 +19,7 @@ depends: [
   "dune" {>= "3.14"}
   "ocaml" {>= "4.13.0"}
   "backoff" {>= "0.1.0"}
-  "domain-local-await" {>= "1.0.1"}
-  "domain-local-timeout" {>= "1.0.1"}
+  "picos" {>= "0.5.0"}
   "multicore-magic" {>= "2.3.0"}
   "domain_shims" {>= "0.1.0" & with-test}
   "alcotest" {>= "1.8.0" & with-test}
@@ -46,3 +45,6 @@ build: [
 ]
 dev-repo: "git+https://github.com/ocaml-multicore/kcas.git"
 doc: "https://ocaml-multicore.github.io/kcas/doc/kcas/Kcas/"
+pin-depends: [
+  [ "picos.dev" "git+https://github.com/ocaml-multicore/picos#53212d0164b32a034ef03f8cb60767fac4ae8029" ]
+]

kcas.opam.template

@@ -1 +1,4 @@
 doc: "https://ocaml-multicore.github.io/kcas/doc/kcas/Kcas/"
+pin-depends: [
+  [ "picos.dev" "git+https://github.com/ocaml-multicore/picos#53212d0164b32a034ef03f8cb60767fac4ae8029" ]
+]

kcas_data.opam

@@ -20,7 +20,7 @@ depends: [
   "kcas" {= version}
   "multicore-magic" {>= "2.3.0"}
   "backoff" {>= "0.1.0" & with-test}
-  "domain-local-await" {>= "1.0.1" & with-test}
+  "picos" {>= "0.5.0" & with-test}
   "domain_shims" {>= "0.1.0" & with-test}
   "multicore-bench" {>= "0.1.4" & with-test}
   "alcotest" {>= "1.8.0" & with-test}

src/kcas/dune

@@ -1,11 +1,11 @@
 (library
  (name kcas)
  (public_name kcas)
- (libraries domain-local-await domain-local-timeout backoff multicore-magic))
+ (libraries picos backoff multicore-magic))
 
-(mdx
- (package kcas)
- (deps
-  (package kcas))
- (libraries kcas backoff domain_shims)
- (files kcas.mli))
+;(mdx
+; (package kcas)
+; (deps
+;  (package kcas))
+; (libraries kcas backoff domain_shims)
+; (files kcas.mli))