package miou

  1. Overview
  2. Docs
Composable concurrency primitives for OCaml

Install 

dune-project
 Dependency

github.com Readme Changelog MIT License Edit opam file Versions (13)

Authors

  1. R
    Romain Calascibetta <romain.calascibetta@gmail.com>

Maintainers

  1. R
    Romain Calascibetta <romain.calascibetta@gmail.com>

Sources

miou-0.10.0.tbz
sha256=bf1954c6f66ac9d306b3b4f948b19f59d2c327213af930e19d9fbc73f134fa18
sha512=cea8136bf9fef32898c962b4136fd784a20fc8a6626cd19bb7d0a37e798aa7a7f06ea9f19b47f6e03bb1afd477cf46e57d4c6a376601eb282c4fb07d490ca727

doc/src/miou.unix/miou_epoll.ml.html

Source file miou_epoll.ml

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
module C = struct
  external create : unit -> Unix.file_descr = "miou_epoll_create"

  external ctl : Unix.file_descr -> int -> Unix.file_descr -> int -> int
    = "miou_epoll_ctl"

  external wait :
       Unix.file_descr
    -> (int32, Bigarray.int32_elt, Bigarray.c_layout) Bigarray.Array1.t
    -> int
    -> int64
    -> int = "miou_epoll_wait"

  external flag_in : unit -> int = "miou_epoll_flag_in" [@@noalloc]
  external flag_out : unit -> int = "miou_epoll_flag_out" [@@noalloc]
  external flag_err : unit -> int = "miou_epoll_flag_err" [@@noalloc]
  external flag_hup : unit -> int = "miou_epoll_flag_hup" [@@noalloc]
  external flag_rdhup : unit -> int = "miou_epoll_flag_rdhup" [@@noalloc]
  external flag_oneshot : unit -> int = "miou_epoll_flag_oneshot" [@@noalloc]
end

type t = Unix.file_descr

module Flags = struct
  type t = int

  let epollin = C.flag_in ()
  let epollout = C.flag_out ()
  let epollerr = C.flag_err ()
  let epollhup = C.flag_hup ()
  let epollrdhup = C.flag_rdhup ()
  let epolloneshot = C.flag_oneshot ()
  let empty = 0
  let ( + ) = ( lor )
  let mem a b = a land b != 0
  let of_int = Fun.id
end

let () = assert (Obj.is_int (Obj.repr Unix.stdout))
let invalid_fd : Unix.file_descr = Obj.magic (-1)
let create () = C.create ()
let close t = if t <> invalid_fd then Unix.close t
let add t fd flags = C.ctl t 0 fd flags
let upd t fd flags = C.ctl t 1 fd flags
let del t fd = C.ctl t 2 fd 0

type events = (int32, Bigarray.int32_elt, Bigarray.c_layout) Bigarray.Array1.t

let events n = Bigarray.Array1.create Bigarray.int32 Bigarray.c_layout (n * 2)

type epoll_timeout = Infinite | No_wait | Nanoseconds of int64

let wait t events timeout =
  let timeout =
    match timeout with
    | Infinite -> Int64.minus_one
    | No_wait -> 0L
    | Nanoseconds ns -> if Int64.compare ns 0L < 0 then 0L else ns
  in
  let maxevents = Bigarray.Array1.dim events / 2 in
  C.wait t events maxevents timeout

let iter events n fn =
  for i = 0 to n - 1 do
    let fd : Unix.file_descr =
      Obj.magic (Int32.to_int (Bigarray.Array1.unsafe_get events (i * 2)))
    in
    let flags =
      Int32.to_int (Bigarray.Array1.unsafe_get events ((i * 2) + 1))
    in
    fn fd flags
  done