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
|
(* TEST
include systhreads;
hassysthreads;
libunix; (* Broken on Windows (missing join?), needs to be fixed *)
{
bytecode;
}{
native;
}
*)
open Printf
(* Threads and sockets *)
let serve_connection s =
let buf = Bytes.make 1024 '>' in
let n = Unix.read s buf 2 (Bytes.length buf - 2) in
ignore (Unix.write s buf 0 (n + 2));
Unix.close s
let server sock =
while true do
let (s, _) = Unix.accept sock in
ignore(Thread.create serve_connection s)
done
let client1_done = Event.new_channel ()
let wait_for_turn id =
if id = 2 then
Event.receive client1_done |> Event.sync |> ignore
let signal_turn id =
if id = 1 then
Event.send client1_done 2 |> Event.sync
let client (id, addr) =
let msg = "Client #" ^ Int.to_string id ^ "\n" in
let sock =
Unix.socket (Unix.domain_of_sockaddr addr) Unix.SOCK_STREAM 0 in
Unix.connect sock addr;
let buf = Bytes.make 1024 ' ' in
ignore (Unix.write_substring sock msg 0 (String.length msg));
let n = Unix.read sock buf 0 (Bytes.length buf) in
wait_for_turn id;
print_bytes (Bytes.sub buf 0 n); flush stdout;
signal_turn id
let _ =
let addr = Unix.ADDR_INET(Unix.inet_addr_loopback, 0) in
let sock =
Unix.socket (Unix.domain_of_sockaddr addr) Unix.SOCK_STREAM 0 in
Unix.setsockopt sock Unix.SO_REUSEADDR true;
Unix.bind sock addr;
let addr = Unix.getsockname sock in
Unix.listen sock 5;
ignore (Thread.create server sock);
let c = Thread.create client (2, addr) in
client (1, addr);
Thread.join c
|
