From: Jürg Billeter Date: Tue, 19 Oct 2010 08:57:05 +0000 (+0200) Subject: D-Bus: Add test for sending and receiving errors X-Git-Tag: 0.11.1~72 X-Git-Url: http://git.ipfire.org/cgi-bin/gitweb.cgi?a=commitdiff_plain;h=e4138336cb4700df9715822ea96789847df2c8a7;p=thirdparty%2Fvala.git D-Bus: Add test for sending and receiving errors --- diff --git a/tests/Makefile.am b/tests/Makefile.am index 66b8c8f31..26436cc61 100644 --- a/tests/Makefile.am +++ b/tests/Makefile.am @@ -92,7 +92,9 @@ TESTS = \ dbus/basic-types.test \ dbus/arrays.test \ dbus/structs.test \ + dbus/errors.test \ dbus/async.test \ + dbus/async-errors.test \ dbus/signals.test \ dbus/bug596862.vala \ dbus/bug602003.test \ diff --git a/tests/dbus/async-errors.test b/tests/dbus/async-errors.test new file mode 100644 index 000000000..7dd3edbbb --- /dev/null +++ b/tests/dbus/async-errors.test @@ -0,0 +1,96 @@ +Packages: gio-2.0 +D-Bus + +Program: client + +[DBus (name = "org.example.Test")] +interface Test : Object { + public abstract async void test_void () throws Error; + public abstract async int test_int (int i, out int j) throws Error; + public abstract async string test_string (string s, out string t) throws Error; +} + +MainLoop main_loop; + +async void run (Test test) { + try { + yield test.test_void (); + assert_not_reached (); + } catch { + } + + try { + int j, k; + k = yield test.test_int (42, out j); + assert_not_reached (); + } catch { + } + + try { + string t, u; + u = yield test.test_string ("hello", out t); + assert_not_reached (); + } catch { + } + + main_loop.quit (); +} + +void main () { + // client + Test test = Bus.get_proxy_sync (BusType.SESSION, "org.example.Test", "/org/example/test"); + + run.begin (test); + + main_loop = new MainLoop (null, false); + main_loop.run (); +} + +Program: server + +[DBus (name = "org.example.Test")] +class Test : Object { + public async void test_void () throws Error { + Idle.add (test_void.callback); + yield; + throw new IOError.FAILED ("Operation failed"); + } + + public async int test_int (int i, out int j) throws Error { + Idle.add (test_int.callback); + yield; + throw new IOError.FAILED ("Operation failed"); + } + + public async string test_string (string s, out string t) throws Error { + Idle.add (test_string.callback); + yield; + throw new IOError.FAILED ("Operation failed"); + } +} + +MainLoop main_loop; + +void client_exit (Pid pid, int status) { + // client finished, terminate server + assert (status == 0); + main_loop.quit (); +} + +void main () { + var conn = Bus.get_sync (BusType.SESSION); + conn.register_object ("/org/example/test", new Test ()); + + // try to register service in session bus + var request_result = conn.call_sync ("org.freedesktop.DBus", "/org/freedesktop/DBus", "org.freedesktop.DBus", "RequestName", + new Variant ("(su)", "org.example.Test", 0x4), null, 0, -1); + assert ((uint) request_result.get_child_value (0) == 1); + + // server ready, spawn client + Pid client_pid; + Process.spawn_async (null, { "test", "/dbus/async-errors/client" }, null, SpawnFlags.DO_NOT_REAP_CHILD, null, out client_pid); + ChildWatch.add (client_pid, client_exit); + + main_loop = new MainLoop (); + main_loop.run (); +} diff --git a/tests/dbus/errors.test b/tests/dbus/errors.test new file mode 100644 index 000000000..826aeb371 --- /dev/null +++ b/tests/dbus/errors.test @@ -0,0 +1,81 @@ +Packages: gio-2.0 +D-Bus + +Program: client + +[DBus (name = "org.example.Test")] +interface Test : Object { + public abstract void test_void () throws Error; + public abstract int test_int (int i, out int j) throws Error; + public abstract string test_string (string s, out string t) throws Error; +} + +void main () { + // client + Test test = Bus.get_proxy_sync (BusType.SESSION, "org.example.Test", "/org/example/test"); + + try { + test.test_void (); + assert_not_reached (); + } catch { + } + + try { + int j, k; + k = test.test_int (42, out j); + assert_not_reached (); + } catch { + } + + try { + string t, u; + u = test.test_string ("hello", out t); + assert (t == "world"); + assert (u == "vala"); + assert_not_reached (); + } catch { + } +} + +Program: server + +[DBus (name = "org.example.Test")] +class Test : Object { + public void test_void () throws Error { + throw new IOError.FAILED ("Operation failed"); + } + + public int test_int (int i, out int j) throws Error { + throw new IOError.FAILED ("Operation failed"); + } + + public string test_string (string s, out string t) throws Error { + throw new IOError.FAILED ("Operation failed"); + } +} + +MainLoop main_loop; + +void client_exit (Pid pid, int status) { + // client finished, terminate server + assert (status == 0); + main_loop.quit (); +} + +void main () { + var conn = Bus.get_sync (BusType.SESSION); + conn.register_object ("/org/example/test", new Test ()); + + // try to register service in session bus + var request_result = conn.call_sync ("org.freedesktop.DBus", "/org/freedesktop/DBus", "org.freedesktop.DBus", "RequestName", + new Variant ("(su)", "org.example.Test", 0x4), null, 0, -1); + assert ((uint) request_result.get_child_value (0) == 1); + + // server ready, spawn client + Pid client_pid; + Process.spawn_async (null, { "test", "/dbus/errors/client" }, null, SpawnFlags.DO_NOT_REAP_CHILD, null, out client_pid); + ChildWatch.add (client_pid, client_exit); + + main_loop = new MainLoop (); + main_loop.run (); +}