Lockfree -> Saturn

domainslib.opam

@@ -1,16 +1,16 @@
 # This file is generated by dune, edit dune-project instead
 opam-version: "2.0"
 synopsis: "Parallel Structures over Domains for Multicore OCaml"
-maintainer: ["KC Sivaramakrishnan <kc@kcsrk.info>"]
-authors: ["KC Sivaramakrishnan <kc@kcsrk.info>" "Sudha Parimala"]
+maintainer: ["KC Sivaramakrishnan <kc@kcsrk.info>" "Sudha Parimala"]
+authors: ["KC Sivaramakrishnan <kc@kcsrk.info>"]
 license: "ISC"
 homepage: "https://github.com/ocaml-multicore/domainslib"
 doc: "https://kayceesrk.github.io/domainslib/doc"
 bug-reports: "https://github.com/ocaml-multicore/domainslib/issues"
 depends: [
   "dune" {>= "3.0"}
   "ocaml" {>= "5.0"}
-  "lockfree" {>= "0.3.1"}
+  "saturn" {>= "0.4.0"}
   "domain-local-await" {>= "0.1.0"}
   "kcas" {>= "0.3.0" & with-test}
   "mirage-clock-unix" {with-test & >= "4.2.0"}

dune-project

@@ -5,7 +5,7 @@
 
 (source (github ocaml-multicore/domainslib))
 (authors "KC Sivaramakrishnan <kc@kcsrk.info>")
-(maintainers "KC Sivaramakrishnan <kc@kcsrk.info>")
+(maintainers "KC Sivaramakrishnan <kc@kcsrk.info>" "Sudha Parimala")
 (documentation "https://kayceesrk.github.io/domainslib/doc")
 (license "ISC")
 
@@ -14,7 +14,7 @@
  (synopsis "Parallel Structures over Domains for Multicore OCaml")
  (depends
   (ocaml (>= "5.0"))
-  (lockfree (>= "0.2.0"))
+  (saturn (>= "0.4.0"))
   (domain-local-await (>= 0.1.0))
   (kcas (and (>= 0.3.0) :with-test))
   (mirage-clock-unix (and :with-test (>= "4.2.0")))

lib/dune

@@ -1,4 +1,4 @@
 (library
  (name domainslib)
  (public_name domainslib)
- (libraries lockfree domain-local-await))
+ (libraries saturn domain-local-await))

lib/multi_channel.ml

@@ -14,7 +14,7 @@
  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
  *)
 
-module Ws_deque = Lockfree.Ws_deque.M
+module Ws_deque = Saturn.Work_stealing_deque.M
 
 type mutex_condvar = {
   mutex: Mutex.t;
@@ -32,7 +32,7 @@ type dls_state = {
   mc: mutex_condvar;
 }
 
-module Foreign_queue = Lockfree.Michael_scott_queue
+module Foreign_queue = Saturn.Queue
 
 type 'a t = {
   channels: 'a Ws_deque.t array;