blob: 1fe6e4b345ad5a9644b39fda935a37dc2dd5dcf0 (
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
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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
|
(* TEST
include systhreads;
readonly_files = "input_all.ml";
hassysthreads;
{
bytecode;
}{
native;
}
*)
let data_file =
"data.txt"
let random_string size =
String.init size (fun _ -> Char.chr (Random.int 256))
(* various sizes, binary mode *)
let check size =
let data = random_string size in
Out_channel.with_open_bin data_file (fun oc -> Out_channel.output_string oc data);
let read_data = In_channel.with_open_bin data_file In_channel.input_all in
assert (data = read_data)
let () =
List.iter check [ 0; 1; 65536; 65536 + 1; 2 * 65536 ]
(* binary mode; non-zero starting position *)
let data_size = 65536
let check midpoint =
let data = random_string data_size in
Out_channel.with_open_bin data_file
(fun oc -> Out_channel.output_string oc data);
let contents =
In_channel.with_open_bin data_file
(fun ic ->
let s1 = Option.get (In_channel.really_input_string ic midpoint) in
let s2 = In_channel.input_all ic in
s1 ^ s2
)
in
assert (contents = data)
let () =
List.iter check [0; 1; 100; data_size]
(* text mode *)
(* translates into LF *)
let dos2unix inp out =
let s = In_channel.with_open_text inp In_channel.input_all in
Out_channel.with_open_bin out
(fun oc -> Out_channel.output_string oc s)
(* translates into CRLF *)
let unix2dos inp out =
let s = In_channel.with_open_text inp In_channel.input_all in
Out_channel.with_open_text out
(fun oc -> Out_channel.output_string oc s)
let source_fn =
"input_all.ml"
let source_fn_lf =
source_fn ^ ".lf"
let source_fn_crlf =
source_fn ^ ".crlf"
let () =
dos2unix source_fn source_fn_lf
let () =
unix2dos source_fn source_fn_crlf
let raw_contents =
In_channel.with_open_bin source_fn_lf
(fun ic -> Stdlib.really_input_string ic (Stdlib.in_channel_length ic))
let check midpoint =
let contents =
In_channel.with_open_text source_fn_crlf
(fun ic ->
let s1 = Option.get (In_channel.really_input_string ic midpoint) in
let s2 = In_channel.input_all ic in
s1 ^ s2
)
in
assert (contents = raw_contents)
let () =
List.iter check [0; 1; String.length raw_contents]
let random_char () =
Char.chr (Random.int 256)
let test_pipe n =
let buf = Bytes.init n (fun _ -> random_char ()) in
let toread, towrite = Unix.pipe () in
let producer () =
let rec loop pos rem =
let n = Unix.write towrite buf pos rem in
if n = rem then Unix.close towrite
else loop (pos + n) (rem - n)
in
loop 0 (Bytes.length buf)
in
let read_buf = ref "" in
let consumer () = read_buf := In_channel.input_all (Unix.in_channel_of_descr toread) in
let producer = Thread.create producer () in
let consumer = Thread.create consumer () in
Thread.join producer;
Thread.join consumer;
assert (!read_buf = Bytes.unsafe_to_string buf)
let () =
test_pipe 655397
|
