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
module Request_ =
struct
type t = [ `Random ] Request.t
let make () =
Request.allocate C.Types.Random.Request.t
end
module Async =
struct
let trampoline =
C.Functions.Random.get_trampoline ()
let random ?loop ?(request = Request_.make ()) buffer callback =
Request.set_callback request begin fun result ->
ignore (Compatibility.Sys.opaque_identity buffer);
Error.catch_exceptions callback (Error.to_result () result)
end;
let immediate_result =
C.Functions.Random.random
(Loop.or_default loop)
request
Ctypes.(bigarray_start array1 buffer)
(Unsigned.Size_t.of_int (Buffer.size buffer))
Unsigned.UInt.zero
trampoline
in
if immediate_result < 0 then begin
Request.release request;
callback (Error.result_from_c immediate_result)
end
end
include Async
module Sync =
struct
let null_callback =
C.Functions.Random.get_null_callback ()
let random buffer =
C.Blocking.Random.random
Ctypes.(from_voidp C.Types.Loop.t null)
Ctypes.(from_voidp C.Types.Random.Request.t null)
Ctypes.(bigarray_start array1 buffer)
(Unsigned.Size_t.of_int (Buffer.size buffer))
Unsigned.UInt.zero
null_callback
|> Error.to_result ()
end
module Request = Request_