1 /* SPDX-License-Identifier: LGPL-2.1-or-later */
10 #include "alloc-util.h"
11 #include "bus-error.h"
12 #include "bus-internal.h"
13 #include "bus-match.h"
14 #include "errno-util.h"
16 #include "format-util.h"
19 #include "string-util.h"
22 static int match_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
23 log_info("Match triggered! destination=%s interface=%s member=%s",
24 strna(sd_bus_message_get_destination(m
)),
25 strna(sd_bus_message_get_interface(m
)),
26 strna(sd_bus_message_get_member(m
)));
30 static int object_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
33 if (sd_bus_message_is_method_error(m
, NULL
))
36 if (sd_bus_message_is_method_call(m
, "org.object.test", "Foobar")) {
37 log_info("Invoked Foobar() on %s", sd_bus_message_get_path(m
));
39 r
= sd_bus_reply_method_return(m
, NULL
);
41 return log_error_errno(r
, "Failed to send reply: %m");
49 static int server_init(sd_bus
**_bus
) {
53 const char *unique
, *desc
;
57 r
= sd_bus_open_user_with_description(&bus
, "my bus!");
59 log_error_errno(r
, "Failed to connect to user bus: %m");
63 r
= sd_bus_get_bus_id(bus
, &id
);
65 log_error_errno(r
, "Failed to get server ID: %m");
69 r
= sd_bus_get_unique_name(bus
, &unique
);
71 log_error_errno(r
, "Failed to get unique name: %m");
75 assert_se(sd_bus_get_description(bus
, &desc
) >= 0);
76 assert_se(streq(desc
, "my bus!"));
78 log_info("Peer ID is " SD_ID128_FORMAT_STR
".", SD_ID128_FORMAT_VAL(id
));
79 log_info("Unique ID: %s", unique
);
80 log_info("Can send file handles: %i", sd_bus_can_send(bus
, 'h'));
82 r
= sd_bus_request_name(bus
, "org.freedesktop.systemd.test", 0);
84 log_error_errno(r
, "Failed to acquire name: %m");
88 r
= sd_bus_add_fallback(bus
, NULL
, "/foo/bar", object_callback
, NULL
);
90 log_error_errno(r
, "Failed to add object: %m");
94 r
= sd_bus_match_signal(bus
, NULL
, NULL
, NULL
, "foo.bar", "Notify", match_callback
, NULL
);
96 log_error_errno(r
, "Failed to request match: %m");
100 r
= sd_bus_match_signal(bus
, NULL
, NULL
, NULL
, "foo.bar", "NotifyTo", match_callback
, NULL
);
102 log_error_errno(r
, "Failed to request match: %m");
106 r
= sd_bus_add_match(bus
, NULL
, "type='signal',interface='org.freedesktop.DBus',member='NameOwnerChanged'", match_callback
, NULL
);
108 log_error_errno(r
, "Failed to add match: %m");
112 bus_match_dump(stdout
, &bus
->match_callbacks
, 0);
122 static int server(sd_bus
*bus
) {
124 bool client1_gone
= false, client2_gone
= false;
126 while (!client1_gone
|| !client2_gone
) {
127 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*m
= NULL
;
129 const char *label
= NULL
;
131 r
= sd_bus_process(bus
, &m
);
133 log_error_errno(r
, "Failed to process requests: %m");
138 r
= sd_bus_wait(bus
, UINT64_MAX
);
140 log_error_errno(r
, "Failed to wait: %m");
150 sd_bus_creds_get_pid(sd_bus_message_get_creds(m
), &pid
);
151 sd_bus_creds_get_selinux_context(sd_bus_message_get_creds(m
), &label
);
152 log_info("Got message! member=%s pid="PID_FMT
" label=%s",
153 strna(sd_bus_message_get_member(m
)),
156 /* sd_bus_message_dump(m); */
157 /* sd_bus_message_rewind(m, true); */
159 if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "LowerCase")) {
161 _cleanup_free_
char *lowercase
= NULL
;
163 r
= sd_bus_message_read(m
, "s", &hello
);
165 log_error_errno(r
, "Failed to get parameter: %m");
169 lowercase
= strdup(hello
);
175 ascii_strlower(lowercase
);
177 r
= sd_bus_reply_method_return(m
, "s", lowercase
);
179 log_error_errno(r
, "Failed to send reply: %m");
182 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "ExitClient1")) {
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", "ExitClient2")) {
193 r
= sd_bus_reply_method_return(m
, NULL
);
195 log_error_errno(r
, "Failed to send reply: %m");
200 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "Slow")) {
204 r
= sd_bus_reply_method_return(m
, NULL
);
206 log_error_errno(r
, "Failed to send reply: %m");
210 } else if (sd_bus_message_is_method_call(m
, "org.freedesktop.systemd.test", "FileDescriptor")) {
212 static const char x
= 'X';
214 r
= sd_bus_message_read(m
, "h", &fd
);
216 log_error_errno(r
, "Failed to get parameter: %m");
220 log_info("Received fd=%d", fd
);
222 if (write(fd
, &x
, 1) < 0) {
223 log_error_errno(errno
, "Failed to write to fd: %m");
228 r
= sd_bus_reply_method_return(m
, NULL
);
230 log_error_errno(r
, "Failed to send reply: %m");
234 } else if (sd_bus_message_is_method_call(m
, NULL
, NULL
)) {
236 r
= sd_bus_reply_method_error(
238 &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_UNKNOWN_METHOD
, "Unknown method."));
240 log_error_errno(r
, "Failed to send reply: %m");
257 static void* client1(void *p
) {
258 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*reply
= NULL
;
259 _cleanup_(sd_bus_flush_close_unrefp
) sd_bus
*bus
= NULL
;
260 _cleanup_(sd_bus_error_free
) sd_bus_error error
= SD_BUS_ERROR_NULL
;
263 _cleanup_close_pair_
int pp
[2] = { -EBADF
, -EBADF
};
266 r
= sd_bus_open_user(&bus
);
268 log_error_errno(r
, "Failed to connect to user bus: %m");
272 r
= sd_bus_call_method(
274 "org.freedesktop.systemd.test",
276 "org.freedesktop.systemd.test",
283 log_error_errno(r
, "Failed to issue method call: %m");
287 r
= sd_bus_message_read(reply
, "s", &hello
);
289 log_error_errno(r
, "Failed to get string: %m");
293 assert_se(streq(hello
, "hello"));
295 if (pipe2(pp
, O_CLOEXEC
|O_NONBLOCK
) < 0) {
296 r
= log_error_errno(errno
, "Failed to allocate pipe: %m");
300 log_info("Sending fd=%d", pp
[1]);
302 r
= sd_bus_call_method(
304 "org.freedesktop.systemd.test",
306 "org.freedesktop.systemd.test",
313 log_error_errno(r
, "Failed to issue method call: %m");
318 if (read(pp
[0], &x
, 1) <= 0) {
319 log_error("Failed to read from pipe: %s", STRERROR_OR_EOF(errno
));
327 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*q
= NULL
;
329 r
= sd_bus_message_new_method_call(
332 "org.freedesktop.systemd.test",
334 "org.freedesktop.systemd.test",
337 log_error_errno(r
, "Failed to allocate method call: %m");
339 sd_bus_send(bus
, q
, NULL
);
343 return INT_TO_PTR(r
);
346 static int quit_callback(sd_bus_message
*m
, void *userdata
, sd_bus_error
*ret_error
) {
349 log_error_errno(sd_bus_message_get_errno(m
), "Quit callback: %m");
355 static void* client2(void *p
) {
356 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*m
= NULL
, *reply
= NULL
;
357 _cleanup_(sd_bus_flush_close_unrefp
) sd_bus
*bus
= NULL
;
358 _cleanup_(sd_bus_error_free
) sd_bus_error error
= SD_BUS_ERROR_NULL
;
363 r
= sd_bus_open_user(&bus
);
365 log_error_errno(r
, "Failed to connect to user bus: %m");
369 r
= sd_bus_message_new_method_call(
372 "org.freedesktop.systemd.test",
373 "/foo/bar/waldo/piep",
377 log_error_errno(r
, "Failed to allocate method call: %m");
381 r
= sd_bus_send(bus
, m
, NULL
);
383 log_error("Failed to issue method call: %s", bus_error_message(&error
, r
));
387 m
= sd_bus_message_unref(m
);
389 r
= sd_bus_message_new_signal(
396 log_error_errno(r
, "Failed to allocate signal: %m");
400 r
= sd_bus_send(bus
, m
, NULL
);
402 log_error("Failed to issue signal: %s", bus_error_message(&error
, r
));
406 m
= sd_bus_message_unref(m
);
408 r
= sd_bus_message_new_signal_to(
411 "org.freedesktop.systemd.test",
416 log_error_errno(r
, "Failed to allocate signal to: %m");
420 r
= sd_bus_send(bus
, m
, NULL
);
422 log_error("Failed to issue signal to: %s", bus_error_message(&error
, r
));
426 m
= sd_bus_message_unref(m
);
428 r
= sd_bus_message_new_method_call(
431 "org.freedesktop.systemd.test",
433 "org.freedesktop.DBus.Peer",
436 log_error_errno(r
, "Failed to allocate method call: %m");
440 r
= sd_bus_call(bus
, m
, 0, &error
, &reply
);
442 log_error("Failed to issue method call: %s", bus_error_message(&error
, r
));
446 r
= sd_bus_message_read(reply
, "s", &mid
);
448 log_error_errno(r
, "Failed to parse machine ID: %m");
452 log_info("Machine ID is %s.", mid
);
454 m
= sd_bus_message_unref(m
);
456 r
= sd_bus_message_new_method_call(
459 "org.freedesktop.systemd.test",
461 "org.freedesktop.systemd.test",
464 log_error_errno(r
, "Failed to allocate method call: %m");
468 reply
= sd_bus_message_unref(reply
);
470 r
= sd_bus_call(bus
, m
, 200 * USEC_PER_MSEC
, &error
, &reply
);
472 log_info("Failed to issue method call: %s", bus_error_message(&error
, r
));
474 log_info("Slow call succeed.");
476 m
= sd_bus_message_unref(m
);
478 r
= sd_bus_message_new_method_call(
481 "org.freedesktop.systemd.test",
483 "org.freedesktop.systemd.test",
486 log_error_errno(r
, "Failed to allocate method call: %m");
490 r
= sd_bus_call_async(bus
, NULL
, m
, quit_callback
, &quit
, 200 * USEC_PER_MSEC
);
492 log_info("Failed to issue method call: %s", bus_error_message(&error
, r
));
497 r
= sd_bus_process(bus
, NULL
);
499 log_error_errno(r
, "Failed to process requests: %m");
503 r
= sd_bus_wait(bus
, UINT64_MAX
);
505 log_error_errno(r
, "Failed to wait: %m");
515 _cleanup_(sd_bus_message_unrefp
) sd_bus_message
*q
= NULL
;
517 r
= sd_bus_message_new_method_call(
520 "org.freedesktop.systemd.test",
522 "org.freedesktop.systemd.test",
525 log_error_errno(r
, "Failed to allocate method call: %m");
529 (void) sd_bus_send(bus
, q
, NULL
);
532 return INT_TO_PTR(r
);
535 int main(int argc
, char *argv
[]) {
541 test_setup_logging(LOG_INFO
);
543 r
= server_init(&bus
);
545 return log_tests_skipped("Failed to connect to bus");
547 log_info("Initialized...");
549 r
= pthread_create(&c1
, NULL
, client1
, bus
);
553 r
= pthread_create(&c2
, NULL
, client2
, bus
);
559 q
= pthread_join(c1
, &p
);
562 if (PTR_TO_INT(p
) < 0)
565 q
= pthread_join(c2
, &p
);
568 if (PTR_TO_INT(p
) < 0)