feat: broaden io ops types to fd

CHANGES.md

@@ -1,5 +1,10 @@
 # Changes
 
+## Unreleased
+
+* Fix issue with schedulers busy-waiting
+* Switch to `poll` to support kqueue on macOS
+
 ## 0.0.5
 
 * Add `register name pid`

riot/runtime/net/io.ml

@@ -178,15 +178,15 @@ let accept (_t : t) (socket : Fd.t) : accept =
   | exception Unix.(Unix_error ((EINTR | EAGAIN | EWOULDBLOCK), _, _)) -> `Retry
   | exception Unix.(Unix_error (reason, _, _)) -> `Abort reason
 
-let read (conn : Socket.stream_socket) buf off len : read =
-  Fd.use ~op_name:"read" conn @@ fun fd ->
+let read (fd : Fd.t) buf off len : read =
+  Fd.use ~op_name:"read" fd @@ fun fd ->
   match Unix.read fd buf off len with
   | len -> `Read len
   | exception Unix.(Unix_error ((EINTR | EAGAIN | EWOULDBLOCK), _, _)) -> `Retry
   | exception Unix.(Unix_error (reason, _, _)) -> `Abort reason
 
-let write (conn : Socket.stream_socket) buf off len : write =
-  Fd.use ~op_name:"write" conn @@ fun fd ->
+let write (fd : Fd.t) buf off len : write =
+  Fd.use ~op_name:"write" fd @@ fun fd ->
   match Unix.write fd buf off len with
   | len -> `Wrote len
   | exception Unix.(Unix_error ((EINTR | EAGAIN | EWOULDBLOCK), _, _)) -> `Retry

riot/runtime/net/io.mli

@@ -38,5 +38,5 @@ val connect :
   [> `Abort of Unix.error | `Connected of Fd.t | `In_progress of Fd.t | `Retry ]
 
 val accept : t -> Fd.t -> accept
-val read : Socket.stream_socket -> bytes -> int -> int -> read
-val write : Socket.stream_socket -> bytes -> int -> int -> write
+val read : Fd.t -> bytes -> int -> int -> read
+val write : Fd.t -> bytes -> int -> int -> write