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
121
122
123
124
125
126
|
(*
* Copyright (C) 2006-2009 Vincent Hanquez <vincent@snarc.org>
*
* This program is free software; you can redistribute it and/or modify
* it under the terms of the GNU Lesser General Public License as published
* by the Free Software Foundation; version 2.1 only. with the special
* exception on linking described in file LICENSE.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* Dbus example
*)
open Printf
let client bus =
let msg = DBus.Message.new_signal "/test/signal/Object"
"test.signal.Type" "Test" in
DBus.Message.append msg [ (DBus.String "Ping!!"); (DBus.Bool false) ];
let serial = DBus.Connection.send bus msg in
printf "client serial: %ld\n" serial;
DBus.Connection.flush bus
let server bus =
let match_s = "type='signal',interface='test.signal.Type'" in
DBus.Bus.add_match bus match_s false;
DBus.Connection.flush bus;
DBus.Connection.add_filter bus (fun bus msg -> true);
while true
do
DBus.Connection.read_write bus 0;
let msg = DBus.Connection.pop_message bus in
match msg with
| None -> Unix.sleep 1; ()
| Some msg ->
if DBus.Message.is_signal msg "test.signal.Type" "Test" then (
let params = DBus.Message.get msg in
let show p =
match p with
| DBus.String s -> printf "S: %s\n%!" s;
| DBus.Int32 i -> printf "I: %ld\n%!" i;
| DBus.Bool b -> printf "B: %b\n%!" b;
| _ -> printf "other type\n";
in
List.iter show params
) else if DBus.Message.is_method_call msg
"test.method.Type" "Method" then (
printf "method call\n%!";
) else
printf "other call\n%!"
done
let server2 bus =
let match_s = "type='signal',interface='test.signal.Type'" in
DBus.Bus.add_match bus match_s false;
DBus.Connection.flush bus;
DBus.Connection.add_filter bus (fun bus msg -> true);
let rset = ref [] in
let wset = ref [] in
let addfn watch =
let flags = DBus.Watch.get_flags watch in
printf "added watch\n";
let x = String.concat ", " (List.map (fun flag ->
match flag with
| DBus.Watch.Readable -> "readable"
| DBus.Watch.Writable -> "writable"
) flags) in
let fd = DBus.Watch.get_unix_fd watch in
List.iter (fun flag ->
match flag with
| DBus.Watch.Readable -> rset := fd :: !rset;
| DBus.Watch.Writable -> wset := fd :: !wset;
) flags;
printf "added watch (%s)\n" x;
true
in
let rmfn watch = printf "rmed watch\n" in
let togglefn watch = printf "toggled watch\n" in
DBus.Connection.set_watch_functions bus (addfn, rmfn, Some togglefn);
DBus.Connection.flush bus;
let rset = !rset and wset = !wset in
while true
do
let r, w, _ = Unix.select rset [] [] (1.1) in
if r <> [] || w <> [] then (
if r <> [] then printf "something to read\n%!";
DBus.Connection.read_write bus 0;
let msg = DBus.Connection.pop_message bus in
match msg with
| None -> Unix.sleep 1; ()
| Some msg ->
let params = DBus.Message.get msg in
let show p =
match p with
| DBus.String s -> printf "S: %s\n%!" s;
| DBus.Int32 i -> printf "I: %ld\n%!" i;
| DBus.Bool b -> printf "B: %b\n%!" b;
| _ -> printf "other type\n";
in
List.iter show params
)
done
let _ =
if (Array.length Sys.argv) < 2 then (
eprintf "usage: test [server|client]\n";
exit 1
);
let bus = DBus.Bus.get DBus.Bus.System in
match Sys.argv.(1) with
| "server" -> server2 bus
| "client" -> client bus
| _ -> eprintf "unknown command\n";
|
