tests/dbus/signals.test

   1 Packages: gio-2.0
   2 D-Bus
   3
   4 Program: client
   5
   6 [DBus (name = "org.example.Test")]
   7 interface Test : Object {
   8         public signal void foo (int i);
   9
  10         public abstract void do_foo (int i) throws IOError;
  11 }
  12
  13 MainLoop main_loop;
  14
  15 void main () {
  16         // client
  17         Test test = Bus.get_proxy_sync (BusType.SESSION, "org.example.Test", "/org/example/test");
  18
  19         test.foo.connect ((i) => {
  20                 assert (i == 42);
  21                 main_loop.quit ();
  22         });
  23
  24         test.do_foo (42);
  25
  26         main_loop = new MainLoop ();
  27         main_loop.run ();
  28 }
  29
  30 Program: server
  31
  32 [DBus (name = "org.example.Test")]
  33 class Test : Object {
  34         public signal void foo (int i);
  35
  36         public void do_foo (int i) {
  37                 this.foo (i);
  38         }
  39 }
  40
  41 MainLoop main_loop;
  42
  43 void client_exit (Pid pid, int status) {
  44         // client finished, terminate server
  45         assert (status == 0);
  46         main_loop.quit ();
  47 }
  48
  49 void main () {
  50         var conn = Bus.get_sync (BusType.SESSION);
  51         conn.register_object ("/org/example/test", new Test ());
  52
  53         // try to register service in session bus
  54         var request_result = conn.call_sync ("org.freedesktop.DBus", "/org/freedesktop/DBus", "org.freedesktop.DBus", "RequestName",
  55                                               new Variant ("(su)", "org.example.Test", 0x4), null, 0, -1);
  56         assert ((uint) request_result.get_child_value (0) == 1);
  57
  58         // server ready, spawn client
  59         Pid client_pid;
  60         Process.spawn_async (null, { "test", "/dbus/signals/client" }, null, SpawnFlags.DO_NOT_REAP_CHILD, null, out client_pid);
  61         ChildWatch.add (client_pid, client_exit);
  62
  63         main_loop = new MainLoop ();
  64         main_loop.run ();
  65 }