]> git.proxmox.com Git - systemd.git/blame - src/libsystemd/sd-bus/test-bus-objects.c
projects / systemd.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
bump version to 252.11-pve1
[systemd.git] / src / libsystemd / sd-bus / test-bus-objects.c
CommitLineData
a032b68d 1/* SPDX-License-Identifier: LGPL-2.1-or-later */
60f067b4 2
60f067b4 3#include <pthread.h>
db2df898 4#include <stdlib.h>
60f067b4
JS		 5
6#include "sd-bus.h"
db2df898
MP		 7
8#include "alloc-util.h"
9#include "bus-dump.h"
60f067b4
JS		 10#include "bus-internal.h"
11#include "bus-message.h"
db2df898
MP		 12#include "log.h"
13#include "macro.h"
14#include "strv.h"
15#include "util.h"
60f067b4
JS		 16
17struct context {
18 int fds[2];
19 bool quit;
20 char *something;
21 char *automatic_string_property;
22 uint32_t automatic_integer_property;
23};
24
e3bff60a 25static int something_handler(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 26 struct context *c = userdata;
27 const char *s;
28 char *n = NULL;
29 int r;
30
31 r = sd_bus_message_read(m, "s", &s);
32 assert_se(r > 0);
33
2897b343 34 n = strjoin("<<<", s, ">>>");
60f067b4
JS		 35 assert_se(n);
36
37 free(c->something);
38 c->something = n;
39
40 log_info("AlterSomething() called, got %s, returning %s", s, n);
41
42 /* This should fail, since the return type doesn't match */
43 assert_se(sd_bus_reply_method_return(m, "u", 4711) == -ENOMSG);
44
45 r = sd_bus_reply_method_return(m, "s", n);
46 assert_se(r >= 0);
47
48 return 1;
49}
50
e3bff60a 51static int exit_handler(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 52 struct context *c = userdata;
53 int r;
54
55 c->quit = true;
56
57 log_info("Exit called");
58
59 r = sd_bus_reply_method_return(m, "");
60 assert_se(r >= 0);
61
62 return 1;
63}
64
65static int get_handler(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error) {
66 struct context *c = userdata;
67 int r;
68
69 log_info("property get for %s called, returning \"%s\".", property, c->something);
70
71 r = sd_bus_message_append(reply, "s", c->something);
72 assert_se(r >= 0);
73
74 return 1;
75}
76
77static int set_handler(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *value, void *userdata, sd_bus_error *error) {
78 struct context *c = userdata;
79 const char *s;
80 char *n;
81 int r;
82
83 log_info("property set for %s called", property);
84
85 r = sd_bus_message_read(value, "s", &s);
86 assert_se(r >= 0);
87
88 n = strdup(s);
89 assert_se(n);
90
91 free(c->something);
92 c->something = n;
93
94 return 1;
95}
96
97static int value_handler(sd_bus *bus, const char *path, const char *interface, const char *property, sd_bus_message *reply, void *userdata, sd_bus_error *error) {
98 _cleanup_free_ char *s = NULL;
13d276d0 99 const char *x;
60f067b4
JS		 100 int r;
101
102 assert_se(asprintf(&s, "object %p, path %s", userdata, path) >= 0);
103 r = sd_bus_message_append(reply, "s", s);
104 assert_se(r >= 0);
105
13d276d0 106 assert_se(x = startswith(path, "/value/"));
60f067b4
JS		 107
108 assert_se(PTR_TO_UINT(userdata) == 30);
109
110 return 1;
111}
112
e3bff60a 113static int notify_test(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 114 int r;
115
e3bff60a 116 assert_se(sd_bus_emit_properties_changed(sd_bus_message_get_bus(m), m->path, "org.freedesktop.systemd.ValueTest", "Value", NULL) >= 0);
60f067b4
JS		 117
118 r = sd_bus_reply_method_return(m, NULL);
119 assert_se(r >= 0);
120
121 return 1;
122}
123
e3bff60a 124static int notify_test2(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 125 int r;
126
e3bff60a 127 assert_se(sd_bus_emit_properties_changed_strv(sd_bus_message_get_bus(m), m->path, "org.freedesktop.systemd.ValueTest", NULL) >= 0);
60f067b4
JS		 128
129 r = sd_bus_reply_method_return(m, NULL);
130 assert_se(r >= 0);
131
132 return 1;
133}
134
e3bff60a 135static int emit_interfaces_added(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 136 int r;
137
7035cd9e 138 assert_se(sd_bus_emit_interfaces_added(sd_bus_message_get_bus(m), "/value/a/x", "org.freedesktop.systemd.ValueTest", NULL) >= 0);
60f067b4
JS		 139
140 r = sd_bus_reply_method_return(m, NULL);
141 assert_se(r >= 0);
142
143 return 1;
144}
145
e3bff60a 146static int emit_interfaces_removed(sd_bus_message *m, void *userdata, sd_bus_error *error) {
60f067b4
JS		 147 int r;
148
7035cd9e 149 assert_se(sd_bus_emit_interfaces_removed(sd_bus_message_get_bus(m), "/value/a/x", "org.freedesktop.systemd.ValueTest", NULL) >= 0);
60f067b4
JS		 150
151 r = sd_bus_reply_method_return(m, NULL);
152 assert_se(r >= 0);
153
154 return 1;
155}
156
e3bff60a 157static int emit_object_added(sd_bus_message *m, void *userdata, sd_bus_error *error) {
e735f4d4
MP		 158 int r;
159
7035cd9e 160 assert_se(sd_bus_emit_object_added(sd_bus_message_get_bus(m), "/value/a/x") >= 0);
e735f4d4
MP		 161
162 r = sd_bus_reply_method_return(m, NULL);
163 assert_se(r >= 0);
164
165 return 1;
166}
167
d9f5095a
MB		 168static int emit_object_with_manager_added(sd_bus_message *m, void *userdata, sd_bus_error *error) {
169 assert_se(sd_bus_emit_object_added(sd_bus_message_get_bus(m), "/value/a") >= 0);
170
171 return ASSERT_SE_NONNEG(sd_bus_reply_method_return(m, NULL));
172}
173
e3bff60a 174static int emit_object_removed(sd_bus_message *m, void *userdata, sd_bus_error *error) {
e735f4d4
MP		 175 int r;
176
7035cd9e 177 assert_se(sd_bus_emit_object_removed(sd_bus_message_get_bus(m), "/value/a/x") >= 0);
e735f4d4
MP		 178
179 r = sd_bus_reply_method_return(m, NULL);
180 assert_se(r >= 0);
181
182 return 1;
183}
184
60f067b4
JS		 185static const sd_bus_vtable vtable[] = {
186 SD_BUS_VTABLE_START(0),
187 SD_BUS_METHOD("AlterSomething", "s", "s", something_handler, 0),
188 SD_BUS_METHOD("Exit", "", "", exit_handler, 0),
189 SD_BUS_WRITABLE_PROPERTY("Something", "s", get_handler, set_handler, 0, 0),
190 SD_BUS_WRITABLE_PROPERTY("AutomaticStringProperty", "s", NULL, NULL, offsetof(struct context, automatic_string_property), 0),
191 SD_BUS_WRITABLE_PROPERTY("AutomaticIntegerProperty", "u", NULL, NULL, offsetof(struct context, automatic_integer_property), 0),
192 SD_BUS_METHOD("NoOperation", NULL, NULL, NULL, 0),
193 SD_BUS_METHOD("EmitInterfacesAdded", NULL, NULL, emit_interfaces_added, 0),
194 SD_BUS_METHOD("EmitInterfacesRemoved", NULL, NULL, emit_interfaces_removed, 0),
e735f4d4 195 SD_BUS_METHOD("EmitObjectAdded", NULL, NULL, emit_object_added, 0),
d9f5095a 196 SD_BUS_METHOD("EmitObjectWithManagerAdded", NULL, NULL, emit_object_with_manager_added, 0),
e735f4d4 197 SD_BUS_METHOD("EmitObjectRemoved", NULL, NULL, emit_object_removed, 0),
60f067b4
JS		 198 SD_BUS_VTABLE_END
199};
200
201static const sd_bus_vtable vtable2[] = {
202 SD_BUS_VTABLE_START(0),
203 SD_BUS_METHOD("NotifyTest", "", "", notify_test, 0),
204 SD_BUS_METHOD("NotifyTest2", "", "", notify_test2, 0),
205 SD_BUS_PROPERTY("Value", "s", value_handler, 10, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE),
206 SD_BUS_PROPERTY("Value2", "s", value_handler, 10, SD_BUS_VTABLE_PROPERTY_EMITS_INVALIDATION),
207 SD_BUS_PROPERTY("Value3", "s", value_handler, 10, SD_BUS_VTABLE_PROPERTY_CONST),
208 SD_BUS_PROPERTY("Value4", "s", value_handler, 10, 0),
13d276d0 209 SD_BUS_PROPERTY("AnExplicitProperty", "s", NULL, offsetof(struct context, something), SD_BUS_VTABLE_PROPERTY_EXPLICIT|SD_BUS_VTABLE_PROPERTY_EMITS_INVALIDATION),
60f067b4
JS		 210 SD_BUS_VTABLE_END
211};
212
213static int enumerator_callback(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
214
215 if (object_path_startswith("/value", path))
6e866b33 216 assert_se(*nodes = strv_new("/value/a", "/value/b", "/value/c"));
60f067b4
JS		 217
218 return 1;
219}
220
7035cd9e
MP		 221static int enumerator2_callback(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
222
223 if (object_path_startswith("/value/a", path))
6e866b33 224 assert_se(*nodes = strv_new("/value/a/x", "/value/a/y", "/value/a/z"));
7035cd9e
MP		 225
226 return 1;
227}
228
ea0999c9
MB		 229static int enumerator3_callback(sd_bus *bus, const char *path, void *userdata, char ***nodes, sd_bus_error *error) {
230 _cleanup_strv_free_ char **v = NULL;
231
232 if (!object_path_startswith("/value/b", path))
233 return 1;
234
235 for (unsigned i = 0; i < 30; i++)
236 assert_se(strv_extendf(&v, "/value/b/%u", i) >= 0);
237
238 *nodes = TAKE_PTR(v);
239 return 1;
240}
241
60f067b4
JS		 242static void *server(void *p) {
243 struct context *c = p;
244 sd_bus *bus = NULL;
245 sd_id128_t id;
246 int r;
247
248 c->quit = false;
249
250 assert_se(sd_id128_randomize(&id) >= 0);
251
252 assert_se(sd_bus_new(&bus) >= 0);
253 assert_se(sd_bus_set_fd(bus, c->fds[0], c->fds[0]) >= 0);
254 assert_se(sd_bus_set_server(bus, 1, id) >= 0);
255
256 assert_se(sd_bus_add_object_vtable(bus, NULL, "/foo", "org.freedesktop.systemd.test", vtable, c) >= 0);
257 assert_se(sd_bus_add_object_vtable(bus, NULL, "/foo", "org.freedesktop.systemd.test2", vtable, c) >= 0);
258 assert_se(sd_bus_add_fallback_vtable(bus, NULL, "/value", "org.freedesktop.systemd.ValueTest", vtable2, NULL, UINT_TO_PTR(20)) >= 0);
259 assert_se(sd_bus_add_node_enumerator(bus, NULL, "/value", enumerator_callback, NULL) >= 0);
7035cd9e 260 assert_se(sd_bus_add_node_enumerator(bus, NULL, "/value/a", enumerator2_callback, NULL) >= 0);
ea0999c9 261 assert_se(sd_bus_add_node_enumerator(bus, NULL, "/value/b", enumerator3_callback, NULL) >= 0);
60f067b4 262 assert_se(sd_bus_add_object_manager(bus, NULL, "/value") >= 0);
7035cd9e 263 assert_se(sd_bus_add_object_manager(bus, NULL, "/value/a") >= 0);
60f067b4
JS		 264
265 assert_se(sd_bus_start(bus) >= 0);
266
267 log_error("Entering event loop on server");
268
269 while (!c->quit) {
270 log_error("Loop!");
271
272 r = sd_bus_process(bus, NULL);
273 if (r < 0) {
f47781d8 274 log_error_errno(r, "Failed to process requests: %m");
60f067b4
JS		 275 goto fail;
276 }
277
278 if (r == 0) {
3a6ce677 279 r = sd_bus_wait(bus, UINT64_MAX);
60f067b4 280 if (r < 0) {
f47781d8 281 log_error_errno(r, "Failed to wait: %m");
60f067b4
JS		 282 goto fail;
283 }
284
285 continue;
286 }
287 }
288
289 r = 0;
290
291fail:
292 if (bus) {
293 sd_bus_flush(bus);
294 sd_bus_unref(bus);
295 }
296
297 return INT_TO_PTR(r);
298}
299
300static int client(struct context *c) {
4c89c718
MP		 301 _cleanup_(sd_bus_message_unrefp) sd_bus_message *reply = NULL;
302 _cleanup_(sd_bus_unrefp) sd_bus *bus = NULL;
303 _cleanup_(sd_bus_error_free) sd_bus_error error = SD_BUS_ERROR_NULL;
ea0999c9 304 _cleanup_strv_free_ char **lines = NULL;
60f067b4
JS		 305 const char *s;
306 int r;
307
308 assert_se(sd_bus_new(&bus) >= 0);
309 assert_se(sd_bus_set_fd(bus, c->fds[1], c->fds[1]) >= 0);
310 assert_se(sd_bus_start(bus) >= 0);
311
312 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "NoOperation", &error, NULL, NULL);
313 assert_se(r >= 0);
314
315 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "AlterSomething", &error, &reply, "s", "hallo");
316 assert_se(r >= 0);
317
318 r = sd_bus_message_read(reply, "s", &s);
319 assert_se(r >= 0);
320 assert_se(streq(s, "<<<hallo>>>"));
321
3a6ce677 322 reply = sd_bus_message_unref(reply);
60f067b4
JS		 323
324 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Doesntexist", &error, &reply, "");
325 assert_se(r < 0);
326 assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_METHOD));
327
328 sd_bus_error_free(&error);
329
3a6ce677
BR		 330 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Doesntexist", &error, &reply, NULL); /* NULL and "" are equivalent */
331 assert_se(r < 0);
332 assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_METHOD));
333
334 sd_bus_error_free(&error);
335
60f067b4
JS		 336 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "AlterSomething", &error, &reply, "as", 1, "hallo");
337 assert_se(r < 0);
338 assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_INVALID_ARGS));
339
340 sd_bus_error_free(&error);
341
342 r = sd_bus_get_property(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Something", &error, &reply, "s");
343 assert_se(r >= 0);
344
345 r = sd_bus_message_read(reply, "s", &s);
346 assert_se(r >= 0);
347 assert_se(streq(s, "<<<hallo>>>"));
348
3a6ce677 349 reply = sd_bus_message_unref(reply);
60f067b4
JS		 350
351 r = sd_bus_set_property(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Something", &error, "s", "test");
352 assert_se(r >= 0);
353
354 r = sd_bus_get_property(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Something", &error, &reply, "s");
355 assert_se(r >= 0);
356
357 r = sd_bus_message_read(reply, "s", &s);
358 assert_se(r >= 0);
359 assert_se(streq(s, "test"));
360
3a6ce677 361 reply = sd_bus_message_unref(reply);
60f067b4
JS		 362
363 r = sd_bus_set_property(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "AutomaticIntegerProperty", &error, "u", 815);
364 assert_se(r >= 0);
365
366 assert_se(c->automatic_integer_property == 815);
367
368 r = sd_bus_set_property(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "AutomaticStringProperty", &error, "s", "Du Dödel, Du!");
369 assert_se(r >= 0);
370
371 assert_se(streq(c->automatic_string_property, "Du Dödel, Du!"));
372
373 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, "");
374 assert_se(r >= 0);
375
376 r = sd_bus_message_read(reply, "s", &s);
377 assert_se(r >= 0);
378 fputs(s, stdout);
379
3a6ce677
BR		 380 reply = sd_bus_message_unref(reply);
381
382 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, NULL); /* NULL and "" are equivalent */
383 assert_se(r >= 0);
384
385 r = sd_bus_message_read(reply, "s", &s);
386 assert_se(r >= 0);
387 fputs(s, stdout);
388
389 reply = sd_bus_message_unref(reply);
60f067b4
JS		 390
391 r = sd_bus_get_property(bus, "org.freedesktop.systemd.test", "/value/xuzz", "org.freedesktop.systemd.ValueTest", "Value", &error, &reply, "s");
392 assert_se(r >= 0);
393
394 r = sd_bus_message_read(reply, "s", &s);
395 assert_se(r >= 0);
396 log_info("read %s", s);
397
3a6ce677 398 reply = sd_bus_message_unref(reply);
60f067b4 399
3a6ce677 400 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, NULL);
60f067b4
JS		 401 assert_se(r >= 0);
402
403 r = sd_bus_message_read(reply, "s", &s);
404 assert_se(r >= 0);
405 fputs(s, stdout);
406
3a6ce677 407 reply = sd_bus_message_unref(reply);
60f067b4 408
3a6ce677 409 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, NULL);
60f067b4
JS		 410 assert_se(r >= 0);
411
412 r = sd_bus_message_read(reply, "s", &s);
413 assert_se(r >= 0);
414 fputs(s, stdout);
415
3a6ce677 416 reply = sd_bus_message_unref(reply);
60f067b4 417
3a6ce677 418 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value/a", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, NULL);
60f067b4
JS		 419 assert_se(r >= 0);
420
421 r = sd_bus_message_read(reply, "s", &s);
422 assert_se(r >= 0);
423 fputs(s, stdout);
424
ea0999c9
MB		 425 assert_se(lines = strv_split_newlines(s));
426 assert_se(strv_contains(lines, " <node name=\"x\"/>"));
427 assert_se(strv_contains(lines, " <node name=\"y\"/>"));
428 assert_se(strv_contains(lines, " <node name=\"z\"/>"));
429 lines = strv_free(lines);
430
431 reply = sd_bus_message_unref(reply);
432
433 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value/b", "org.freedesktop.DBus.Introspectable", "Introspect", &error, &reply, NULL);
434 assert_se(r >= 0);
435
436 r = sd_bus_message_read(reply, "s", &s);
437 assert_se(r >= 0);
438 fputs(s, stdout);
439
440 assert_se(lines = strv_split_newlines(s));
441 for (unsigned i = 0; i < 30; i++) {
442 _cleanup_free_ char *n = NULL;
443
444 assert_se(asprintf(&n, " <node name=\"%u\"/>", i) >= 0);
445 assert_se(strv_contains(lines, n));
446 }
447 lines = strv_free(lines);
448
3a6ce677 449 reply = sd_bus_message_unref(reply);
60f067b4 450
3a6ce677 451 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.DBus.Properties", "GetAll", &error, &reply, "s", NULL);
60f067b4
JS		 452 assert_se(r >= 0);
453
46cdbd49 454 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 455
3a6ce677 456 reply = sd_bus_message_unref(reply);
60f067b4
JS		 457
458 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value/a", "org.freedesktop.DBus.Properties", "GetAll", &error, &reply, "s", "org.freedesktop.systemd.ValueTest2");
459 assert_se(r < 0);
460 assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_INTERFACE));
461 sd_bus_error_free(&error);
462
3a6ce677 463 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.DBus.ObjectManager", "GetManagedObjects", &error, &reply, NULL);
60f067b4
JS		 464 assert_se(r < 0);
465 assert_se(sd_bus_error_has_name(&error, SD_BUS_ERROR_UNKNOWN_METHOD));
466 sd_bus_error_free(&error);
467
3a6ce677 468 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value", "org.freedesktop.DBus.ObjectManager", "GetManagedObjects", &error, &reply, NULL);
60f067b4
JS		 469 assert_se(r >= 0);
470
46cdbd49 471 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 472
d9f5095a
MB		 473 /* Check that /value/b does not have ObjectManager interface but /value/a does */
474 assert_se(sd_bus_message_rewind(reply, 1) > 0);
475 assert_se(sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{oa{sa{sv}}}") > 0);
476 while (ASSERT_SE_NONNEG(sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "oa{sa{sv}}")) > 0) {
477 const char *path = NULL;
478 assert_se(sd_bus_message_read_basic(reply, 'o', &path) > 0);
479 if (STR_IN_SET(path, "/value/b", "/value/a")) {
480 /* Check that there is no object manager interface here */
481 bool found_object_manager_interface = false;
482 assert_se(sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sa{sv}}") > 0);
483 while (ASSERT_SE_NONNEG(sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sa{sv}")) > 0) {
484 const char *interface_name = NULL;
485 assert_se(sd_bus_message_read_basic(reply, 's', &interface_name) > 0);
486
487 if (streq(interface_name, "org.freedesktop.DBus.ObjectManager")) {
488 assert_se(!streq(path, "/value/b"));
489 found_object_manager_interface = true;
490 }
491
492 assert_se(sd_bus_message_skip(reply, "a{sv}") >= 0);
493 assert_se(sd_bus_message_exit_container(reply) >= 0);
494 }
495 assert_se(sd_bus_message_exit_container(reply) >= 0);
496
497 if (streq(path, "/value/a")) {
498 /* ObjectManager must be here */
499 assert_se(found_object_manager_interface);
500 }
501
502 } else
503 assert_se(sd_bus_message_skip(reply, "a{sa{sv}}") >= 0);
504
505 assert_se(sd_bus_message_exit_container(reply) >= 0);
506 }
507
3a6ce677 508 reply = sd_bus_message_unref(reply);
60f067b4 509
3a6ce677 510 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value/a", "org.freedesktop.systemd.ValueTest", "NotifyTest", &error, NULL, NULL);
60f067b4
JS		 511 assert_se(r >= 0);
512
513 r = sd_bus_process(bus, &reply);
514 assert_se(r > 0);
515
516 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.Properties", "PropertiesChanged"));
46cdbd49 517 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 518
3a6ce677 519 reply = sd_bus_message_unref(reply);
60f067b4 520
3a6ce677 521 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/value/a", "org.freedesktop.systemd.ValueTest", "NotifyTest2", &error, NULL, NULL);
60f067b4
JS		 522 assert_se(r >= 0);
523
524 r = sd_bus_process(bus, &reply);
525 assert_se(r > 0);
526
527 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.Properties", "PropertiesChanged"));
46cdbd49 528 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 529
3a6ce677 530 reply = sd_bus_message_unref(reply);
60f067b4 531
3a6ce677 532 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "EmitInterfacesAdded", &error, NULL, NULL);
60f067b4
JS		 533 assert_se(r >= 0);
534
535 r = sd_bus_process(bus, &reply);
536 assert_se(r > 0);
537
538 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.ObjectManager", "InterfacesAdded"));
46cdbd49 539 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 540
3a6ce677 541 reply = sd_bus_message_unref(reply);
60f067b4 542
3a6ce677 543 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "EmitInterfacesRemoved", &error, NULL, NULL);
60f067b4
JS		 544 assert_se(r >= 0);
545
546 r = sd_bus_process(bus, &reply);
547 assert_se(r > 0);
548
549 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.ObjectManager", "InterfacesRemoved"));
46cdbd49 550 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
e735f4d4 551
3a6ce677 552 reply = sd_bus_message_unref(reply);
e735f4d4 553
3a6ce677 554 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "EmitObjectAdded", &error, NULL, NULL);
e735f4d4
MP		 555 assert_se(r >= 0);
556
557 r = sd_bus_process(bus, &reply);
558 assert_se(r > 0);
559
560 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.ObjectManager", "InterfacesAdded"));
46cdbd49 561 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
e735f4d4 562
d9f5095a
MB		 563 /* Check if /value/a/x does not have org.freedesktop.DBus.ObjectManager */
564 assert_se(sd_bus_message_rewind(reply, 1) >= 0);
565 const char* should_be_value_a_x = NULL;
566 assert_se(sd_bus_message_read_basic(reply, 'o', &should_be_value_a_x) > 0);
567 assert_se(streq(should_be_value_a_x, "/value/a/x"));
568 assert_se(sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sa{sv}}") > 0);
569 while (ASSERT_SE_NONNEG(sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sa{sv}")) > 0) {
570 const char* interface_name = NULL;
571 assert_se(sd_bus_message_read_basic(reply, 's', &interface_name) > 0);
572
573 assert(!streq(interface_name, "org.freedesktop.DBus.ObjectManager"));
574
575 assert_se(sd_bus_message_skip(reply, "a{sv}") >= 0);
576
577 assert_se(sd_bus_message_exit_container(reply) >= 0);
578 }
579
580 reply = sd_bus_message_unref(reply);
581
582 assert_se(sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "EmitObjectWithManagerAdded", &error, NULL, NULL) >= 0);
583
584 assert_se(sd_bus_process(bus, &reply) > 0);
585
586 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.ObjectManager", "InterfacesAdded"));
587 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
588
589 /* Check if /value/a has org.freedesktop.DBus.ObjectManager */
590 assert_se(sd_bus_message_rewind(reply, 1) >= 0);
591 const char* should_be_value_a = NULL;
592 bool found_object_manager = false;
593 assert_se(sd_bus_message_read_basic(reply, 'o', &should_be_value_a) > 0);
594 assert_se(streq(should_be_value_a, "/value/a"));
595 assert_se(sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "{sa{sv}}") > 0);
596 while (ASSERT_SE_NONNEG(sd_bus_message_enter_container(reply, SD_BUS_TYPE_DICT_ENTRY, "sa{sv}")) > 0) {
597 const char* interface_name = NULL;
598 assert_se(sd_bus_message_read_basic(reply, 's', &interface_name));
599
600 if (streq(interface_name, "org.freedesktop.DBus.ObjectManager")) {
601 found_object_manager = true;
602 break;
603 }
604
605 assert_se(sd_bus_message_skip(reply, "a{sv}") >= 0);
606
607 assert_se(sd_bus_message_exit_container(reply) >= 0);
608 }
609 assert_se(found_object_manager);
610
3a6ce677 611 reply = sd_bus_message_unref(reply);
e735f4d4 612
3a6ce677 613 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "EmitObjectRemoved", &error, NULL, NULL);
e735f4d4
MP		 614 assert_se(r >= 0);
615
616 r = sd_bus_process(bus, &reply);
617 assert_se(r > 0);
618
619 assert_se(sd_bus_message_is_signal(reply, "org.freedesktop.DBus.ObjectManager", "InterfacesRemoved"));
46cdbd49 620 sd_bus_message_dump(reply, stdout, SD_BUS_MESSAGE_DUMP_WITH_HEADER);
60f067b4 621
d9f5095a
MB		 622 /* Check if /value/a/x does not have org.freedesktop.DBus.ObjectManager */
623 assert_se(sd_bus_message_rewind(reply, 1) >= 0);
624 should_be_value_a_x = NULL;
625 assert_se(sd_bus_message_read_basic(reply, 'o', &should_be_value_a_x) > 0);
626 assert_se(streq(should_be_value_a_x, "/value/a/x"));
627 assert_se(sd_bus_message_enter_container(reply, SD_BUS_TYPE_ARRAY, "s") > 0);
628 const char* deleted_interface_name = NULL;
629 while (ASSERT_SE_NONNEG(sd_bus_message_read_basic(reply, 's', &deleted_interface_name)) > 0) {
630 assert(!streq(deleted_interface_name, "org.freedesktop.DBus.ObjectManager"));
631 }
632 assert_se(sd_bus_message_exit_container(reply) >= 0);
633
3a6ce677 634 reply = sd_bus_message_unref(reply);
60f067b4 635
3a6ce677 636 r = sd_bus_call_method(bus, "org.freedesktop.systemd.test", "/foo", "org.freedesktop.systemd.test", "Exit", &error, NULL, NULL);
60f067b4
JS		 637 assert_se(r >= 0);
638
639 sd_bus_flush(bus);
640
641 return 0;
642}
643
644int main(int argc, char *argv[]) {
645 struct context c = {};
646 pthread_t s;
647 void *p;
648 int r, q;
649
60f067b4
JS		 650 c.automatic_integer_property = 4711;
651 assert_se(c.automatic_string_property = strdup("dudeldu"));
652
653 assert_se(socketpair(AF_UNIX, SOCK_STREAM, 0, c.fds) >= 0);
654
655 r = pthread_create(&s, NULL, server, &c);
656 if (r != 0)
657 return -r;
658
659 r = client(&c);
660
661 q = pthread_join(s, &p);
662 if (q != 0)
663 return -q;
664
665 if (r < 0)
666 return r;
667
668 if (PTR_TO_INT(p) < 0)
669 return PTR_TO_INT(p);
670
671 free(c.something);
672 free(c.automatic_string_property);
673
674 return EXIT_SUCCESS;
675}
systemd for Proxmox projects