1 /* GLib testing framework examples and tests
2 *
3 * Copyright (C) 2008-2018 Red Hat, Inc.
4 *
5 * This library is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU Lesser General Public
7 * License as published by the Free Software Foundation; either
8 * version 2.1 of the License, or (at your option) any later version.
9 *
10 * This library is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * Lesser General Public License for more details.
14 *
15 * You should have received a copy of the GNU Lesser General
16 * Public License along with this library; if not, see <http://www.gnu.org/licenses/>.
17 *
18 * Author: David Zeuthen <davidz@redhat.com>
19 */
20
21 #include <gio/gio.h>
22 #include <unistd.h>
23 #include <string.h>
24 #include <stdio.h>
25
26 #include "gdbus-tests.h"
27
28 #include "gdbus-test-codegen-generated.h"
29 #include "gdbus-test-codegen-generated-interface-info.h"
30
31 /* ---------------------------------------------------------------------------------------------------- */
32
33 static guint
count_annotations(GDBusAnnotationInfo ** annotations)34 count_annotations (GDBusAnnotationInfo **annotations)
35 {
36 guint ret;
37 ret = 0;
38 while (annotations != NULL && annotations[ret] != NULL)
39 ret++;
40 return ret;
41 }
42
43 /* checks that
44 *
45 * - non-internal annotations are written out correctly; and
46 * - injection via --annotation --key --value works
47 */
48 static void
test_annotations(void)49 test_annotations (void)
50 {
51 GDBusInterfaceInfo *iface;
52 GDBusMethodInfo *method;
53 GDBusSignalInfo *signal;
54 GDBusPropertyInfo *property;
55
56 iface = foo_igen_bar_interface_info ();
57 g_assert (iface != NULL);
58
59 /* see meson.build for where these annotations are injected */
60 g_assert_cmpint (count_annotations (iface->annotations), ==, 1);
61 g_assert_cmpstr (g_dbus_annotation_info_lookup (iface->annotations, "Key1"), ==, "Value1");
62
63 method = g_dbus_interface_info_lookup_method (iface, "HelloWorld");
64 g_assert (method != NULL);
65 g_assert_cmpint (count_annotations (method->annotations), ==, 2);
66 g_assert_cmpstr (g_dbus_annotation_info_lookup (method->annotations, "ExistingAnnotation"), ==, "blah");
67 g_assert_cmpstr (g_dbus_annotation_info_lookup (method->annotations, "Key3"), ==, "Value3");
68
69 signal = g_dbus_interface_info_lookup_signal (iface, "TestSignal");
70 g_assert (signal != NULL);
71 g_assert_cmpint (count_annotations (signal->annotations), ==, 1);
72 g_assert_cmpstr (g_dbus_annotation_info_lookup (signal->annotations, "Key4"), ==, "Value4");
73 g_assert_cmpstr (g_dbus_annotation_info_lookup (signal->args[1]->annotations, "Key8"), ==, "Value8");
74
75 property = g_dbus_interface_info_lookup_property (iface, "ay");
76 g_assert (property != NULL);
77 g_assert_cmpint (count_annotations (property->annotations), ==, 1);
78 g_assert_cmpstr (g_dbus_annotation_info_lookup (property->annotations, "Key5"), ==, "Value5");
79
80 method = g_dbus_interface_info_lookup_method (iface, "TestPrimitiveTypes");
81 g_assert (method != NULL);
82 g_assert_cmpstr (g_dbus_annotation_info_lookup (method->in_args[4]->annotations, "Key6"), ==, "Value6");
83 g_assert_cmpstr (g_dbus_annotation_info_lookup (method->out_args[5]->annotations, "Key7"), ==, "Value7");
84 }
85
86 /* ---------------------------------------------------------------------------------------------------- */
87
88 static gboolean
on_handle_hello_world(FooiGenBar * object,GDBusMethodInvocation * invocation,const gchar * greeting,gpointer user_data)89 on_handle_hello_world (FooiGenBar *object,
90 GDBusMethodInvocation *invocation,
91 const gchar *greeting,
92 gpointer user_data)
93 {
94 gchar *response;
95 response = g_strdup_printf ("Word! You said '%s'. I'm Skeleton, btw!", greeting);
96 foo_igen_bar_complete_hello_world (object, invocation, response);
97 g_free (response);
98 return TRUE;
99 }
100
101 static gboolean
on_handle_test_primitive_types(FooiGenBar * object,GDBusMethodInvocation * invocation,guchar val_byte,gboolean val_boolean,gint16 val_int16,guint16 val_uint16,gint val_int32,guint val_uint32,gint64 val_int64,guint64 val_uint64,gdouble val_double,const gchar * val_string,const gchar * val_objpath,const gchar * val_signature,const gchar * val_bytestring,gpointer user_data)102 on_handle_test_primitive_types (FooiGenBar *object,
103 GDBusMethodInvocation *invocation,
104 guchar val_byte,
105 gboolean val_boolean,
106 gint16 val_int16,
107 guint16 val_uint16,
108 gint val_int32,
109 guint val_uint32,
110 gint64 val_int64,
111 guint64 val_uint64,
112 gdouble val_double,
113 const gchar *val_string,
114 const gchar *val_objpath,
115 const gchar *val_signature,
116 const gchar *val_bytestring,
117 gpointer user_data)
118 {
119 gchar *s1;
120 gchar *s2;
121 gchar *s3;
122 s1 = g_strdup_printf ("Word! You said '%s'. Rock'n'roll!", val_string);
123 s2 = g_strdup_printf ("/modified%s", val_objpath);
124 s3 = g_strdup_printf ("assgit%s", val_signature);
125 foo_igen_bar_complete_test_primitive_types (object,
126 invocation,
127 10 + val_byte,
128 !val_boolean,
129 100 + val_int16,
130 1000 + val_uint16,
131 10000 + val_int32,
132 100000 + val_uint32,
133 1000000 + val_int64,
134 10000000 + val_uint64,
135 val_double / G_PI,
136 s1,
137 s2,
138 s3,
139 "bytestring!\xff");
140 g_free (s1);
141 g_free (s2);
142 g_free (s3);
143 return TRUE;
144 }
145
146 static gboolean
on_handle_test_non_primitive_types(FooiGenBar * object,GDBusMethodInvocation * invocation,GVariant * dict_s_to_s,GVariant * dict_s_to_pairs,GVariant * a_struct,const gchar * const * array_of_strings,const gchar * const * array_of_objpaths,GVariant * array_of_signatures,const gchar * const * array_of_bytestrings,gpointer user_data)147 on_handle_test_non_primitive_types (FooiGenBar *object,
148 GDBusMethodInvocation *invocation,
149 GVariant *dict_s_to_s,
150 GVariant *dict_s_to_pairs,
151 GVariant *a_struct,
152 const gchar* const *array_of_strings,
153 const gchar* const *array_of_objpaths,
154 GVariant *array_of_signatures,
155 const gchar* const *array_of_bytestrings,
156 gpointer user_data)
157 {
158 gchar *s;
159 GString *str;
160 str = g_string_new (NULL);
161 s = g_variant_print (dict_s_to_s, TRUE); g_string_append (str, s); g_free (s);
162 s = g_variant_print (dict_s_to_pairs, TRUE); g_string_append (str, s); g_free (s);
163 s = g_variant_print (a_struct, TRUE); g_string_append (str, s); g_free (s);
164 s = g_strjoinv (", ", (gchar **) array_of_strings);
165 g_string_append_printf (str, "array_of_strings: [%s] ", s);
166 g_free (s);
167 s = g_strjoinv (", ", (gchar **) array_of_objpaths);
168 g_string_append_printf (str, "array_of_objpaths: [%s] ", s);
169 g_free (s);
170 s = g_variant_print (array_of_signatures, TRUE);
171 g_string_append_printf (str, "array_of_signatures: %s ", s);
172 g_free (s);
173 s = g_strjoinv (", ", (gchar **) array_of_bytestrings);
174 g_string_append_printf (str, "array_of_bytestrings: [%s] ", s);
175 g_free (s);
176 foo_igen_bar_complete_test_non_primitive_types (object, invocation,
177 array_of_strings,
178 array_of_objpaths,
179 array_of_signatures,
180 array_of_bytestrings,
181 str->str);
182 g_string_free (str, TRUE);
183 return TRUE;
184 }
185
186 static gboolean
on_handle_request_signal_emission(FooiGenBar * object,GDBusMethodInvocation * invocation,gint which_one,gpointer user_data)187 on_handle_request_signal_emission (FooiGenBar *object,
188 GDBusMethodInvocation *invocation,
189 gint which_one,
190 gpointer user_data)
191 {
192 if (which_one == 0)
193 {
194 const gchar *a_strv[] = {"foo", "bar", NULL};
195 const gchar *a_bytestring_array[] = {"foo\xff", "bar\xff", NULL};
196 GVariant *a_variant = g_variant_new_parsed ("{'first': (42, 42), 'second': (43, 43)}");
197 foo_igen_bar_emit_test_signal (object, 43, a_strv, a_bytestring_array, a_variant); /* consumes a_variant */
198 foo_igen_bar_complete_request_signal_emission (object, invocation);
199 }
200 return TRUE;
201 }
202
203 static gboolean
on_handle_request_multi_property_mods(FooiGenBar * object,GDBusMethodInvocation * invocation,gpointer user_data)204 on_handle_request_multi_property_mods (FooiGenBar *object,
205 GDBusMethodInvocation *invocation,
206 gpointer user_data)
207 {
208 foo_igen_bar_set_y (object, foo_igen_bar_get_y (object) + 1);
209 foo_igen_bar_set_i (object, foo_igen_bar_get_i (object) + 1);
210 foo_igen_bar_set_y (object, foo_igen_bar_get_y (object) + 1);
211 foo_igen_bar_set_i (object, foo_igen_bar_get_i (object) + 1);
212 g_dbus_interface_skeleton_flush (G_DBUS_INTERFACE_SKELETON (object));
213 foo_igen_bar_set_y (object, foo_igen_bar_get_y (object) + 1);
214 foo_igen_bar_set_i (object, foo_igen_bar_get_i (object) + 1);
215 foo_igen_bar_complete_request_multi_property_mods (object, invocation);
216 return TRUE;
217 }
218
219 static gboolean
on_handle_property_cancellation(FooiGenBar * object,GDBusMethodInvocation * invocation,gpointer user_data)220 on_handle_property_cancellation (FooiGenBar *object,
221 GDBusMethodInvocation *invocation,
222 gpointer user_data)
223 {
224 guint n;
225 n = foo_igen_bar_get_n (object);
226 /* This queues up a PropertiesChange event */
227 foo_igen_bar_set_n (object, n + 1);
228 /* this modifies the queued up event */
229 foo_igen_bar_set_n (object, n);
230 /* this flushes all PropertiesChanges event (sends the D-Bus message right
231 * away, if any - there should not be any)
232 */
233 g_dbus_interface_skeleton_flush (G_DBUS_INTERFACE_SKELETON (object));
234 /* this makes us return the reply D-Bus method */
235 foo_igen_bar_complete_property_cancellation (object, invocation);
236 return TRUE;
237 }
238
239 /* ---------------------------------------------------------------------------------------------------- */
240
241 static gboolean
on_handle_force_method(FooiGenBat * object,GDBusMethodInvocation * invocation,GVariant * force_in_i,GVariant * force_in_s,GVariant * force_in_ay,GVariant * force_in_struct,gpointer user_data)242 on_handle_force_method (FooiGenBat *object,
243 GDBusMethodInvocation *invocation,
244 GVariant *force_in_i,
245 GVariant *force_in_s,
246 GVariant *force_in_ay,
247 GVariant *force_in_struct,
248 gpointer user_data)
249 {
250 GVariant *ret_i;
251 GVariant *ret_s;
252 GVariant *ret_ay;
253 GVariant *ret_struct;
254 gint32 val;
255 gchar *s;
256
257 ret_i = g_variant_new_int32 (g_variant_get_int32 (force_in_i) + 10);
258 s = g_strdup_printf ("%s_foo", g_variant_get_string (force_in_s, NULL));
259 ret_s = g_variant_new_string (s);
260 g_free (s);
261 s = g_strdup_printf ("%s_foo\xff", g_variant_get_bytestring (force_in_ay));
262 ret_ay = g_variant_new_bytestring (s);
263 g_free (s);
264
265 g_variant_get (force_in_struct, "(i)", &val);
266 ret_struct = g_variant_new ("(i)", val + 10);
267
268 g_variant_ref_sink (ret_i);
269 g_variant_ref_sink (ret_s);
270 g_variant_ref_sink (ret_ay);
271 g_variant_ref_sink (ret_struct);
272
273 foo_igen_bat_emit_force_signal (object,
274 ret_i,
275 ret_s,
276 ret_ay,
277 ret_struct);
278
279 foo_igen_bat_complete_force_method (object,
280 invocation,
281 ret_i,
282 ret_s,
283 ret_ay,
284 ret_struct);
285
286 g_variant_unref (ret_i);
287 g_variant_unref (ret_s);
288 g_variant_unref (ret_ay);
289 g_variant_unref (ret_struct);
290
291 return TRUE;
292 }
293
294
295 /* ---------------------------------------------------------------------------------------------------- */
296
297 static gboolean
my_g_authorize_method_handler(GDBusInterfaceSkeleton * interface,GDBusMethodInvocation * invocation,gpointer user_data)298 my_g_authorize_method_handler (GDBusInterfaceSkeleton *interface,
299 GDBusMethodInvocation *invocation,
300 gpointer user_data)
301 {
302 const gchar *method_name;
303 gboolean authorized;
304
305 authorized = FALSE;
306
307 method_name = g_dbus_method_invocation_get_method_name (invocation);
308 if (g_strcmp0 (method_name, "CheckNotAuthorized") == 0)
309 {
310 authorized = FALSE;
311 }
312 else if (g_strcmp0 (method_name, "CheckAuthorized") == 0)
313 {
314 authorized = TRUE;
315 }
316 else if (g_strcmp0 (method_name, "CheckNotAuthorizedFromObject") == 0)
317 {
318 authorized = TRUE;
319 }
320 else
321 {
322 g_assert_not_reached ();
323 }
324
325 if (!authorized)
326 {
327 g_dbus_method_invocation_return_error (invocation,
328 G_IO_ERROR,
329 G_IO_ERROR_PERMISSION_DENIED,
330 "not authorized...");
331 }
332 return authorized;
333 }
334
335 static gboolean
my_object_authorize_method_handler(GDBusObjectSkeleton * object,GDBusInterfaceSkeleton * interface,GDBusMethodInvocation * invocation,gpointer user_data)336 my_object_authorize_method_handler (GDBusObjectSkeleton *object,
337 GDBusInterfaceSkeleton *interface,
338 GDBusMethodInvocation *invocation,
339 gpointer user_data)
340 {
341 const gchar *method_name;
342 gboolean authorized;
343
344 authorized = FALSE;
345
346 method_name = g_dbus_method_invocation_get_method_name (invocation);
347 if (g_strcmp0 (method_name, "CheckNotAuthorized") == 0)
348 {
349 authorized = TRUE;
350 }
351 else if (g_strcmp0 (method_name, "CheckAuthorized") == 0)
352 {
353 authorized = TRUE;
354 }
355 else if (g_strcmp0 (method_name, "CheckNotAuthorizedFromObject") == 0)
356 {
357 authorized = FALSE;
358 }
359 else
360 {
361 g_assert_not_reached ();
362 }
363
364 if (!authorized)
365 {
366 g_dbus_method_invocation_return_error (invocation,
367 G_IO_ERROR,
368 G_IO_ERROR_PENDING,
369 "not authorized (from object)...");
370 }
371 return authorized;
372 }
373
374 static gboolean
on_handle_check_not_authorized(FooiGenAuthorize * object,GDBusMethodInvocation * invocation,gpointer user_data)375 on_handle_check_not_authorized (FooiGenAuthorize *object,
376 GDBusMethodInvocation *invocation,
377 gpointer user_data)
378 {
379 foo_igen_authorize_complete_check_not_authorized (object, invocation);
380 return TRUE;
381 }
382
383 static gboolean
on_handle_check_authorized(FooiGenAuthorize * object,GDBusMethodInvocation * invocation,gpointer user_data)384 on_handle_check_authorized (FooiGenAuthorize *object,
385 GDBusMethodInvocation *invocation,
386 gpointer user_data)
387 {
388 foo_igen_authorize_complete_check_authorized (object, invocation);
389 return TRUE;
390 }
391
392 static gboolean
on_handle_check_not_authorized_from_object(FooiGenAuthorize * object,GDBusMethodInvocation * invocation,gpointer user_data)393 on_handle_check_not_authorized_from_object (FooiGenAuthorize *object,
394 GDBusMethodInvocation *invocation,
395 gpointer user_data)
396 {
397 foo_igen_authorize_complete_check_not_authorized_from_object (object, invocation);
398 return TRUE;
399 }
400
401 /* ---------------------------------------------------------------------------------------------------- */
402
403 static gboolean
on_handle_get_self(FooiGenMethodThreads * object,GDBusMethodInvocation * invocation,gpointer user_data)404 on_handle_get_self (FooiGenMethodThreads *object,
405 GDBusMethodInvocation *invocation,
406 gpointer user_data)
407 {
408 gchar *s;
409 s = g_strdup_printf ("%p", (void *)g_thread_self ());
410 foo_igen_method_threads_complete_get_self (object, invocation, s);
411 g_free (s);
412 return TRUE;
413 }
414
415 /* ---------------------------------------------------------------------------------------------------- */
416
417 static GThread *method_handler_thread = NULL;
418
419 static FooiGenBar *exported_bar_object = NULL;
420 static FooiGenBat *exported_bat_object = NULL;
421 static FooiGenAuthorize *exported_authorize_object = NULL;
422 static GDBusObjectSkeleton *authorize_enclosing_object = NULL;
423 static FooiGenMethodThreads *exported_thread_object_1 = NULL;
424 static FooiGenMethodThreads *exported_thread_object_2 = NULL;
425
426 static void
unexport_objects(void)427 unexport_objects (void)
428 {
429 g_dbus_interface_skeleton_unexport (G_DBUS_INTERFACE_SKELETON (exported_bar_object));
430 g_dbus_interface_skeleton_unexport (G_DBUS_INTERFACE_SKELETON (exported_bat_object));
431 g_dbus_interface_skeleton_unexport (G_DBUS_INTERFACE_SKELETON (exported_authorize_object));
432 g_dbus_interface_skeleton_unexport (G_DBUS_INTERFACE_SKELETON (exported_thread_object_1));
433 g_dbus_interface_skeleton_unexport (G_DBUS_INTERFACE_SKELETON (exported_thread_object_2));
434 }
435
436 static void
on_bus_acquired(GDBusConnection * connection,const gchar * name,gpointer user_data)437 on_bus_acquired (GDBusConnection *connection,
438 const gchar *name,
439 gpointer user_data)
440 {
441 GError *error;
442
443 /* Test that we can export an object using the generated
444 * FooiGenBarSkeleton subclass. Notes:
445 *
446 * 1. We handle methods by simply connecting to the appropriate
447 * GObject signal.
448 *
449 * 2. Property storage is taken care of by the class; we can
450 * use g_object_get()/g_object_set() (and the generated
451 * C bindings at will)
452 */
453 error = NULL;
454 exported_bar_object = foo_igen_bar_skeleton_new ();
455 foo_igen_bar_set_ay (exported_bar_object, "ABCabc");
456 foo_igen_bar_set_y (exported_bar_object, 42);
457 foo_igen_bar_set_d (exported_bar_object, 43.0);
458 foo_igen_bar_set_finally_normal_name (exported_bar_object, "There aint no place like home");
459 foo_igen_bar_set_writeonly_property (exported_bar_object, "Mr. Burns");
460
461 /* The following works because it's on the Skeleton object - it will
462 * fail (at run-time) on a Proxy (see on_proxy_appeared() below)
463 */
464 foo_igen_bar_set_readonly_property (exported_bar_object, "blah");
465 g_assert_cmpstr (foo_igen_bar_get_writeonly_property (exported_bar_object), ==, "Mr. Burns");
466
467 g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (exported_bar_object),
468 connection,
469 "/bar",
470 &error);
471 g_assert_no_error (error);
472 g_signal_connect (exported_bar_object,
473 "handle-hello-world",
474 G_CALLBACK (on_handle_hello_world),
475 NULL);
476 g_signal_connect (exported_bar_object,
477 "handle-test-primitive-types",
478 G_CALLBACK (on_handle_test_primitive_types),
479 NULL);
480 g_signal_connect (exported_bar_object,
481 "handle-test-non-primitive-types",
482 G_CALLBACK (on_handle_test_non_primitive_types),
483 NULL);
484 g_signal_connect (exported_bar_object,
485 "handle-request-signal-emission",
486 G_CALLBACK (on_handle_request_signal_emission),
487 NULL);
488 g_signal_connect (exported_bar_object,
489 "handle-request-multi-property-mods",
490 G_CALLBACK (on_handle_request_multi_property_mods),
491 NULL);
492 g_signal_connect (exported_bar_object,
493 "handle-property-cancellation",
494 G_CALLBACK (on_handle_property_cancellation),
495 NULL);
496
497 exported_bat_object = foo_igen_bat_skeleton_new ();
498 g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (exported_bat_object),
499 connection,
500 "/bat",
501 &error);
502 g_assert_no_error (error);
503 g_signal_connect (exported_bat_object,
504 "handle-force-method",
505 G_CALLBACK (on_handle_force_method),
506 NULL);
507 g_object_set (exported_bat_object,
508 "force-i", g_variant_new_int32 (43),
509 "force-s", g_variant_new_string ("prop string"),
510 "force-ay", g_variant_new_bytestring ("prop bytestring\xff"),
511 "force-struct", g_variant_new ("(i)", 4300),
512 NULL);
513
514 authorize_enclosing_object = g_dbus_object_skeleton_new ("/authorize");
515 g_signal_connect (authorize_enclosing_object,
516 "authorize-method",
517 G_CALLBACK (my_object_authorize_method_handler),
518 NULL);
519 exported_authorize_object = foo_igen_authorize_skeleton_new ();
520 g_dbus_object_skeleton_add_interface (authorize_enclosing_object,
521 G_DBUS_INTERFACE_SKELETON (exported_authorize_object));
522 g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (exported_authorize_object),
523 connection,
524 "/authorize",
525 &error);
526 g_assert_no_error (error);
527 g_signal_connect (exported_authorize_object,
528 "g-authorize-method",
529 G_CALLBACK (my_g_authorize_method_handler),
530 NULL);
531 g_signal_connect (exported_authorize_object,
532 "handle-check-not-authorized",
533 G_CALLBACK (on_handle_check_not_authorized),
534 NULL);
535 g_signal_connect (exported_authorize_object,
536 "handle-check-authorized",
537 G_CALLBACK (on_handle_check_authorized),
538 NULL);
539 g_signal_connect (exported_authorize_object,
540 "handle-check-not-authorized-from-object",
541 G_CALLBACK (on_handle_check_not_authorized_from_object),
542 NULL);
543
544
545 /* only object 1 has the G_DBUS_INTERFACE_SKELETON_FLAGS_HANDLE_METHOD_INVOCATIONS_IN_THREAD flag set */
546 exported_thread_object_1 = foo_igen_method_threads_skeleton_new ();
547 g_dbus_interface_skeleton_set_flags (G_DBUS_INTERFACE_SKELETON (exported_thread_object_1),
548 G_DBUS_INTERFACE_SKELETON_FLAGS_HANDLE_METHOD_INVOCATIONS_IN_THREAD);
549
550 g_assert (!g_dbus_interface_skeleton_has_connection (G_DBUS_INTERFACE_SKELETON (exported_thread_object_1), connection));
551 g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (exported_thread_object_1),
552 connection,
553 "/method_threads_1",
554 &error);
555 g_assert_no_error (error);
556 g_signal_connect (exported_thread_object_1,
557 "handle-get-self",
558 G_CALLBACK (on_handle_get_self),
559 NULL);
560 g_assert_cmpint (g_dbus_interface_skeleton_get_flags (G_DBUS_INTERFACE_SKELETON (exported_thread_object_1)), ==, G_DBUS_INTERFACE_SKELETON_FLAGS_HANDLE_METHOD_INVOCATIONS_IN_THREAD);
561
562 exported_thread_object_2 = foo_igen_method_threads_skeleton_new ();
563 g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (exported_thread_object_2),
564 connection,
565 "/method_threads_2",
566 &error);
567 g_assert_no_error (error);
568 g_signal_connect (exported_thread_object_2,
569 "handle-get-self",
570 G_CALLBACK (on_handle_get_self),
571 NULL);
572
573 g_assert_cmpint (g_dbus_interface_skeleton_get_flags (G_DBUS_INTERFACE_SKELETON (exported_thread_object_2)), ==, G_DBUS_INTERFACE_SKELETON_FLAGS_NONE);
574
575 method_handler_thread = g_thread_self ();
576 }
577
578 static gpointer check_proxies_in_thread (gpointer user_data);
579
580 static void
on_name_acquired(GDBusConnection * connection,const gchar * name,gpointer user_data)581 on_name_acquired (GDBusConnection *connection,
582 const gchar *name,
583 gpointer user_data)
584 {
585 GMainLoop *loop = user_data;
586 GThread *thread = g_thread_new ("check-proxies", check_proxies_in_thread, loop);
587 g_thread_unref (thread);
588 }
589
590 static void
on_name_lost(GDBusConnection * connection,const gchar * name,gpointer user_data)591 on_name_lost (GDBusConnection *connection,
592 const gchar *name,
593 gpointer user_data)
594 {
595 g_assert_not_reached ();
596 }
597
598 /* ---------------------------------------------------------------------------------------------------- */
599
600 typedef struct
601 {
602 GMainLoop *thread_loop;
603 gint initial_y;
604 gint initial_i;
605 guint num_g_properties_changed;
606 gboolean received_test_signal;
607 guint num_notify_u;
608 guint num_notify_n;
609 } ClientData;
610
611 static void
on_notify_u(GObject * object,GParamSpec * pspec,gpointer user_data)612 on_notify_u (GObject *object,
613 GParamSpec *pspec,
614 gpointer user_data)
615 {
616 ClientData *data = user_data;
617 g_assert_cmpstr (pspec->name, ==, "u");
618 data->num_notify_u += 1;
619 }
620
621 static void
on_notify_n(GObject * object,GParamSpec * pspec,gpointer user_data)622 on_notify_n (GObject *object,
623 GParamSpec *pspec,
624 gpointer user_data)
625 {
626 ClientData *data = user_data;
627 g_assert_cmpstr (pspec->name, ==, "n");
628 data->num_notify_n += 1;
629 }
630
631 static void
on_g_properties_changed(GDBusProxy * _proxy,GVariant * changed_properties,const gchar * const * invalidated_properties,gpointer user_data)632 on_g_properties_changed (GDBusProxy *_proxy,
633 GVariant *changed_properties,
634 const gchar* const *invalidated_properties,
635 gpointer user_data)
636 {
637 ClientData *data = user_data;
638 FooiGenBar *proxy = FOO_IGEN_BAR (_proxy);
639
640 g_assert_cmpint (g_variant_n_children (changed_properties), ==, 2);
641
642 if (data->num_g_properties_changed == 0)
643 {
644 g_assert_cmpint (data->initial_y, ==, foo_igen_bar_get_y (proxy) - 2);
645 g_assert_cmpint (data->initial_i, ==, foo_igen_bar_get_i (proxy) - 2);
646 }
647 else if (data->num_g_properties_changed == 1)
648 {
649 g_assert_cmpint (data->initial_y, ==, foo_igen_bar_get_y (proxy) - 3);
650 g_assert_cmpint (data->initial_i, ==, foo_igen_bar_get_i (proxy) - 3);
651 }
652 else
653 g_assert_not_reached ();
654
655 data->num_g_properties_changed++;
656
657 if (data->num_g_properties_changed == 2)
658 g_main_loop_quit (data->thread_loop);
659 }
660
661 static void
on_test_signal(FooiGenBar * proxy,gint val_int32,const gchar * const * array_of_strings,const gchar * const * array_of_bytestrings,GVariant * dict_s_to_pairs,gpointer user_data)662 on_test_signal (FooiGenBar *proxy,
663 gint val_int32,
664 const gchar* const *array_of_strings,
665 const gchar* const *array_of_bytestrings,
666 GVariant *dict_s_to_pairs,
667 gpointer user_data)
668 {
669 ClientData *data = user_data;
670
671 g_assert_cmpint (val_int32, ==, 43);
672 g_assert_cmpstr (array_of_strings[0], ==, "foo");
673 g_assert_cmpstr (array_of_strings[1], ==, "bar");
674 g_assert (array_of_strings[2] == NULL);
675 g_assert_cmpstr (array_of_bytestrings[0], ==, "foo\xff");
676 g_assert_cmpstr (array_of_bytestrings[1], ==, "bar\xff");
677 g_assert (array_of_bytestrings[2] == NULL);
678
679 data->received_test_signal = TRUE;
680 g_main_loop_quit (data->thread_loop);
681 }
682
683 static void
on_property_cancellation_cb(FooiGenBar * proxy,GAsyncResult * res,gpointer user_data)684 on_property_cancellation_cb (FooiGenBar *proxy,
685 GAsyncResult *res,
686 gpointer user_data)
687 {
688 ClientData *data = user_data;
689 gboolean ret;
690 GError *error = NULL;
691
692 error = NULL;
693 ret = foo_igen_bar_call_property_cancellation_finish (proxy, res, &error);
694 g_assert_no_error (error);
695 g_assert (ret);
696
697 g_main_loop_quit (data->thread_loop);
698 }
699
700 static void
check_bar_proxy(FooiGenBar * proxy,GMainLoop * thread_loop)701 check_bar_proxy (FooiGenBar *proxy,
702 GMainLoop *thread_loop)
703 {
704 const gchar *array_of_strings[3] = {"one", "two", NULL};
705 const gchar *array_of_strings_2[3] = {"one2", "two2", NULL};
706 const gchar *array_of_objpaths[3] = {"/one", "/one/two", NULL};
707 GVariant *array_of_signatures = NULL;
708 const gchar *array_of_bytestrings[3] = {"one\xff", "two\xff", NULL};
709 gchar **ret_array_of_strings = NULL;
710 gchar **ret_array_of_objpaths = NULL;
711 GVariant *ret_array_of_signatures = NULL;
712 gchar **ret_array_of_bytestrings = NULL;
713 guchar ret_val_byte;
714 gboolean ret_val_boolean;
715 gint16 ret_val_int16;
716 guint16 ret_val_uint16;
717 gint ret_val_int32;
718 guint ret_val_uint32;
719 gint64 ret_val_int64;
720 guint64 ret_val_uint64;
721 gdouble ret_val_double;
722 gchar *ret_val_string;
723 gchar *ret_val_objpath;
724 gchar *ret_val_signature;
725 gchar *ret_val_bytestring;
726 gboolean ret;
727 GError *error;
728 ClientData *data;
729 guchar val_y;
730 gboolean val_b;
731 gint val_n;
732 guint val_q;
733 gint val_i;
734 guint val_u;
735 gint64 val_x;
736 guint64 val_t;
737 gdouble val_d;
738 gchar *val_s;
739 gchar *val_o;
740 gchar *val_g;
741 gchar *val_ay;
742 gchar **val_as;
743 gchar **val_ao;
744 GVariant *val_ag;
745 gint32 val_unset_i;
746 gdouble val_unset_d;
747 gchar *val_unset_s;
748 gchar *val_unset_o;
749 gchar *val_unset_g;
750 gchar *val_unset_ay;
751 gchar **val_unset_as;
752 gchar **val_unset_ao;
753 GVariant *val_unset_ag;
754 GVariant *val_unset_struct;
755 gchar *val_finally_normal_name;
756 GVariant *v;
757 gchar *s;
758 const gchar *const *read_as;
759 const gchar *const *read_as2;
760 const gchar *const *read_as3;
761
762 data = g_new0 (ClientData, 1);
763 data->thread_loop = thread_loop;
764
765 v = g_dbus_proxy_get_cached_property (G_DBUS_PROXY (proxy), "y");
766 g_assert (v != NULL);
767 g_variant_unref (v);
768
769 /* set empty values to non-empty */
770 val_unset_i = 42;
771 val_unset_d = 42.0;
772 val_unset_s = "42";
773 val_unset_o = "42";
774 val_unset_g = "42";
775 val_unset_ay = NULL;
776 val_unset_as = NULL;
777 val_unset_ao = NULL;
778 val_unset_ag = NULL;
779 val_unset_struct = NULL;
780 /* check properties */
781 g_object_get (proxy,
782 "y", &val_y,
783 "b", &val_b,
784 "n", &val_n,
785 "q", &val_q,
786 "i", &val_i,
787 "u", &val_u,
788 "x", &val_x,
789 "t", &val_t,
790 "d", &val_d,
791 "s", &val_s,
792 "o", &val_o,
793 "g", &val_g,
794 "ay", &val_ay,
795 "as", &val_as,
796 "ao", &val_ao,
797 "ag", &val_ag,
798 "unset_i", &val_unset_i,
799 "unset_d", &val_unset_d,
800 "unset_s", &val_unset_s,
801 "unset_o", &val_unset_o,
802 "unset_g", &val_unset_g,
803 "unset_ay", &val_unset_ay,
804 "unset_as", &val_unset_as,
805 "unset_ao", &val_unset_ao,
806 "unset_ag", &val_unset_ag,
807 "unset_struct", &val_unset_struct,
808 "finally-normal-name", &val_finally_normal_name,
809 NULL);
810 g_assert_cmpint (val_y, ==, 42);
811 g_assert_cmpstr (val_finally_normal_name, ==, "There aint no place like home");
812 g_free (val_s);
813 g_free (val_o);
814 g_free (val_g);
815 g_assert_cmpstr (val_ay, ==, "ABCabc");
816 g_free (val_ay);
817 g_strfreev (val_as);
818 g_strfreev (val_ao);
819 g_variant_unref (val_ag);
820 g_free (val_finally_normal_name);
821 /* check empty values */
822 g_assert_cmpint (val_unset_i, ==, 0);
823 g_assert_cmpfloat (val_unset_d, ==, 0.0);
824 g_assert_cmpstr (val_unset_s, ==, "");
825 g_assert_cmpstr (val_unset_o, ==, "/");
826 g_assert_cmpstr (val_unset_g, ==, "");
827 g_free (val_unset_s);
828 g_free (val_unset_o);
829 g_free (val_unset_g);
830 g_assert_cmpstr (val_unset_ay, ==, "");
831 g_assert (val_unset_as[0] == NULL);
832 g_assert (val_unset_ao[0] == NULL);
833 g_assert (g_variant_is_of_type (val_unset_ag, G_VARIANT_TYPE ("ag")));
834 g_assert (g_variant_is_of_type (val_unset_struct, G_VARIANT_TYPE ("(idsogayasaoag)")));
835 s = g_variant_print (val_unset_struct, TRUE);
836 g_assert_cmpstr (s, ==, "(0, 0.0, '', objectpath '/', signature '', @ay [], @as [], @ao [], @ag [])");
837 g_free (s);
838 g_free (val_unset_ay);
839 g_strfreev (val_unset_as);
840 g_strfreev (val_unset_ao);
841 g_variant_unref (val_unset_ag);
842 g_variant_unref (val_unset_struct);
843
844 /* Try setting a property. This causes the generated glue to invoke
845 * the org.fd.DBus.Properties.Set() method asynchronously. So we
846 * have to wait for properties-changed...
847 */
848 foo_igen_bar_set_finally_normal_name (proxy, "foo!");
849 _g_assert_property_notify (proxy, "finally-normal-name");
850 g_assert_cmpstr (foo_igen_bar_get_finally_normal_name (proxy), ==, "foo!");
851
852 /* Try setting properties that requires memory management. This
853 * is to exercise the paths that frees the references.
854 */
855
856 g_object_set (proxy,
857 "s", "a string",
858 "o", "/a/path",
859 "g", "asig",
860 "ay", g_variant_new_parsed ("[byte 0x65, 0x67]"),
861 "as", array_of_strings,
862 "ao", array_of_objpaths,
863 "ag", g_variant_new_parsed ("[@g 'ass', 'git']"),
864 NULL);
865
866 error = NULL;
867 ret = foo_igen_bar_call_test_primitive_types_sync (proxy,
868 10,
869 TRUE,
870 11,
871 12,
872 13,
873 14,
874 15,
875 16,
876 17,
877 "a string",
878 "/a/path",
879 "asig",
880 "bytestring\xff",
881 &ret_val_byte,
882 &ret_val_boolean,
883 &ret_val_int16,
884 &ret_val_uint16,
885 &ret_val_int32,
886 &ret_val_uint32,
887 &ret_val_int64,
888 &ret_val_uint64,
889 &ret_val_double,
890 &ret_val_string,
891 &ret_val_objpath,
892 &ret_val_signature,
893 &ret_val_bytestring,
894 NULL, /* GCancellable */
895 &error);
896 g_assert_no_error (error);
897 g_assert (ret);
898
899 g_clear_pointer (&ret_val_string, g_free);
900 g_clear_pointer (&ret_val_objpath, g_free);
901 g_clear_pointer (&ret_val_signature, g_free);
902 g_clear_pointer (&ret_val_bytestring, g_free);
903
904 error = NULL;
905 array_of_signatures = g_variant_ref_sink (g_variant_new_parsed ("[@g 'ass', 'git']"));
906 ret = foo_igen_bar_call_test_non_primitive_types_sync (proxy,
907 g_variant_new_parsed ("{'one': 'red',"
908 " 'two': 'blue'}"),
909 g_variant_new_parsed ("{'first': (42, 42), "
910 "'second': (43, 43)}"),
911 g_variant_new_parsed ("(42, 'foo', 'bar')"),
912 array_of_strings,
913 array_of_objpaths,
914 array_of_signatures,
915 array_of_bytestrings,
916 &ret_array_of_strings,
917 &ret_array_of_objpaths,
918 &ret_array_of_signatures,
919 &ret_array_of_bytestrings,
920 &s,
921 NULL, /* GCancellable */
922 &error);
923
924 g_assert_no_error (error);
925 g_assert (ret);
926
927 g_assert_nonnull (ret_array_of_strings);
928 g_assert_cmpuint (g_strv_length ((gchar **) ret_array_of_strings), ==,
929 g_strv_length ((gchar **) array_of_strings));
930 g_assert_nonnull (ret_array_of_objpaths);
931 g_assert_cmpuint (g_strv_length ((gchar **) ret_array_of_objpaths), ==,
932 g_strv_length ((gchar **) array_of_objpaths));
933 g_assert_nonnull (ret_array_of_signatures);
934 g_assert_cmpvariant (ret_array_of_signatures, array_of_signatures);
935 g_assert_nonnull (ret_array_of_bytestrings);
936 g_assert_cmpuint (g_strv_length ((gchar **) ret_array_of_bytestrings), ==,
937 g_strv_length ((gchar **) array_of_bytestrings));
938
939 g_clear_pointer (&ret_array_of_strings, g_strfreev);
940 g_clear_pointer (&ret_array_of_objpaths, g_strfreev);
941 g_clear_pointer (&ret_array_of_signatures, g_variant_unref);
942 g_clear_pointer (&ret_array_of_bytestrings, g_strfreev);
943 g_clear_pointer (&s, g_free);
944
945 /* Check that org.freedesktop.DBus.Error.UnknownMethod is returned on
946 * unimplemented methods.
947 */
948 error = NULL;
949 ret = foo_igen_bar_call_unimplemented_method_sync (proxy, NULL /* GCancellable */, &error);
950 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD);
951 g_error_free (error);
952 error = NULL;
953 g_assert (!ret);
954
955 g_signal_connect (proxy,
956 "test-signal",
957 G_CALLBACK (on_test_signal),
958 data);
959 error = NULL;
960 ret = foo_igen_bar_call_request_signal_emission_sync (proxy, 0, NULL, &error);
961 g_assert_no_error (error);
962 g_assert (ret);
963
964 g_assert (!data->received_test_signal);
965 g_main_loop_run (thread_loop);
966 g_assert (data->received_test_signal);
967
968 /* Try setting a property. This causes the generated glue to invoke
969 * the org.fd.DBus.Properties.Set() method asynchronously. So we
970 * have to wait for properties-changed...
971 */
972 foo_igen_bar_set_finally_normal_name (proxy, "hey back!");
973 _g_assert_property_notify (proxy, "finally-normal-name");
974 g_assert_cmpstr (foo_igen_bar_get_finally_normal_name (proxy), ==, "hey back!");
975
976 /* Check that multiple calls to a strv getter works... and that
977 * updates on them works as well (See comment for "property vfuncs"
978 * in gio/gdbus-codegen/codegen.py for details)
979 */
980 read_as = foo_igen_bar_get_as (proxy);
981 read_as2 = foo_igen_bar_get_as (proxy);
982 g_assert_cmpint (g_strv_length ((gchar **) read_as), ==, 2);
983 g_assert_cmpstr (read_as[0], ==, "one");
984 g_assert_cmpstr (read_as[1], ==, "two");
985 g_assert (read_as == read_as2); /* this is more testing an implementation detail */
986 g_object_set (proxy,
987 "as", array_of_strings_2,
988 NULL);
989 _g_assert_property_notify (proxy, "as");
990 read_as3 = foo_igen_bar_get_as (proxy);
991 g_assert_cmpint (g_strv_length ((gchar **) read_as3), ==, 2);
992 g_assert_cmpstr (read_as3[0], ==, "one2");
993 g_assert_cmpstr (read_as3[1], ==, "two2");
994
995 /* Check that grouping changes in idle works.
996 *
997 * See on_handle_request_multi_property_mods(). The server should
998 * emit exactly two PropertiesChanged signals each containing two
999 * properties.
1000 *
1001 * On the first reception, y and i should both be increased by
1002 * two. On the second reception, only by one. The signal handler
1003 * checks this.
1004 *
1005 * This also checks that _drain_notify() works.
1006 */
1007 data->initial_y = foo_igen_bar_get_y (proxy);
1008 data->initial_i = foo_igen_bar_get_i (proxy);
1009 g_signal_connect (proxy,
1010 "g-properties-changed",
1011 G_CALLBACK (on_g_properties_changed),
1012 data);
1013 error = NULL;
1014 ret = foo_igen_bar_call_request_multi_property_mods_sync (proxy, NULL, &error);
1015 g_assert_no_error (error);
1016 g_assert (ret);
1017 g_main_loop_run (thread_loop);
1018 g_assert_cmpint (data->num_g_properties_changed, ==, 2);
1019 g_signal_handlers_disconnect_by_func (proxy,
1020 G_CALLBACK (on_g_properties_changed),
1021 data);
1022
1023 /* Check that we don't emit PropertiesChanged() if the property
1024 * didn't change... we actually get two notifies.. one for the
1025 * local set (without a value change) and one when receiving
1026 * the PropertiesChanged() signal generated from the remote end.
1027 */
1028 g_assert_cmpint (data->num_notify_u, ==, 0);
1029 g_signal_connect (proxy,
1030 "notify::u",
1031 G_CALLBACK (on_notify_u),
1032 data);
1033 foo_igen_bar_set_u (proxy, 1042);
1034 g_assert_cmpint (data->num_notify_u, ==, 1);
1035 g_assert_cmpint (foo_igen_bar_get_u (proxy), ==, 0);
1036 _g_assert_property_notify (proxy, "u");
1037 g_assert_cmpint (foo_igen_bar_get_u (proxy), ==, 1042);
1038 g_assert_cmpint (data->num_notify_u, ==, 2);
1039
1040 /* Now change u again to the same value.. this will cause a
1041 * local notify:: notify and the usual Properties.Set() call
1042 *
1043 * (Btw, why also the Set() call if the value in the cache is
1044 * the same? Because someone else might have changed it
1045 * in the mean time and we're just waiting to receive the
1046 * PropertiesChanged() signal...)
1047 *
1048 * More tricky - how do we check for the *absence* of the
1049 * notification that u changed? Simple: we change another
1050 * property and wait for that PropertiesChanged() message
1051 * to arrive.
1052 */
1053 foo_igen_bar_set_u (proxy, 1042);
1054 g_assert_cmpint (data->num_notify_u, ==, 3);
1055
1056 g_assert_cmpint (data->num_notify_n, ==, 0);
1057 g_signal_connect (proxy,
1058 "notify::n",
1059 G_CALLBACK (on_notify_n),
1060 data);
1061 foo_igen_bar_set_n (proxy, 10042);
1062 g_assert_cmpint (data->num_notify_n, ==, 1);
1063 g_assert_cmpint (foo_igen_bar_get_n (proxy), ==, 0);
1064 _g_assert_property_notify (proxy, "n");
1065 g_assert_cmpint (foo_igen_bar_get_n (proxy), ==, 10042);
1066 g_assert_cmpint (data->num_notify_n, ==, 2);
1067 /* Checks that u didn't change at all */
1068 g_assert_cmpint (data->num_notify_u, ==, 3);
1069
1070 /* Now we check that if the service does
1071 *
1072 * guint n = foo_igen_bar_get_n (foo);
1073 * foo_igen_bar_set_n (foo, n + 1);
1074 * foo_igen_bar_set_n (foo, n);
1075 *
1076 * then no PropertiesChanged() signal is emitted!
1077 */
1078 error = NULL;
1079 foo_igen_bar_call_property_cancellation (proxy,
1080 NULL, /* GCancellable */
1081 (GAsyncReadyCallback) on_property_cancellation_cb,
1082 data);
1083 g_main_loop_run (thread_loop);
1084 /* Checks that n didn't change at all */
1085 g_assert_cmpint (data->num_notify_n, ==, 2);
1086
1087 /* cleanup */
1088 g_free (data);
1089 g_variant_unref (array_of_signatures);
1090 }
1091
1092 /* ---------------------------------------------------------------------------------------------------- */
1093
1094 static void
on_force_signal(FooiGenBat * proxy,GVariant * force_i,GVariant * force_s,GVariant * force_ay,GVariant * force_struct,gpointer user_data)1095 on_force_signal (FooiGenBat *proxy,
1096 GVariant *force_i,
1097 GVariant *force_s,
1098 GVariant *force_ay,
1099 GVariant *force_struct,
1100 gpointer user_data)
1101 {
1102 gboolean *signal_received = user_data;
1103 gint val;
1104
1105 g_assert (!(*signal_received));
1106
1107 g_assert_cmpint (g_variant_get_int32 (force_i), ==, 42 + 10);
1108 g_assert_cmpstr (g_variant_get_string (force_s, NULL), ==, "a string_foo");
1109 g_assert_cmpstr (g_variant_get_bytestring (force_ay), ==, "a bytestring\xff_foo\xff");
1110 g_variant_get (force_struct, "(i)", &val);
1111 g_assert_cmpint (val, ==, 4200 + 10);
1112
1113 *signal_received = TRUE;
1114 }
1115
1116 static void
check_bat_proxy(FooiGenBat * proxy,GMainLoop * thread_loop)1117 check_bat_proxy (FooiGenBat *proxy,
1118 GMainLoop *thread_loop)
1119 {
1120 GError *error;
1121 GVariant *ret_i;
1122 GVariant *ret_s;
1123 GVariant *ret_ay;
1124 GVariant *ret_struct;
1125 gint val;
1126 gboolean force_signal_received;
1127
1128 /* --------------------------------------------------- */
1129 /* Check type-mapping where we force use of a GVariant */
1130 /* --------------------------------------------------- */
1131
1132 /* check properties */
1133 g_object_get (proxy,
1134 "force-i", &ret_i,
1135 "force-s", &ret_s,
1136 "force-ay", &ret_ay,
1137 "force-struct", &ret_struct,
1138 NULL);
1139 g_assert_cmpint (g_variant_get_int32 (ret_i), ==, 43);
1140 g_assert_cmpstr (g_variant_get_string (ret_s, NULL), ==, "prop string");
1141 g_assert_cmpstr (g_variant_get_bytestring (ret_ay), ==, "prop bytestring\xff");
1142 g_variant_get (ret_struct, "(i)", &val);
1143 g_assert_cmpint (val, ==, 4300);
1144 g_variant_unref (ret_i);
1145 g_variant_unref (ret_s);
1146 g_variant_unref (ret_ay);
1147 g_variant_unref (ret_struct);
1148
1149 /* check method and signal */
1150 force_signal_received = FALSE;
1151 g_signal_connect (proxy,
1152 "force-signal",
1153 G_CALLBACK (on_force_signal),
1154 &force_signal_received);
1155
1156 error = NULL;
1157 foo_igen_bat_call_force_method_sync (proxy,
1158 g_variant_new_int32 (42),
1159 g_variant_new_string ("a string"),
1160 g_variant_new_bytestring ("a bytestring\xff"),
1161 g_variant_new ("(i)", 4200),
1162 &ret_i,
1163 &ret_s,
1164 &ret_ay,
1165 &ret_struct,
1166 NULL, /* GCancellable* */
1167 &error);
1168 g_assert_no_error (error);
1169 g_assert_cmpint (g_variant_get_int32 (ret_i), ==, 42 + 10);
1170 g_assert_cmpstr (g_variant_get_string (ret_s, NULL), ==, "a string_foo");
1171 g_assert_cmpstr (g_variant_get_bytestring (ret_ay), ==, "a bytestring\xff_foo\xff");
1172 g_variant_get (ret_struct, "(i)", &val);
1173 g_assert_cmpint (val, ==, 4200 + 10);
1174 g_variant_unref (ret_i);
1175 g_variant_unref (ret_s);
1176 g_variant_unref (ret_ay);
1177 g_variant_unref (ret_struct);
1178 _g_assert_signal_received (proxy, "force-signal");
1179 g_assert (force_signal_received);
1180 }
1181
1182 /* ---------------------------------------------------------------------------------------------------- */
1183
1184 static void
check_authorize_proxy(FooiGenAuthorize * proxy,GMainLoop * thread_loop)1185 check_authorize_proxy (FooiGenAuthorize *proxy,
1186 GMainLoop *thread_loop)
1187 {
1188 GError *error;
1189 gboolean ret;
1190
1191 /* Check that g-authorize-method works as intended */
1192
1193 error = NULL;
1194 ret = foo_igen_authorize_call_check_not_authorized_sync (proxy, NULL, &error);
1195 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_PERMISSION_DENIED);
1196 g_error_free (error);
1197 g_assert (!ret);
1198
1199 error = NULL;
1200 ret = foo_igen_authorize_call_check_authorized_sync (proxy, NULL, &error);
1201 g_assert_no_error (error);
1202 g_assert (ret);
1203
1204 error = NULL;
1205 ret = foo_igen_authorize_call_check_not_authorized_from_object_sync (proxy, NULL, &error);
1206 g_assert_error (error, G_IO_ERROR, G_IO_ERROR_PENDING);
1207 g_error_free (error);
1208 g_assert (!ret);
1209 }
1210
1211 /* ---------------------------------------------------------------------------------------------------- */
1212
1213 static GThread *
get_self_via_proxy(FooiGenMethodThreads * proxy_1)1214 get_self_via_proxy (FooiGenMethodThreads *proxy_1)
1215 {
1216 GError *error;
1217 gchar *self_str;
1218 gboolean ret;
1219 gpointer self;
1220
1221 error = NULL;
1222 ret = foo_igen_method_threads_call_get_self_sync (proxy_1, &self_str, NULL, &error);
1223 g_assert_no_error (error);
1224 g_assert (ret);
1225
1226 g_assert_cmpint (sscanf (self_str, "%p", &self), ==, 1);
1227
1228 g_free (self_str);
1229
1230 return self;
1231 }
1232
1233 static void
check_thread_proxies(FooiGenMethodThreads * proxy_1,FooiGenMethodThreads * proxy_2,GMainLoop * thread_loop)1234 check_thread_proxies (FooiGenMethodThreads *proxy_1,
1235 FooiGenMethodThreads *proxy_2,
1236 GMainLoop *thread_loop)
1237 {
1238 /* proxy_1 is indeed using threads so should never get the handler thread */
1239 g_assert (get_self_via_proxy (proxy_1) != method_handler_thread);
1240
1241 /* proxy_2 is not using threads so should get the handler thread */
1242 g_assert (get_self_via_proxy (proxy_2) == method_handler_thread);
1243 }
1244
1245 /* ---------------------------------------------------------------------------------------------------- */
1246
1247 static gpointer
check_proxies_in_thread(gpointer user_data)1248 check_proxies_in_thread (gpointer user_data)
1249 {
1250 GMainLoop *loop = user_data;
1251 GMainContext *thread_context;
1252 GMainLoop *thread_loop;
1253 GError *error;
1254 FooiGenBar *bar_proxy;
1255 FooiGenBat *bat_proxy;
1256 FooiGenAuthorize *authorize_proxy;
1257 FooiGenMethodThreads *thread_proxy_1;
1258 FooiGenMethodThreads *thread_proxy_2;
1259
1260 thread_context = g_main_context_new ();
1261 thread_loop = g_main_loop_new (thread_context, FALSE);
1262 g_main_context_push_thread_default (thread_context);
1263
1264 /* Check the object */
1265 error = NULL;
1266 bar_proxy = foo_igen_bar_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION,
1267 G_DBUS_PROXY_FLAGS_NONE,
1268 "org.gtk.GDBus.BindingsTool.Test",
1269 "/bar",
1270 NULL, /* GCancellable* */
1271 &error);
1272 check_bar_proxy (bar_proxy, thread_loop);
1273 g_assert_no_error (error);
1274 g_object_unref (bar_proxy);
1275
1276 error = NULL;
1277 bat_proxy = foo_igen_bat_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION,
1278 G_DBUS_PROXY_FLAGS_NONE,
1279 "org.gtk.GDBus.BindingsTool.Test",
1280 "/bat",
1281 NULL, /* GCancellable* */
1282 &error);
1283 check_bat_proxy (bat_proxy, thread_loop);
1284 g_assert_no_error (error);
1285 g_object_unref (bat_proxy);
1286
1287 error = NULL;
1288 authorize_proxy = foo_igen_authorize_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION,
1289 G_DBUS_PROXY_FLAGS_NONE,
1290 "org.gtk.GDBus.BindingsTool.Test",
1291 "/authorize",
1292 NULL, /* GCancellable* */
1293 &error);
1294 check_authorize_proxy (authorize_proxy, thread_loop);
1295 g_assert_no_error (error);
1296 g_object_unref (authorize_proxy);
1297
1298 error = NULL;
1299 thread_proxy_1 = foo_igen_method_threads_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION,
1300 G_DBUS_PROXY_FLAGS_NONE,
1301 "org.gtk.GDBus.BindingsTool.Test",
1302 "/method_threads_1",
1303 NULL, /* GCancellable* */
1304 &error);
1305 g_assert_no_error (error);
1306 thread_proxy_2 = foo_igen_method_threads_proxy_new_for_bus_sync (G_BUS_TYPE_SESSION,
1307 G_DBUS_PROXY_FLAGS_NONE,
1308 "org.gtk.GDBus.BindingsTool.Test",
1309 "/method_threads_2",
1310 NULL, /* GCancellable* */
1311 &error);
1312 g_assert_no_error (error);
1313 check_thread_proxies (thread_proxy_1, thread_proxy_2, thread_loop);
1314 g_object_unref (thread_proxy_1);
1315 g_object_unref (thread_proxy_2);
1316
1317 g_main_loop_unref (thread_loop);
1318 g_main_context_unref (thread_context);
1319
1320 /* this breaks out of the loop in main() (below) */
1321 g_main_loop_quit (loop);
1322 return NULL;
1323 }
1324
1325 /* ---------------------------------------------------------------------------------------------------- */
1326
1327 typedef struct
1328 {
1329 gchar *xml;
1330 GMainLoop *loop;
1331 } IntrospectData;
1332
1333 static void
introspect_cb(GDBusConnection * connection,GAsyncResult * res,gpointer user_data)1334 introspect_cb (GDBusConnection *connection,
1335 GAsyncResult *res,
1336 gpointer user_data)
1337 {
1338 IntrospectData *data = user_data;
1339 GVariant *result;
1340 GError *error;
1341
1342 error = NULL;
1343 result = g_dbus_connection_call_finish (connection,
1344 res,
1345 &error);
1346 g_assert_no_error (error);
1347 g_assert (result != NULL);
1348 g_variant_get (result, "(s)", &data->xml);
1349 g_variant_unref (result);
1350
1351 g_main_loop_quit (data->loop);
1352 }
1353
1354 static GDBusNodeInfo *
introspect(GDBusConnection * connection,const gchar * name,const gchar * object_path,GMainLoop * loop)1355 introspect (GDBusConnection *connection,
1356 const gchar *name,
1357 const gchar *object_path,
1358 GMainLoop *loop)
1359 {
1360 GError *error;
1361 GDBusNodeInfo *node_info;
1362 IntrospectData *data;
1363
1364 data = g_new0 (IntrospectData, 1);
1365 data->xml = NULL;
1366 data->loop = loop;
1367
1368 /* do this async to avoid deadlocks */
1369 g_dbus_connection_call (connection,
1370 name,
1371 object_path,
1372 "org.freedesktop.DBus.Introspectable",
1373 "Introspect",
1374 NULL, /* params */
1375 G_VARIANT_TYPE ("(s)"),
1376 G_DBUS_CALL_FLAGS_NONE,
1377 -1,
1378 NULL,
1379 (GAsyncReadyCallback) introspect_cb,
1380 data);
1381 g_main_loop_run (loop);
1382 g_assert (data->xml != NULL);
1383
1384 error = NULL;
1385 node_info = g_dbus_node_info_new_for_xml (data->xml, &error);
1386 g_assert_no_error (error);
1387 g_assert (node_info != NULL);
1388 g_free (data->xml);
1389 g_free (data);
1390
1391 return node_info;
1392 }
1393
1394 static guint
count_interfaces(GDBusNodeInfo * info)1395 count_interfaces (GDBusNodeInfo *info)
1396 {
1397 guint n;
1398 for (n = 0; info->interfaces != NULL && info->interfaces[n] != NULL; n++)
1399 ;
1400 return n;
1401 }
1402
1403 static guint
count_nodes(GDBusNodeInfo * info)1404 count_nodes (GDBusNodeInfo *info)
1405 {
1406 guint n;
1407 for (n = 0; info->nodes != NULL && info->nodes[n] != NULL; n++)
1408 ;
1409 return n;
1410 }
1411
1412 static guint
has_interface(GDBusNodeInfo * info,const gchar * name)1413 has_interface (GDBusNodeInfo *info,
1414 const gchar *name)
1415 {
1416 guint n;
1417 for (n = 0; info->interfaces != NULL && info->interfaces[n] != NULL; n++)
1418 {
1419 if (g_strcmp0 (info->interfaces[n]->name, name) == 0)
1420 return TRUE;
1421 }
1422 return FALSE;
1423 }
1424
1425 /* ---------------------------------------------------------------------------------------------------- */
1426
1427 typedef struct {
1428 GMainLoop *loop;
1429 GVariant *result;
1430 } OMGetManagedObjectsData;
1431
1432 static void
om_get_all_cb(GDBusConnection * connection,GAsyncResult * res,gpointer user_data)1433 om_get_all_cb (GDBusConnection *connection,
1434 GAsyncResult *res,
1435 gpointer user_data)
1436 {
1437 OMGetManagedObjectsData *data = user_data;
1438 GError *error;
1439
1440 error = NULL;
1441 data->result = g_dbus_connection_call_finish (connection,
1442 res,
1443 &error);
1444 g_assert_no_error (error);
1445 g_assert (data->result != NULL);
1446 g_main_loop_quit (data->loop);
1447 }
1448
1449 static void
om_check_get_all(GDBusConnection * c,GMainLoop * loop,const gchar * str)1450 om_check_get_all (GDBusConnection *c,
1451 GMainLoop *loop,
1452 const gchar *str)
1453 {
1454 OMGetManagedObjectsData data;
1455 gchar *s;
1456
1457 data.loop = loop;
1458 data.result = NULL;
1459
1460 /* do this async to avoid deadlocks */
1461 g_dbus_connection_call (c,
1462 g_dbus_connection_get_unique_name (c),
1463 "/managed",
1464 "org.freedesktop.DBus.ObjectManager",
1465 "GetManagedObjects",
1466 NULL, /* params */
1467 G_VARIANT_TYPE ("(a{oa{sa{sv}}})"),
1468 G_DBUS_CALL_FLAGS_NONE,
1469 -1,
1470 NULL,
1471 (GAsyncReadyCallback) om_get_all_cb,
1472 &data);
1473 g_main_loop_run (loop);
1474 g_assert (data.result != NULL);
1475 s = g_variant_print (data.result, TRUE);
1476 g_assert_cmpstr (s, ==, str);
1477 g_free (s);
1478 g_variant_unref (data.result);
1479 }
1480
1481 typedef struct
1482 {
1483 GMainLoop *loop;
1484 guint state;
1485
1486 guint num_object_proxy_added_signals;
1487 guint num_object_proxy_removed_signals;
1488 guint num_interface_added_signals;
1489 guint num_interface_removed_signals;
1490 } OMData;
1491
1492 static gint
my_pstrcmp(const gchar ** a,const gchar ** b)1493 my_pstrcmp (const gchar **a, const gchar **b)
1494 {
1495 return g_strcmp0 (*a, *b);
1496 }
1497
1498 static void
om_check_interfaces_added(const gchar * signal_name,GVariant * parameters,const gchar * object_path,const gchar * first_interface_name,...)1499 om_check_interfaces_added (const gchar *signal_name,
1500 GVariant *parameters,
1501 const gchar *object_path,
1502 const gchar *first_interface_name,
1503 ...)
1504 {
1505 const gchar *path;
1506 GVariant *array;
1507 guint n;
1508 GPtrArray *interfaces;
1509 GPtrArray *interfaces_in_message;
1510 va_list var_args;
1511 const gchar *str;
1512
1513 interfaces = g_ptr_array_new ();
1514 g_ptr_array_add (interfaces, (gpointer) first_interface_name);
1515 va_start (var_args, first_interface_name);
1516 do
1517 {
1518 str = va_arg (var_args, const gchar *);
1519 if (str == NULL)
1520 break;
1521 g_ptr_array_add (interfaces, (gpointer) str);
1522 }
1523 while (TRUE);
1524 va_end (var_args);
1525
1526 g_variant_get (parameters, "(&o*)", &path, &array);
1527 g_assert_cmpstr (signal_name, ==, "InterfacesAdded");
1528 g_assert_cmpstr (path, ==, object_path);
1529 g_assert_cmpint (g_variant_n_children (array), ==, interfaces->len);
1530 interfaces_in_message = g_ptr_array_new ();
1531 for (n = 0; n < interfaces->len; n++)
1532 {
1533 const gchar *iface_name;
1534 g_variant_get_child (array, n, "{&sa{sv}}", &iface_name, NULL);
1535 g_ptr_array_add (interfaces_in_message, (gpointer) iface_name);
1536 }
1537 g_assert_cmpint (interfaces_in_message->len, ==, interfaces->len);
1538 g_ptr_array_sort (interfaces, (GCompareFunc) my_pstrcmp);
1539 g_ptr_array_sort (interfaces_in_message, (GCompareFunc) my_pstrcmp);
1540 for (n = 0; n < interfaces->len; n++)
1541 g_assert_cmpstr (interfaces->pdata[n], ==, interfaces_in_message->pdata[n]);
1542 g_ptr_array_unref (interfaces_in_message);
1543 g_ptr_array_unref (interfaces);
1544 g_variant_unref (array);
1545 }
1546
1547 static void
om_check_interfaces_removed(const gchar * signal_name,GVariant * parameters,const gchar * object_path,const gchar * first_interface_name,...)1548 om_check_interfaces_removed (const gchar *signal_name,
1549 GVariant *parameters,
1550 const gchar *object_path,
1551 const gchar *first_interface_name,
1552 ...)
1553 {
1554 const gchar *path;
1555 GVariant *array;
1556 guint n;
1557 GPtrArray *interfaces;
1558 GPtrArray *interfaces_in_message;
1559 va_list var_args;
1560 const gchar *str;
1561
1562 interfaces = g_ptr_array_new ();
1563 g_ptr_array_add (interfaces, (gpointer) first_interface_name);
1564 va_start (var_args, first_interface_name);
1565 do
1566 {
1567 str = va_arg (var_args, const gchar *);
1568 if (str == NULL)
1569 break;
1570 g_ptr_array_add (interfaces, (gpointer) str);
1571 }
1572 while (TRUE);
1573 va_end (var_args);
1574
1575 g_variant_get (parameters, "(&o*)", &path, &array);
1576 g_assert_cmpstr (signal_name, ==, "InterfacesRemoved");
1577 g_assert_cmpstr (path, ==, object_path);
1578 g_assert_cmpint (g_variant_n_children (array), ==, interfaces->len);
1579 interfaces_in_message = g_ptr_array_new ();
1580 for (n = 0; n < interfaces->len; n++)
1581 {
1582 const gchar *iface_name;
1583 g_variant_get_child (array, n, "&s", &iface_name, NULL);
1584 g_ptr_array_add (interfaces_in_message, (gpointer) iface_name);
1585 }
1586 g_assert_cmpint (interfaces_in_message->len, ==, interfaces->len);
1587 g_ptr_array_sort (interfaces, (GCompareFunc) my_pstrcmp);
1588 g_ptr_array_sort (interfaces_in_message, (GCompareFunc) my_pstrcmp);
1589 for (n = 0; n < interfaces->len; n++)
1590 g_assert_cmpstr (interfaces->pdata[n], ==, interfaces_in_message->pdata[n]);
1591 g_ptr_array_unref (interfaces_in_message);
1592 g_ptr_array_unref (interfaces);
1593 g_variant_unref (array);
1594 }
1595
1596 static void
om_on_signal(GDBusConnection * connection,const gchar * sender_name,const gchar * object_path,const gchar * interface_name,const gchar * signal_name,GVariant * parameters,gpointer user_data)1597 om_on_signal (GDBusConnection *connection,
1598 const gchar *sender_name,
1599 const gchar *object_path,
1600 const gchar *interface_name,
1601 const gchar *signal_name,
1602 GVariant *parameters,
1603 gpointer user_data)
1604 {
1605 OMData *om_data = user_data;
1606
1607 //g_debug ("foo: %s", g_variant_print (parameters, TRUE));
1608
1609 switch (om_data->state)
1610 {
1611 default:
1612 case 0:
1613 g_printerr ("failing and om_data->state=%d on signal %s, params=%s\n",
1614 om_data->state,
1615 signal_name,
1616 g_variant_print (parameters, TRUE));
1617 g_assert_not_reached ();
1618 break;
1619
1620 case 1:
1621 om_check_interfaces_added (signal_name, parameters, "/managed/first",
1622 "org.project.Bar", NULL);
1623 om_data->state = 2;
1624 g_main_loop_quit (om_data->loop);
1625 break;
1626
1627 case 3:
1628 om_check_interfaces_removed (signal_name, parameters, "/managed/first",
1629 "org.project.Bar", NULL);
1630 om_data->state = 5;
1631 /* keep running the loop */
1632 break;
1633
1634 case 5:
1635 om_check_interfaces_added (signal_name, parameters, "/managed/first",
1636 "org.project.Bar", NULL);
1637 om_data->state = 6;
1638 g_main_loop_quit (om_data->loop);
1639 break;
1640
1641 case 7:
1642 om_check_interfaces_removed (signal_name, parameters, "/managed/first",
1643 "org.project.Bar", NULL);
1644 om_data->state = 9;
1645 /* keep running the loop */
1646 break;
1647
1648 case 9:
1649 om_check_interfaces_added (signal_name, parameters, "/managed/first",
1650 "org.project.Bar", NULL);
1651 om_data->state = 10;
1652 g_main_loop_quit (om_data->loop);
1653 break;
1654
1655 case 11:
1656 om_check_interfaces_added (signal_name, parameters, "/managed/first",
1657 "org.project.Bat", NULL);
1658 om_data->state = 12;
1659 g_main_loop_quit (om_data->loop);
1660 break;
1661
1662 case 13:
1663 om_check_interfaces_removed (signal_name, parameters, "/managed/first",
1664 "org.project.Bar", NULL);
1665 om_data->state = 14;
1666 g_main_loop_quit (om_data->loop);
1667 break;
1668
1669 case 15:
1670 om_check_interfaces_removed (signal_name, parameters, "/managed/first",
1671 "org.project.Bat", NULL);
1672 om_data->state = 16;
1673 g_main_loop_quit (om_data->loop);
1674 break;
1675
1676 case 17:
1677 om_check_interfaces_added (signal_name, parameters, "/managed/first",
1678 "com.acme.Coyote", NULL);
1679 om_data->state = 18;
1680 g_main_loop_quit (om_data->loop);
1681 break;
1682
1683 case 101:
1684 om_check_interfaces_added (signal_name, parameters, "/managed/second",
1685 "org.project.Bat", "org.project.Bar", NULL);
1686 om_data->state = 102;
1687 g_main_loop_quit (om_data->loop);
1688 break;
1689
1690 case 103:
1691 om_check_interfaces_removed (signal_name, parameters, "/managed/second",
1692 "org.project.Bat", "org.project.Bar", NULL);
1693 om_data->state = 104;
1694 g_main_loop_quit (om_data->loop);
1695 break;
1696
1697 case 200:
1698 om_check_interfaces_added (signal_name, parameters, "/managed/first_1",
1699 "com.acme.Coyote", NULL);
1700 om_data->state = 201;
1701 g_main_loop_quit (om_data->loop);
1702 break;
1703 }
1704 }
1705
1706 static GAsyncResult *om_res = NULL;
1707
1708 static void
om_pm_start_cb(FooiGenObjectManagerClient * manager,GAsyncResult * res,gpointer user_data)1709 om_pm_start_cb (FooiGenObjectManagerClient *manager,
1710 GAsyncResult *res,
1711 gpointer user_data)
1712 {
1713 GMainLoop *loop = user_data;
1714 om_res = g_object_ref (res);
1715 g_main_loop_quit (loop);
1716 }
1717
1718 static void
on_interface_added(GDBusObject * object,GDBusInterface * interface,gpointer user_data)1719 on_interface_added (GDBusObject *object,
1720 GDBusInterface *interface,
1721 gpointer user_data)
1722 {
1723 OMData *om_data = user_data;
1724 om_data->num_interface_added_signals += 1;
1725 }
1726
1727 static void
on_interface_removed(GDBusObject * object,GDBusInterface * interface,gpointer user_data)1728 on_interface_removed (GDBusObject *object,
1729 GDBusInterface *interface,
1730 gpointer user_data)
1731 {
1732 OMData *om_data = user_data;
1733 om_data->num_interface_removed_signals += 1;
1734 }
1735
1736 static void
on_object_proxy_added(GDBusObjectManagerClient * manager,GDBusObjectProxy * object_proxy,gpointer user_data)1737 on_object_proxy_added (GDBusObjectManagerClient *manager,
1738 GDBusObjectProxy *object_proxy,
1739 gpointer user_data)
1740 {
1741 OMData *om_data = user_data;
1742 om_data->num_object_proxy_added_signals += 1;
1743 g_signal_connect (object_proxy,
1744 "interface-added",
1745 G_CALLBACK (on_interface_added),
1746 om_data);
1747 g_signal_connect (object_proxy,
1748 "interface-removed",
1749 G_CALLBACK (on_interface_removed),
1750 om_data);
1751 }
1752
1753 static void
on_object_proxy_removed(GDBusObjectManagerClient * manager,GDBusObjectProxy * object_proxy,gpointer user_data)1754 on_object_proxy_removed (GDBusObjectManagerClient *manager,
1755 GDBusObjectProxy *object_proxy,
1756 gpointer user_data)
1757 {
1758 OMData *om_data = user_data;
1759 om_data->num_object_proxy_removed_signals += 1;
1760 g_assert_cmpint (g_signal_handlers_disconnect_by_func (object_proxy,
1761 G_CALLBACK (on_interface_added),
1762 om_data), ==, 1);
1763 g_assert_cmpint (g_signal_handlers_disconnect_by_func (object_proxy,
1764 G_CALLBACK (on_interface_removed),
1765 om_data), ==, 1);
1766 }
1767
1768 static void
property_changed(GObject * object,GParamSpec * pspec,gpointer user_data)1769 property_changed (GObject *object,
1770 GParamSpec *pspec,
1771 gpointer user_data)
1772 {
1773 gboolean *changed = user_data;
1774
1775 *changed = TRUE;
1776 }
1777
1778 static void
om_check_property_and_signal_emission(GMainLoop * loop,FooiGenBar * skeleton,FooiGenBar * proxy)1779 om_check_property_and_signal_emission (GMainLoop *loop,
1780 FooiGenBar *skeleton,
1781 FooiGenBar *proxy)
1782 {
1783 gboolean d_changed = FALSE;
1784 gboolean quiet_changed = FALSE;
1785 gboolean quiet_too_changed = FALSE;
1786 guint handler;
1787
1788 /* First PropertiesChanged */
1789 g_assert_cmpint (foo_igen_bar_get_i (skeleton), ==, 0);
1790 g_assert_cmpint (foo_igen_bar_get_i (proxy), ==, 0);
1791 foo_igen_bar_set_i (skeleton, 1);
1792 _g_assert_property_notify (proxy, "i");
1793 g_assert_cmpint (foo_igen_bar_get_i (skeleton), ==, 1);
1794 g_assert_cmpint (foo_igen_bar_get_i (proxy), ==, 1);
1795
1796 /* Double-check the gdouble case */
1797 g_assert_cmpfloat (foo_igen_bar_get_d (skeleton), ==, 0.0);
1798 g_assert_cmpfloat (foo_igen_bar_get_d (proxy), ==, 0.0);
1799 foo_igen_bar_set_d (skeleton, 1.0);
1800 _g_assert_property_notify (proxy, "d");
1801
1802 /* Verify that re-setting it to the same value doesn't cause a
1803 * notify on the proxy, by taking advantage of the fact that
1804 * notifications are serialized.
1805 */
1806 handler = g_signal_connect (proxy, "notify::d",
1807 G_CALLBACK (property_changed), &d_changed);
1808 foo_igen_bar_set_d (skeleton, 1.0);
1809 foo_igen_bar_set_i (skeleton, 2);
1810 _g_assert_property_notify (proxy, "i");
1811 g_assert (d_changed == FALSE);
1812 g_signal_handler_disconnect (proxy, handler);
1813
1814 /* Verify that re-setting a property with the "EmitsChangedSignal"
1815 * set to false doesn't emit a signal. */
1816 handler = g_signal_connect (proxy, "notify::quiet",
1817 G_CALLBACK (property_changed), &quiet_changed);
1818 foo_igen_bar_set_quiet (skeleton, "hush!");
1819 foo_igen_bar_set_i (skeleton, 3);
1820 _g_assert_property_notify (proxy, "i");
1821 g_assert (quiet_changed == FALSE);
1822 g_assert_cmpstr (foo_igen_bar_get_quiet (skeleton), ==, "hush!");
1823 g_signal_handler_disconnect (proxy, handler);
1824
1825 /* Also verify that re-setting a property with the "EmitsChangedSignal"
1826 * set to 'const' doesn't emit a signal. */
1827 handler = g_signal_connect (proxy, "notify::quiet-too",
1828 G_CALLBACK (property_changed), &quiet_changed);
1829 foo_igen_bar_set_quiet_too (skeleton, "hush too!");
1830 foo_igen_bar_set_i (skeleton, 4);
1831 _g_assert_property_notify (proxy, "i");
1832 g_assert (quiet_too_changed == FALSE);
1833 g_assert_cmpstr (foo_igen_bar_get_quiet_too (skeleton), ==, "hush too!");
1834 g_signal_handler_disconnect (proxy, handler);
1835
1836 /* Then just a regular signal */
1837 foo_igen_bar_emit_another_signal (skeleton, "word");
1838 _g_assert_signal_received (proxy, "another-signal");
1839 }
1840
1841 static void
check_object_manager(void)1842 check_object_manager (void)
1843 {
1844 FooiGenObjectSkeleton *o = NULL;
1845 FooiGenObjectSkeleton *o2 = NULL;
1846 FooiGenObjectSkeleton *o3 = NULL;
1847 GDBusInterfaceSkeleton *i;
1848 GDBusConnection *c;
1849 GDBusObjectManagerServer *manager = NULL;
1850 GDBusNodeInfo *info;
1851 GError *error;
1852 GMainLoop *loop;
1853 OMData *om_data = NULL;
1854 guint om_signal_id = -1;
1855 GDBusObjectManager *pm = NULL;
1856 GList *object_proxies;
1857 GList *proxies;
1858 GDBusObject *op;
1859 GDBusProxy *p;
1860 FooiGenBar *bar_skeleton;
1861 GDBusInterface *iface;
1862 gchar *path, *name, *name_owner;
1863 GDBusConnection *c2;
1864 GDBusObjectManagerClientFlags flags;
1865
1866 loop = g_main_loop_new (NULL, FALSE);
1867
1868 om_data = g_new0 (OMData, 1);
1869 om_data->loop = loop;
1870 om_data->state = 0;
1871
1872 error = NULL;
1873 c = g_bus_get_sync (G_BUS_TYPE_SESSION, NULL, &error);
1874 g_assert_no_error (error);
1875 g_assert (c != NULL);
1876
1877 om_signal_id = g_dbus_connection_signal_subscribe (c,
1878 NULL, /* sender */
1879 "org.freedesktop.DBus.ObjectManager",
1880 NULL, /* member */
1881 NULL, /* object_path */
1882 NULL, /* arg0 */
1883 G_DBUS_SIGNAL_FLAGS_NONE,
1884 om_on_signal,
1885 om_data,
1886 NULL); /* user_data_free_func */
1887
1888 /* Our GDBusObjectManagerClient tests are simple - we basically just count the
1889 * number of times the various signals have been emitted (we don't check
1890 * that the right objects/interfaces are passed though - that's checked
1891 * in the lower-level tests in om_on_signal()...)
1892 *
1893 * Note that these tests rely on the D-Bus signal handlers used by
1894 * GDBusObjectManagerClient firing before om_on_signal().
1895 */
1896 error = NULL;
1897 pm = foo_igen_object_manager_client_new_sync (c,
1898 G_DBUS_OBJECT_MANAGER_CLIENT_FLAGS_NONE,
1899 g_dbus_connection_get_unique_name (c),
1900 "/managed",
1901 NULL, /* GCancellable */
1902 &error);
1903 g_assert_error (error, G_DBUS_ERROR, G_DBUS_ERROR_UNKNOWN_METHOD);
1904 g_error_free (error);
1905 g_assert (pm == NULL);
1906
1907 manager = g_dbus_object_manager_server_new ("/managed");
1908
1909 g_assert (g_dbus_object_manager_server_get_connection (manager) == NULL);
1910
1911 g_dbus_object_manager_server_set_connection (manager, c);
1912
1913 g_assert_cmpstr (g_dbus_object_manager_get_object_path (G_DBUS_OBJECT_MANAGER (manager)), ==, "/managed");
1914 g_object_get (manager, "object-path", &path, "connection", &c2, NULL);
1915 g_assert_cmpstr (path, ==, "/managed");
1916 g_assert (c2 == c);
1917 g_free (path);
1918 g_clear_object (&c2);
1919
1920 /* Check that the manager object is visible */
1921 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed", loop);
1922 g_assert_cmpint (count_interfaces (info), ==, 4); /* ObjectManager + Properties,Introspectable,Peer */
1923 g_assert (has_interface (info, "org.freedesktop.DBus.ObjectManager"));
1924 g_assert_cmpint (count_nodes (info), ==, 0);
1925 g_dbus_node_info_unref (info);
1926
1927 /* Check GetManagedObjects() - should be empty since we have no objects */
1928 om_check_get_all (c, loop,
1929 "(@a{oa{sa{sv}}} {},)");
1930
1931 /* Now try to create the proxy manager again - this time it should work */
1932 error = NULL;
1933 foo_igen_object_manager_client_new (c,
1934 G_DBUS_OBJECT_MANAGER_CLIENT_FLAGS_NONE,
1935 g_dbus_connection_get_unique_name (c),
1936 "/managed",
1937 NULL, /* GCancellable */
1938 (GAsyncReadyCallback) om_pm_start_cb,
1939 loop);
1940 g_main_loop_run (loop);
1941 error = NULL;
1942 pm = foo_igen_object_manager_client_new_finish (om_res, &error);
1943 g_clear_object (&om_res);
1944 g_assert_no_error (error);
1945 g_assert (pm != NULL);
1946 g_signal_connect (pm,
1947 "object-added",
1948 G_CALLBACK (on_object_proxy_added),
1949 om_data);
1950 g_signal_connect (pm,
1951 "object-removed",
1952 G_CALLBACK (on_object_proxy_removed),
1953 om_data);
1954
1955 g_assert_cmpstr (g_dbus_object_manager_get_object_path (G_DBUS_OBJECT_MANAGER (pm)), ==, "/managed");
1956 g_object_get (pm,
1957 "object-path", &path,
1958 "connection", &c2,
1959 "name", &name,
1960 "name-owner", &name_owner,
1961 "flags", &flags,
1962 NULL);
1963 g_assert_cmpstr (path, ==, "/managed");
1964 g_assert_cmpstr (name, ==, g_dbus_connection_get_unique_name (c));
1965 g_assert_cmpstr (name_owner, ==, g_dbus_connection_get_unique_name (c));
1966 g_assert_cmpint (flags, ==, G_DBUS_OBJECT_MANAGER_CLIENT_FLAGS_NONE);
1967 g_assert (c2 == c);
1968 g_free (path);
1969 g_clear_object (&c2);
1970 g_free (name);
1971 g_free (name_owner);
1972
1973 /* ... check there are no object proxies yet */
1974 object_proxies = g_dbus_object_manager_get_objects (pm);
1975 g_assert (object_proxies == NULL);
1976
1977 /* First, export an object with a single interface (also check that
1978 * g_dbus_interface_get_object() works and that the object isn't reffed)
1979 */
1980 o = foo_igen_object_skeleton_new ("/managed/first");
1981 i = G_DBUS_INTERFACE_SKELETON (foo_igen_bar_skeleton_new ());
1982 g_assert (g_dbus_interface_get_object (G_DBUS_INTERFACE (i)) == NULL);
1983 g_assert_cmpint (G_OBJECT (o)->ref_count, ==, 1);
1984 foo_igen_object_skeleton_set_bar (o, FOO_IGEN_BAR (i));
1985 g_assert_cmpint (G_OBJECT (o)->ref_count, ==, 1);
1986 g_assert (g_dbus_interface_get_object (G_DBUS_INTERFACE (i)) == G_DBUS_OBJECT (o));
1987 g_assert_cmpint (G_OBJECT (o)->ref_count, ==, 1);
1988 foo_igen_object_skeleton_set_bar (o, NULL);
1989 g_assert (g_dbus_interface_get_object (G_DBUS_INTERFACE (i)) == NULL);
1990 g_assert_cmpint (G_OBJECT (o)->ref_count, ==, 1);
1991 foo_igen_object_skeleton_set_bar (o, FOO_IGEN_BAR (i));
1992 g_assert (g_dbus_interface_get_object (G_DBUS_INTERFACE (i)) == G_DBUS_OBJECT (o));
1993 g_assert_cmpint (G_OBJECT (o)->ref_count, ==, 1);
1994
1995 o2 = FOO_IGEN_OBJECT_SKELETON (g_dbus_interface_dup_object (G_DBUS_INTERFACE (i)));
1996 g_assert (G_DBUS_OBJECT (o2) == G_DBUS_OBJECT (o));
1997 g_assert_cmpint (G_OBJECT (o2)->ref_count, ==, 2);
1998 g_clear_object (&o2);
1999
2000 g_dbus_object_manager_server_export (manager, G_DBUS_OBJECT_SKELETON (o));
2001
2002 /* ... check we get the InterfacesAdded signal */
2003 om_data->state = 1;
2004
2005 g_main_loop_run (om_data->loop);
2006
2007 g_assert_cmpint (om_data->state, ==, 2);
2008 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 1);
2009 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 0);
2010 g_assert_cmpint (om_data->num_interface_added_signals, ==, 0);
2011 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 0);
2012 /* ... check there's one non-standard interfaces */
2013 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2014 g_assert_cmpint (count_interfaces (info), ==, 4); /* Bar + Properties,Introspectable,Peer */
2015 g_assert (has_interface (info, "org.project.Bar"));
2016 g_dbus_node_info_unref (info);
2017
2018 /* Also check g_dbus_object_manager_get_interface */
2019 iface = g_dbus_object_manager_get_interface (G_DBUS_OBJECT_MANAGER (manager), "/managed/first", "org.project.Bar");
2020 g_assert (iface != NULL);
2021 g_clear_object (&iface);
2022 iface = g_dbus_object_manager_get_interface (G_DBUS_OBJECT_MANAGER (manager), "/managed/first", "org.project.Bat");
2023 g_assert (iface == NULL);
2024 iface = g_dbus_object_manager_get_interface (G_DBUS_OBJECT_MANAGER (pm), "/managed/first", "org.project.Bar");
2025 g_assert (iface != NULL);
2026 g_clear_object (&iface);
2027 iface = g_dbus_object_manager_get_interface (G_DBUS_OBJECT_MANAGER (pm), "/managed/first", "org.project.Bat");
2028 g_assert (iface == NULL);
2029
2030 /* Now, check adding the same interface replaces the existing one */
2031 foo_igen_object_skeleton_set_bar (o, FOO_IGEN_BAR (i));
2032 /* ... check we get the InterfacesRemoved */
2033 om_data->state = 3;
2034 g_main_loop_run (om_data->loop);
2035 /* ... and then check we get the InterfacesAdded */
2036 g_assert_cmpint (om_data->state, ==, 6);
2037 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 2);
2038 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 1);
2039 g_assert_cmpint (om_data->num_interface_added_signals, ==, 0);
2040 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 0);
2041 /* ... check introspection data */
2042 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2043 g_assert_cmpint (count_interfaces (info), ==, 4); /* Bar + Properties,Introspectable,Peer */
2044 g_assert (has_interface (info, "org.project.Bar"));
2045 g_dbus_node_info_unref (info);
2046 g_clear_object (&i);
2047
2048 /* check adding an interface of same type (but not same object) replaces the existing one */
2049 i = G_DBUS_INTERFACE_SKELETON (foo_igen_bar_skeleton_new ());
2050 foo_igen_object_skeleton_set_bar (o, FOO_IGEN_BAR (i));
2051 /* ... check we get the InterfacesRemoved and then InterfacesAdded */
2052 om_data->state = 7;
2053 g_main_loop_run (om_data->loop);
2054 g_assert_cmpint (om_data->state, ==, 10);
2055 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 3);
2056 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 2);
2057 g_assert_cmpint (om_data->num_interface_added_signals, ==, 0);
2058 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 0);
2059 /* ... check introspection data */
2060 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2061 g_assert_cmpint (count_interfaces (info), ==, 4); /* Bar + Properties,Introspectable,Peer */
2062 g_assert (has_interface (info, "org.project.Bar"));
2063 g_dbus_node_info_unref (info);
2064 g_clear_object (&i);
2065
2066 /* check adding an interface of another type doesn't replace the existing one */
2067 i = G_DBUS_INTERFACE_SKELETON (foo_igen_bat_skeleton_new ());
2068 foo_igen_object_skeleton_set_bat (o, FOO_IGEN_BAT (i));
2069 g_clear_object (&i);
2070 /* ... check we get the InterfacesAdded */
2071 om_data->state = 11;
2072 g_main_loop_run (om_data->loop);
2073 g_assert_cmpint (om_data->state, ==, 12);
2074 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 3);
2075 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 2);
2076 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2077 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 0);
2078 /* ... check introspection data */
2079 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2080 g_assert_cmpint (count_interfaces (info), ==, 5); /* Bar,Bat + Properties,Introspectable,Peer */
2081 g_assert (has_interface (info, "org.project.Bar"));
2082 g_assert (has_interface (info, "org.project.Bat"));
2083 g_dbus_node_info_unref (info);
2084
2085 /* check we can remove an interface */
2086 foo_igen_object_skeleton_set_bar (o, NULL);
2087 /* ... check we get the InterfacesRemoved */
2088 om_data->state = 13;
2089 g_main_loop_run (om_data->loop);
2090 g_assert_cmpint (om_data->state, ==, 14);
2091 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 3);
2092 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 2);
2093 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2094 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 1);
2095 /* ... check introspection data */
2096 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2097 g_assert_cmpint (count_interfaces (info), ==, 4); /* Bat + Properties,Introspectable,Peer */
2098 g_assert (has_interface (info, "org.project.Bat"));
2099 g_dbus_node_info_unref (info);
2100 /* also and that the call only has effect if the interface actually exists
2101 *
2102 * (Note: if a signal was emitted we'd assert in the signal handler
2103 * because we're in state 14)
2104 */
2105 foo_igen_object_skeleton_set_bar (o, NULL);
2106 /* ... check introspection data */
2107 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2108 g_assert_cmpint (count_interfaces (info), ==, 4); /* Bat + Properties,Introspectable,Peer */
2109 g_assert (has_interface (info, "org.project.Bat"));
2110 g_dbus_node_info_unref (info);
2111
2112 /* remove the last interface */
2113 foo_igen_object_skeleton_set_bat (o, NULL);
2114 /* ... check we get the InterfacesRemoved */
2115 om_data->state = 15;
2116 g_main_loop_run (om_data->loop);
2117 g_assert_cmpint (om_data->state, ==, 16);
2118 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 3);
2119 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 3);
2120 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2121 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 1);
2122 /* ... check introspection data */
2123 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2124 g_assert_cmpint (count_interfaces (info), ==, 0); /* nothing */
2125 g_dbus_node_info_unref (info);
2126
2127 /* and add an interface again */
2128 i = G_DBUS_INTERFACE_SKELETON (foo_igen_com_acme_coyote_skeleton_new ());
2129 foo_igen_object_skeleton_set_com_acme_coyote (o, FOO_IGEN_COM_ACME_COYOTE (i));
2130 g_clear_object (&i);
2131 /* ... check we get the InterfacesAdded */
2132 om_data->state = 17;
2133 g_main_loop_run (om_data->loop);
2134 g_assert_cmpint (om_data->state, ==, 18);
2135 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 4);
2136 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 3);
2137 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2138 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 1);
2139 /* ... check introspection data */
2140 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/first", loop);
2141 g_assert_cmpint (count_interfaces (info), ==, 4); /* com.acme.Coyote + Properties,Introspectable,Peer */
2142 g_assert (has_interface (info, "com.acme.Coyote"));
2143 g_dbus_node_info_unref (info);
2144
2145 /* Check GetManagedObjects() - should be just the Coyote */
2146 om_check_get_all (c, loop,
2147 "({objectpath '/managed/first': {'com.acme.Coyote': {'Mood': <''>}}},)");
2148
2149 /* -------------------------------------------------- */
2150
2151 /* create a new object with two interfaces */
2152 o2 = foo_igen_object_skeleton_new ("/managed/second");
2153 i = G_DBUS_INTERFACE_SKELETON (foo_igen_bar_skeleton_new ());
2154 bar_skeleton = FOO_IGEN_BAR (i); /* save for later test */
2155 foo_igen_object_skeleton_set_bar (o2, FOO_IGEN_BAR (i));
2156 g_clear_object (&i);
2157 i = G_DBUS_INTERFACE_SKELETON (foo_igen_bat_skeleton_new ());
2158 foo_igen_object_skeleton_set_bat (o2, FOO_IGEN_BAT (i));
2159 g_clear_object (&i);
2160 /* ... add it */
2161 g_dbus_object_manager_server_export (manager, G_DBUS_OBJECT_SKELETON (o2));
2162 /* ... check we get the InterfacesAdded with _two_ interfaces */
2163 om_data->state = 101;
2164 g_main_loop_run (om_data->loop);
2165 g_assert_cmpint (om_data->state, ==, 102);
2166 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 5);
2167 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 3);
2168 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2169 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 1);
2170
2171 /* -------------------------------------------------- */
2172
2173 /* Now that we have a couple of objects with interfaces, check
2174 * that ObjectManager.GetManagedObjects() works
2175 */
2176 om_check_get_all (c, loop,
2177 "({objectpath '/managed/first': {'com.acme.Coyote': {'Mood': <''>}}, '/managed/second': {'org.project.Bar': {'y': <byte 0x00>, 'b': <false>, 'n': <int16 0>, 'q': <uint16 0>, 'i': <0>, 'u': <uint32 0>, 'x': <int64 0>, 't': <uint64 0>, 'd': <0.0>, 's': <''>, 'o': <objectpath '/'>, 'g': <signature ''>, 'ay': <b''>, 'as': <@as []>, 'aay': <@aay []>, 'ao': <@ao []>, 'ag': <@ag []>, 'FinallyNormalName': <''>, 'ReadonlyProperty': <''>, 'quiet': <''>, 'quiet_too': <''>, 'unset_i': <0>, 'unset_d': <0.0>, 'unset_s': <''>, 'unset_o': <objectpath '/'>, 'unset_g': <signature ''>, 'unset_ay': <b''>, 'unset_as': <@as []>, 'unset_ao': <@ao []>, 'unset_ag': <@ag []>, 'unset_struct': <(0, 0.0, '', objectpath '/', signature '', @ay [], @as [], @ao [], @ag [])>}, 'org.project.Bat': {'force_i': <0>, 'force_s': <''>, 'force_ay': <@ay []>, 'force_struct': <(0,)>}}},)");
2178
2179 /* Set connection to NULL, causing everything to be unexported.. verify this.. and
2180 * then set the connection back.. and then check things still work
2181 */
2182 g_dbus_object_manager_server_set_connection (manager, NULL);
2183 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed", loop);
2184 g_assert_cmpint (count_interfaces (info), ==, 0); /* nothing */
2185 g_dbus_node_info_unref (info);
2186
2187 g_dbus_object_manager_server_set_connection (manager, c);
2188 om_check_get_all (c, loop,
2189 "({objectpath '/managed/first': {'com.acme.Coyote': {'Mood': <''>}}, '/managed/second': {'org.project.Bar': {'y': <byte 0x00>, 'b': <false>, 'n': <int16 0>, 'q': <uint16 0>, 'i': <0>, 'u': <uint32 0>, 'x': <int64 0>, 't': <uint64 0>, 'd': <0.0>, 's': <''>, 'o': <objectpath '/'>, 'g': <signature ''>, 'ay': <b''>, 'as': <@as []>, 'aay': <@aay []>, 'ao': <@ao []>, 'ag': <@ag []>, 'FinallyNormalName': <''>, 'ReadonlyProperty': <''>, 'quiet': <''>, 'quiet_too': <''>, 'unset_i': <0>, 'unset_d': <0.0>, 'unset_s': <''>, 'unset_o': <objectpath '/'>, 'unset_g': <signature ''>, 'unset_ay': <b''>, 'unset_as': <@as []>, 'unset_ao': <@ao []>, 'unset_ag': <@ag []>, 'unset_struct': <(0, 0.0, '', objectpath '/', signature '', @ay [], @as [], @ao [], @ag [])>}, 'org.project.Bat': {'force_i': <0>, 'force_s': <''>, 'force_ay': <@ay []>, 'force_struct': <(0,)>}}},)");
2190
2191 /* Also check that the ObjectManagerClient returns these objects - and
2192 * that they are of the right GType cf. what was requested via
2193 * the generated ::get-proxy-type signal handler
2194 */
2195 object_proxies = g_dbus_object_manager_get_objects (pm);
2196 g_assert (g_list_length (object_proxies) == 2);
2197 g_list_free_full (object_proxies, g_object_unref);
2198 op = g_dbus_object_manager_get_object (pm, "/managed/first");
2199 g_assert (op != NULL);
2200 g_assert (FOO_IGEN_IS_OBJECT_PROXY (op));
2201 g_assert_cmpstr (g_dbus_object_get_object_path (op), ==, "/managed/first");
2202 proxies = g_dbus_object_get_interfaces (op);
2203 g_assert (g_list_length (proxies) == 1);
2204 g_list_free_full (proxies, g_object_unref);
2205 p = G_DBUS_PROXY (foo_igen_object_get_com_acme_coyote (FOO_IGEN_OBJECT (op)));
2206 g_assert (p != NULL);
2207 g_assert_cmpint (G_TYPE_FROM_INSTANCE (p), ==, FOO_IGEN_TYPE_COM_ACME_COYOTE_PROXY);
2208 g_assert (g_type_is_a (G_TYPE_FROM_INSTANCE (p), FOO_IGEN_TYPE_COM_ACME_COYOTE));
2209 g_clear_object (&p);
2210 p = (GDBusProxy *) g_dbus_object_get_interface (op, "org.project.NonExisting");
2211 g_assert (p == NULL);
2212 g_clear_object (&op);
2213
2214 /* -- */
2215 op = g_dbus_object_manager_get_object (pm, "/managed/second");
2216 g_assert (op != NULL);
2217 g_assert (FOO_IGEN_IS_OBJECT_PROXY (op));
2218 g_assert_cmpstr (g_dbus_object_get_object_path (op), ==, "/managed/second");
2219 proxies = g_dbus_object_get_interfaces (op);
2220 g_assert (g_list_length (proxies) == 2);
2221 g_list_free_full (proxies, g_object_unref);
2222 p = G_DBUS_PROXY (foo_igen_object_get_bat (FOO_IGEN_OBJECT (op)));
2223 g_assert (p != NULL);
2224 g_assert_cmpint (G_TYPE_FROM_INSTANCE (p), ==, FOO_IGEN_TYPE_BAT_PROXY);
2225 g_assert (g_type_is_a (G_TYPE_FROM_INSTANCE (p), FOO_IGEN_TYPE_BAT));
2226 g_clear_object (&p);
2227 p = G_DBUS_PROXY (foo_igen_object_get_bar (FOO_IGEN_OBJECT (op)));
2228 g_assert (p != NULL);
2229 g_assert_cmpint (G_TYPE_FROM_INSTANCE (p), ==, FOO_IGEN_TYPE_BAR_PROXY);
2230 g_assert (g_type_is_a (G_TYPE_FROM_INSTANCE (p), FOO_IGEN_TYPE_BAR));
2231 /* ... now that we have a Bar instance around, also check that we get signals
2232 * and property changes...
2233 */
2234 om_check_property_and_signal_emission (loop, bar_skeleton, FOO_IGEN_BAR (p));
2235 g_clear_object (&p);
2236 p = (GDBusProxy *) g_dbus_object_get_interface (op, "org.project.NonExisting");
2237 g_assert (p == NULL);
2238 g_clear_object (&op);
2239
2240 /* -------------------------------------------------- */
2241
2242 /* Now remove the second object added above */
2243 g_dbus_object_manager_server_unexport (manager, "/managed/second");
2244 /* ... check we get InterfacesRemoved with both interfaces */
2245 om_data->state = 103;
2246 g_main_loop_run (om_data->loop);
2247 g_assert_cmpint (om_data->state, ==, 104);
2248 g_assert_cmpint (om_data->num_object_proxy_added_signals, ==, 5);
2249 g_assert_cmpint (om_data->num_object_proxy_removed_signals, ==, 4);
2250 g_assert_cmpint (om_data->num_interface_added_signals, ==, 1);
2251 g_assert_cmpint (om_data->num_interface_removed_signals, ==, 1);
2252 /* ... check introspection data (there should be nothing) */
2253 info = introspect (c, g_dbus_connection_get_unique_name (c), "/managed/second", loop);
2254 g_assert_cmpint (count_nodes (info), ==, 0);
2255 g_assert_cmpint (count_interfaces (info), ==, 0);
2256 g_dbus_node_info_unref (info);
2257
2258 /* Check GetManagedObjects() again */
2259 om_check_get_all (c, loop,
2260 "({objectpath '/managed/first': {'com.acme.Coyote': {'Mood': <''>}}},)");
2261 /* -------------------------------------------------- */
2262
2263 /* Check that export_uniquely() works */
2264
2265 o3 = foo_igen_object_skeleton_new ("/managed/first");
2266 i = G_DBUS_INTERFACE_SKELETON (foo_igen_com_acme_coyote_skeleton_new ());
2267 foo_igen_com_acme_coyote_set_mood (FOO_IGEN_COM_ACME_COYOTE (i), "indifferent");
2268 foo_igen_object_skeleton_set_com_acme_coyote (o3, FOO_IGEN_COM_ACME_COYOTE (i));
2269 g_clear_object (&i);
2270 g_dbus_object_manager_server_export_uniquely (manager, G_DBUS_OBJECT_SKELETON (o3));
2271 /* ... check we get the InterfacesAdded signal */
2272 om_data->state = 200;
2273 g_main_loop_run (om_data->loop);
2274 g_assert_cmpint (om_data->state, ==, 201);
2275
2276 om_check_get_all (c, loop,
2277 "({objectpath '/managed/first': {'com.acme.Coyote': {'Mood': <''>}}, '/managed/first_1': {'com.acme.Coyote': {'Mood': <'indifferent'>}}},)");
2278
2279 //g_main_loop_run (loop); /* TODO: tmp */
2280
2281 /* Clean up objects */
2282 g_assert (g_dbus_object_manager_server_unexport (manager, "/managed/first_1"));
2283 //g_assert (g_dbus_object_manager_server_unexport (manager, "/managed/second"));
2284 g_assert (g_dbus_object_manager_server_unexport (manager, "/managed/first"));
2285 g_assert_cmpint (g_list_length (g_dbus_object_manager_get_objects (G_DBUS_OBJECT_MANAGER (manager))), ==, 0);
2286
2287 if (loop != NULL)
2288 g_main_loop_unref (loop);
2289
2290 if (om_signal_id != -1)
2291 g_dbus_connection_signal_unsubscribe (c, om_signal_id);
2292 g_clear_object (&o3);
2293 g_clear_object (&o2);
2294 g_clear_object (&o);
2295 g_clear_object (&manager);
2296 if (pm != NULL)
2297 {
2298 g_assert_cmpint (g_signal_handlers_disconnect_by_func (pm,
2299 G_CALLBACK (on_object_proxy_added),
2300 om_data), ==, 1);
2301 g_assert_cmpint (g_signal_handlers_disconnect_by_func (pm,
2302 G_CALLBACK (on_object_proxy_removed),
2303 om_data), ==, 1);
2304 g_clear_object (&pm);
2305 }
2306 g_clear_object (&c);
2307
2308 g_free (om_data);
2309 }
2310
2311 /* ---------------------------------------------------------------------------------------------------- */
2312
2313 static void
test_object_manager(void)2314 test_object_manager (void)
2315 {
2316 GMainLoop *loop;
2317 guint id;
2318
2319 loop = g_main_loop_new (NULL, FALSE);
2320
2321 id = g_bus_own_name (G_BUS_TYPE_SESSION,
2322 "org.gtk.GDBus.BindingsTool.Test",
2323 G_BUS_NAME_OWNER_FLAGS_NONE,
2324 on_bus_acquired,
2325 on_name_acquired,
2326 on_name_lost,
2327 loop,
2328 NULL);
2329
2330 g_main_loop_run (loop);
2331
2332 check_object_manager ();
2333
2334 /* uncomment to keep the service around (to e.g. introspect it) */
2335 /* g_main_loop_run (loop); */
2336
2337 unexport_objects ();
2338
2339 g_bus_unown_name (id);
2340 g_main_loop_unref (loop);
2341 }
2342
2343 /* ---------------------------------------------------------------------------------------------------- */
2344 /* This checks that forcing names via org.gtk.GDBus.Name works (see test-codegen.xml) */
2345
2346 extern gpointer name_forcing_1;
2347 extern gpointer name_forcing_2;
2348 extern gpointer name_forcing_3;
2349 extern gpointer name_forcing_4;
2350 extern gpointer name_forcing_5;
2351 extern gpointer name_forcing_6;
2352 extern gpointer name_forcing_7;
2353 gpointer name_forcing_1 = foo_igen_rocket123_get_type;
2354 gpointer name_forcing_2 = foo_igen_rocket123_call_ignite_xyz;
2355 gpointer name_forcing_3 = foo_igen_rocket123_emit_exploded_xyz;
2356 gpointer name_forcing_4 = foo_igen_rocket123_get_speed_xyz;
2357 gpointer name_forcing_5 = foo_igen_test_ugly_case_interface_call_get_iscsi_servers;
2358 gpointer name_forcing_6 = foo_igen_test_ugly_case_interface_emit_servers_updated_now;
2359 gpointer name_forcing_7 = foo_igen_test_ugly_case_interface_get_ugly_name;
2360
2361 /* ---------------------------------------------------------------------------------------------------- */
2362
2363 /* See https://bugzilla.gnome.org/show_bug.cgi?id=647577#c5 for details */
2364
2365 #define CHECK_FIELD(name, v1, v2) g_assert_cmpint (G_STRUCT_OFFSET (FooiGenChangingInterface##v1##Iface, name), ==, G_STRUCT_OFFSET (FooiGenChangingInterface##v2##Iface, name));
2366
2367 static void
test_interface_stability(void)2368 test_interface_stability (void)
2369 {
2370 CHECK_FIELD(handle_foo_method, V1, V2);
2371 CHECK_FIELD(handle_bar_method, V1, V2);
2372 CHECK_FIELD(handle_baz_method, V1, V2);
2373 CHECK_FIELD(foo_signal, V1, V2);
2374 CHECK_FIELD(bar_signal, V1, V2);
2375 CHECK_FIELD(baz_signal, V1, V2);
2376 CHECK_FIELD(handle_new_method_in2, V2, V10);
2377 CHECK_FIELD(new_signal_in2, V2, V10);
2378 }
2379
2380 #undef CHECK_FIELD
2381
2382 /* ---------------------------------------------------------------------------------------------------- */
2383
2384 /* property naming
2385 *
2386 * - check that a property with name "Type" is mapped into g-name "type"
2387 * with C accessors get_type_ (to avoid clashing with the GType accessor)
2388 * and set_type_ (for symmetri)
2389 * (see https://bugzilla.gnome.org/show_bug.cgi?id=679473 for details)
2390 *
2391 * - (could add more tests here)
2392 */
2393
2394 static void
test_property_naming(void)2395 test_property_naming (void)
2396 {
2397 gpointer c_getter_name = foo_igen_naming_get_type_;
2398 gpointer c_setter_name = foo_igen_naming_set_type_;
2399 FooiGenNaming *skel;
2400
2401 (void) c_getter_name;
2402 (void) c_setter_name;
2403
2404 skel = foo_igen_naming_skeleton_new ();
2405 g_assert (g_object_class_find_property (G_OBJECT_GET_CLASS (skel), "type") != NULL);
2406 g_object_unref (skel);
2407 }
2408
2409 /* ---------------------------------------------------------------------------------------------------- */
2410
2411 /* autocleanups
2412 *
2413 * - check that g_autoptr() works for all generated types, if supported by the
2414 * current compiler
2415 */
2416
2417 static void
test_autocleanups(void)2418 test_autocleanups (void)
2419 {
2420 #ifdef g_autoptr
2421 g_autoptr(FooiGenBar) bar = NULL;
2422 g_autoptr(FooiGenBarProxy) bar_proxy = NULL;
2423 g_autoptr(FooiGenBarSkeleton) bar_skeleton = NULL;
2424 g_autoptr(FooiGenObject) object = NULL;
2425 g_autoptr(FooiGenObjectProxy) object_proxy = NULL;
2426 g_autoptr(FooiGenObjectSkeleton) object_skeleton = NULL;
2427 g_autoptr(FooiGenObjectManagerClient) object_manager_client = NULL;
2428
2429 (void) bar;
2430 (void) bar_proxy;
2431 (void) bar_skeleton;
2432 (void) object;
2433 (void) object_proxy;
2434 (void) object_skeleton;
2435 (void) object_manager_client;
2436 #elif GLIB_CHECK_VERSION(2, 38, 0)
2437 /* This file is compiled twice, once without GLib version guards and once
2438 * with
2439 *
2440 * -DGLIB_VERSION_MIN_REQUIRED=GLIB_VERSION_2_36
2441 * -DGLIB_VERSION_MAX_ALLOWED=GLIB_VERSION_2_36
2442 *
2443 * g_test_skip() was added in 2.38.
2444 */
2445 g_test_skip ("g_autoptr() not supported on this compiler");
2446 #else
2447 /* Let's just say it passed. */
2448 #endif
2449 }
2450
2451 /* ---------------------------------------------------------------------------------------------------- */
2452
2453 /* deprecations
2454 */
2455
2456 static void
test_deprecations(void)2457 test_deprecations (void)
2458 {
2459 {
2460 FooiGenOldieInterface *iskel;
2461 GParamSpec *pspec;
2462
2463 G_GNUC_BEGIN_IGNORE_DEPRECATIONS;
2464 iskel = foo_igen_oldie_interface_skeleton_new ();
2465 G_GNUC_END_IGNORE_DEPRECATIONS;
2466
2467 pspec = g_object_class_find_property (G_OBJECT_GET_CLASS (iskel), "bat");
2468 g_assert_nonnull (pspec);
2469 g_assert_cmpint (pspec->flags & G_PARAM_DEPRECATED, ==, G_PARAM_DEPRECATED);
2470
2471 g_object_unref (iskel);
2472 }
2473
2474 {
2475 FooiGenObjectSkeleton *oskel;
2476 GParamSpec *pspec;
2477
2478 oskel = foo_igen_object_skeleton_new ("/objects/first");
2479 pspec = g_object_class_find_property (G_OBJECT_GET_CLASS (oskel), "oldie-interface");
2480 g_assert_nonnull (pspec);
2481 g_assert_cmpint (pspec->flags & G_PARAM_DEPRECATED, ==, G_PARAM_DEPRECATED);
2482
2483 g_object_unref (oskel);
2484 }
2485 }
2486
2487 /* ---------------------------------------------------------------------------------------------------- */
2488
2489 static void
assert_arg_infos_equal(GDBusArgInfo ** a,GDBusArgInfo ** b)2490 assert_arg_infos_equal (GDBusArgInfo **a,
2491 GDBusArgInfo **b)
2492 {
2493 if (a == NULL)
2494 {
2495 g_assert_null (b);
2496 return;
2497 }
2498
2499 g_assert_nonnull (b);
2500
2501 for (; *a != NULL && *b != NULL; a++, b++)
2502 {
2503 g_assert_cmpstr ((*a)->name, ==, (*b)->name);
2504 g_assert_cmpstr ((*a)->signature, ==, (*b)->signature);
2505 }
2506
2507 g_assert_null (*a);
2508 g_assert_null (*b);
2509 }
2510
2511 static void
assert_annotations_equal(GDBusAnnotationInfo ** a,GDBusAnnotationInfo ** b)2512 assert_annotations_equal (GDBusAnnotationInfo **a,
2513 GDBusAnnotationInfo **b)
2514 {
2515 guint a_len = count_annotations (a);
2516 guint b_len = count_annotations (b);
2517
2518 g_assert_cmpuint (a_len, ==, b_len);
2519
2520 if (a == NULL || b == NULL)
2521 return;
2522
2523 for (; *a != NULL && *b != NULL; a++, b++)
2524 {
2525 g_assert_cmpstr ((*a)->key, ==, (*b)->key);
2526 g_assert_cmpstr ((*a)->value, ==, (*b)->value);
2527 assert_annotations_equal ((*a)->annotations, (*b)->annotations);
2528 }
2529
2530 g_assert_null (*a);
2531 g_assert_null (*b);
2532 }
2533
2534 /* Test that the GDBusInterfaceInfo structure generated by gdbus-codegen
2535 * --interface-info-body matches that generated by the other mode.
2536 */
2537 static void
test_standalone_interface_info(void)2538 test_standalone_interface_info (void)
2539 {
2540 GDBusInterfaceSkeleton *skel = G_DBUS_INTERFACE_SKELETON (foo_igen_bar_skeleton_new ());
2541 GDBusInterfaceInfo *skel_info = g_dbus_interface_skeleton_get_info (skel);
2542 const GDBusInterfaceInfo *slim_info = &org_project_bar_interface;
2543 gsize i;
2544
2545 g_assert_cmpstr (skel_info->name, ==, slim_info->name);
2546
2547 for (i = 0; skel_info->methods[i] != NULL; i++)
2548 {
2549 GDBusMethodInfo *skel_method = skel_info->methods[i];
2550 GDBusMethodInfo *slim_method = slim_info->methods[i];
2551
2552 g_assert_nonnull (slim_method);
2553 g_assert_cmpstr (skel_method->name, ==, slim_method->name);
2554 assert_arg_infos_equal (skel_method->in_args, slim_method->in_args);
2555 assert_arg_infos_equal (skel_method->out_args, slim_method->out_args);
2556 assert_annotations_equal (skel_method->annotations, slim_method->annotations);
2557 }
2558 g_assert_null (slim_info->methods[i]);
2559
2560 for (i = 0; skel_info->signals[i] != NULL; i++)
2561 {
2562 GDBusSignalInfo *skel_signal = skel_info->signals[i];
2563 GDBusSignalInfo *slim_signal = slim_info->signals[i];
2564
2565 g_assert_nonnull (slim_signal);
2566 g_assert_cmpstr (skel_signal->name, ==, slim_signal->name);
2567 assert_arg_infos_equal (skel_signal->args, slim_signal->args);
2568 assert_annotations_equal (skel_signal->annotations, slim_signal->annotations);
2569 }
2570 g_assert_null (slim_info->signals[i]);
2571
2572 for (i = 0; skel_info->properties[i] != NULL; i++)
2573 {
2574 GDBusPropertyInfo *skel_prop = skel_info->properties[i];
2575 GDBusPropertyInfo *slim_prop = slim_info->properties[i];
2576
2577 g_assert_nonnull (slim_prop);
2578
2579 g_assert_cmpstr (skel_prop->name, ==, slim_prop->name);
2580 g_assert_cmpstr (skel_prop->signature, ==, slim_prop->signature);
2581 g_assert_cmpuint (skel_prop->flags, ==, slim_prop->flags);
2582 assert_annotations_equal (skel_prop->annotations, slim_prop->annotations);
2583 }
2584 g_assert_null (slim_info->properties[i]);
2585
2586 assert_annotations_equal (skel_info->annotations, slim_info->annotations);
2587
2588 g_clear_object (&skel);
2589 }
2590
2591 /* ---------------------------------------------------------------------------------------------------- */
2592
2593 int
main(int argc,char * argv[])2594 main (int argc,
2595 char *argv[])
2596 {
2597 g_test_init (&argc, &argv, NULL);
2598
2599 g_test_add_func ("/gdbus/codegen/annotations", test_annotations);
2600 g_test_add_func ("/gdbus/codegen/interface_stability", test_interface_stability);
2601 g_test_add_func ("/gdbus/codegen/object-manager", test_object_manager);
2602 g_test_add_func ("/gdbus/codegen/property-naming", test_property_naming);
2603 g_test_add_func ("/gdbus/codegen/autocleanups", test_autocleanups);
2604 g_test_add_func ("/gdbus/codegen/deprecations", test_deprecations);
2605 g_test_add_func ("/gdbus/codegen/standalone-interface-info", test_standalone_interface_info);
2606
2607 return session_bus_run ();
2608 }
2609