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
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
|
open Eio.Std
module Timeout = struct
let test clock () =
let t0 = Unix.gettimeofday () in
Eio.Time.sleep clock 0.01;
let t1 = Unix.gettimeofday () in
let diff = t1 -. t0 in
if diff >= 0.01 then () else Alcotest.failf "Expected bigger difference than %f" diff
let tests env = [
"timeout", `Quick, test env#clock
]
end
module Random = struct
let test_random env () =
let src = Eio.Stdenv.secure_random env in
let b1 = Cstruct.create 8 in
let b2 = Cstruct.create 8 in
Eio.Flow.read_exact src b1;
Eio.Flow.read_exact src b2;
Alcotest.(check bool) "different random" (not (Cstruct.equal b1 b2)) true
let tests env = [
"different", `Quick, test_random env
]
end
module Dla = struct
let test_dla () =
let open Kcas in
let x = Loc.make 0 in
let y = Loc.make 0 in
let foreign_domain = Domain.spawn @@ fun () ->
let x = Loc.get_as (fun x -> Retry.unless (x <> 0); x) x in
Loc.set y 22;
x
in
Loc.set x 20;
let y' = Loc.get_as (fun y -> Retry.unless (y <> 0); y) y in
Alcotest.(check int) "correct y" y' 22;
let ans = y' + Domain.join foreign_domain in
Alcotest.(check int) "answer" ans 42
let tests = [
"dla", `Quick, test_dla
]
end
module Await_fd = struct
let test_cancel () =
let a, b = Unix.(socketpair PF_UNIX SOCK_STREAM 0) in
(* Start awaiting readable/writable state, but cancel immediately. *)
try
Eio.Cancel.sub (fun cc ->
Fiber.all [
(fun () -> Eio_unix.await_readable a);
(fun () -> Eio_unix.await_writable b);
(fun () -> Eio.Cancel.cancel cc Exit);
];
assert false
)
with Eio.Cancel.Cancelled _ ->
(* Now wait for something else. Will fail if the old FDs are still being waited on. *)
let c, d = Unix.(socketpair PF_UNIX SOCK_STREAM 0) in
Unix.close a;
Unix.close b;
Fiber.first
(fun () -> Eio_unix.await_readable c)
(fun () -> Eio_unix.await_writable d);
Unix.close c;
Unix.close d
let tests = [
"cancel", `Quick, test_cancel;
]
end
let () =
Eio_windows.run @@ fun env ->
Alcotest.run ~bail:true "eio_windows" [
"net", Test_net.tests env;
"fs", Test_fs.tests env;
"timeout", Timeout.tests env;
"random", Random.tests env;
"dla", Dla.tests;
"await", Await_fd.tests;
]
|
