+1 -1

dune-project

··· 35 (alcotest (and (>= 1.7.0) :with-test)) 36 (eio (= :version)) 37 (mdx (and (>= 2.2.0) :with-test)) 38 - (logs (>= 0.7.0)) 39 (fmt (>= 0.8.9)) 40 (cmdliner (and (>= 1.1.0) :with-test)) 41 (uring (>= 0.7))))

··· 35 (alcotest (and (>= 1.7.0) :with-test)) 36 (eio (= :version)) 37 (mdx (and (>= 2.2.0) :with-test)) 38 + (logs (and (>= 0.7.0) :with-test)) 39 (fmt (>= 0.8.9)) 40 (cmdliner (and (>= 1.1.0) :with-test)) 41 (uring (>= 0.7))))

+1 -1

eio_linux.opam

··· 13 "alcotest" {>= "1.7.0" & with-test} 14 "eio" {= version} 15 "mdx" {>= "2.2.0" & with-test} 16 - "logs" {>= "0.7.0"} 17 "fmt" {>= "0.8.9"} 18 "cmdliner" {>= "1.1.0" & with-test} 19 "uring" {>= "0.7"}

··· 13 "alcotest" {>= "1.7.0" & with-test} 14 "eio" {= version} 15 "mdx" {>= "2.2.0" & with-test} 16 + "logs" {>= "0.7.0" & with-test} 17 "fmt" {>= "0.8.9"} 18 "cmdliner" {>= "1.1.0" & with-test} 19 "uring" {>= "0.7"}

+1 -1

lib_eio_linux/dune

··· 11 (flags :standard -D_LARGEFILE64_SOURCE) 12 (include_dirs ../lib_eio/unix/include) 13 (names eio_stubs)) 14 - (libraries eio eio.utils eio.unix uring logs fmt)) 15 16 (rule 17 (enabled_if

··· 11 (flags :standard -D_LARGEFILE64_SOURCE) 12 (include_dirs ../lib_eio/unix/include) 13 (names eio_stubs)) 14 + (libraries eio eio.utils eio.unix uring fmt)) 15 16 (rule 17 (enabled_if

-2

lib_eio_linux/log.ml

··· 1 - let src = Logs.Src.create "eio_linux" ~doc:"Effect-based IO system for Linux/io-uring" 2 - include (val Logs.src_log src : Logs.LOG)

··· 0 0

+5 -9

lib_eio_linux/sched.ml

··· 292 | Job_no_cancel k -> 293 Suspended.continue k result 294 | Cancel_job -> 295 - begin match result with 296 - | 0 (* Operation cancelled successfully *) 297 - | -2 (* ENOENT - operation completed before cancel took effect *) 298 - | -114 (* EALREADY - operation already in progress *) 299 - -> () 300 - | errno -> 301 - Log.warn (fun f -> f "Cancel returned unexpected error: %s" (Unix.error_message (Uring.error_of_errno errno))) 302 - end; 303 schedule st 304 | Job_fn (k, f) -> 305 Fiber_context.clear_cancel_fn k.fiber; ··· 552 | Ok () -> 553 Some (Uring.Region.init ~block_size buf n_blocks) 554 | Error `ENOMEM -> 555 - Log.warn (fun f -> f "Failed to allocate %d byte fixed buffer" fixed_buf_len); 556 None 557 in 558 let run_q = Lf_queue.create () in

··· 292 | Job_no_cancel k -> 293 Suspended.continue k result 294 | Cancel_job -> 295 + (* We don't care about the result of the cancel operation, and there's nowhere to send it. 296 + The possibilities are: 297 + 0 : Operation cancelled successfully 298 + -2 : ENOENT - operation completed before cancel took effect 299 + -114 : EALREADY - operation already in progress *) 0 0 0 300 schedule st 301 | Job_fn (k, f) -> 302 Fiber_context.clear_cancel_fn k.fiber; ··· 549 | Ok () -> 550 Some (Uring.Region.init ~block_size buf n_blocks) 551 | Error `ENOMEM -> 0 552 None 553 in 554 let run_q = Lf_queue.create () in

+2 -2

lib_eio_linux/tests/dune

··· 6 (= %{system} "linux_elf") ; Historically, Linux-x86_32 7 (= %{system} "elf"))) ; Historically, Linux-ppc64 8 (modules eurcp_lib) 9 - (libraries eio_linux)) 10 11 (executable 12 (name eurcp) ··· 47 (= %{system} "linux_elf") ; Historically, Linux-x86_32 48 (= %{system} "elf"))) ; Historically, Linux-ppc64 49 (modules test) 50 - (libraries alcotest eio_linux)) 51 52 (mdx 53 (package eio_linux)

··· 6 (= %{system} "linux_elf") ; Historically, Linux-x86_32 7 (= %{system} "elf"))) ; Historically, Linux-ppc64 8 (modules eurcp_lib) 9 + (libraries eio_linux logs)) 10 11 (executable 12 (name eurcp) ··· 47 (= %{system} "linux_elf") ; Historically, Linux-x86_32 48 (= %{system} "elf"))) ; Historically, Linux-ppc64 49 (modules test) 50 + (libraries alcotest eio_linux logs)) 51 52 (mdx 53 (package eio_linux)