1 /* SPDX-License-Identifier: LGPL-2.1+ */
10 #include "alloc-util.h"
11 #include "bus-error.h"
12 #include "bus-internal.h"
13 #include "bus-match.h"
16 #include "format-util.h"
22 static int match_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
23 log_info("Match triggered! interface=%s member=%s", strna(sd_bus_message_get_interface(m
)), strna(sd_bus_message_get_member(m
)));
27 static int object_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
30 if (sd_bus_message_is_method_error(m
, NULL
))
33 if (sd_bus_message_is_method_call(m
, "org.object.test", "Foobar")) {
34 log_info("Invoked Foobar() on %s", sd_bus_message_get_path(m
));
36 r
= sd_bus_reply_method_return(m
, NULL
);
38 return log_error_errno(r
, "Failed to send reply: %m");
46 static int server_init(sd_bus
**_bus
) {
50 const char *unique
, *desc
;
54 r
= sd_bus_open_user_with_description(&bus
, "my bus!");
56 log_error_errno(r
, "Failed to connect to user bus: %m");
60 r
= sd_bus_get_bus_id(bus
, &id
);
62 log_error_errno(r
, "Failed to get server ID: %m");
66 r
= sd_bus_get_unique_name(bus
, &unique
);
68 log_error_errno(r
, "Failed to get unique name: %m");
72 r
= sd_bus_get_description(bus
, &desc
);
73 assert_se(streq(desc
, "my bus!"));
75 log_info("Peer ID is " SD_ID128_FORMAT_STR
".", SD_ID128_FORMAT_VAL(id
));
76 log_info("Unique ID: %s", unique
);
77 log_info("Can send file handles: %i", sd_bus_can_send(bus
, 'h'));
79 r
= sd_bus_request_name(bus
, "org.freedesktop.systemd.test", 0);
81 log_error_errno(r
, "Failed to acquire name: %m");
85 r
= sd_bus_add_fallback(bus
, NULL
, "/foo/bar", object_callback
, NULL
);
87 log_error_errno(r
, "Failed to add object: %m");
91 r
= sd_bus_match_signal(bus
, NULL
, NULL
, NULL
, "foo.bar", "Notify", match_callback
, NULL
);
93 log_error_errno(r
, "Failed to request match: %m");
97 r
= sd_bus_add_match(bus
, NULL
, "type='signal',interface='org.freedesktop.DBus',member='NameOwnerChanged'", match_callback
, NULL
);
99 log_error_errno(r
, "Failed to add match: %m");
103 bus_match_dump(&bus
->match_callbacks
, 0);
113 static int server(sd_bus
*bus
) {
115 bool client1_gone
= false, client2_gone
= false;
117 while (!client1_gone
|| !client2_gone
) {
118 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*m
= NULL
;
120 const char *label
= NULL
;
122 r
= sd_bus_process(bus
, &m
);
124 log_error_errno(r
, "Failed to process requests: %m");
129 r
= sd_bus_wait(bus
, (uint64_t) -1);
131 log_error_errno(r
, "Failed to wait: %m");
141 sd_bus_creds_get_pid(sd_bus_message_get_creds(m
), &pid
);
142 sd_bus_creds_get_selinux_context(sd_bus_message_get_creds(m
), &label
);
143 log_info("Got message! member=%s pid="PID_FMT
" label=%s",
144 strna(sd_bus_message_get_member(m
)),
147 /* bus_message_dump(m); */
148 /* sd_bus_message_rewind(m, true); */
150 if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "LowerCase")) {
152 _cleanup_free_
char *lowercase
= NULL
;
154 r
= sd_bus_message_read(m
, "s", &hello
);
156 log_error_errno(r
, "Failed to get parameter: %m");
160 lowercase
= strdup(hello
);
166 ascii_strlower(lowercase
);
168 r
= sd_bus_reply_method_return(m
, "s", lowercase
);
170 log_error_errno(r
, "Failed to send reply: %m");
173 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "ExitClient1")) {
175 r
= sd_bus_reply_method_return(m
, NULL
);
177 log_error_errno(r
, "Failed to send reply: %m");
182 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "ExitClient2")) {
184 r
= sd_bus_reply_method_return(m
, NULL
);
186 log_error_errno(r
, "Failed to send reply: %m");
191 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "Slow")) {
195 r
= sd_bus_reply_method_return(m
, NULL
);
197 log_error_errno(r
, "Failed to send reply: %m");
201 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "FileDescriptor")) {
203 static const char x
= 'X';
205 r
= sd_bus_message_read(m
, "h", &fd
);
207 log_error_errno(r
, "Failed to get parameter: %m");
211 log_info("Received fd=%d", fd
);
213 if (write(fd
, &x
, 1) < 0) {
214 log_error_errno(errno
, "Failed to write to fd: %m");
219 r
= sd_bus_reply_method_return(m
, NULL
);
221 log_error_errno(r
, "Failed to send reply: %m");
225 } else if (sd_bus_message_is_method_call(m
, NULL
, NULL
)) {
227 r
= sd_bus_reply_method_error(
229 &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_UNKNOWN_METHOD
, "Unknown method."));
231 log_error_errno(r
, "Failed to send reply: %m");
248 static void* client1(void*p
) {
249 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*reply
= NULL
;
250 _cleanup_(sd_bus_flush_close_unrefp
) sd_bus
*bus
= NULL
;
251 _cleanup_(sd_bus_error_free
) sd_bus_error error
= SD_BUS_ERROR_NULL
;
254 _cleanup_close_pair_
int pp
[2] = { -1, -1 };
257 r
= sd_bus_open_user(&bus
);
259 log_error_errno(r
, "Failed to connect to user bus: %m");
263 r
= sd_bus_call_method(
265 "org.freedesktop.systemd.test",
267 "org.freedesktop.systemd.test",
274 log_error_errno(r
, "Failed to issue method call: %m");
278 r
= sd_bus_message_read(reply
, "s", &hello
);
280 log_error_errno(r
, "Failed to get string: %m");
284 assert_se(streq(hello
, "hello"));
286 if (pipe2(pp
, O_CLOEXEC
|O_NONBLOCK
) < 0) {
287 log_error_errno(errno
, "Failed to allocate pipe: %m");
292 log_info("Sending fd=%d", pp
[1]);
294 r
= sd_bus_call_method(
296 "org.freedesktop.systemd.test",
298 "org.freedesktop.systemd.test",
305 log_error_errno(r
, "Failed to issue method call: %m");
310 if (read(pp
[0], &x
, 1) <= 0) {
311 log_error("Failed to read from pipe: %s", errno
? strerror(errno
) : "early read");
319 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*q
;
321 r
= sd_bus_message_new_method_call(
324 "org.freedesktop.systemd.test",
326 "org.freedesktop.systemd.test",
329 log_error_errno(r
, "Failed to allocate method call: %m");
331 sd_bus_send(bus
, q
, NULL
);
335 return INT_TO_PTR(r
);
338 static int quit_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
341 log_error_errno(sd_bus_message_get_errno(m
), "Quit callback: %m");
347 static void* client2(void*p
) {
348 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*m
= NULL
, *reply
= NULL
;
349 _cleanup_(sd_bus_flush_close_unrefp
) sd_bus
*bus
= NULL
;
350 _cleanup_(sd_bus_error_free
) sd_bus_error error
= SD_BUS_ERROR_NULL
;
355 r
= sd_bus_open_user(&bus
);
357 log_error_errno(r
, "Failed to connect to user bus: %m");
361 r
= sd_bus_message_new_method_call(
364 "org.freedesktop.systemd.test",
365 "/foo/bar/waldo/piep",
369 log_error_errno(r
, "Failed to allocate method call: %m");
373 r
= sd_bus_send(bus
, m
, NULL
);
375 log_error("Failed to issue method call: %s", bus_error_message(&error
, -r
));
379 m
= sd_bus_message_unref(m
);
381 r
= sd_bus_message_new_signal(
388 log_error_errno(r
, "Failed to allocate signal: %m");
392 r
= sd_bus_send(bus
, m
, NULL
);
394 log_error("Failed to issue signal: %s", bus_error_message(&error
, -r
));
398 m
= sd_bus_message_unref(m
);
400 r
= sd_bus_message_new_method_call(
403 "org.freedesktop.systemd.test",
405 "org.freedesktop.DBus.Peer",
408 log_error_errno(r
, "Failed to allocate method call: %m");
412 r
= sd_bus_call(bus
, m
, 0, &error
, &reply
);
414 log_error("Failed to issue method call: %s", bus_error_message(&error
, -r
));
418 r
= sd_bus_message_read(reply
, "s", &mid
);
420 log_error_errno(r
, "Failed to parse machine ID: %m");
424 log_info("Machine ID is %s.", mid
);
426 m
= sd_bus_message_unref(m
);
428 r
= sd_bus_message_new_method_call(
431 "org.freedesktop.systemd.test",
433 "org.freedesktop.systemd.test",
436 log_error_errno(r
, "Failed to allocate method call: %m");
440 reply
= sd_bus_message_unref(reply
);
442 r
= sd_bus_call(bus
, m
, 200 * USEC_PER_MSEC
, &error
, &reply
);
444 log_info("Failed to issue method call: %s", bus_error_message(&error
, -r
));
446 log_info("Slow call succeed.");
448 m
= sd_bus_message_unref(m
);
450 r
= sd_bus_message_new_method_call(
453 "org.freedesktop.systemd.test",
455 "org.freedesktop.systemd.test",
458 log_error_errno(r
, "Failed to allocate method call: %m");
462 r
= sd_bus_call_async(bus
, NULL
, m
, quit_callback
, &quit
, 200 * USEC_PER_MSEC
);
464 log_info("Failed to issue method call: %s", bus_error_message(&error
, -r
));
469 r
= sd_bus_process(bus
, NULL
);
471 log_error_errno(r
, "Failed to process requests: %m");
475 r
= sd_bus_wait(bus
, (uint64_t) -1);
477 log_error_errno(r
, "Failed to wait: %m");
487 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*q
;
489 r
= sd_bus_message_new_method_call(
492 "org.freedesktop.systemd.test",
494 "org.freedesktop.systemd.test",
497 log_error_errno(r
, "Failed to allocate method call: %m");
501 (void) sd_bus_send(bus
, q
, NULL
);
504 return INT_TO_PTR(r
);
507 int main(int argc
, char *argv
[]) {
513 test_setup_logging(LOG_INFO
);
515 r
= server_init(&bus
);
517 return log_tests_skipped("Failed to connect to bus");
519 log_info("Initialized...");
521 r
= pthread_create(&c1
, NULL
, client1
, bus
);
525 r
= pthread_create(&c2
, NULL
, client2
, bus
);
531 q
= pthread_join(c1
, &p
);
534 if (PTR_TO_INT(p
) < 0)
537 q
= pthread_join(c2
, &p
);
540 if (PTR_TO_INT(p
) < 0)