blob: 47bd2aa9111d5516a0eaab9b5796b43d3a60f15b (
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
|
(* $Id$ *)
let print_message app message =
Printf.printf "%s sent" (Ivy.name_of_client app);
Array.iter (fun s -> Printf.printf " '%s'" s) message;
print_newline ()
let read = fun channel ->
let l = input_line channel in
Ivy.send l
let watch_clients c e =
let dis = match e with Ivy.Connected -> "" | Ivy.Disconnected -> "dis" in
Printf.printf "%s %sconnected from %s\n"
(Ivy.name_of_client c)
dis
(Ivy.host_of_client c);
flush stdout
let init = fun () ->
let regexp = ref ""
and name = ref "MLIVYPROBE"
and port = ref 2010
and domain = ref "127.255.255.255" in
Arg.parse
[ "-b", Arg.Int (fun x -> port := x), "<Port number>\tDefault is 2010, unused if IVYBUS is set";
"-domain", Arg.String (fun x -> domain := x), "<Network address>\tDefault is 127.255.255.255, unused if IVYBUS is set";
"-n", Arg.String (fun s -> name := s), "<Name of the prober>\tDefault is MLIVYPROBE"]
(fun s -> regexp := s)
"Usage: ";
let bus =
try Sys.getenv "IVYBUS" with
Not_found -> Printf.sprintf "%s:%d" !domain !port in
Ivy.init !name "READY" watch_clients;
Ivy.start bus;
Printf.printf "\nEnd of file to stop\n\n"; flush stdout;
ignore (Ivy.bind print_message !regexp)
|
