blob: 04df10ef9f081581c4b5244aaf22b63ad8bf31d4 (
plain)
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
|
(* TEST
include runtime_events;
include unix;
set OCAMLRUNPARAM = "e=6";
libunix;
{
native;
}{
bytecode;
}
*)
type Runtime_events.User.tag += Ev
let ev = Runtime_events.User.register "ev" Ev Runtime_events.Type.int
let producer () =
let open Runtime_events in
for _ = 0 to 100000 do
User.write ev 0
done
let ready = Atomic.make 0
let wait_ready () =
let v = Atomic.fetch_and_add ready 1 in
if v < 2 then
while Atomic.get ready < 2 do
Domain.cpu_relax ()
done
let _ =
Domain.spawn (fun () ->
Runtime_events.start ();
wait_ready ();
producer ())
let callbacks =
let open Runtime_events in
let evs = Runtime_events.Callbacks.create ()
in
let id_callback d ts c i =
assert (i = 0)
in
Callbacks.add_user_event Runtime_events.Type.int id_callback evs
let ()
=
Unix.sleepf 0.1;
let cursor = Runtime_events.create_cursor None in
wait_ready ();
for _ = 0 to 10 do
Runtime_events.read_poll cursor callbacks None
|> ignore
done
|