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