Bug Summary

File:build-scan/../src/libsystemd/sd-bus/sd-bus.c
Warning:line 932, column 32
Potential leak of memory pointed to by 'machine'

Annotated Source Code

Press '?' to see keyboard shortcuts

clang -cc1 -cc1 -triple x86_64-unknown-linux-gnu -analyze -disable-free -disable-llvm-verifier -discard-value-names -main-file-name sd-bus.c -analyzer-store=region -analyzer-opt-analyze-nested-blocks -analyzer-checker=core -analyzer-checker=apiModeling -analyzer-checker=unix -analyzer-checker=deadcode -analyzer-checker=security.insecureAPI.UncheckedReturn -analyzer-checker=security.insecureAPI.getpw -analyzer-checker=security.insecureAPI.gets -analyzer-checker=security.insecureAPI.mktemp -analyzer-checker=security.insecureAPI.mkstemp -analyzer-checker=security.insecureAPI.vfork -analyzer-checker=nullability.NullPassedToNonnull -analyzer-checker=nullability.NullReturnedFromNonnull -analyzer-output plist -w -setup-static-analyzer -mrelocation-model pic -pic-level 2 -fhalf-no-semantic-interposition -mframe-pointer=all -relaxed-aliasing -menable-no-infs -menable-no-nans -menable-unsafe-fp-math -fno-signed-zeros -mreassociate -freciprocal-math -fdenormal-fp-math=preserve-sign,preserve-sign -ffp-contract=fast -fno-rounding-math -ffast-math -ffinite-math-only -mconstructor-aliases -munwind-tables -target-cpu x86-64 -tune-cpu generic -fno-split-dwarf-inlining -debugger-tuning=gdb -resource-dir /usr/lib64/clang/12.0.0 -include config.h -I src/libsystemd/libsystemd_static.a.p -I src/libsystemd -I ../src/libsystemd -I src/basic -I ../src/basic -I src/shared -I ../src/shared -I src/systemd -I ../src/systemd -I src/journal -I ../src/journal -I src/journal-remote -I ../src/journal-remote -I src/nspawn -I ../src/nspawn -I src/resolve -I ../src/resolve -I src/timesync -I ../src/timesync -I ../src/time-wait-sync -I src/login -I ../src/login -I src/udev -I ../src/udev -I src/libudev -I ../src/libudev -I src/core -I ../src/core -I ../src/libsystemd/sd-bus -I ../src/libsystemd/sd-device -I ../src/libsystemd/sd-hwdb -I ../src/libsystemd/sd-id128 -I ../src/libsystemd/sd-netlink -I ../src/libsystemd/sd-network -I src/libsystemd-network -I ../src/libsystemd-network -I . -I .. -D _FILE_OFFSET_BITS=64 -internal-isystem /usr/local/include -internal-isystem /usr/lib64/clang/12.0.0/include -internal-externc-isystem /include -internal-externc-isystem /usr/include -Wwrite-strings -Wno-unused-parameter -Wno-missing-field-initializers -Wno-unused-result -Wno-format-signedness -Wno-error=nonnull -std=gnu99 -fconst-strings -fdebug-compilation-dir /home/mrc0mmand/repos/@redhat-plumbers/systemd-rhel8/build-scan -ferror-limit 19 -fvisibility default -stack-protector 2 -fgnuc-version=4.2.1 -fcolor-diagnostics -analyzer-output=html -faddrsig -o /tmp/scan-build-2021-07-16-221226-1465241-1 -x c ../src/libsystemd/sd-bus/sd-bus.c
1/* SPDX-License-Identifier: LGPL-2.1+ */
2/***
3***/
4
5#include <endian.h>
6#include <netdb.h>
7#include <poll.h>
8#include <pthread.h>
9#include <signal.h>
10#include <stdlib.h>
11#include <sys/mman.h>
12#include <sys/wait.h>
13#include <unistd.h>
14
15#include "sd-bus.h"
16
17#include "alloc-util.h"
18#include "bus-container.h"
19#include "bus-control.h"
20#include "bus-internal.h"
21#include "bus-kernel.h"
22#include "bus-label.h"
23#include "bus-message.h"
24#include "bus-objects.h"
25#include "bus-protocol.h"
26#include "bus-slot.h"
27#include "bus-socket.h"
28#include "bus-track.h"
29#include "bus-type.h"
30#include "bus-util.h"
31#include "cgroup-util.h"
32#include "def.h"
33#include "fd-util.h"
34#include "hexdecoct.h"
35#include "hostname-util.h"
36#include "macro.h"
37#include "missing.h"
38#include "parse-util.h"
39#include "process-util.h"
40#include "string-util.h"
41#include "strv.h"
42#include "util.h"
43
44#define log_debug_bus_message(m)do { sd_bus_message *_mm = (m); ({ int _level = (((7))), _e =
((0)), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm
(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((
_realm) << 10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c"
, 44, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); }); } while (0) \
45 do { \
46 sd_bus_message *_mm = (m); \
47 log_debug("Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%" PRIu64 " reply_cookie=%" PRIu64 " signature=%s error-name=%s error-message=%s", \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
48 bus_message_type_to_string(_mm->header->type), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
49 strna(sd_bus_message_get_sender(_mm)), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
50 strna(sd_bus_message_get_destination(_mm)), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
51 strna(sd_bus_message_get_path(_mm)), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
52 strna(sd_bus_message_get_interface(_mm)), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
53 strna(sd_bus_message_get_member(_mm)), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
54 BUS_MESSAGE_COOKIE(_mm), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
55 _mm->reply_cookie, \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
56 strna(_mm->root_container.signature), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
57 strna(_mm->error.name), \({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); })
58 strna(_mm->error.message))({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 58, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); }); \
59 } while (false0)
60
61static int bus_poll(sd_bus *bus, bool_Bool need_more, uint64_t timeout_usec);
62static void bus_detach_io_events(sd_bus *b);
63static void bus_detach_inotify_event(sd_bus *b);
64
65static thread_local__thread sd_bus *default_system_bus = NULL((void*)0);
66static thread_local__thread sd_bus *default_user_bus = NULL((void*)0);
67static thread_local__thread sd_bus *default_starter_bus = NULL((void*)0);
68
69static sd_bus **bus_choose_default(int (**bus_open)(sd_bus **)) {
70 const char *e;
71
72 /* Let's try our best to reuse another cached connection. If
73 * the starter bus type is set, connect via our normal
74 * connection logic, ignoring $DBUS_STARTER_ADDRESS, so that
75 * we can share the connection with the user/system default
76 * bus. */
77
78 e = secure_getenv("DBUS_STARTER_BUS_TYPE");
79 if (e) {
80 if (streq(e, "system")(strcmp((e),("system")) == 0)) {
81 if (bus_open)
82 *bus_open = sd_bus_open_system;
83 return &default_system_bus;
84 } else if (STR_IN_SET(e, "user", "session")(!!strv_find((((char**) ((const char*[]) { "user", "session",
((void*)0) }))), (e)))) {
85 if (bus_open)
86 *bus_open = sd_bus_open_user;
87 return &default_user_bus;
88 }
89 }
90
91 /* No type is specified, so we have not other option than to
92 * use the starter address if it is set. */
93 e = secure_getenv("DBUS_STARTER_ADDRESS");
94 if (e) {
95 if (bus_open)
96 *bus_open = sd_bus_open;
97 return &default_starter_bus;
98 }
99
100 /* Finally, if nothing is set use the cached connection for
101 * the right scope */
102
103 if (cg_pid_get_owner_uid(0, NULL((void*)0)) >= 0) {
104 if (bus_open)
105 *bus_open = sd_bus_open_user;
106 return &default_user_bus;
107 } else {
108 if (bus_open)
109 *bus_open = sd_bus_open_system;
110 return &default_system_bus;
111 }
112}
113
114sd_bus *bus_resolve(sd_bus *bus) {
115 switch ((uintptr_t) bus) {
116 case (uintptr_t) SD_BUS_DEFAULT((sd_bus *) 1):
117 return *(bus_choose_default(NULL((void*)0)));
118 case (uintptr_t) SD_BUS_DEFAULT_USER((sd_bus *) 2):
119 return default_user_bus;
120 case (uintptr_t) SD_BUS_DEFAULT_SYSTEM((sd_bus *) 3):
121 return default_system_bus;
122 default:
123 return bus;
124 }
125}
126
127void bus_close_io_fds(sd_bus *b) {
128 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 128, __PRETTY_FUNCTION__); } while (0);
129
130 bus_detach_io_events(b);
131
132 if (b->input_fd != b->output_fd)
133 safe_close(b->output_fd);
134 b->output_fd = b->input_fd = safe_close(b->input_fd);
135}
136
137void bus_close_inotify_fd(sd_bus *b) {
138 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 138, __PRETTY_FUNCTION__); } while (0);
139
140 bus_detach_inotify_event(b);
141
142 b->inotify_fd = safe_close(b->inotify_fd);
143 b->inotify_watches = mfree(b->inotify_watches);
144 b->n_inotify_watches = 0;
145}
146
147static void bus_reset_queues(sd_bus *b) {
148 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 148, __PRETTY_FUNCTION__); } while (0);
149
150 while (b->rqueue_size > 0)
151 bus_message_unref_queued(b->rqueue[--b->rqueue_size], b);
152
153 b->rqueue = mfree(b->rqueue);
154 b->rqueue_allocated = 0;
155
156 while (b->wqueue_size > 0)
157 bus_message_unref_queued(b->wqueue[--b->wqueue_size], b);
158
159 b->wqueue = mfree(b->wqueue);
160 b->wqueue_allocated = 0;
161}
162
163static sd_bus* bus_free(sd_bus *b) {
164 sd_bus_slot *s;
165
166 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 166, __PRETTY_FUNCTION__); } while (0);
167 assert(!b->track_queue)do { if ((__builtin_expect(!!(!(!b->track_queue)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("!b->track_queue"), "../src/libsystemd/sd-bus/sd-bus.c"
, 167, __PRETTY_FUNCTION__); } while (0);
168 assert(!b->tracks)do { if ((__builtin_expect(!!(!(!b->tracks)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("!b->tracks"), "../src/libsystemd/sd-bus/sd-bus.c"
, 168, __PRETTY_FUNCTION__); } while (0);
169
170 b->state = BUS_CLOSED;
171
172 sd_bus_detach_event(b);
173
174 while ((s = b->slots)) {
175 /* At this point only floating slots can still be
176 * around, because the non-floating ones keep a
177 * reference to the bus, and we thus couldn't be
178 * destructing right now... We forcibly disconnect the
179 * slots here, so that they still can be referenced by
180 * apps, but are dead. */
181
182 assert(s->floating)do { if ((__builtin_expect(!!(!(s->floating)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("s->floating"), "../src/libsystemd/sd-bus/sd-bus.c"
, 182, __PRETTY_FUNCTION__); } while (0);
183 bus_slot_disconnect(s);
184 sd_bus_slot_unref(s);
185 }
186
187 if (b->default_bus_ptr)
188 *b->default_bus_ptr = NULL((void*)0);
189
190 bus_close_io_fds(b);
191 bus_close_inotify_fd(b);
192
193 free(b->label);
194 free(b->groups);
195 free(b->rbuffer);
196 free(b->unique_name);
197 free(b->auth_buffer);
198 free(b->address);
199 free(b->machine);
200 free(b->cgroup_root);
201 free(b->description);
202 free(b->patch_sender);
203
204 free(b->exec_path);
205 strv_free(b->exec_argv);
206
207 close_many(b->fds, b->n_fds);
208 free(b->fds);
209
210 bus_reset_queues(b);
211
212 ordered_hashmap_free_free(b->reply_callbacks);
213 prioq_free(b->reply_callbacks_prioq);
214
215 assert(b->match_callbacks.type == BUS_MATCH_ROOT)do { if ((__builtin_expect(!!(!(b->match_callbacks.type ==
BUS_MATCH_ROOT)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD
, ("b->match_callbacks.type == BUS_MATCH_ROOT"), "../src/libsystemd/sd-bus/sd-bus.c"
, 215, __PRETTY_FUNCTION__); } while (0);
216 bus_match_free(&b->match_callbacks);
217
218 hashmap_free_free(b->vtable_methods);
219 hashmap_free_free(b->vtable_properties);
220
221 assert(hashmap_isempty(b->nodes))do { if ((__builtin_expect(!!(!(hashmap_isempty(b->nodes))
),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("hashmap_isempty(b->nodes)"
), "../src/libsystemd/sd-bus/sd-bus.c", 221, __PRETTY_FUNCTION__
); } while (0);
222 hashmap_free(b->nodes);
223
224 bus_flush_memfd(b);
225
226 assert_se(pthread_mutex_destroy(&b->memfd_cache_mutex) == 0)do { if ((__builtin_expect(!!(!(pthread_mutex_destroy(&b->
memfd_cache_mutex) == 0)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD
, ("pthread_mutex_destroy(&b->memfd_cache_mutex) == 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 226, __PRETTY_FUNCTION__
); } while (0);
227
228 return mfree(b);
229}
230
231DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus*, bus_free)static inline void bus_freep(sd_bus* *p) { if (*p) bus_free(*
p); };
232
233_public___attribute__ ((visibility("default"))) int sd_bus_new(sd_bus **ret) {
234 _cleanup_free___attribute__((cleanup(freep))) sd_bus *b = NULL((void*)0);
235
236 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 236, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
237
238 b = new0(sd_bus, 1)((sd_bus*) calloc((1), sizeof(sd_bus)));
239 if (!b)
240 return -ENOMEM12;
241
242 b->n_ref = REFCNT_INIT((RefCount) { ._value = 1 });
243 b->input_fd = b->output_fd = -1;
244 b->inotify_fd = -1;
245 b->message_version = 1;
246 b->creds_mask |= SD_BUS_CREDS_WELL_KNOWN_NAMES|SD_BUS_CREDS_UNIQUE_NAME;
247 b->accept_fd = true1;
248 b->original_pid = getpid_cached();
249 b->n_groups = (size_t) -1;
250
251 /* We guarantee that wqueue always has space for at least one entry */
252 if (!GREEDY_REALLOC(b->wqueue, b->wqueue_allocated, 1)greedy_realloc((void**) &(b->wqueue), &(b->wqueue_allocated
), (1), sizeof((b->wqueue)[0])))
253 return -ENOMEM12;
254
255 assert_se(pthread_mutex_init(&b->memfd_cache_mutex, NULL) == 0)do { if ((__builtin_expect(!!(!(pthread_mutex_init(&b->
memfd_cache_mutex, ((void*)0)) == 0)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("pthread_mutex_init(&b->memfd_cache_mutex, NULL) == 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 255, __PRETTY_FUNCTION__
); } while (0);
256
257 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
258 return 0;
259}
260
261_public___attribute__ ((visibility("default"))) int sd_bus_set_address(sd_bus *bus, const char *address) {
262 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 262, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
263 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 263, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
264 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 264, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
265 assert_return(address, -EINVAL)do { if (!(((__builtin_expect(!!(address),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("address"), "../src/libsystemd/sd-bus/sd-bus.c"
, 265, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
266 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 266, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
267
268 return free_and_strdup(&bus->address, address);
269}
270
271_public___attribute__ ((visibility("default"))) int sd_bus_set_fd(sd_bus *bus, int input_fd, int output_fd) {
272 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 272, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
273 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 273, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
274 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 274, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
275 assert_return(input_fd >= 0, -EBADF)do { if (!(((__builtin_expect(!!(input_fd >= 0),1))) ? (1)
: (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("input_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 275, __PRETTY_FUNCTION__
), 0))) return (-9); } while (0);
276 assert_return(output_fd >= 0, -EBADF)do { if (!(((__builtin_expect(!!(output_fd >= 0),1))) ? (1
) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("output_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 276, __PRETTY_FUNCTION__
), 0))) return (-9); } while (0);
277 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 277, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
278
279 bus->input_fd = input_fd;
280 bus->output_fd = output_fd;
281 return 0;
282}
283
284_public___attribute__ ((visibility("default"))) int sd_bus_set_exec(sd_bus *bus, const char *path, char *const argv[]) {
285 _cleanup_strv_free___attribute__((cleanup(strv_freep))) char **a = NULL((void*)0);
286 int r;
287
288 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 288, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
289 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 289, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
290 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 290, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
291 assert_return(path, -EINVAL)do { if (!(((__builtin_expect(!!(path),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("path"), "../src/libsystemd/sd-bus/sd-bus.c"
, 291, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
292 assert_return(!strv_isempty(argv), -EINVAL)do { if (!(((__builtin_expect(!!(!strv_isempty(argv)),1))) ? (
1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!strv_isempty(argv)"
), "../src/libsystemd/sd-bus/sd-bus.c", 292, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
293 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 293, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
294
295 a = strv_copy(argv);
296 if (!a)
297 return -ENOMEM12;
298
299 r = free_and_strdup(&bus->exec_path, path);
300 if (r < 0)
301 return r;
302
303 return strv_free_and_replace(bus->exec_argv, a)({ strv_free(bus->exec_argv); (bus->exec_argv) = (a); (
a) = ((void*)0); 0; });
304}
305
306_public___attribute__ ((visibility("default"))) int sd_bus_set_bus_client(sd_bus *bus, int b) {
307 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 307, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
308 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 308, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
309 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 309, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
310 assert_return(!bus->patch_sender, -EPERM)do { if (!(((__builtin_expect(!!(!bus->patch_sender),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus->patch_sender"
), "../src/libsystemd/sd-bus/sd-bus.c", 310, __PRETTY_FUNCTION__
), 0))) return (-1); } while (0);
311 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 311, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
312
313 bus->bus_client = !!b;
314 return 0;
315}
316
317_public___attribute__ ((visibility("default"))) int sd_bus_set_monitor(sd_bus *bus, int b) {
318 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 318, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
319 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 319, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
320 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 320, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
321 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 321, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
322
323 bus->is_monitor = !!b;
324 return 0;
325}
326
327_public___attribute__ ((visibility("default"))) int sd_bus_negotiate_fds(sd_bus *bus, int b) {
328 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 328, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
329 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 329, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
330 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 330, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
331 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 331, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
332
333 bus->accept_fd = !!b;
334 return 0;
335}
336
337_public___attribute__ ((visibility("default"))) int sd_bus_negotiate_timestamp(sd_bus *bus, int b) {
338 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 338, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
339 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 339, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
340 assert_return(!IN_SET(bus->state, BUS_CLOSING, BUS_CLOSED), -EPERM)do { if (!(((__builtin_expect(!!(!({ _Bool _found = 0; static
__attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_CLOSING, BUS_CLOSED})/sizeof(int)]; switch
(bus->state) { case BUS_CLOSING: case BUS_CLOSED: _found =
1; break; default: break; } _found; })),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("!IN_SET(bus->state, BUS_CLOSING, BUS_CLOSED)"
), "../src/libsystemd/sd-bus/sd-bus.c", 340, __PRETTY_FUNCTION__
), 0))) return (-1); } while (0);
341 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 341, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
342
343 /* This is not actually supported by any of our transports these days, but we do honour it for synthetic
344 * replies, and maybe one day classic D-Bus learns this too */
345 bus->attach_timestamp = !!b;
346
347 return 0;
348}
349
350_public___attribute__ ((visibility("default"))) int sd_bus_negotiate_creds(sd_bus *bus, int b, uint64_t mask) {
351 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 351, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
352 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 352, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
353 assert_return(mask <= _SD_BUS_CREDS_ALL, -EINVAL)do { if (!(((__builtin_expect(!!(mask <= _SD_BUS_CREDS_ALL
),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("mask <= _SD_BUS_CREDS_ALL"), "../src/libsystemd/sd-bus/sd-bus.c"
, 353, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
354 assert_return(!IN_SET(bus->state, BUS_CLOSING, BUS_CLOSED), -EPERM)do { if (!(((__builtin_expect(!!(!({ _Bool _found = 0; static
__attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_CLOSING, BUS_CLOSED})/sizeof(int)]; switch
(bus->state) { case BUS_CLOSING: case BUS_CLOSED: _found =
1; break; default: break; } _found; })),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("!IN_SET(bus->state, BUS_CLOSING, BUS_CLOSED)"
), "../src/libsystemd/sd-bus/sd-bus.c", 354, __PRETTY_FUNCTION__
), 0))) return (-1); } while (0);
355 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 355, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
356
357 SET_FLAG(bus->creds_mask, mask, b)(bus->creds_mask) = (b) ? ((bus->creds_mask) | (mask)) :
((bus->creds_mask) & ~(mask));
358
359 /* The well knowns we need unconditionally, so that matches can work */
360 bus->creds_mask |= SD_BUS_CREDS_WELL_KNOWN_NAMES|SD_BUS_CREDS_UNIQUE_NAME;
361
362 return 0;
363}
364
365_public___attribute__ ((visibility("default"))) int sd_bus_set_server(sd_bus *bus, int b, sd_id128_t server_id) {
366 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 366, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
367 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 367, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
368 assert_return(b || sd_id128_equal(server_id, SD_ID128_NULL), -EINVAL)do { if (!(((__builtin_expect(!!(b || sd_id128_equal(server_id
, ((const sd_id128_t) { .qwords = { 0, 0 }}))),1))) ? (1) : (
log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("b || sd_id128_equal(server_id, SD_ID128_NULL)"
), "../src/libsystemd/sd-bus/sd-bus.c", 368, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
369 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 369, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
370 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 370, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
371
372 bus->is_server = !!b;
373 bus->server_id = server_id;
374 return 0;
375}
376
377_public___attribute__ ((visibility("default"))) int sd_bus_set_anonymous(sd_bus *bus, int b) {
378 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 378, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
379 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 379, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
380 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 380, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
381 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 381, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
382
383 bus->anonymous_auth = !!b;
384 return 0;
385}
386
387_public___attribute__ ((visibility("default"))) int sd_bus_set_trusted(sd_bus *bus, int b) {
388 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 388, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
389 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 389, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
390 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 390, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
391 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 391, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
392
393 bus->trusted = !!b;
394 return 0;
395}
396
397_public___attribute__ ((visibility("default"))) int sd_bus_set_description(sd_bus *bus, const char *description) {
398 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 398, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
399 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 399, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
400 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 400, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
401 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 401, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
402
403 return free_and_strdup(&bus->description, description);
404}
405
406_public___attribute__ ((visibility("default"))) int sd_bus_set_allow_interactive_authorization(sd_bus *bus, int b) {
407 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 407, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
408 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 408, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
409 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 409, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
410
411 bus->allow_interactive_authorization = !!b;
412 return 0;
413}
414
415_public___attribute__ ((visibility("default"))) int sd_bus_get_allow_interactive_authorization(sd_bus *bus) {
416 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 416, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
417 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 417, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
418 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 418, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
419
420 return bus->allow_interactive_authorization;
421}
422
423_public___attribute__ ((visibility("default"))) int sd_bus_set_watch_bind(sd_bus *bus, int b) {
424 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 424, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
425 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 425, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
426 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 426, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
427 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 427, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
428
429 bus->watch_bind = !!b;
430 return 0;
431}
432
433_public___attribute__ ((visibility("default"))) int sd_bus_get_watch_bind(sd_bus *bus) {
434 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 434, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
435 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 435, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
436 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 436, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
437
438 return bus->watch_bind;
439}
440
441_public___attribute__ ((visibility("default"))) int sd_bus_set_connected_signal(sd_bus *bus, int b) {
442 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 442, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
443 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 443, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
444 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 444, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
445 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 445, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
446
447 bus->connected_signal = !!b;
448 return 0;
449}
450
451_public___attribute__ ((visibility("default"))) int sd_bus_get_connected_signal(sd_bus *bus) {
452 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 452, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
453 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 453, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
454 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 454, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
455
456 return bus->connected_signal;
457}
458
459static int synthesize_connected_signal(sd_bus *bus) {
460 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0);
461 int r;
462
463 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 463, __PRETTY_FUNCTION__); } while (0);
464
465 /* If enabled, synthesizes a local "Connected" signal mirroring the local "Disconnected" signal. This is called
466 * whenever we fully established a connection, i.e. after the authorization phase, and after receiving the
467 * Hello() reply. Or in other words, whenver we enter BUS_RUNNING state.
468 *
469 * This is useful so that clients can start doing stuff whenver the connection is fully established in a way
470 * that works independently from whether we connected to a full bus or just a direct connection. */
471
472 if (!bus->connected_signal)
473 return 0;
474
475 r = sd_bus_message_new_signal(
476 bus,
477 &m,
478 "/org/freedesktop/DBus/Local",
479 "org.freedesktop.DBus.Local",
480 "Connected");
481 if (r < 0)
482 return r;
483
484 bus_message_set_sender_local(bus, m);
485
486 r = bus_seal_synthetic_message(bus, m);
487 if (r < 0)
488 return r;
489
490 r = bus_rqueue_make_room(bus);
491 if (r < 0)
492 return r;
493
494 /* Insert at the very front */
495 memmove(bus->rqueue + 1, bus->rqueue, sizeof(sd_bus_message*) * bus->rqueue_size);
496 bus->rqueue[0] = bus_message_ref_queued(m, bus);
497 bus->rqueue_size++;
498
499 return 0;
500}
501
502void bus_set_state(sd_bus *bus, enum bus_state state) {
503
504 static const char * const table[_BUS_STATE_MAX] = {
505 [BUS_UNSET] = "UNSET",
506 [BUS_WATCH_BIND] = "WATCH_BIND",
507 [BUS_OPENING] = "OPENING",
508 [BUS_AUTHENTICATING] = "AUTHENTICATING",
509 [BUS_HELLO] = "HELLO",
510 [BUS_RUNNING] = "RUNNING",
511 [BUS_CLOSING] = "CLOSING",
512 [BUS_CLOSED] = "CLOSED",
513 };
514
515 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 515, __PRETTY_FUNCTION__); } while (0);
516 assert(state < _BUS_STATE_MAX)do { if ((__builtin_expect(!!(!(state < _BUS_STATE_MAX)),0
))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("state < _BUS_STATE_MAX"
), "../src/libsystemd/sd-bus/sd-bus.c", 516, __PRETTY_FUNCTION__
); } while (0);
517
518 if (state == bus->state)
519 return;
520
521 log_debug("Bus %s: changing state %s → %s", strna(bus->description), table[bus->state], table[state])({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 521, __func__, "Bus %s: changing state %s → %s"
, strna(bus->description), table[bus->state], table[state
]) : -abs(_e); });
522 bus->state = state;
523}
524
525static int hello_callback(sd_bus_message *reply, void *userdata, sd_bus_error *error) {
526 const char *s;
527 sd_bus *bus;
528 int r;
529
530 assert(reply)do { if ((__builtin_expect(!!(!(reply)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("reply"), "../src/libsystemd/sd-bus/sd-bus.c"
, 530, __PRETTY_FUNCTION__); } while (0);
531 bus = reply->bus;
532 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 532, __PRETTY_FUNCTION__); } while (0);
533 assert(IN_SET(bus->state, BUS_HELLO, BUS_CLOSING))do { if ((__builtin_expect(!!(!(({ _Bool _found = 0; static __attribute__
((unused)) char _static_assert__macros_need_to_be_extended[20
- sizeof((int[]){BUS_HELLO, BUS_CLOSING})/sizeof(int)]; switch
(bus->state) { case BUS_HELLO: case BUS_CLOSING: _found = 1
; break; default: break; } _found; }))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("IN_SET(bus->state, BUS_HELLO, BUS_CLOSING)"
), "../src/libsystemd/sd-bus/sd-bus.c", 533, __PRETTY_FUNCTION__
); } while (0);
534
535 r = sd_bus_message_get_errno(reply);
536 if (r > 0)
537 return -r;
538
539 r = sd_bus_message_read(reply, "s", &s);
540 if (r < 0)
541 return r;
542
543 if (!service_name_is_valid(s) || s[0] != ':')
544 return -EBADMSG74;
545
546 r = free_and_strdup(&bus->unique_name, s);
547 if (r < 0)
548 return r;
549
550 if (bus->state == BUS_HELLO) {
551 bus_set_state(bus, BUS_RUNNING);
552
553 r = synthesize_connected_signal(bus);
554 if (r < 0)
555 return r;
556 }
557
558 return 1;
559}
560
561static int bus_send_hello(sd_bus *bus) {
562 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0);
563 int r;
564
565 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 565, __PRETTY_FUNCTION__); } while (0);
566
567 if (!bus->bus_client)
568 return 0;
569
570 r = sd_bus_message_new_method_call(
571 bus,
572 &m,
573 "org.freedesktop.DBus",
574 "/org/freedesktop/DBus",
575 "org.freedesktop.DBus",
576 "Hello");
577 if (r < 0)
578 return r;
579
580 return sd_bus_call_async(bus, NULL((void*)0), m, hello_callback, NULL((void*)0), 0);
581}
582
583int bus_start_running(sd_bus *bus) {
584 struct reply_callback *c;
585 Iterator i;
586 usec_t n;
587 int r;
588
589 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 589, __PRETTY_FUNCTION__); } while (0);
590 assert(bus->state < BUS_HELLO)do { if ((__builtin_expect(!!(!(bus->state < BUS_HELLO)
),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->state < BUS_HELLO"
), "../src/libsystemd/sd-bus/sd-bus.c", 590, __PRETTY_FUNCTION__
); } while (0);
591
592 /* We start all method call timeouts when we enter BUS_HELLO or BUS_RUNNING mode. At this point let's convert
593 * all relative to absolute timestamps. Note that we do not reshuffle the reply callback priority queue since
594 * adding a fixed value to all entries should not alter the internal order. */
595
596 n = now(CLOCK_MONOTONIC1);
597 ORDERED_HASHMAP_FOREACH(c, bus->reply_callbacks, i)for ((i) = ((Iterator) { .idx = ((2147483647 *2U +1U) - 1), .
next_key = ((void*)0) }); ordered_hashmap_iterate((bus->reply_callbacks
), &(i), (void**)&(c), ((void*)0)); ) {
598 if (c->timeout_usec == 0)
599 continue;
600
601 c->timeout_usec = usec_add(n, c->timeout_usec);
602 }
603
604 if (bus->bus_client) {
605 bus_set_state(bus, BUS_HELLO);
606 return 1;
607 }
608
609 bus_set_state(bus, BUS_RUNNING);
610
611 r = synthesize_connected_signal(bus);
612 if (r < 0)
613 return r;
614
615 return 1;
616}
617
618static int parse_address_key(const char **p, const char *key, char **value) {
619 size_t l, n = 0, allocated = 0;
620 _cleanup_free___attribute__((cleanup(freep))) char *r = NULL((void*)0);
621 const char *a;
622
623 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 623, __PRETTY_FUNCTION__); } while (0);
19
←
Taking false branch
→
20
←
Loop condition is false. Exiting loop
→
624 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 624, __PRETTY_FUNCTION__); } while (0);
21
←
Taking false branch
→
22
←
Loop condition is false. Exiting loop
→
625 assert(value)do { if ((__builtin_expect(!!(!(value)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("value"), "../src/libsystemd/sd-bus/sd-bus.c"
, 625, __PRETTY_FUNCTION__); } while (0);
23
←
Taking false branch
→
24
←
Loop condition is false. Exiting loop
→
626
627 if (key
24.1
'key' is non-null
) {
25
←
Taking true branch
→
628 l = strlen(key);
629 if (strncmp(*p, key, l) != 0)
26
←
Taking false branch
→
630 return 0;
631
632 if ((*p)[l] != '=')
27
←
Assuming the condition is false
→
28
←
Taking false branch
→
633 return 0;
634
635 if (*value)
29
←
Taking false branch
→
636 return -EINVAL22;
637
638 a = *p + l + 1;
639 } else
640 a = *p;
641
642 while (!IN_SET(*a, ';', ',', 0)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){';', ',', 0})/sizeof(int)]; switch(*a) {
case ';': case ',': case 0: _found = 1; break; default: break
; } _found; })) {
30
←
Control jumps to 'case 44:' at line 642
→
31
←
 Execution continues on line 642
→
32
←
Loop condition is false. Execution continues on line 669
→
643 char c;
644
645 if (*a == '%') {
646 int x, y;
647
648 x = unhexchar(a[1]);
649 if (x < 0)
650 return x;
651
652 y = unhexchar(a[2]);
653 if (y < 0)
654 return y;
655
656 c = (char) ((x << 4) | y);
657 a += 3;
658 } else {
659 c = *a;
660 a++;
661 }
662
663 if (!GREEDY_REALLOC(r, allocated, n + 2)greedy_realloc((void**) &(r), &(allocated), (n + 2), sizeof
((r)[0])))
664 return -ENOMEM12;
665
666 r[n++] = c;
667 }
668
669 if (!r
32.1
'r' is null
) {
33
←
Taking true branch
→
670 r = strdup("");
34
←
Memory is allocated
→
671 if (!r)
35
←
Assuming 'r' is non-null
→
36
←
Taking false branch
→
672 return -ENOMEM12;
673 } else
674 r[n] = 0;
675
676 if (*a == ',')
37
←
Taking true branch
→
677 a++;
678
679 *p = a;
680
681 free_and_replace(*value, r)({ free(*value); (*value) = (r); (r) = ((void*)0); 0; });
682
683 return 1;
684}
685
686static void skip_address_key(const char **p) {
687 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 687, __PRETTY_FUNCTION__); } while (0);
688 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 688, __PRETTY_FUNCTION__); } while (0);
689
690 *p += strcspn(*p, ",");
691
692 if (**p == ',')
693 (*p)++;
694}
695
696static int parse_unix_address(sd_bus *b, const char **p, char **guid) {
697 _cleanup_free___attribute__((cleanup(freep))) char *path = NULL((void*)0), *abstract = NULL((void*)0);
698 size_t l;
699 int r;
700
701 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 701, __PRETTY_FUNCTION__); } while (0);
702 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 702, __PRETTY_FUNCTION__); } while (0);
703 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 703, __PRETTY_FUNCTION__); } while (0);
704 assert(guid)do { if ((__builtin_expect(!!(!(guid)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("guid"), "../src/libsystemd/sd-bus/sd-bus.c"
, 704, __PRETTY_FUNCTION__); } while (0);
705
706 while (!IN_SET(**p, 0, ';')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){0, ';'})/sizeof(int)]; switch(**p) { case
0: case ';': _found = 1; break; default: break; } _found; })) {
707 r = parse_address_key(p, "guid", guid);
708 if (r < 0)
709 return r;
710 else if (r > 0)
711 continue;
712
713 r = parse_address_key(p, "path", &path);
714 if (r < 0)
715 return r;
716 else if (r > 0)
717 continue;
718
719 r = parse_address_key(p, "abstract", &abstract);
720 if (r < 0)
721 return r;
722 else if (r > 0)
723 continue;
724
725 skip_address_key(p);
726 }
727
728 if (!path && !abstract)
729 return -EINVAL22;
730
731 if (path && abstract)
732 return -EINVAL22;
733
734 if (path) {
735 l = strlen(path);
736 if (l > sizeof(b->sockaddr.un.sun_path))
737 return -E2BIG7;
738
739 b->sockaddr.un.sun_family = AF_UNIX1;
740 strncpy(b->sockaddr.un.sun_path, path, sizeof(b->sockaddr.un.sun_path));
741 b->sockaddr_size = offsetof(struct sockaddr_un, sun_path)__builtin_offsetof(struct sockaddr_un, sun_path) + l;
742 } else if (abstract) {
743 l = strlen(abstract);
744 if (l > sizeof(b->sockaddr.un.sun_path) - 1)
745 return -E2BIG7;
746
747 b->sockaddr.un.sun_family = AF_UNIX1;
748 b->sockaddr.un.sun_path[0] = 0;
749 strncpy(b->sockaddr.un.sun_path+1, abstract, sizeof(b->sockaddr.un.sun_path)-1);
750 b->sockaddr_size = offsetof(struct sockaddr_un, sun_path)__builtin_offsetof(struct sockaddr_un, sun_path) + 1 + l;
751 }
752
753 b->is_local = true1;
754
755 return 0;
756}
757
758static int parse_tcp_address(sd_bus *b, const char **p, char **guid) {
759 _cleanup_free___attribute__((cleanup(freep))) char *host = NULL((void*)0), *port = NULL((void*)0), *family = NULL((void*)0);
760 int r;
761 struct addrinfo *result, hints = {
762 .ai_socktype = SOCK_STREAMSOCK_STREAM,
763 .ai_flags = AI_ADDRCONFIG0x0020,
764 };
765
766 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 766, __PRETTY_FUNCTION__); } while (0);
767 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 767, __PRETTY_FUNCTION__); } while (0);
768 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 768, __PRETTY_FUNCTION__); } while (0);
769 assert(guid)do { if ((__builtin_expect(!!(!(guid)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("guid"), "../src/libsystemd/sd-bus/sd-bus.c"
, 769, __PRETTY_FUNCTION__); } while (0);
770
771 while (!IN_SET(**p, 0, ';')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){0, ';'})/sizeof(int)]; switch(**p) { case
0: case ';': _found = 1; break; default: break; } _found; })) {
772 r = parse_address_key(p, "guid", guid);
773 if (r < 0)
774 return r;
775 else if (r > 0)
776 continue;
777
778 r = parse_address_key(p, "host", &host);
779 if (r < 0)
780 return r;
781 else if (r > 0)
782 continue;
783
784 r = parse_address_key(p, "port", &port);
785 if (r < 0)
786 return r;
787 else if (r > 0)
788 continue;
789
790 r = parse_address_key(p, "family", &family);
791 if (r < 0)
792 return r;
793 else if (r > 0)
794 continue;
795
796 skip_address_key(p);
797 }
798
799 if (!host || !port)
800 return -EINVAL22;
801
802 if (family) {
803 if (streq(family, "ipv4")(strcmp((family),("ipv4")) == 0))
804 hints.ai_family = AF_INET2;
805 else if (streq(family, "ipv6")(strcmp((family),("ipv6")) == 0))
806 hints.ai_family = AF_INET610;
807 else
808 return -EINVAL22;
809 }
810
811 r = getaddrinfo(host, port, &hints, &result);
812 if (r == EAI_SYSTEM-11)
813 return -errno(*__errno_location ());
814 else if (r != 0)
815 return -EADDRNOTAVAIL99;
816
817 memcpy(&b->sockaddr, result->ai_addr, result->ai_addrlen);
818 b->sockaddr_size = result->ai_addrlen;
819
820 freeaddrinfo(result);
821
822 b->is_local = false0;
823
824 return 0;
825}
826
827static int parse_exec_address(sd_bus *b, const char **p, char **guid) {
828 char *path = NULL((void*)0);
829 unsigned n_argv = 0, j;
830 char **argv = NULL((void*)0);
831 size_t allocated = 0;
832 int r;
833
834 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 834, __PRETTY_FUNCTION__); } while (0);
835 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 835, __PRETTY_FUNCTION__); } while (0);
836 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 836, __PRETTY_FUNCTION__); } while (0);
837 assert(guid)do { if ((__builtin_expect(!!(!(guid)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("guid"), "../src/libsystemd/sd-bus/sd-bus.c"
, 837, __PRETTY_FUNCTION__); } while (0);
838
839 while (!IN_SET(**p, 0, ';')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){0, ';'})/sizeof(int)]; switch(**p) { case
0: case ';': _found = 1; break; default: break; } _found; })) {
840 r = parse_address_key(p, "guid", guid);
841 if (r < 0)
842 goto fail;
843 else if (r > 0)
844 continue;
845
846 r = parse_address_key(p, "path", &path);
847 if (r < 0)
848 goto fail;
849 else if (r > 0)
850 continue;
851
852 if (startswith(*p, "argv")) {
853 unsigned ul;
854
855 errno(*__errno_location ()) = 0;
856 ul = strtoul(*p + 4, (char**) p, 10);
857 if (errno(*__errno_location ()) > 0 || **p != '=' || ul > 256) {
858 r = -EINVAL22;
859 goto fail;
860 }
861
862 (*p)++;
863
864 if (ul >= n_argv) {
865 if (!GREEDY_REALLOC0(argv, allocated, ul + 2)greedy_realloc0((void**) &(argv), &(allocated), (ul +
2), sizeof((argv)[0]))) {
866 r = -ENOMEM12;
867 goto fail;
868 }
869
870 n_argv = ul + 1;
871 }
872
873 r = parse_address_key(p, NULL((void*)0), argv + ul);
874 if (r < 0)
875 goto fail;
876
877 continue;
878 }
879
880 skip_address_key(p);
881 }
882
883 if (!path) {
884 r = -EINVAL22;
885 goto fail;
886 }
887
888 /* Make sure there are no holes in the array, with the
889 * exception of argv[0] */
890 for (j = 1; j < n_argv; j++)
891 if (!argv[j]) {
892 r = -EINVAL22;
893 goto fail;
894 }
895
896 if (argv && argv[0] == NULL((void*)0)) {
897 argv[0] = strdup(path);
898 if (!argv[0]) {
899 r = -ENOMEM12;
900 goto fail;
901 }
902 }
903
904 b->exec_path = path;
905 b->exec_argv = argv;
906
907 b->is_local = false0;
908
909 return 0;
910
911fail:
912 for (j = 0; j < n_argv; j++)
913 free(argv[j]);
914
915 free(argv);
916 free(path);
917 return r;
918}
919
920static int parse_container_unix_address(sd_bus *b, const char **p, char **guid) {
921 _cleanup_free___attribute__((cleanup(freep))) char *machine = NULL((void*)0), *pid = NULL((void*)0);
922 int r;
923
924 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 924, __PRETTY_FUNCTION__); } while (0);
1
Assuming 'b' is non-null
→
2
←
Taking false branch
→
3
←
Loop condition is false. Exiting loop
→
925 assert(p)do { if ((__builtin_expect(!!(!(p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 925, __PRETTY_FUNCTION__); } while (0);
4
←
Assuming 'p' is non-null
→
5
←
Taking false branch
→
6
←
Loop condition is false. Exiting loop
→
926 assert(*p)do { if ((__builtin_expect(!!(!(*p)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("*p"), "../src/libsystemd/sd-bus/sd-bus.c"
, 926, __PRETTY_FUNCTION__); } while (0);
7
←
Assuming the condition is false
→
8
←
Taking false branch
→
9
←
Loop condition is false. Exiting loop
→
927 assert(guid)do { if ((__builtin_expect(!!(!(guid)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("guid"), "../src/libsystemd/sd-bus/sd-bus.c"
, 927, __PRETTY_FUNCTION__); } while (0);
10
←
Assuming 'guid' is non-null
→
11
←
Taking false branch
→
12
←
Loop condition is false. Exiting loop
→
928
929 while (!IN_SET(**p, 0, ';')({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){0, ';'})/sizeof(int)]; switch(**p) { case
0: case ';': _found = 1; break; default: break; } _found; })) {
13
←
Control jumps to the 'default' case at line 929
→
14
←
 Execution continues on line 929
→
15
←
Loop condition is true. Entering loop body
→
42
←
Control jumps to the 'default' case at line 929
→
43
←
 Execution continues on line 929
→
44
←
Loop condition is true. Entering loop body
→
930 r = parse_address_key(p, "guid", guid);
931 if (r
15.1
'r' is >= 0
 < 0)
16
←
Taking false branch
→
45
←
Assuming 'r' is < 0
→
46
←
Taking true branch
→
932 return r;
47
←
Potential leak of memory pointed to by 'machine'
933 else if (r
16.1
'r' is <= 0
 > 0)
17
←
Taking false branch
→
934 continue;
935
936 r = parse_address_key(p, "machine", &machine);
18
←
Calling 'parse_address_key'
→
38
←
Returned allocated memory via 3rd parameter
→
937 if (r
38.1
'r' is >= 0
 < 0)
39
←
Taking false branch
→
938 return r;
939 else if (r
39.1
'r' is > 0
 > 0)
40
←
Taking true branch
→
940 continue;
41
←
 Execution continues on line 929
→
941
942 r = parse_address_key(p, "pid", &pid);
943 if (r < 0)
944 return r;
945 else if (r > 0)
946 continue;
947
948 skip_address_key(p);
949 }
950
951 if (!machine == !pid)
952 return -EINVAL22;
953
954 if (machine) {
955 if (!streq(machine, ".host")(strcmp((machine),(".host")) == 0) && !machine_name_is_valid(machine)hostname_is_valid(machine, 0))
956 return -EINVAL22;
957
958 free_and_replace(b->machine, machine)({ free(b->machine); (b->machine) = (machine); (machine
) = ((void*)0); 0; });
959 } else {
960 b->machine = mfree(b->machine);
961 }
962
963 if (pid) {
964 r = parse_pid(pid, &b->nspid);
965 if (r < 0)
966 return r;
967 } else
968 b->nspid = 0;
969
970 b->sockaddr.un.sun_family = AF_UNIX1;
971 /* Note that we use the old /var/run prefix here, to increase compatibility with really old containers */
972 strncpy(b->sockaddr.un.sun_path, "/var/run/dbus/system_bus_socket", sizeof(b->sockaddr.un.sun_path));
973 b->sockaddr_size = SOCKADDR_UN_LEN(b->sockaddr.un)({ const struct sockaddr_un *_sa = &(b->sockaddr.un); do
{ if ((__builtin_expect(!!(!(_sa->sun_family == 1)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_sa->sun_family == AF_UNIX"), "../src/libsystemd/sd-bus/sd-bus.c"
, 973, __PRETTY_FUNCTION__); } while (0); __builtin_offsetof(
struct sockaddr_un, sun_path) + (_sa->sun_path[0] == 0 ? 1
+ strnlen(_sa->sun_path+1, sizeof(_sa->sun_path)-1) : strnlen
(_sa->sun_path, sizeof(_sa->sun_path))); });
974 b->is_local = false0;
975
976 return 0;
977}
978
979static void bus_reset_parsed_address(sd_bus *b) {
980 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 980, __PRETTY_FUNCTION__); } while (0);
981
982 zero(b->sockaddr)(({ size_t _l_ = (sizeof(b->sockaddr)); void *_x_ = (&
(b->sockaddr)); _l_ == 0 ? _x_ : memset(_x_, 0, _l_); }));
983 b->sockaddr_size = 0;
984 b->exec_argv = strv_free(b->exec_argv);
985 b->exec_path = mfree(b->exec_path);
986 b->server_id = SD_ID128_NULL((const sd_id128_t) { .qwords = { 0, 0 }});
987 b->machine = mfree(b->machine);
988 b->nspid = 0;
989}
990
991static int bus_parse_next_address(sd_bus *b) {
992 _cleanup_free___attribute__((cleanup(freep))) char *guid = NULL((void*)0);
993 const char *a;
994 int r;
995
996 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 996, __PRETTY_FUNCTION__); } while (0);
997
998 if (!b->address)
999 return 0;
1000 if (b->address[b->address_index] == 0)
1001 return 0;
1002
1003 bus_reset_parsed_address(b);
1004
1005 a = b->address + b->address_index;
1006
1007 while (*a != 0) {
1008
1009 if (*a == ';') {
1010 a++;
1011 continue;
1012 }
1013
1014 if (startswith(a, "unix:")) {
1015 a += 5;
1016
1017 r = parse_unix_address(b, &a, &guid);
1018 if (r < 0)
1019 return r;
1020 break;
1021
1022 } else if (startswith(a, "tcp:")) {
1023
1024 a += 4;
1025 r = parse_tcp_address(b, &a, &guid);
1026 if (r < 0)
1027 return r;
1028
1029 break;
1030
1031 } else if (startswith(a, "unixexec:")) {
1032
1033 a += 9;
1034 r = parse_exec_address(b, &a, &guid);
1035 if (r < 0)
1036 return r;
1037
1038 break;
1039
1040 } else if (startswith(a, "x-machine-unix:")) {
1041
1042 a += 15;
1043 r = parse_container_unix_address(b, &a, &guid);
1044 if (r < 0)
1045 return r;
1046
1047 break;
1048 }
1049
1050 a = strchr(a, ';');
1051 if (!a)
1052 return 0;
1053 }
1054
1055 if (guid) {
1056 r = sd_id128_from_string(guid, &b->server_id);
1057 if (r < 0)
1058 return r;
1059 }
1060
1061 b->address_index = a - b->address;
1062 return 1;
1063}
1064
1065static void bus_kill_exec(sd_bus *bus) {
1066 if (pid_is_valid(bus->busexec_pid) > 0) {
1067 sigterm_wait(bus->busexec_pid);
1068 bus->busexec_pid = 0;
1069 }
1070}
1071
1072static int bus_start_address(sd_bus *b) {
1073 int r;
1074
1075 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1075, __PRETTY_FUNCTION__); } while (0);
1076
1077 for (;;) {
1078 bus_close_io_fds(b);
1079 bus_close_inotify_fd(b);
1080
1081 bus_kill_exec(b);
1082
1083 /* If you provide multiple different bus-addresses, we
1084 * try all of them in order and use the first one that
1085 * succeeds. */
1086
1087 if (b->exec_path)
1088 r = bus_socket_exec(b);
1089 else if ((b->nspid > 0 || b->machine) && b->sockaddr.sa.sa_family != AF_UNSPEC0)
1090 r = bus_container_connect_socket(b);
1091 else if (b->sockaddr.sa.sa_family != AF_UNSPEC0)
1092 r = bus_socket_connect(b);
1093 else
1094 goto next;
1095
1096 if (r >= 0) {
1097 int q;
1098
1099 q = bus_attach_io_events(b);
1100 if (q < 0)
1101 return q;
1102
1103 q = bus_attach_inotify_event(b);
1104 if (q < 0)
1105 return q;
1106
1107 return r;
1108 }
1109
1110 b->last_connect_error = -r;
1111
1112 next:
1113 r = bus_parse_next_address(b);
1114 if (r < 0)
1115 return r;
1116 if (r == 0)
1117 return b->last_connect_error > 0 ? -b->last_connect_error : -ECONNREFUSED111;
1118 }
1119}
1120
1121int bus_next_address(sd_bus *b) {
1122 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1122, __PRETTY_FUNCTION__); } while (0);
1123
1124 bus_reset_parsed_address(b);
1125 return bus_start_address(b);
1126}
1127
1128static int bus_start_fd(sd_bus *b) {
1129 struct stat st;
1130 int r;
1131
1132 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1132, __PRETTY_FUNCTION__); } while (0);
1133 assert(b->input_fd >= 0)do { if ((__builtin_expect(!!(!(b->input_fd >= 0)),0)))
log_assert_failed_realm(LOG_REALM_SYSTEMD, ("b->input_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 1133, __PRETTY_FUNCTION__
); } while (0);
1134 assert(b->output_fd >= 0)do { if ((__builtin_expect(!!(!(b->output_fd >= 0)),0))
) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("b->output_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 1134, __PRETTY_FUNCTION__
); } while (0);
1135
1136 r = fd_nonblock(b->input_fd, true1);
1137 if (r < 0)
1138 return r;
1139
1140 r = fd_cloexec(b->input_fd, true1);
1141 if (r < 0)
1142 return r;
1143
1144 if (b->input_fd != b->output_fd) {
1145 r = fd_nonblock(b->output_fd, true1);
1146 if (r < 0)
1147 return r;
1148
1149 r = fd_cloexec(b->output_fd, true1);
1150 if (r < 0)
1151 return r;
1152 }
1153
1154 if (fstat(b->input_fd, &st) < 0)
1155 return -errno(*__errno_location ());
1156
1157 return bus_socket_take_fd(b);
1158}
1159
1160_public___attribute__ ((visibility("default"))) int sd_bus_start(sd_bus *bus) {
1161 int r;
1162
1163 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1163, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1164 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1164, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
1165 assert_return(bus->state == BUS_UNSET, -EPERM)do { if (!(((__builtin_expect(!!(bus->state == BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state == BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1165, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
1166 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1166, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1167
1168 bus_set_state(bus, BUS_OPENING);
1169
1170 if (bus->is_server && bus->bus_client)
1171 return -EINVAL22;
1172
1173 if (bus->input_fd >= 0)
1174 r = bus_start_fd(bus);
1175 else if (bus->address || bus->sockaddr.sa.sa_family != AF_UNSPEC0 || bus->exec_path || bus->machine)
1176 r = bus_start_address(bus);
1177 else
1178 return -EINVAL22;
1179
1180 if (r < 0) {
1181 sd_bus_close(bus);
1182 return r;
1183 }
1184
1185 return bus_send_hello(bus);
1186}
1187
1188_public___attribute__ ((visibility("default"))) int sd_bus_open_with_description(sd_bus **ret, const char *description) {
1189 const char *e;
1190 _cleanup_(bus_freep)__attribute__((cleanup(bus_freep))) sd_bus *b = NULL((void*)0);
1191 int r;
1192
1193 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1193, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1194
1195 /* Let's connect to the starter bus if it is set, and
1196 * otherwise to the bus that is appropropriate for the scope
1197 * we are running in */
1198
1199 e = secure_getenv("DBUS_STARTER_BUS_TYPE");
1200 if (e) {
1201 if (streq(e, "system")(strcmp((e),("system")) == 0))
1202 return sd_bus_open_system_with_description(ret, description);
1203 else if (STR_IN_SET(e, "session", "user")(!!strv_find((((char**) ((const char*[]) { "session", "user",
((void*)0) }))), (e))))
1204 return sd_bus_open_user_with_description(ret, description);
1205 }
1206
1207 e = secure_getenv("DBUS_STARTER_ADDRESS");
1208 if (!e) {
1209 if (cg_pid_get_owner_uid(0, NULL((void*)0)) >= 0)
1210 return sd_bus_open_user_with_description(ret, description);
1211 else
1212 return sd_bus_open_system_with_description(ret, description);
1213 }
1214
1215 r = sd_bus_new(&b);
1216 if (r < 0)
1217 return r;
1218
1219 r = sd_bus_set_address(b, e);
1220 if (r < 0)
1221 return r;
1222
1223 b->bus_client = true1;
1224
1225 /* We don't know whether the bus is trusted or not, so better
1226 * be safe, and authenticate everything */
1227 b->trusted = false0;
1228 b->is_local = false0;
1229 b->creds_mask |= SD_BUS_CREDS_UID | SD_BUS_CREDS_EUID | SD_BUS_CREDS_EFFECTIVE_CAPS;
1230
1231 r = sd_bus_start(b);
1232 if (r < 0)
1233 return r;
1234
1235 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
1236 return 0;
1237}
1238
1239_public___attribute__ ((visibility("default"))) int sd_bus_open(sd_bus **ret) {
1240 return sd_bus_open_with_description(ret, NULL((void*)0));
1241}
1242
1243int bus_set_address_system(sd_bus *b) {
1244 const char *e;
1245 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1245, __PRETTY_FUNCTION__); } while (0);
1246
1247 e = secure_getenv("DBUS_SYSTEM_BUS_ADDRESS");
1248 if (e)
1249 return sd_bus_set_address(b, e);
1250
1251 return sd_bus_set_address(b, DEFAULT_SYSTEM_BUS_ADDRESS"unix:path=/run/dbus/system_bus_socket");
1252}
1253
1254_public___attribute__ ((visibility("default"))) int sd_bus_open_system_with_description(sd_bus **ret, const char *description) {
1255 _cleanup_(bus_freep)__attribute__((cleanup(bus_freep))) sd_bus *b = NULL((void*)0);
1256 int r;
1257
1258 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1258, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1259
1260 r = sd_bus_new(&b);
1261 if (r < 0)
1262 return r;
1263
1264 if (description) {
1265 r = sd_bus_set_description(b, description);
1266 if (r < 0)
1267 return r;
1268 }
1269
1270 r = bus_set_address_system(b);
1271 if (r < 0)
1272 return r;
1273
1274 b->bus_client = true1;
1275 b->is_system = true1;
1276
1277 /* Let's do per-method access control on the system bus. We
1278 * need the caller's UID and capability set for that. */
1279 b->trusted = false0;
1280 b->creds_mask |= SD_BUS_CREDS_UID | SD_BUS_CREDS_EUID | SD_BUS_CREDS_EFFECTIVE_CAPS;
1281 b->is_local = true1;
1282
1283 r = sd_bus_start(b);
1284 if (r < 0)
1285 return r;
1286
1287 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
1288 return 0;
1289}
1290
1291_public___attribute__ ((visibility("default"))) int sd_bus_open_system(sd_bus **ret) {
1292 return sd_bus_open_system_with_description(ret, NULL((void*)0));
1293}
1294
1295int bus_set_address_user(sd_bus *b) {
1296 const char *e;
1297 _cleanup_free___attribute__((cleanup(freep))) char *ee = NULL((void*)0), *s = NULL((void*)0);
1298
1299 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1299, __PRETTY_FUNCTION__); } while (0);
1300
1301 e = secure_getenv("DBUS_SESSION_BUS_ADDRESS");
1302 if (e)
1303 return sd_bus_set_address(b, e);
1304
1305 e = secure_getenv("XDG_RUNTIME_DIR");
1306 if (!e)
1307 return -ENOENT2;
1308
1309 ee = bus_address_escape(e);
1310 if (!ee)
1311 return -ENOMEM12;
1312
1313 if (asprintf(&s, DEFAULT_USER_BUS_ADDRESS_FMT"unix:path=%s/bus", ee) < 0)
1314 return -ENOMEM12;
1315
1316 b->address = TAKE_PTR(s)({ typeof(s) _ptr_ = (s); (s) = ((void*)0); _ptr_; });
1317
1318 return 0;
1319}
1320
1321_public___attribute__ ((visibility("default"))) int sd_bus_open_user_with_description(sd_bus **ret, const char *description) {
1322 _cleanup_(bus_freep)__attribute__((cleanup(bus_freep))) sd_bus *b = NULL((void*)0);
1323 int r;
1324
1325 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1325, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1326
1327 r = sd_bus_new(&b);
1328 if (r < 0)
1329 return r;
1330
1331 if (description) {
1332 r = sd_bus_set_description(b, description);
1333 if (r < 0)
1334 return r;
1335 }
1336
1337 r = bus_set_address_user(b);
1338 if (r < 0)
1339 return r;
1340
1341 b->bus_client = true1;
1342 b->is_user = true1;
1343
1344 /* We don't do any per-method access control on the user bus. */
1345 b->trusted = true1;
1346 b->is_local = true1;
1347
1348 r = sd_bus_start(b);
1349 if (r < 0)
1350 return r;
1351
1352 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
1353 return 0;
1354}
1355
1356_public___attribute__ ((visibility("default"))) int sd_bus_open_user(sd_bus **ret) {
1357 return sd_bus_open_user_with_description(ret, NULL((void*)0));
1358}
1359
1360int bus_set_address_system_remote(sd_bus *b, const char *host) {
1361 _cleanup_free___attribute__((cleanup(freep))) char *e = NULL((void*)0);
1362 char *m = NULL((void*)0), *c = NULL((void*)0), *a;
1363
1364 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1364, __PRETTY_FUNCTION__); } while (0);
1365 assert(host)do { if ((__builtin_expect(!!(!(host)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("host"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1365, __PRETTY_FUNCTION__); } while (0);
1366
1367 /* Let's see if we shall enter some container */
1368 m = strchr(host, ':');
1369 if (m) {
1370 m++;
1371
1372 /* Let's make sure this is not a port of some kind,
1373 * and is a valid machine name. */
1374 if (!in_charset(m, DIGITS"0123456789") && machine_name_is_valid(m)hostname_is_valid(m, 0)) {
1375 char *t;
1376
1377 /* Cut out the host part */
1378 t = strndupa(host, m - host - 1)(__extension__ ({ const char *__old = (host); size_t __len = strnlen
(__old, (m - host - 1)); char *__new = (char *) __builtin_alloca
(__len + 1); __new[__len] = '\0'; (char *) memcpy (__new, __old
, __len); }));
1379 e = bus_address_escape(t);
1380 if (!e)
1381 return -ENOMEM12;
1382
1383 c = strjoina(",argv5=--machine=", m)({ const char *_appendees_[] = { ",argv5=--machine=", m }; char
*_d_, *_p_; size_t _len_ = 0; size_t _i_; for (_i_ = 0; _i_ <
__extension__ (__builtin_choose_expr( !__builtin_types_compatible_p
(typeof(_appendees_), typeof(&*(_appendees_))), sizeof(_appendees_
)/sizeof((_appendees_)[0]), ((void)0))) && _appendees_
[_i_]; _i_++) _len_ += strlen(_appendees_[_i_]); _p_ = _d_ = __builtin_alloca
(_len_ + 1); for (_i_ = 0; _i_ < __extension__ (__builtin_choose_expr
( !__builtin_types_compatible_p(typeof(_appendees_), typeof(&
*(_appendees_))), sizeof(_appendees_)/sizeof((_appendees_)[0]
), ((void)0))) && _appendees_[_i_]; _i_++) _p_ = stpcpy
(_p_, _appendees_[_i_]); *_p_ = 0; _d_; });
1384 }
1385 }
1386
1387 if (!e) {
1388 e = bus_address_escape(host);
1389 if (!e)
1390 return -ENOMEM12;
1391 }
1392
1393 a = strjoin("unixexec:path=ssh,argv1=-xT,argv2=--,argv3=", e, ",argv4=systemd-stdio-bridge", c)strjoin_real(("unixexec:path=ssh,argv1=-xT,argv2=--,argv3="),
e, ",argv4=systemd-stdio-bridge", c, ((void*)0));
1394 if (!a)
1395 return -ENOMEM12;
1396
1397 return free_and_replace(b->address, a)({ free(b->address); (b->address) = (a); (a) = ((void*)
0); 0; });
1398}
1399
1400_public___attribute__ ((visibility("default"))) int sd_bus_open_system_remote(sd_bus **ret, const char *host) {
1401 _cleanup_(bus_freep)__attribute__((cleanup(bus_freep))) sd_bus *b = NULL((void*)0);
1402 int r;
1403
1404 assert_return(host, -EINVAL)do { if (!(((__builtin_expect(!!(host),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("host"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1404, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1405 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1405, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1406
1407 r = sd_bus_new(&b);
1408 if (r < 0)
1409 return r;
1410
1411 r = bus_set_address_system_remote(b, host);
1412 if (r < 0)
1413 return r;
1414
1415 b->bus_client = true1;
1416 b->trusted = false0;
1417 b->is_system = true1;
1418 b->is_local = false0;
1419
1420 r = sd_bus_start(b);
1421 if (r < 0)
1422 return r;
1423
1424 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
1425 return 0;
1426}
1427
1428int bus_set_address_system_machine(sd_bus *b, const char *machine) {
1429 _cleanup_free___attribute__((cleanup(freep))) char *e = NULL((void*)0);
1430 char *a;
1431
1432 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1432, __PRETTY_FUNCTION__); } while (0);
1433 assert(machine)do { if ((__builtin_expect(!!(!(machine)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("machine"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1433, __PRETTY_FUNCTION__); } while (0);
1434
1435 e = bus_address_escape(machine);
1436 if (!e)
1437 return -ENOMEM12;
1438
1439 a = strjoin("x-machine-unix:machine=", e)strjoin_real(("x-machine-unix:machine="), e, ((void*)0));
1440 if (!a)
1441 return -ENOMEM12;
1442
1443 return free_and_replace(b->address, a)({ free(b->address); (b->address) = (a); (a) = ((void*)
0); 0; });
1444}
1445
1446_public___attribute__ ((visibility("default"))) int sd_bus_open_system_machine(sd_bus **ret, const char *machine) {
1447 _cleanup_(bus_freep)__attribute__((cleanup(bus_freep))) sd_bus *b = NULL((void*)0);
1448 int r;
1449
1450 assert_return(machine, -EINVAL)do { if (!(((__builtin_expect(!!(machine),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("machine"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1450, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1451 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1451, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1452 assert_return(streq(machine, ".host") || machine_name_is_valid(machine), -EINVAL)do { if (!(((__builtin_expect(!!((strcmp((machine),(".host"))
== 0) || hostname_is_valid(machine, 0)),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("streq(machine, \".host\") || machine_name_is_valid(machine)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1452, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
1453
1454 r = sd_bus_new(&b);
1455 if (r < 0)
1456 return r;
1457
1458 r = bus_set_address_system_machine(b, machine);
1459 if (r < 0)
1460 return r;
1461
1462 b->bus_client = true1;
1463 b->trusted = false0;
1464 b->is_system = true1;
1465 b->is_local = false0;
1466
1467 r = sd_bus_start(b);
1468 if (r < 0)
1469 return r;
1470
1471 *ret = TAKE_PTR(b)({ typeof(b) _ptr_ = (b); (b) = ((void*)0); _ptr_; });
1472 return 0;
1473}
1474
1475_public___attribute__ ((visibility("default"))) void sd_bus_close(sd_bus *bus) {
1476 if (!bus)
1477 return;
1478 if (bus->state == BUS_CLOSED)
1479 return;
1480 if (bus_pid_changed(bus))
1481 return;
1482
1483 /* Don't leave ssh hanging around */
1484 bus_kill_exec(bus);
1485
1486 bus_set_state(bus, BUS_CLOSED);
1487
1488 sd_bus_detach_event(bus);
1489
1490 /* Drop all queued messages so that they drop references to
1491 * the bus object and the bus may be freed */
1492 bus_reset_queues(bus);
1493
1494 bus_close_io_fds(bus);
1495 bus_close_inotify_fd(bus);
1496}
1497
1498_public___attribute__ ((visibility("default"))) sd_bus* sd_bus_flush_close_unref(sd_bus *bus) {
1499 if (!bus)
1500 return NULL((void*)0);
1501
1502 /* Have to do this before flush() to prevent hang */
1503 bus_kill_exec(bus);
1504
1505 sd_bus_flush(bus);
1506 sd_bus_close(bus);
1507
1508 return sd_bus_unref(bus);
1509}
1510
1511void bus_enter_closing(sd_bus *bus) {
1512 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1512, __PRETTY_FUNCTION__); } while (0);
1513
1514 if (!IN_SET(bus->state, BUS_WATCH_BIND, BUS_OPENING, BUS_AUTHENTICATING, BUS_HELLO, BUS_RUNNING)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_WATCH_BIND, BUS_OPENING, BUS_AUTHENTICATING
, BUS_HELLO, BUS_RUNNING})/sizeof(int)]; switch(bus->state
) { case BUS_WATCH_BIND: case BUS_OPENING: case BUS_AUTHENTICATING
: case BUS_HELLO: case BUS_RUNNING: _found = 1; break; default
: break; } _found; }))
1515 return;
1516
1517 bus_set_state(bus, BUS_CLOSING);
1518}
1519
1520_public___attribute__ ((visibility("default"))) sd_bus *sd_bus_ref(sd_bus *bus) {
1521 if (!bus)
1522 return NULL((void*)0);
1523
1524 assert_se(REFCNT_INC(bus->n_ref) >= 2)do { if ((__builtin_expect(!!(!((__sync_add_and_fetch(&(bus
->n_ref)._value, 1)) >= 2)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("REFCNT_INC(bus->n_ref) >= 2"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1524, __PRETTY_FUNCTION__); } while (0);
1525
1526 return bus;
1527}
1528
1529_public___attribute__ ((visibility("default"))) sd_bus *sd_bus_unref(sd_bus *bus) {
1530 unsigned i;
1531
1532 if (!bus)
1533 return NULL((void*)0);
1534
1535 i = REFCNT_DEC(bus->n_ref)(__sync_sub_and_fetch(&(bus->n_ref)._value, 1));
1536 if (i > 0)
1537 return NULL((void*)0);
1538
1539 return bus_free(bus);
1540}
1541
1542_public___attribute__ ((visibility("default"))) int sd_bus_is_open(sd_bus *bus) {
1543 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1543, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1544 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1544, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
1545 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1545, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1546
1547 return BUS_IS_OPEN(bus->state);
1548}
1549
1550_public___attribute__ ((visibility("default"))) int sd_bus_is_ready(sd_bus *bus) {
1551 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1551, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1552 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1552, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
1553 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1553, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1554
1555 return bus->state == BUS_RUNNING;
1556}
1557
1558_public___attribute__ ((visibility("default"))) int sd_bus_can_send(sd_bus *bus, char type) {
1559 int r;
1560
1561 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1561, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1562 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1562, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
1563 assert_return(bus->state != BUS_UNSET, -ENOTCONN)do { if (!(((__builtin_expect(!!(bus->state != BUS_UNSET),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->state != BUS_UNSET"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1563, __PRETTY_FUNCTION__), 0))) return (-107); } while (0);
1564 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1564, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1565
1566 if (bus->is_monitor)
1567 return 0;
1568
1569 if (type == SD_BUS_TYPE_UNIX_FD) {
1570 if (!bus->accept_fd)
1571 return 0;
1572
1573 r = bus_ensure_running(bus);
1574 if (r < 0)
1575 return r;
1576
1577 return bus->can_fds;
1578 }
1579
1580 return bus_type_is_valid(type);
1581}
1582
1583_public___attribute__ ((visibility("default"))) int sd_bus_get_bus_id(sd_bus *bus, sd_id128_t *id) {
1584 int r;
1585
1586 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1586, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1587 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1587, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
1588 assert_return(id, -EINVAL)do { if (!(((__builtin_expect(!!(id),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("id"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1588, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1589 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1589, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1590
1591 r = bus_ensure_running(bus);
1592 if (r < 0)
1593 return r;
1594
1595 *id = bus->server_id;
1596 return 0;
1597}
1598
1599#define COOKIE_CYCLED(1U << 31) (UINT32_C(1)1U << 31)
1600
1601static uint64_t cookie_inc(uint64_t cookie) {
1602
1603 /* Stay within the 32bit range, since classic D-Bus can't deal with more */
1604 if (cookie >= UINT32_MAX(4294967295U))
1605 return COOKIE_CYCLED(1U << 31); /* Don't go back to zero, but use the highest bit for checking
1606 * whether we are looping. */
1607
1608 return cookie + 1;
1609}
1610
1611static int next_cookie(sd_bus *b) {
1612 uint64_t new_cookie;
1613
1614 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1614, __PRETTY_FUNCTION__); } while (0);
1615
1616 new_cookie = cookie_inc(b->cookie);
1617
1618 /* Small optimization: don't bother with checking for cookie reuse until we overran cookiespace at
1619 * least once, but then do it thorougly. */
1620 if (FLAGS_SET(new_cookie, COOKIE_CYCLED)(((new_cookie) & ((1U << 31))) == ((1U << 31)
))) {
1621 uint32_t i;
1622
1623 /* Check if the cookie is currently in use. If so, pick the next one */
1624 for (i = 0; i < COOKIE_CYCLED(1U << 31); i++) {
1625 if (!ordered_hashmap_contains(b->reply_callbacks, &new_cookie))
1626 goto good;
1627
1628 new_cookie = cookie_inc(new_cookie);
1629 }
1630
1631 /* Can't fulfill request */
1632 return -EBUSY16;
1633 }
1634
1635good:
1636 b->cookie = new_cookie;
1637 return 0;
1638}
1639
1640static int bus_seal_message(sd_bus *b, sd_bus_message *m, usec_t timeout) {
1641 int r;
1642
1643 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1643, __PRETTY_FUNCTION__); } while (0);
1644 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1644, __PRETTY_FUNCTION__); } while (0);
1645
1646 if (m->sealed) {
1647 /* If we copy the same message to multiple
1648 * destinations, avoid using the same cookie
1649 * numbers. */
1650 b->cookie = MAX(b->cookie, BUS_MESSAGE_COOKIE(m))__extension__ ({ const typeof((b->cookie)) __unique_prefix_A28
= ((b->cookie)); const typeof((BUS_MESSAGE_COOKIE(m))) __unique_prefix_B29
= ((BUS_MESSAGE_COOKIE(m))); __unique_prefix_A28 > __unique_prefix_B29
? __unique_prefix_A28 : __unique_prefix_B29; });
1651 return 0;
1652 }
1653
1654 if (timeout == 0)
1655 timeout = BUS_DEFAULT_TIMEOUT((usec_t) (25 * ((usec_t) 1000000ULL)));
1656
1657 if (!m->sender && b->patch_sender) {
1658 r = sd_bus_message_set_sender(m, b->patch_sender);
1659 if (r < 0)
1660 return r;
1661 }
1662
1663 r = next_cookie(b);
1664 if (r < 0)
1665 return r;
1666
1667 return sd_bus_message_seal(m, b->cookie, timeout);
1668}
1669
1670static int bus_remarshal_message(sd_bus *b, sd_bus_message **m) {
1671 bool_Bool remarshal = false0;
1672
1673 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1673, __PRETTY_FUNCTION__); } while (0);
1674
1675 /* wrong packet version */
1676 if (b->message_version != 0 && b->message_version != (*m)->header->version)
1677 remarshal = true1;
1678
1679 /* wrong packet endianness */
1680 if (b->message_endian != 0 && b->message_endian != (*m)->header->endian)
1681 remarshal = true1;
1682
1683 return remarshal ? bus_message_remarshal(b, m) : 0;
1684}
1685
1686int bus_seal_synthetic_message(sd_bus *b, sd_bus_message *m) {
1687 assert(b)do { if ((__builtin_expect(!!(!(b)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1687, __PRETTY_FUNCTION__); } while (0);
1688 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1688, __PRETTY_FUNCTION__); } while (0);
1689
1690 /* Fake some timestamps, if they were requested, and not
1691 * already initialized */
1692 if (b->attach_timestamp) {
1693 if (m->realtime <= 0)
1694 m->realtime = now(CLOCK_REALTIME0);
1695
1696 if (m->monotonic <= 0)
1697 m->monotonic = now(CLOCK_MONOTONIC1);
1698 }
1699
1700 /* The bus specification says the serial number cannot be 0,
1701 * hence let's fill something in for synthetic messages. Since
1702 * synthetic messages might have a fake sender and we don't
1703 * want to interfere with the real sender's serial numbers we
1704 * pick a fixed, artificial one. We use (uint32_t) -1 rather
1705 * than (uint64_t) -1 since dbus1 only had 32bit identifiers,
1706 * even though kdbus can do 64bit. */
1707 return sd_bus_message_seal(m, 0xFFFFFFFFULL, 0);
1708}
1709
1710static int bus_write_message(sd_bus *bus, sd_bus_message *m, size_t *idx) {
1711 int r;
1712
1713 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1713, __PRETTY_FUNCTION__); } while (0);
1714 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1714, __PRETTY_FUNCTION__); } while (0);
1715
1716 r = bus_socket_write_message(bus, m, idx);
1717 if (r <= 0)
1718 return r;
1719
1720 if (*idx >= BUS_MESSAGE_SIZE(m))
1721 log_debug("Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%" PRIu64 " reply_cookie=%" PRIu64 " signature=%s error-name=%s error-message=%s",({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1722 bus_message_type_to_string(m->header->type),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1723 strna(sd_bus_message_get_sender(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1724 strna(sd_bus_message_get_destination(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1725 strna(sd_bus_message_get_path(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1726 strna(sd_bus_message_get_interface(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1727 strna(sd_bus_message_get_member(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1728 BUS_MESSAGE_COOKIE(m),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1729 m->reply_cookie,({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1730 strna(m->root_container.signature),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1731 strna(m->error.name),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); })
1732 strna(m->error.message))({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 1732, __func__, "Sent message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(m->header->type), strna(sd_bus_message_get_sender
(m)), strna(sd_bus_message_get_destination(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m)), BUS_MESSAGE_COOKIE(m), m->reply_cookie, strna(m->
root_container.signature), strna(m->error.name), strna(m->
error.message)) : -abs(_e); });
1733
1734 return r;
1735}
1736
1737static int dispatch_wqueue(sd_bus *bus) {
1738 int r, ret = 0;
1739
1740 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1740, __PRETTY_FUNCTION__); } while (0);
1741 assert(IN_SET(bus->state, BUS_RUNNING, BUS_HELLO))do { if ((__builtin_expect(!!(!(({ _Bool _found = 0; static __attribute__
((unused)) char _static_assert__macros_need_to_be_extended[20
- sizeof((int[]){BUS_RUNNING, BUS_HELLO})/sizeof(int)]; switch
(bus->state) { case BUS_RUNNING: case BUS_HELLO: _found = 1
; break; default: break; } _found; }))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("IN_SET(bus->state, BUS_RUNNING, BUS_HELLO)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1741, __PRETTY_FUNCTION__
); } while (0);
1742
1743 while (bus->wqueue_size > 0) {
1744
1745 r = bus_write_message(bus, bus->wqueue[0], &bus->windex);
1746 if (r < 0)
1747 return r;
1748 else if (r == 0)
1749 /* Didn't do anything this time */
1750 return ret;
1751 else if (bus->windex >= BUS_MESSAGE_SIZE(bus->wqueue[0])) {
1752 /* Fully written. Let's drop the entry from
1753 * the queue.
1754 *
1755 * This isn't particularly optimized, but
1756 * well, this is supposed to be our worst-case
1757 * buffer only, and the socket buffer is
1758 * supposed to be our primary buffer, and if
1759 * it got full, then all bets are off
1760 * anyway. */
1761
1762 bus->wqueue_size--;
1763 bus_message_unref_queued(bus->wqueue[0], bus);
1764 memmove(bus->wqueue, bus->wqueue + 1, sizeof(sd_bus_message*) * bus->wqueue_size);
1765 bus->windex = 0;
1766
1767 ret = 1;
1768 }
1769 }
1770
1771 return ret;
1772}
1773
1774static int bus_read_message(sd_bus *bus, bool_Bool hint_priority, int64_t priority) {
1775 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1775, __PRETTY_FUNCTION__); } while (0);
1776
1777 return bus_socket_read_message(bus);
1778}
1779
1780int bus_rqueue_make_room(sd_bus *bus) {
1781 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1781, __PRETTY_FUNCTION__); } while (0);
1782
1783 if (bus->rqueue_size >= BUS_RQUEUE_MAX(384*1024))
1784 return -ENOBUFS105;
1785
1786 if (!GREEDY_REALLOC(bus->rqueue, bus->rqueue_allocated, bus->rqueue_size + 1)greedy_realloc((void**) &(bus->rqueue), &(bus->
rqueue_allocated), (bus->rqueue_size + 1), sizeof((bus->
rqueue)[0])))
1787 return -ENOMEM12;
1788
1789 return 0;
1790}
1791
1792static void rqueue_drop_one(sd_bus *bus, size_t i) {
1793 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1793, __PRETTY_FUNCTION__); } while (0);
1794 assert(i < bus->rqueue_size)do { if ((__builtin_expect(!!(!(i < bus->rqueue_size)),
0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("i < bus->rqueue_size"
), "../src/libsystemd/sd-bus/sd-bus.c", 1794, __PRETTY_FUNCTION__
); } while (0);
1795
1796 bus_message_unref_queued(bus->rqueue[i], bus);
1797 memmove(bus->rqueue + i, bus->rqueue + i + 1, sizeof(sd_bus_message*) * (bus->rqueue_size - i - 1));
1798 bus->rqueue_size--;
1799}
1800
1801static int dispatch_rqueue(sd_bus *bus, bool_Bool hint_priority, int64_t priority, sd_bus_message **m) {
1802 int r, ret = 0;
1803
1804 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1804, __PRETTY_FUNCTION__); } while (0);
1805 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1805, __PRETTY_FUNCTION__); } while (0);
1806 assert(IN_SET(bus->state, BUS_RUNNING, BUS_HELLO))do { if ((__builtin_expect(!!(!(({ _Bool _found = 0; static __attribute__
((unused)) char _static_assert__macros_need_to_be_extended[20
- sizeof((int[]){BUS_RUNNING, BUS_HELLO})/sizeof(int)]; switch
(bus->state) { case BUS_RUNNING: case BUS_HELLO: _found = 1
; break; default: break; } _found; }))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("IN_SET(bus->state, BUS_RUNNING, BUS_HELLO)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1806, __PRETTY_FUNCTION__
); } while (0);
1807
1808 /* Note that the priority logic is only available on kdbus,
1809 * where the rqueue is unused. We check the rqueue here
1810 * anyway, because it's simple... */
1811
1812 for (;;) {
1813 if (bus->rqueue_size > 0) {
1814 /* Dispatch a queued message */
1815 *m = sd_bus_message_ref(bus->rqueue[0]);
1816 rqueue_drop_one(bus, 0);
1817 return 1;
1818 }
1819
1820 /* Try to read a new message */
1821 r = bus_read_message(bus, hint_priority, priority);
1822 if (r < 0)
1823 return r;
1824 if (r == 0) {
1825 *m = NULL((void*)0);
1826 return ret;
1827 }
1828
1829 ret = 1;
1830 }
1831}
1832
1833_public___attribute__ ((visibility("default"))) int sd_bus_send(sd_bus *bus, sd_bus_message *_m, uint64_t *cookie) {
1834 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = sd_bus_message_ref(_m);
1835 int r;
1836
1837 assert_return(m, -EINVAL)do { if (!(((__builtin_expect(!!(m),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1837, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1838
1839 if (!bus)
1840 bus = m->bus;
1841
1842 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1842, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1843
1844 if (!BUS_IS_OPEN(bus->state))
1845 return -ENOTCONN107;
1846
1847 if (m->n_fds > 0) {
1848 r = sd_bus_can_send(bus, SD_BUS_TYPE_UNIX_FD);
1849 if (r < 0)
1850 return r;
1851 if (r == 0)
1852 return -EOPNOTSUPP95;
1853 }
1854
1855 /* If the cookie number isn't kept, then we know that no reply
1856 * is expected */
1857 if (!cookie && !m->sealed)
1858 m->header->flags |= BUS_MESSAGE_NO_REPLY_EXPECTED;
1859
1860 r = bus_seal_message(bus, m, 0);
1861 if (r < 0)
1862 return r;
1863
1864 /* Remarshall if we have to. This will possibly unref the
1865 * message and place a replacement in m */
1866 r = bus_remarshal_message(bus, &m);
1867 if (r < 0)
1868 return r;
1869
1870 /* If this is a reply and no reply was requested, then let's
1871 * suppress this, if we can */
1872 if (m->dont_send)
1873 goto finish;
1874
1875 if (IN_SET(bus->state, BUS_RUNNING, BUS_HELLO)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_RUNNING, BUS_HELLO})/sizeof(int)]; switch
(bus->state) { case BUS_RUNNING: case BUS_HELLO: _found = 1
; break; default: break; } _found; }) && bus->wqueue_size <= 0) {
1876 size_t idx = 0;
1877
1878 r = bus_write_message(bus, m, &idx);
1879 if (r < 0) {
1880 if (IN_SET(r, -ENOTCONN, -ECONNRESET, -EPIPE, -ESHUTDOWN)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){-107, -104, -32, -108})/sizeof(int)]; switch
(r) { case -107: case -104: case -32: case -108: _found = 1; break
; default: break; } _found; })) {
1881 bus_enter_closing(bus);
1882 return -ECONNRESET104;
1883 }
1884
1885 return r;
1886 }
1887
1888 if (idx < BUS_MESSAGE_SIZE(m)) {
1889 /* Wasn't fully written. So let's remember how
1890 * much was written. Note that the first entry
1891 * of the wqueue array is always allocated so
1892 * that we always can remember how much was
1893 * written. */
1894 bus->wqueue[0] = bus_message_ref_queued(m, bus);
1895 bus->wqueue_size = 1;
1896 bus->windex = idx;
1897 }
1898
1899 } else {
1900 /* Just append it to the queue. */
1901
1902 if (bus->wqueue_size >= BUS_WQUEUE_MAX(384*1024))
1903 return -ENOBUFS105;
1904
1905 if (!GREEDY_REALLOC(bus->wqueue, bus->wqueue_allocated, bus->wqueue_size + 1)greedy_realloc((void**) &(bus->wqueue), &(bus->
wqueue_allocated), (bus->wqueue_size + 1), sizeof((bus->
wqueue)[0])))
1906 return -ENOMEM12;
1907
1908 bus->wqueue[bus->wqueue_size++] = bus_message_ref_queued(m, bus);
1909 }
1910
1911finish:
1912 if (cookie)
1913 *cookie = BUS_MESSAGE_COOKIE(m);
1914
1915 return 1;
1916}
1917
1918_public___attribute__ ((visibility("default"))) int sd_bus_send_to(sd_bus *bus, sd_bus_message *m, const char *destination, uint64_t *cookie) {
1919 int r;
1920
1921 assert_return(m, -EINVAL)do { if (!(((__builtin_expect(!!(m),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1921, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1922
1923 if (!bus)
1924 bus = m->bus;
1925
1926 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1926, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1927
1928 if (!BUS_IS_OPEN(bus->state))
1929 return -ENOTCONN107;
1930
1931 if (!streq_ptr(m->destination, destination)) {
1932
1933 if (!destination)
1934 return -EEXIST17;
1935
1936 r = sd_bus_message_set_destination(m, destination);
1937 if (r < 0)
1938 return r;
1939 }
1940
1941 return sd_bus_send(bus, m, cookie);
1942}
1943
1944static usec_t calc_elapse(sd_bus *bus, uint64_t usec) {
1945 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1945, __PRETTY_FUNCTION__); } while (0);
1946
1947 if (usec == (uint64_t) -1)
1948 return 0;
1949
1950 /* We start all timeouts the instant we enter BUS_HELLO/BUS_RUNNING state, so that the don't run in parallel
1951 * with any connection setup states. Hence, if a method callback is started earlier than that we just store the
1952 * relative timestamp, and afterwards the absolute one. */
1953
1954 if (IN_SET(bus->state, BUS_WATCH_BIND, BUS_OPENING, BUS_AUTHENTICATING)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_WATCH_BIND, BUS_OPENING, BUS_AUTHENTICATING
})/sizeof(int)]; switch(bus->state) { case BUS_WATCH_BIND:
case BUS_OPENING: case BUS_AUTHENTICATING: _found = 1; break
; default: break; } _found; }))
1955 return usec;
1956 else
1957 return now(CLOCK_MONOTONIC1) + usec;
1958}
1959
1960static int timeout_compare(const void *a, const void *b) {
1961 const struct reply_callback *x = a, *y = b;
1962
1963 if (x->timeout_usec != 0 && y->timeout_usec == 0)
1964 return -1;
1965
1966 if (x->timeout_usec == 0 && y->timeout_usec != 0)
1967 return 1;
1968
1969 if (x->timeout_usec < y->timeout_usec)
1970 return -1;
1971
1972 if (x->timeout_usec > y->timeout_usec)
1973 return 1;
1974
1975 return 0;
1976}
1977
1978_public___attribute__ ((visibility("default"))) int sd_bus_call_async(
1979 sd_bus *bus,
1980 sd_bus_slot **slot,
1981 sd_bus_message *_m,
1982 sd_bus_message_handler_t callback,
1983 void *userdata,
1984 uint64_t usec) {
1985
1986 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = sd_bus_message_ref(_m);
1987 _cleanup_(sd_bus_slot_unrefp)__attribute__((cleanup(sd_bus_slot_unrefp))) sd_bus_slot *s = NULL((void*)0);
1988 int r;
1989
1990 assert_return(m, -EINVAL)do { if (!(((__builtin_expect(!!(m),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1990, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1991 assert_return(m->header->type == SD_BUS_MESSAGE_METHOD_CALL, -EINVAL)do { if (!(((__builtin_expect(!!(m->header->type == SD_BUS_MESSAGE_METHOD_CALL
),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("m->header->type == SD_BUS_MESSAGE_METHOD_CALL"), "../src/libsystemd/sd-bus/sd-bus.c"
, 1991, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
1992 assert_return(!m->sealed || (!!callback == !(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED)), -EINVAL)do { if (!(((__builtin_expect(!!(!m->sealed || (!!callback
== !(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED
))),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("!m->sealed || (!!callback == !(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED))"
), "../src/libsystemd/sd-bus/sd-bus.c", 1992, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
1993
1994 if (!bus)
1995 bus = m->bus;
1996
1997 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 1997, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
1998
1999 if (!BUS_IS_OPEN(bus->state))
2000 return -ENOTCONN107;
2001
2002 /* If no callback is specified and there's no interest in a slot, then there's no reason to ask for a reply */
2003 if (!callback && !slot && !m->sealed)
2004 m->header->flags |= BUS_MESSAGE_NO_REPLY_EXPECTED;
2005
2006 r = ordered_hashmap_ensure_allocated(&bus->reply_callbacks, &uint64_hash_ops)internal_ordered_hashmap_ensure_allocated(&bus->reply_callbacks
, &uint64_hash_ops );
2007 if (r < 0)
2008 return r;
2009
2010 r = prioq_ensure_allocated(&bus->reply_callbacks_prioq, timeout_compare);
2011 if (r < 0)
2012 return r;
2013
2014 r = bus_seal_message(bus, m, usec);
2015 if (r < 0)
2016 return r;
2017
2018 r = bus_remarshal_message(bus, &m);
2019 if (r < 0)
2020 return r;
2021
2022 if (slot || callback) {
2023 s = bus_slot_allocate(bus, !slot, BUS_REPLY_CALLBACK, sizeof(struct reply_callback), userdata);
2024 if (!s)
2025 return -ENOMEM12;
2026
2027 s->reply_callback.callback = callback;
2028
2029 s->reply_callback.cookie = BUS_MESSAGE_COOKIE(m);
2030 r = ordered_hashmap_put(bus->reply_callbacks, &s->reply_callback.cookie, &s->reply_callback);
2031 if (r < 0) {
2032 s->reply_callback.cookie = 0;
2033 return r;
2034 }
2035
2036 s->reply_callback.timeout_usec = calc_elapse(bus, m->timeout);
2037 if (s->reply_callback.timeout_usec != 0) {
2038 r = prioq_put(bus->reply_callbacks_prioq, &s->reply_callback, &s->reply_callback.prioq_idx);
2039 if (r < 0) {
2040 s->reply_callback.timeout_usec = 0;
2041 return r;
2042 }
2043 }
2044 }
2045
2046 r = sd_bus_send(bus, m, s ? &s->reply_callback.cookie : NULL((void*)0));
2047 if (r < 0)
2048 return r;
2049
2050 if (slot)
2051 *slot = s;
2052 s = NULL((void*)0);
2053
2054 return r;
2055}
2056
2057int bus_ensure_running(sd_bus *bus) {
2058 int r;
2059
2060 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2060, __PRETTY_FUNCTION__); } while (0);
2061
2062 if (bus->state == BUS_RUNNING)
2063 return 1;
2064
2065 for (;;) {
2066 if (IN_SET(bus->state, BUS_UNSET, BUS_CLOSED, BUS_CLOSING)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){BUS_UNSET, BUS_CLOSED, BUS_CLOSING})/sizeof
(int)]; switch(bus->state) { case BUS_UNSET: case BUS_CLOSED
: case BUS_CLOSING: _found = 1; break; default: break; } _found
; }))
2067 return -ENOTCONN107;
2068
2069 r = sd_bus_process(bus, NULL((void*)0));
2070 if (r < 0)
2071 return r;
2072 if (bus->state == BUS_RUNNING)
2073 return 1;
2074 if (r > 0)
2075 continue;
2076
2077 r = sd_bus_wait(bus, (uint64_t) -1);
2078 if (r < 0)
2079 return r;
2080 }
2081}
2082
2083_public___attribute__ ((visibility("default"))) int sd_bus_call(
2084 sd_bus *bus,
2085 sd_bus_message *_m,
2086 uint64_t usec,
2087 sd_bus_error *error,
2088 sd_bus_message **reply) {
2089
2090 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = sd_bus_message_ref(_m);
2091 usec_t timeout;
2092 uint64_t cookie;
2093 size_t i;
2094 int r;
2095
2096 bus_assert_return(m, -EINVAL, error)do { if (!(((__builtin_expect(!!(m),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2096, __PRETTY_FUNCTION__), 0))) return sd_bus_error_set_errno
(error, -22); } while (0);
2097 bus_assert_return(m->header->type == SD_BUS_MESSAGE_METHOD_CALL, -EINVAL, error)do { if (!(((__builtin_expect(!!(m->header->type == SD_BUS_MESSAGE_METHOD_CALL
),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("m->header->type == SD_BUS_MESSAGE_METHOD_CALL"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2097, __PRETTY_FUNCTION__), 0))) return sd_bus_error_set_errno
(error, -22); } while (0);
2098 bus_assert_return(!(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED), -EINVAL, error)do { if (!(((__builtin_expect(!!(!(m->header->flags &
BUS_MESSAGE_NO_REPLY_EXPECTED)),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("!(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2098, __PRETTY_FUNCTION__
), 0))) return sd_bus_error_set_errno(error, -22); } while (0
);
2099 bus_assert_return(!bus_error_is_dirty(error), -EINVAL, error)do { if (!(((__builtin_expect(!!(!bus_error_is_dirty(error)),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("!bus_error_is_dirty(error)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2099, __PRETTY_FUNCTION__), 0))) return sd_bus_error_set_errno
(error, -22); } while (0);
2100
2101 if (!bus)
2102 bus = m->bus;
2103
2104 bus_assert_return(!bus_pid_changed(bus), -ECHILD, error)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2104, __PRETTY_FUNCTION__
), 0))) return sd_bus_error_set_errno(error, -10); } while (0
);
2105
2106 if (!BUS_IS_OPEN(bus->state)) {
2107 r = -ENOTCONN107;
2108 goto fail;
2109 }
2110
2111 r = bus_ensure_running(bus);
2112 if (r < 0)
2113 goto fail;
2114
2115 i = bus->rqueue_size;
2116
2117 r = bus_seal_message(bus, m, usec);
2118 if (r < 0)
2119 goto fail;
2120
2121 r = bus_remarshal_message(bus, &m);
2122 if (r < 0)
2123 goto fail;
2124
2125 r = sd_bus_send(bus, m, &cookie);
2126 if (r < 0)
2127 goto fail;
2128
2129 timeout = calc_elapse(bus, m->timeout);
2130
2131 for (;;) {
2132 usec_t left;
2133
2134 while (i < bus->rqueue_size) {
2135 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *incoming = NULL((void*)0);
2136
2137 incoming = sd_bus_message_ref(bus->rqueue[i]);
2138
2139 if (incoming->reply_cookie == cookie) {
2140 /* Found a match! */
2141
2142 rqueue_drop_one(bus, i);
2143 log_debug_bus_message(incoming)do { sd_bus_message *_mm = (incoming); ({ int _level = (((7))
), _e = ((0)), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm
(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((
_realm) << 10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c"
, 2143, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); }); } while (0);
2144
2145 if (incoming->header->type == SD_BUS_MESSAGE_METHOD_RETURN) {
2146
2147 if (incoming->n_fds <= 0 || bus->accept_fd) {
2148 if (reply)
2149 *reply = TAKE_PTR(incoming)({ typeof(incoming) _ptr_ = (incoming); (incoming) = ((void*)
0); _ptr_; });
2150
2151 return 1;
2152 }
2153
2154 return sd_bus_error_setf(error, SD_BUS_ERROR_INCONSISTENT_MESSAGE"org.freedesktop.DBus.Error.InconsistentMessage", "Reply message contained file descriptors which I couldn't accept. Sorry.");
2155
2156 } else if (incoming->header->type == SD_BUS_MESSAGE_METHOD_ERROR)
2157 return sd_bus_error_copy(error, &incoming->error);
2158 else {
2159 r = -EIO5;
2160 goto fail;
2161 }
2162
2163 } else if (BUS_MESSAGE_COOKIE(incoming) == cookie &&
2164 bus->unique_name &&
2165 incoming->sender &&
2166 streq(bus->unique_name, incoming->sender)(strcmp((bus->unique_name),(incoming->sender)) == 0)) {
2167
2168 rqueue_drop_one(bus, i);
2169
2170 /* Our own message? Somebody is trying to send its own client a message,
2171 * let's not dead-lock, let's fail immediately. */
2172
2173 r = -ELOOP40;
2174 goto fail;
2175 }
2176
2177 /* Try to read more, right-away */
2178 i++;
2179 }
2180
2181 r = bus_read_message(bus, false0, 0);
2182 if (r < 0) {
2183 if (IN_SET(r, -ENOTCONN, -ECONNRESET, -EPIPE, -ESHUTDOWN)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){-107, -104, -32, -108})/sizeof(int)]; switch
(r) { case -107: case -104: case -32: case -108: _found = 1; break
; default: break; } _found; })) {
2184 bus_enter_closing(bus);
2185 r = -ECONNRESET104;
2186 }
2187
2188 goto fail;
2189 }
2190 if (r > 0)
2191 continue;
2192
2193 if (timeout > 0) {
2194 usec_t n;
2195
2196 n = now(CLOCK_MONOTONIC1);
2197 if (n >= timeout) {
2198 r = -ETIMEDOUT110;
2199 goto fail;
2200 }
2201
2202 left = timeout - n;
2203 } else
2204 left = (uint64_t) -1;
2205
2206 r = bus_poll(bus, true1, left);
2207 if (r < 0)
2208 goto fail;
2209 if (r == 0) {
2210 r = -ETIMEDOUT110;
2211 goto fail;
2212 }
2213
2214 r = dispatch_wqueue(bus);
2215 if (r < 0) {
2216 if (IN_SET(r, -ENOTCONN, -ECONNRESET, -EPIPE, -ESHUTDOWN)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){-107, -104, -32, -108})/sizeof(int)]; switch
(r) { case -107: case -104: case -32: case -108: _found = 1; break
; default: break; } _found; })) {
2217 bus_enter_closing(bus);
2218 r = -ECONNRESET104;
2219 }
2220
2221 goto fail;
2222 }
2223 }
2224
2225fail:
2226 return sd_bus_error_set_errno(error, r);
2227}
2228
2229_public___attribute__ ((visibility("default"))) int sd_bus_get_fd(sd_bus *bus) {
2230
2231 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2231, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
2232 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2232, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
2233 assert_return(bus->input_fd == bus->output_fd, -EPERM)do { if (!(((__builtin_expect(!!(bus->input_fd == bus->
output_fd),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("bus->input_fd == bus->output_fd"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2233, __PRETTY_FUNCTION__), 0))) return (-1); } while (0);
2234 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2234, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
2235
2236 if (bus->state == BUS_CLOSED)
2237 return -ENOTCONN107;
2238
2239 if (bus->inotify_fd >= 0)
2240 return bus->inotify_fd;
2241
2242 if (bus->input_fd >= 0)
2243 return bus->input_fd;
2244
2245 return -ENOTCONN107;
2246}
2247
2248_public___attribute__ ((visibility("default"))) int sd_bus_get_events(sd_bus *bus) {
2249 int flags = 0;
2250
2251 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2251, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
2252 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2252, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
2253 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2253, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
2254
2255 switch (bus->state) {
2256
2257 case BUS_UNSET:
2258 case BUS_CLOSED:
2259 return -ENOTCONN107;
2260
2261 case BUS_WATCH_BIND:
2262 flags |= POLLIN0x001;
2263 break;
2264
2265 case BUS_OPENING:
2266 flags |= POLLOUT0x004;
2267 break;
2268
2269 case BUS_AUTHENTICATING:
2270 if (bus_socket_auth_needs_write(bus))
2271 flags |= POLLOUT0x004;
2272
2273 flags |= POLLIN0x001;
2274 break;
2275
2276 case BUS_RUNNING:
2277 case BUS_HELLO:
2278 if (bus->rqueue_size <= 0)
2279 flags |= POLLIN0x001;
2280 if (bus->wqueue_size > 0)
2281 flags |= POLLOUT0x004;
2282 break;
2283
2284 case BUS_CLOSING:
2285 break;
2286
2287 default:
2288 assert_not_reached("Unknown state")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Unknown state"), "../src/libsystemd/sd-bus/sd-bus.c", 2288, __PRETTY_FUNCTION__
); } while (0);
2289 }
2290
2291 return flags;
2292}
2293
2294_public___attribute__ ((visibility("default"))) int sd_bus_get_timeout(sd_bus *bus, uint64_t *timeout_usec) {
2295 struct reply_callback *c;
2296
2297 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2297, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
2298 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2298, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
2299 assert_return(timeout_usec, -EINVAL)do { if (!(((__builtin_expect(!!(timeout_usec),1))) ? (1) : (
log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("timeout_usec"
), "../src/libsystemd/sd-bus/sd-bus.c", 2299, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
2300 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2300, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
2301
2302 if (!BUS_IS_OPEN(bus->state) && bus->state != BUS_CLOSING)
2303 return -ENOTCONN107;
2304
2305 if (bus->track_queue) {
2306 *timeout_usec = 0;
2307 return 1;
2308 }
2309
2310 switch (bus->state) {
2311
2312 case BUS_AUTHENTICATING:
2313 *timeout_usec = bus->auth_timeout;
2314 return 1;
2315
2316 case BUS_RUNNING:
2317 case BUS_HELLO:
2318 if (bus->rqueue_size > 0) {
2319 *timeout_usec = 0;
2320 return 1;
2321 }
2322
2323 c = prioq_peek(bus->reply_callbacks_prioq);
2324 if (!c) {
2325 *timeout_usec = (uint64_t) -1;
2326 return 0;
2327 }
2328
2329 if (c->timeout_usec == 0) {
2330 *timeout_usec = (uint64_t) -1;
2331 return 0;
2332 }
2333
2334 *timeout_usec = c->timeout_usec;
2335 return 1;
2336
2337 case BUS_CLOSING:
2338 *timeout_usec = 0;
2339 return 1;
2340
2341 case BUS_WATCH_BIND:
2342 case BUS_OPENING:
2343 *timeout_usec = (uint64_t) -1;
2344 return 0;
2345
2346 default:
2347 assert_not_reached("Unknown or unexpected stat")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Unknown or unexpected stat"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2347, __PRETTY_FUNCTION__); } while (0);
2348 }
2349}
2350
2351static int process_timeout(sd_bus *bus) {
2352 _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error_buffer = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
2353 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message* m = NULL((void*)0);
2354 struct reply_callback *c;
2355 sd_bus_slot *slot;
2356 bool_Bool is_hello;
2357 usec_t n;
2358 int r;
2359
2360 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2360, __PRETTY_FUNCTION__); } while (0);
2361 assert(IN_SET(bus->state, BUS_RUNNING, BUS_HELLO))do { if ((__builtin_expect(!!(!(({ _Bool _found = 0; static __attribute__
((unused)) char _static_assert__macros_need_to_be_extended[20
- sizeof((int[]){BUS_RUNNING, BUS_HELLO})/sizeof(int)]; switch
(bus->state) { case BUS_RUNNING: case BUS_HELLO: _found = 1
; break; default: break; } _found; }))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("IN_SET(bus->state, BUS_RUNNING, BUS_HELLO)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2361, __PRETTY_FUNCTION__
); } while (0);
2362
2363 c = prioq_peek(bus->reply_callbacks_prioq);
2364 if (!c)
2365 return 0;
2366
2367 n = now(CLOCK_MONOTONIC1);
2368 if (c->timeout_usec > n)
2369 return 0;
2370
2371 r = bus_message_new_synthetic_error(
2372 bus,
2373 c->cookie,
2374 &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_NO_REPLY, "Method call timed out")((const sd_bus_error) {("org.freedesktop.DBus.Error.NoReply")
, ("Method call timed out"), 0}),
2375 &m);
2376 if (r < 0)
2377 return r;
2378
2379 r = bus_seal_synthetic_message(bus, m);
2380 if (r < 0)
2381 return r;
2382
2383 assert_se(prioq_pop(bus->reply_callbacks_prioq) == c)do { if ((__builtin_expect(!!(!(prioq_pop(bus->reply_callbacks_prioq
) == c)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("prioq_pop(bus->reply_callbacks_prioq) == c"
), "../src/libsystemd/sd-bus/sd-bus.c", 2383, __PRETTY_FUNCTION__
); } while (0);
2384 c->timeout_usec = 0;
2385
2386 ordered_hashmap_remove(bus->reply_callbacks, &c->cookie);
2387 c->cookie = 0;
2388
2389 slot = container_of(c, sd_bus_slot, reply_callback)__extension__ ({ const typeof( ((sd_bus_slot*)0)->reply_callback
) *__unique_prefix_A30 = ((c)); (sd_bus_slot*)( (char *)__unique_prefix_A30
- __builtin_offsetof(sd_bus_slot, reply_callback) ); });
2390
2391 bus->iteration_counter++;
2392
2393 is_hello = bus->state == BUS_HELLO && c->callback == hello_callback;
2394
2395 bus->current_message = m;
2396 bus->current_slot = sd_bus_slot_ref(slot);
2397 bus->current_handler = c->callback;
2398 bus->current_userdata = slot->userdata;
2399 r = c->callback(m, slot->userdata, &error_buffer);
2400 bus->current_userdata = NULL((void*)0);
2401 bus->current_handler = NULL((void*)0);
2402 bus->current_slot = NULL((void*)0);
2403 bus->current_message = NULL((void*)0);
2404
2405 if (slot->floating) {
2406 bus_slot_disconnect(slot);
2407 sd_bus_slot_unref(slot);
2408 }
2409
2410 sd_bus_slot_unref(slot);
2411
2412 /* When this is the hello message and it timed out, then make sure to propagate the error up, don't just log
2413 * and ignore the callback handler's return value. */
2414 if (is_hello)
2415 return r;
2416
2417 return bus_maybe_reply_error(m, r, &error_buffer);
2418}
2419
2420static int process_hello(sd_bus *bus, sd_bus_message *m) {
2421 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2421, __PRETTY_FUNCTION__); } while (0);
2422 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2422, __PRETTY_FUNCTION__); } while (0);
2423
2424 if (bus->state != BUS_HELLO)
2425 return 0;
2426
2427 /* Let's make sure the first message on the bus is the HELLO
2428 * reply. But note that we don't actually parse the message
2429 * here (we leave that to the usual handling), we just verify
2430 * we don't let any earlier msg through. */
2431
2432 if (!IN_SET(m->header->type, SD_BUS_MESSAGE_METHOD_RETURN, SD_BUS_MESSAGE_METHOD_ERROR)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){SD_BUS_MESSAGE_METHOD_RETURN, SD_BUS_MESSAGE_METHOD_ERROR
})/sizeof(int)]; switch(m->header->type) { case SD_BUS_MESSAGE_METHOD_RETURN
: case SD_BUS_MESSAGE_METHOD_ERROR: _found = 1; break; default
: break; } _found; }))
2433 return -EIO5;
2434
2435 if (m->reply_cookie != 1)
2436 return -EIO5;
2437
2438 return 0;
2439}
2440
2441static int process_reply(sd_bus *bus, sd_bus_message *m) {
2442 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *synthetic_reply = NULL((void*)0);
2443 _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error_buffer = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
2444 struct reply_callback *c;
2445 sd_bus_slot *slot;
2446 bool_Bool is_hello;
2447 int r;
2448
2449 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2449, __PRETTY_FUNCTION__); } while (0);
2450 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2450, __PRETTY_FUNCTION__); } while (0);
2451
2452 if (!IN_SET(m->header->type, SD_BUS_MESSAGE_METHOD_RETURN, SD_BUS_MESSAGE_METHOD_ERROR)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){SD_BUS_MESSAGE_METHOD_RETURN, SD_BUS_MESSAGE_METHOD_ERROR
})/sizeof(int)]; switch(m->header->type) { case SD_BUS_MESSAGE_METHOD_RETURN
: case SD_BUS_MESSAGE_METHOD_ERROR: _found = 1; break; default
: break; } _found; }))
2453 return 0;
2454
2455 if (m->destination && bus->unique_name && !streq_ptr(m->destination, bus->unique_name))
2456 return 0;
2457
2458 c = ordered_hashmap_remove(bus->reply_callbacks, &m->reply_cookie);
2459 if (!c)
2460 return 0;
2461
2462 c->cookie = 0;
2463
2464 slot = container_of(c, sd_bus_slot, reply_callback)__extension__ ({ const typeof( ((sd_bus_slot*)0)->reply_callback
) *__unique_prefix_A31 = ((c)); (sd_bus_slot*)( (char *)__unique_prefix_A31
- __builtin_offsetof(sd_bus_slot, reply_callback) ); });
2465
2466 if (m->n_fds > 0 && !bus->accept_fd) {
2467
2468 /* If the reply contained a file descriptor which we
2469 * didn't want we pass an error instead. */
2470
2471 r = bus_message_new_synthetic_error(
2472 bus,
2473 m->reply_cookie,
2474 &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_INCONSISTENT_MESSAGE, "Reply message contained file descriptor")((const sd_bus_error) {("org.freedesktop.DBus.Error.InconsistentMessage"
), ("Reply message contained file descriptor"), 0}),
2475 &synthetic_reply);
2476 if (r < 0)
2477 return r;
2478
2479 /* Copy over original timestamp */
2480 synthetic_reply->realtime = m->realtime;
2481 synthetic_reply->monotonic = m->monotonic;
2482 synthetic_reply->seqnum = m->seqnum;
2483
2484 r = bus_seal_synthetic_message(bus, synthetic_reply);
2485 if (r < 0)
2486 return r;
2487
2488 m = synthetic_reply;
2489 } else {
2490 r = sd_bus_message_rewind(m, true1);
2491 if (r < 0)
2492 return r;
2493 }
2494
2495 if (c->timeout_usec != 0) {
2496 prioq_remove(bus->reply_callbacks_prioq, c, &c->prioq_idx);
2497 c->timeout_usec = 0;
2498 }
2499
2500 is_hello = bus->state == BUS_HELLO && c->callback == hello_callback;
2501
2502 bus->current_slot = sd_bus_slot_ref(slot);
2503 bus->current_handler = c->callback;
2504 bus->current_userdata = slot->userdata;
2505 r = c->callback(m, slot->userdata, &error_buffer);
2506 bus->current_userdata = NULL((void*)0);
2507 bus->current_handler = NULL((void*)0);
2508 bus->current_slot = NULL((void*)0);
2509
2510 if (slot->floating) {
2511 bus_slot_disconnect(slot);
2512 sd_bus_slot_unref(slot);
2513 }
2514
2515 sd_bus_slot_unref(slot);
2516
2517 /* When this is the hello message and it failed, then make sure to propagate the error up, don't just log and
2518 * ignore the callback handler's return value. */
2519 if (is_hello)
2520 return r;
2521
2522 return bus_maybe_reply_error(m, r, &error_buffer);
2523}
2524
2525static int process_filter(sd_bus *bus, sd_bus_message *m) {
2526 _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error_buffer = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
2527 struct filter_callback *l;
2528 int r;
2529
2530 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2530, __PRETTY_FUNCTION__); } while (0);
2531 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2531, __PRETTY_FUNCTION__); } while (0);
2532
2533 do {
2534 bus->filter_callbacks_modified = false0;
2535
2536 LIST_FOREACH(callbacks, l, bus->filter_callbacks)for ((l) = (bus->filter_callbacks); (l); (l) = (l)->callbacks_next
) {
2537 sd_bus_slot *slot;
2538
2539 if (bus->filter_callbacks_modified)
2540 break;
2541
2542 /* Don't run this more than once per iteration */
2543 if (l->last_iteration == bus->iteration_counter)
2544 continue;
2545
2546 l->last_iteration = bus->iteration_counter;
2547
2548 r = sd_bus_message_rewind(m, true1);
2549 if (r < 0)
2550 return r;
2551
2552 slot = container_of(l, sd_bus_slot, filter_callback)__extension__ ({ const typeof( ((sd_bus_slot*)0)->filter_callback
) *__unique_prefix_A32 = ((l)); (sd_bus_slot*)( (char *)__unique_prefix_A32
- __builtin_offsetof(sd_bus_slot, filter_callback) ); });
2553
2554 bus->current_slot = sd_bus_slot_ref(slot);
2555 bus->current_handler = l->callback;
2556 bus->current_userdata = slot->userdata;
2557 r = l->callback(m, slot->userdata, &error_buffer);
2558 bus->current_userdata = NULL((void*)0);
2559 bus->current_handler = NULL((void*)0);
2560 bus->current_slot = sd_bus_slot_unref(slot);
2561
2562 r = bus_maybe_reply_error(m, r, &error_buffer);
2563 if (r != 0)
2564 return r;
2565
2566 }
2567
2568 } while (bus->filter_callbacks_modified);
2569
2570 return 0;
2571}
2572
2573static int process_match(sd_bus *bus, sd_bus_message *m) {
2574 int r;
2575
2576 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2576, __PRETTY_FUNCTION__); } while (0);
2577 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2577, __PRETTY_FUNCTION__); } while (0);
2578
2579 do {
2580 bus->match_callbacks_modified = false0;
2581
2582 r = bus_match_run(bus, &bus->match_callbacks, m);
2583 if (r != 0)
2584 return r;
2585
2586 } while (bus->match_callbacks_modified);
2587
2588 return 0;
2589}
2590
2591static int process_builtin(sd_bus *bus, sd_bus_message *m) {
2592 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *reply = NULL((void*)0);
2593 int r;
2594
2595 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2595, __PRETTY_FUNCTION__); } while (0);
2596 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2596, __PRETTY_FUNCTION__); } while (0);
2597
2598 if (bus->is_monitor)
2599 return 0;
2600
2601 if (bus->manual_peer_interface)
2602 return 0;
2603
2604 if (m->header->type != SD_BUS_MESSAGE_METHOD_CALL)
2605 return 0;
2606
2607 if (!streq_ptr(m->interface, "org.freedesktop.DBus.Peer"))
2608 return 0;
2609
2610 if (m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED)
2611 return 1;
2612
2613 if (streq_ptr(m->member, "Ping"))
2614 r = sd_bus_message_new_method_return(m, &reply);
2615 else if (streq_ptr(m->member, "GetMachineId")) {
2616 sd_id128_t id;
2617 char sid[33];
2618
2619 r = sd_id128_get_machine(&id);
2620 if (r < 0)
2621 return r;
2622
2623 r = sd_bus_message_new_method_return(m, &reply);
2624 if (r < 0)
2625 return r;
2626
2627 r = sd_bus_message_append(reply, "s", sd_id128_to_string(id, sid));
2628 } else {
2629 r = sd_bus_message_new_method_errorf(
2630 m, &reply,
2631 SD_BUS_ERROR_UNKNOWN_METHOD"org.freedesktop.DBus.Error.UnknownMethod",
2632 "Unknown method '%s' on interface '%s'.", m->member, m->interface);
2633 }
2634 if (r < 0)
2635 return r;
2636
2637 r = sd_bus_send(bus, reply, NULL((void*)0));
2638 if (r < 0)
2639 return r;
2640
2641 return 1;
2642}
2643
2644static int process_fd_check(sd_bus *bus, sd_bus_message *m) {
2645 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2645, __PRETTY_FUNCTION__); } while (0);
2646 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2646, __PRETTY_FUNCTION__); } while (0);
2647
2648 /* If we got a message with a file descriptor which we didn't
2649 * want to accept, then let's drop it. How can this even
2650 * happen? For example, when the kernel queues a message into
2651 * an activatable names's queue which allows fds, and then is
2652 * delivered to us later even though we ourselves did not
2653 * negotiate it. */
2654
2655 if (bus->is_monitor)
2656 return 0;
2657
2658 if (m->n_fds <= 0)
2659 return 0;
2660
2661 if (bus->accept_fd)
2662 return 0;
2663
2664 if (m->header->type != SD_BUS_MESSAGE_METHOD_CALL)
2665 return 1; /* just eat it up */
2666
2667 return sd_bus_reply_method_errorf(m, SD_BUS_ERROR_INCONSISTENT_MESSAGE"org.freedesktop.DBus.Error.InconsistentMessage", "Message contains file descriptors, which I cannot accept. Sorry.");
2668}
2669
2670static int process_message(sd_bus *bus, sd_bus_message *m) {
2671 int r;
2672
2673 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2673, __PRETTY_FUNCTION__); } while (0);
2674 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2674, __PRETTY_FUNCTION__); } while (0);
2675
2676 bus->current_message = m;
2677 bus->iteration_counter++;
2678
2679 log_debug_bus_message(m)do { sd_bus_message *_mm = (m); ({ int _level = (((7))), _e =
((0)), _realm = (LOG_REALM_SYSTEMD); (log_get_max_level_realm
(_realm) >= ((_level) & 0x07)) ? log_internal_realm(((
_realm) << 10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c"
, 2679, __func__, "Got message type=%s sender=%s destination=%s path=%s interface=%s member=%s cookie=%"
"l" "u" " reply_cookie=%" "l" "u" " signature=%s error-name=%s error-message=%s"
, bus_message_type_to_string(_mm->header->type), strna(
sd_bus_message_get_sender(_mm)), strna(sd_bus_message_get_destination
(_mm)), strna(sd_bus_message_get_path(_mm)), strna(sd_bus_message_get_interface
(_mm)), strna(sd_bus_message_get_member(_mm)), BUS_MESSAGE_COOKIE
(_mm), _mm->reply_cookie, strna(_mm->root_container.signature
), strna(_mm->error.name), strna(_mm->error.message)) :
-abs(_e); }); } while (0);
2680
2681 r = process_hello(bus, m);
2682 if (r != 0)
2683 goto finish;
2684
2685 r = process_reply(bus, m);
2686 if (r != 0)
2687 goto finish;
2688
2689 r = process_fd_check(bus, m);
2690 if (r != 0)
2691 goto finish;
2692
2693 r = process_filter(bus, m);
2694 if (r != 0)
2695 goto finish;
2696
2697 r = process_match(bus, m);
2698 if (r != 0)
2699 goto finish;
2700
2701 r = process_builtin(bus, m);
2702 if (r != 0)
2703 goto finish;
2704
2705 r = bus_process_object(bus, m);
2706
2707finish:
2708 bus->current_message = NULL((void*)0);
2709 return r;
2710}
2711
2712static int dispatch_track(sd_bus *bus) {
2713 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2713, __PRETTY_FUNCTION__); } while (0);
2714
2715 if (!bus->track_queue)
2716 return 0;
2717
2718 bus_track_dispatch(bus->track_queue);
2719 return 1;
2720}
2721
2722static int process_running(sd_bus *bus, bool_Bool hint_priority, int64_t priority, sd_bus_message **ret) {
2723 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0);
2724 int r;
2725
2726 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2726, __PRETTY_FUNCTION__); } while (0);
2727 assert(IN_SET(bus->state, BUS_RUNNING, BUS_HELLO))do { if ((__builtin_expect(!!(!(({ _Bool _found = 0; static __attribute__
((unused)) char _static_assert__macros_need_to_be_extended[20
- sizeof((int[]){BUS_RUNNING, BUS_HELLO})/sizeof(int)]; switch
(bus->state) { case BUS_RUNNING: case BUS_HELLO: _found = 1
; break; default: break; } _found; }))),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("IN_SET(bus->state, BUS_RUNNING, BUS_HELLO)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2727, __PRETTY_FUNCTION__
); } while (0);
2728
2729 r = process_timeout(bus);
2730 if (r != 0)
2731 goto null_message;
2732
2733 r = dispatch_wqueue(bus);
2734 if (r != 0)
2735 goto null_message;
2736
2737 r = dispatch_track(bus);
2738 if (r != 0)
2739 goto null_message;
2740
2741 r = dispatch_rqueue(bus, hint_priority, priority, &m);
2742 if (r < 0)
2743 return r;
2744 if (!m)
2745 goto null_message;
2746
2747 r = process_message(bus, m);
2748 if (r != 0)
2749 goto null_message;
2750
2751 if (ret) {
2752 r = sd_bus_message_rewind(m, true1);
2753 if (r < 0)
2754 return r;
2755
2756 *ret = TAKE_PTR(m)({ typeof(m) _ptr_ = (m); (m) = ((void*)0); _ptr_; });
2757 return 1;
2758 }
2759
2760 if (m->header->type == SD_BUS_MESSAGE_METHOD_CALL) {
2761
2762 log_debug("Unprocessed message call sender=%s object=%s interface=%s member=%s",({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2766, __func__, "Unprocessed message call sender=%s object=%s interface=%s member=%s"
, strna(sd_bus_message_get_sender(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m))) : -abs(_e); })
2763 strna(sd_bus_message_get_sender(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2766, __func__, "Unprocessed message call sender=%s object=%s interface=%s member=%s"
, strna(sd_bus_message_get_sender(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m))) : -abs(_e); })
2764 strna(sd_bus_message_get_path(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2766, __func__, "Unprocessed message call sender=%s object=%s interface=%s member=%s"
, strna(sd_bus_message_get_sender(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m))) : -abs(_e); })
2765 strna(sd_bus_message_get_interface(m)),({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2766, __func__, "Unprocessed message call sender=%s object=%s interface=%s member=%s"
, strna(sd_bus_message_get_sender(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m))) : -abs(_e); })
2766 strna(sd_bus_message_get_member(m)))({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2766, __func__, "Unprocessed message call sender=%s object=%s interface=%s member=%s"
, strna(sd_bus_message_get_sender(m)), strna(sd_bus_message_get_path
(m)), strna(sd_bus_message_get_interface(m)), strna(sd_bus_message_get_member
(m))) : -abs(_e); });
2767
2768 r = sd_bus_reply_method_errorf(
2769 m,
2770 SD_BUS_ERROR_UNKNOWN_OBJECT"org.freedesktop.DBus.Error.UnknownObject",
2771 "Unknown object '%s'.", m->path);
2772 if (r < 0)
2773 return r;
2774 }
2775
2776 return 1;
2777
2778null_message:
2779 if (r >= 0 && ret)
2780 *ret = NULL((void*)0);
2781
2782 return r;
2783}
2784
2785static int bus_exit_now(sd_bus *bus) {
2786 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2786, __PRETTY_FUNCTION__); } while (0);
2787
2788 /* Exit due to close, if this is requested. If this is bus object is attached to an event source, invokes
2789 * sd_event_exit(), otherwise invokes libc exit(). */
2790
2791 if (bus->exited) /* did we already exit? */
2792 return 0;
2793 if (!bus->exit_triggered) /* was the exit condition triggered? */
2794 return 0;
2795 if (!bus->exit_on_disconnect) /* Shall we actually exit on disconnection? */
2796 return 0;
2797
2798 bus->exited = true1; /* never exit more than once */
2799
2800 log_debug("Bus connection disconnected, exiting.")({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 2800, __func__, "Bus connection disconnected, exiting."
) : -abs(_e); });
2801
2802 if (bus->event)
2803 return sd_event_exit(bus->event, EXIT_FAILURE1);
2804 else
2805 exit(EXIT_FAILURE1);
2806
2807 assert_not_reached("exit() didn't exit?")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"exit() didn't exit?"), "../src/libsystemd/sd-bus/sd-bus.c", 2807
, __PRETTY_FUNCTION__); } while (0);
2808}
2809
2810static int process_closing_reply_callback(sd_bus *bus, struct reply_callback *c) {
2811 _cleanup_(sd_bus_error_free)__attribute__((cleanup(sd_bus_error_free))) sd_bus_error error_buffer = SD_BUS_ERROR_NULL((const sd_bus_error) {(((void*)0)), (((void*)0)), 0});
2812 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0);
2813 sd_bus_slot *slot;
2814 int r;
2815
2816 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2816, __PRETTY_FUNCTION__); } while (0);
2817 assert(c)do { if ((__builtin_expect(!!(!(c)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("c"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2817, __PRETTY_FUNCTION__); } while (0);
2818
2819 r = bus_message_new_synthetic_error(
2820 bus,
2821 c->cookie,
2822 &SD_BUS_ERROR_MAKE_CONST(SD_BUS_ERROR_NO_REPLY, "Connection terminated")((const sd_bus_error) {("org.freedesktop.DBus.Error.NoReply")
, ("Connection terminated"), 0}),
2823 &m);
2824 if (r < 0)
2825 return r;
2826
2827 r = bus_seal_synthetic_message(bus, m);
2828 if (r < 0)
2829 return r;
2830
2831 if (c->timeout_usec != 0) {
2832 prioq_remove(bus->reply_callbacks_prioq, c, &c->prioq_idx);
2833 c->timeout_usec = 0;
2834 }
2835
2836 ordered_hashmap_remove(bus->reply_callbacks, &c->cookie);
2837 c->cookie = 0;
2838
2839 slot = container_of(c, sd_bus_slot, reply_callback)__extension__ ({ const typeof( ((sd_bus_slot*)0)->reply_callback
) *__unique_prefix_A33 = ((c)); (sd_bus_slot*)( (char *)__unique_prefix_A33
- __builtin_offsetof(sd_bus_slot, reply_callback) ); });
2840
2841 bus->iteration_counter++;
2842
2843 bus->current_message = m;
2844 bus->current_slot = sd_bus_slot_ref(slot);
2845 bus->current_handler = c->callback;
2846 bus->current_userdata = slot->userdata;
2847 r = c->callback(m, slot->userdata, &error_buffer);
2848 bus->current_userdata = NULL((void*)0);
2849 bus->current_handler = NULL((void*)0);
2850 bus->current_slot = NULL((void*)0);
2851 bus->current_message = NULL((void*)0);
2852
2853 if (slot->floating) {
2854 bus_slot_disconnect(slot);
2855 sd_bus_slot_unref(slot);
2856 }
2857
2858 sd_bus_slot_unref(slot);
2859
2860 return bus_maybe_reply_error(m, r, &error_buffer);
2861}
2862
2863static int process_closing(sd_bus *bus, sd_bus_message **ret) {
2864 _cleanup_(sd_bus_message_unrefp)__attribute__((cleanup(sd_bus_message_unrefp))) sd_bus_message *m = NULL((void*)0);
2865 struct reply_callback *c;
2866 int r;
2867
2868 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2868, __PRETTY_FUNCTION__); } while (0);
2869 assert(bus->state == BUS_CLOSING)do { if ((__builtin_expect(!!(!(bus->state == BUS_CLOSING)
),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->state == BUS_CLOSING"
), "../src/libsystemd/sd-bus/sd-bus.c", 2869, __PRETTY_FUNCTION__
); } while (0);
2870
2871 /* First, fail all outstanding method calls */
2872 c = ordered_hashmap_first(bus->reply_callbacks);
2873 if (c)
2874 return process_closing_reply_callback(bus, c);
2875
2876 /* Then, fake-drop all remaining bus tracking references */
2877 if (bus->tracks) {
2878 bus_track_close(bus->tracks);
2879 return 1;
2880 }
2881
2882 /* Then, synthesize a Disconnected message */
2883 r = sd_bus_message_new_signal(
2884 bus,
2885 &m,
2886 "/org/freedesktop/DBus/Local",
2887 "org.freedesktop.DBus.Local",
2888 "Disconnected");
2889 if (r < 0)
2890 return r;
2891
2892 bus_message_set_sender_local(bus, m);
2893
2894 r = bus_seal_synthetic_message(bus, m);
2895 if (r < 0)
2896 return r;
2897
2898 sd_bus_close(bus);
2899
2900 bus->current_message = m;
2901 bus->iteration_counter++;
2902
2903 r = process_filter(bus, m);
2904 if (r != 0)
2905 goto finish;
2906
2907 r = process_match(bus, m);
2908 if (r != 0)
2909 goto finish;
2910
2911 /* Nothing else to do, exit now, if the condition holds */
2912 bus->exit_triggered = true1;
2913 (void) bus_exit_now(bus);
2914
2915 if (ret)
2916 *ret = TAKE_PTR(m)({ typeof(m) _ptr_ = (m); (m) = ((void*)0); _ptr_; });
2917
2918 r = 1;
2919
2920finish:
2921 bus->current_message = NULL((void*)0);
2922
2923 return r;
2924}
2925
2926static int bus_process_internal(sd_bus *bus, bool_Bool hint_priority, int64_t priority, sd_bus_message **ret) {
2927 int r;
2928
2929 /* Returns 0 when we didn't do anything. This should cause the
2930 * caller to invoke sd_bus_wait() before returning the next
2931 * time. Returns > 0 when we did something, which possibly
2932 * means *ret is filled in with an unprocessed message. */
2933
2934 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2934, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
2935 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2935, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
2936 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 2936, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
2937
2938 /* We don't allow recursively invoking sd_bus_process(). */
2939 assert_return(!bus->current_message, -EBUSY)do { if (!(((__builtin_expect(!!(!bus->current_message),1)
)) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD,
("!bus->current_message"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2939, __PRETTY_FUNCTION__), 0))) return (-16); } while (0);
2940 assert(!bus->current_slot)do { if ((__builtin_expect(!!(!(!bus->current_slot)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("!bus->current_slot"), "../src/libsystemd/sd-bus/sd-bus.c"
, 2940, __PRETTY_FUNCTION__); } while (0);
2941
2942 BUS_DONT_DESTROY(bus)__attribute__((cleanup(sd_bus_unrefp))) __attribute__ ((unused
)) sd_bus *_dont_destroy_bus = sd_bus_ref(bus);
2943
2944 switch (bus->state) {
2945
2946 case BUS_UNSET:
2947 return -ENOTCONN107;
2948
2949 case BUS_CLOSED:
2950 return -ECONNRESET104;
2951
2952 case BUS_WATCH_BIND:
2953 r = bus_socket_process_watch_bind(bus);
2954 break;
2955
2956 case BUS_OPENING:
2957 r = bus_socket_process_opening(bus);
2958 break;
2959
2960 case BUS_AUTHENTICATING:
2961 r = bus_socket_process_authenticating(bus);
2962 break;
2963
2964 case BUS_RUNNING:
2965 case BUS_HELLO:
2966 r = process_running(bus, hint_priority, priority, ret);
2967 if (r >= 0)
2968 return r;
2969
2970 /* This branch initializes *ret, hence we don't use the generic error checking below */
2971 break;
2972
2973 case BUS_CLOSING:
2974 return process_closing(bus, ret);
2975
2976 default:
2977 assert_not_reached("Unknown state")do { log_assert_failed_unreachable_realm(LOG_REALM_SYSTEMD, (
"Unknown state"), "../src/libsystemd/sd-bus/sd-bus.c", 2977, __PRETTY_FUNCTION__
); } while (0);
2978 }
2979
2980 if (IN_SET(r, -ENOTCONN, -ECONNRESET, -EPIPE, -ESHUTDOWN)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){-107, -104, -32, -108})/sizeof(int)]; switch
(r) { case -107: case -104: case -32: case -108: _found = 1; break
; default: break; } _found; })) {
2981 bus_enter_closing(bus);
2982 r = 1;
2983 } else if (r < 0)
2984 return r;
2985
2986 if (ret)
2987 *ret = NULL((void*)0);
2988
2989 return r;
2990}
2991
2992_public___attribute__ ((visibility("default"))) int sd_bus_process(sd_bus *bus, sd_bus_message **ret) {
2993 return bus_process_internal(bus, false0, 0, ret);
2994}
2995
2996_public___attribute__ ((visibility("default"))) int sd_bus_process_priority(sd_bus *bus, int64_t priority, sd_bus_message **ret) {
2997 return bus_process_internal(bus, true1, priority, ret);
2998}
2999
3000static int bus_poll(sd_bus *bus, bool_Bool need_more, uint64_t timeout_usec) {
3001 struct pollfd p[2] = {};
3002 int r, n;
3003 struct timespec ts;
3004 usec_t m = USEC_INFINITY((usec_t) -1);
3005
3006 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3006, __PRETTY_FUNCTION__); } while (0);
3007
3008 if (bus->state == BUS_CLOSING)
3009 return 1;
3010
3011 if (!BUS_IS_OPEN(bus->state))
3012 return -ENOTCONN107;
3013
3014 if (bus->state == BUS_WATCH_BIND) {
3015 assert(bus->inotify_fd >= 0)do { if ((__builtin_expect(!!(!(bus->inotify_fd >= 0)),
0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->inotify_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 3015, __PRETTY_FUNCTION__
); } while (0);
3016
3017 p[0].events = POLLIN0x001;
3018 p[0].fd = bus->inotify_fd;
3019 n = 1;
3020 } else {
3021 int e;
3022
3023 e = sd_bus_get_events(bus);
3024 if (e < 0)
3025 return e;
3026
3027 if (need_more)
3028 /* The caller really needs some more data, he doesn't
3029 * care about what's already read, or any timeouts
3030 * except its own. */
3031 e |= POLLIN0x001;
3032 else {
3033 usec_t until;
3034 /* The caller wants to process if there's something to
3035 * process, but doesn't care otherwise */
3036
3037 r = sd_bus_get_timeout(bus, &until);
3038 if (r < 0)
3039 return r;
3040 if (r > 0)
3041 m = usec_sub_unsigned(until, now(CLOCK_MONOTONIC1));
3042 }
3043
3044 p[0].fd = bus->input_fd;
3045 if (bus->output_fd == bus->input_fd) {
3046 p[0].events = e;
3047 n = 1;
3048 } else {
3049 p[0].events = e & POLLIN0x001;
3050 p[1].fd = bus->output_fd;
3051 p[1].events = e & POLLOUT0x004;
3052 n = 2;
3053 }
3054 }
3055
3056 if (timeout_usec != (uint64_t) -1 && (m == USEC_INFINITY((usec_t) -1) || timeout_usec < m))
3057 m = timeout_usec;
3058
3059 r = ppoll(p, n, m == USEC_INFINITY((usec_t) -1) ? NULL((void*)0) : timespec_store(&ts, m), NULL((void*)0));
3060 if (r < 0)
3061 return -errno(*__errno_location ());
3062
3063 return r > 0 ? 1 : 0;
3064}
3065
3066_public___attribute__ ((visibility("default"))) int sd_bus_wait(sd_bus *bus, uint64_t timeout_usec) {
3067
3068 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3068, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3069 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3069, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3070 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3070, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3071
3072 if (bus->state == BUS_CLOSING)
3073 return 0;
3074
3075 if (!BUS_IS_OPEN(bus->state))
3076 return -ENOTCONN107;
3077
3078 if (bus->rqueue_size > 0)
3079 return 0;
3080
3081 return bus_poll(bus, false0, timeout_usec);
3082}
3083
3084_public___attribute__ ((visibility("default"))) int sd_bus_flush(sd_bus *bus) {
3085 int r;
3086
3087 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3087, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3088 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3088, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3089 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3089, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3090
3091 if (bus->state == BUS_CLOSING)
3092 return 0;
3093
3094 if (!BUS_IS_OPEN(bus->state))
3095 return -ENOTCONN107;
3096
3097 /* We never were connected? Don't hang in inotify for good, as there's no timeout set for it */
3098 if (bus->state == BUS_WATCH_BIND)
3099 return -EUNATCH49;
3100
3101 r = bus_ensure_running(bus);
3102 if (r < 0)
3103 return r;
3104
3105 if (bus->wqueue_size <= 0)
3106 return 0;
3107
3108 for (;;) {
3109 r = dispatch_wqueue(bus);
3110 if (r < 0) {
3111 if (IN_SET(r, -ENOTCONN, -ECONNRESET, -EPIPE, -ESHUTDOWN)({ _Bool _found = 0; static __attribute__ ((unused)) char _static_assert__macros_need_to_be_extended
[20 - sizeof((int[]){-107, -104, -32, -108})/sizeof(int)]; switch
(r) { case -107: case -104: case -32: case -108: _found = 1; break
; default: break; } _found; })) {
3112 bus_enter_closing(bus);
3113 return -ECONNRESET104;
3114 }
3115
3116 return r;
3117 }
3118
3119 if (bus->wqueue_size <= 0)
3120 return 0;
3121
3122 r = bus_poll(bus, false0, (uint64_t) -1);
3123 if (r < 0)
3124 return r;
3125 }
3126}
3127
3128_public___attribute__ ((visibility("default"))) int sd_bus_add_filter(
3129 sd_bus *bus,
3130 sd_bus_slot **slot,
3131 sd_bus_message_handler_t callback,
3132 void *userdata) {
3133
3134 sd_bus_slot *s;
3135
3136 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3136, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3137 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3137, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3138 assert_return(callback, -EINVAL)do { if (!(((__builtin_expect(!!(callback),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("callback"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3138, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3139 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3139, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3140
3141 s = bus_slot_allocate(bus, !slot, BUS_FILTER_CALLBACK, sizeof(struct filter_callback), userdata);
3142 if (!s)
3143 return -ENOMEM12;
3144
3145 s->filter_callback.callback = callback;
3146
3147 bus->filter_callbacks_modified = true1;
3148 LIST_PREPEND(callbacks, bus->filter_callbacks, &s->filter_callback)do { typeof(*(bus->filter_callbacks)) **_head = &(bus->
filter_callbacks), *_item = (&s->filter_callback); do {
if ((__builtin_expect(!!(!(_item)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("_item"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3148, __PRETTY_FUNCTION__); } while (0); if ((_item->callbacks_next
= *_head)) _item->callbacks_next->callbacks_prev = _item
; _item->callbacks_prev = ((void*)0); *_head = _item; } while
(0);
3149
3150 if (slot)
3151 *slot = s;
3152
3153 return 0;
3154}
3155
3156static int add_match_callback(
3157 sd_bus_message *m,
3158 void *userdata,
3159 sd_bus_error *ret_error) {
3160
3161 sd_bus_slot *match_slot = userdata;
3162 bool_Bool failed = false0;
3163 int r;
3164
3165 assert(m)do { if ((__builtin_expect(!!(!(m)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3165, __PRETTY_FUNCTION__); } while (0);
3166 assert(match_slot)do { if ((__builtin_expect(!!(!(match_slot)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("match_slot"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3166, __PRETTY_FUNCTION__); } while (0);
3167
3168 sd_bus_slot_ref(match_slot);
3169
3170 if (sd_bus_message_is_method_error(m, NULL((void*)0))) {
3171 log_debug_errno(sd_bus_message_get_errno(m),({ int _level = ((7)), _e = ((sd_bus_message_get_errno(m))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c", 3174
, __func__, "Unable to add match %s, failing connection: %s",
match_slot->match_callback.match_string, sd_bus_message_get_error
(m)->message) : -abs(_e); })
3172 "Unable to add match %s, failing connection: %s",({ int _level = ((7)), _e = ((sd_bus_message_get_errno(m))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c", 3174
, __func__, "Unable to add match %s, failing connection: %s",
match_slot->match_callback.match_string, sd_bus_message_get_error
(m)->message) : -abs(_e); })
3173 match_slot->match_callback.match_string,({ int _level = ((7)), _e = ((sd_bus_message_get_errno(m))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c", 3174
, __func__, "Unable to add match %s, failing connection: %s",
match_slot->match_callback.match_string, sd_bus_message_get_error
(m)->message) : -abs(_e); })
3174 sd_bus_message_get_error(m)->message)({ int _level = ((7)), _e = ((sd_bus_message_get_errno(m))), _realm
= (LOG_REALM_SYSTEMD); (log_get_max_level_realm(_realm) >=
((_level) & 0x07)) ? log_internal_realm(((_realm) <<
10 | (_level)), _e, "../src/libsystemd/sd-bus/sd-bus.c", 3174
, __func__, "Unable to add match %s, failing connection: %s",
match_slot->match_callback.match_string, sd_bus_message_get_error
(m)->message) : -abs(_e); });
3175
3176 failed = true1;
3177 } else
3178 log_debug("Match %s successfully installed.", match_slot->match_callback.match_string)({ int _level = (((7))), _e = ((0)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 3178, __func__, "Match %s successfully installed."
, match_slot->match_callback.match_string) : -abs(_e); });
3179
3180 if (match_slot->match_callback.install_callback) {
3181 sd_bus *bus;
3182
3183 bus = sd_bus_message_get_bus(m);
3184
3185 /* This function has been called as slot handler, and we want to call another slot handler. Let's
3186 * update the slot callback metadata temporarily with our own data, and then revert back to the old
3187 * values. */
3188
3189 assert(bus->current_slot == match_slot->match_callback.install_slot)do { if ((__builtin_expect(!!(!(bus->current_slot == match_slot
->match_callback.install_slot)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus->current_slot == match_slot->match_callback.install_slot"
), "../src/libsystemd/sd-bus/sd-bus.c", 3189, __PRETTY_FUNCTION__
); } while (0);
3190 assert(bus->current_handler == add_match_callback)do { if ((__builtin_expect(!!(!(bus->current_handler == add_match_callback
)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->current_handler == add_match_callback"
), "../src/libsystemd/sd-bus/sd-bus.c", 3190, __PRETTY_FUNCTION__
); } while (0);
3191 assert(bus->current_userdata == userdata)do { if ((__builtin_expect(!!(!(bus->current_userdata == userdata
)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->current_userdata == userdata"
), "../src/libsystemd/sd-bus/sd-bus.c", 3191, __PRETTY_FUNCTION__
); } while (0);
3192
3193 bus->current_slot = match_slot;
3194 bus->current_handler = match_slot->match_callback.install_callback;
3195 bus->current_userdata = match_slot->userdata;
3196
3197 r = match_slot->match_callback.install_callback(m, match_slot->userdata, ret_error);
3198
3199 bus->current_slot = match_slot->match_callback.install_slot;
3200 bus->current_handler = add_match_callback;
3201 bus->current_userdata = userdata;
3202
3203 match_slot->match_callback.install_slot = sd_bus_slot_unref(match_slot->match_callback.install_slot);
3204 } else {
3205 if (failed) /* Generic failure handling: destroy the connection */
3206 bus_enter_closing(sd_bus_message_get_bus(m));
3207
3208 r = 1;
3209 }
3210
3211 if (failed && match_slot->floating) {
3212 bus_slot_disconnect(match_slot);
3213 sd_bus_slot_unref(match_slot);
3214 }
3215
3216 sd_bus_slot_unref(match_slot);
3217
3218 return r;
3219}
3220
3221static int bus_add_match_full(
3222 sd_bus *bus,
3223 sd_bus_slot **slot,
3224 bool_Bool asynchronous,
3225 const char *match,
3226 sd_bus_message_handler_t callback,
3227 sd_bus_message_handler_t install_callback,
3228 void *userdata) {
3229
3230 struct bus_match_component *components = NULL((void*)0);
3231 unsigned n_components = 0;
3232 sd_bus_slot *s = NULL((void*)0);
3233 int r = 0;
3234
3235 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3235, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3236 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3236, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3237 assert_return(match, -EINVAL)do { if (!(((__builtin_expect(!!(match),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("match"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3237, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3238 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3238, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3239
3240 r = bus_match_parse(match, &components, &n_components);
3241 if (r < 0)
3242 goto finish;
3243
3244 s = bus_slot_allocate(bus, !slot, BUS_MATCH_CALLBACK, sizeof(struct match_callback), userdata);
3245 if (!s) {
3246 r = -ENOMEM12;
3247 goto finish;
3248 }
3249
3250 s->match_callback.callback = callback;
3251 s->match_callback.install_callback = install_callback;
3252
3253 if (bus->bus_client) {
3254 enum bus_match_scope scope;
3255
3256 scope = bus_match_get_scope(components, n_components);
3257
3258 /* Do not install server-side matches for matches against the local service, interface or bus path. */
3259 if (scope != BUS_MATCH_LOCAL) {
3260
3261 /* We store the original match string, so that we can use it to remove the match again. */
3262
3263 s->match_callback.match_string = strdup(match);
3264 if (!s->match_callback.match_string) {
3265 r = -ENOMEM12;
3266 goto finish;
3267 }
3268
3269 if (asynchronous) {
3270 r = bus_add_match_internal_async(bus,
3271 &s->match_callback.install_slot,
3272 s->match_callback.match_string,
3273 add_match_callback,
3274 s);
3275
3276 if (r < 0)
3277 return r;
3278
3279 /* Make the slot of the match call floating now. We need the reference, but we don't
3280 * want that this match pins the bus object, hence we first create it non-floating, but
3281 * then make it floating. */
3282 r = sd_bus_slot_set_floating(s->match_callback.install_slot, true1);
3283 } else
3284 r = bus_add_match_internal(bus, s->match_callback.match_string);
3285 if (r < 0)
3286 goto finish;
3287
3288 s->match_added = true1;
3289 }
3290 }
3291
3292 bus->match_callbacks_modified = true1;
3293 r = bus_match_add(&bus->match_callbacks, components, n_components, &s->match_callback);
3294 if (r < 0)
3295 goto finish;
3296
3297 if (slot)
3298 *slot = s;
3299 s = NULL((void*)0);
3300
3301finish:
3302 bus_match_parse_free(components, n_components);
3303 sd_bus_slot_unref(s);
3304
3305 return r;
3306}
3307
3308_public___attribute__ ((visibility("default"))) int sd_bus_add_match(
3309 sd_bus *bus,
3310 sd_bus_slot **slot,
3311 const char *match,
3312 sd_bus_message_handler_t callback,
3313 void *userdata) {
3314
3315 return bus_add_match_full(bus, slot, false0, match, callback, NULL((void*)0), userdata);
3316}
3317
3318_public___attribute__ ((visibility("default"))) int sd_bus_add_match_async(
3319 sd_bus *bus,
3320 sd_bus_slot **slot,
3321 const char *match,
3322 sd_bus_message_handler_t callback,
3323 sd_bus_message_handler_t install_callback,
3324 void *userdata) {
3325
3326 return bus_add_match_full(bus, slot, true1, match, callback, install_callback, userdata);
3327}
3328
3329bool_Bool bus_pid_changed(sd_bus *bus) {
3330 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3330, __PRETTY_FUNCTION__); } while (0);
3331
3332 /* We don't support people creating a bus connection and
3333 * keeping it around over a fork(). Let's complain. */
3334
3335 return bus->original_pid != getpid_cached();
3336}
3337
3338static int io_callback(sd_event_source *s, int fd, uint32_t revents, void *userdata) {
3339 sd_bus *bus = userdata;
3340 int r;
3341
3342 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3342, __PRETTY_FUNCTION__); } while (0);
3343
3344 /* Note that this is called both on input_fd, output_fd as well as inotify_fd events */
3345
3346 r = sd_bus_process(bus, NULL((void*)0));
3347 if (r < 0) {
3348 log_debug_errno(r, "Processing of bus failed, closing down: %m")({ int _level = ((7)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 3348, __func__, "Processing of bus failed, closing down: %m"
) : -abs(_e); });
3349 bus_enter_closing(bus);
3350 }
3351
3352 return 1;
3353}
3354
3355static int time_callback(sd_event_source *s, uint64_t usec, void *userdata) {
3356 sd_bus *bus = userdata;
3357 int r;
3358
3359 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3359, __PRETTY_FUNCTION__); } while (0);
3360
3361 r = sd_bus_process(bus, NULL((void*)0));
3362 if (r < 0) {
3363 log_debug_errno(r, "Processing of bus failed, closing down: %m")({ int _level = ((7)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 3363, __func__, "Processing of bus failed, closing down: %m"
) : -abs(_e); });
3364 bus_enter_closing(bus);
3365 }
3366
3367 return 1;
3368}
3369
3370static int prepare_callback(sd_event_source *s, void *userdata) {
3371 sd_bus *bus = userdata;
3372 int r, e;
3373 usec_t until;
3374
3375 assert(s)do { if ((__builtin_expect(!!(!(s)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("s"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3375, __PRETTY_FUNCTION__); } while (0);
3376 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3376, __PRETTY_FUNCTION__); } while (0);
3377
3378 e = sd_bus_get_events(bus);
3379 if (e < 0) {
3380 r = e;
3381 goto fail;
3382 }
3383
3384 if (bus->output_fd != bus->input_fd) {
3385
3386 r = sd_event_source_set_io_events(bus->input_io_event_source, e & POLLIN0x001);
3387 if (r < 0)
3388 goto fail;
3389
3390 r = sd_event_source_set_io_events(bus->output_io_event_source, e & POLLOUT0x004);
3391 } else
3392 r = sd_event_source_set_io_events(bus->input_io_event_source, e);
3393 if (r < 0)
3394 goto fail;
3395
3396 r = sd_bus_get_timeout(bus, &until);
3397 if (r < 0)
3398 goto fail;
3399 if (r > 0) {
3400 int j;
3401
3402 j = sd_event_source_set_time(bus->time_event_source, until);
3403 if (j < 0) {
3404 r = j;
3405 goto fail;
3406 }
3407 }
3408
3409 r = sd_event_source_set_enabled(bus->time_event_source, r > 0);
3410 if (r < 0)
3411 goto fail;
3412
3413 return 1;
3414
3415fail:
3416 log_debug_errno(r, "Preparing of bus events failed, closing down: %m")({ int _level = ((7)), _e = ((r)), _realm = (LOG_REALM_SYSTEMD
); (log_get_max_level_realm(_realm) >= ((_level) & 0x07
)) ? log_internal_realm(((_realm) << 10 | (_level)), _e
, "../src/libsystemd/sd-bus/sd-bus.c", 3416, __func__, "Preparing of bus events failed, closing down: %m"
) : -abs(_e); });
3417 bus_enter_closing(bus);
3418
3419 return 1;
3420}
3421
3422static int quit_callback(sd_event_source *event, void *userdata) {
3423 sd_bus *bus = userdata;
3424
3425 assert(event)do { if ((__builtin_expect(!!(!(event)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("event"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3425, __PRETTY_FUNCTION__); } while (0);
3426
3427 sd_bus_flush(bus);
3428 sd_bus_close(bus);
3429
3430 return 1;
3431}
3432
3433int bus_attach_io_events(sd_bus *bus) {
3434 int r;
3435
3436 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3436, __PRETTY_FUNCTION__); } while (0);
3437
3438 if (bus->input_fd < 0)
3439 return 0;
3440
3441 if (!bus->event)
3442 return 0;
3443
3444 if (!bus->input_io_event_source) {
3445 r = sd_event_add_io(bus->event, &bus->input_io_event_source, bus->input_fd, 0, io_callback, bus);
3446 if (r < 0)
3447 return r;
3448
3449 r = sd_event_source_set_prepare(bus->input_io_event_source, prepare_callback);
3450 if (r < 0)
3451 return r;
3452
3453 r = sd_event_source_set_priority(bus->input_io_event_source, bus->event_priority);
3454 if (r < 0)
3455 return r;
3456
3457 r = sd_event_source_set_description(bus->input_io_event_source, "bus-input");
3458 } else
3459 r = sd_event_source_set_io_fd(bus->input_io_event_source, bus->input_fd);
3460
3461 if (r < 0)
3462 return r;
3463
3464 if (bus->output_fd != bus->input_fd) {
3465 assert(bus->output_fd >= 0)do { if ((__builtin_expect(!!(!(bus->output_fd >= 0)),0
))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("bus->output_fd >= 0"
), "../src/libsystemd/sd-bus/sd-bus.c", 3465, __PRETTY_FUNCTION__
); } while (0);
3466
3467 if (!bus->output_io_event_source) {
3468 r = sd_event_add_io(bus->event, &bus->output_io_event_source, bus->output_fd, 0, io_callback, bus);
3469 if (r < 0)
3470 return r;
3471
3472 r = sd_event_source_set_priority(bus->output_io_event_source, bus->event_priority);
3473 if (r < 0)
3474 return r;
3475
3476 r = sd_event_source_set_description(bus->input_io_event_source, "bus-output");
3477 } else
3478 r = sd_event_source_set_io_fd(bus->output_io_event_source, bus->output_fd);
3479
3480 if (r < 0)
3481 return r;
3482 }
3483
3484 return 0;
3485}
3486
3487static void bus_detach_io_events(sd_bus *bus) {
3488 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3488, __PRETTY_FUNCTION__); } while (0);
3489
3490 if (bus->input_io_event_source) {
3491 sd_event_source_set_enabled(bus->input_io_event_source, SD_EVENT_OFF);
3492 bus->input_io_event_source = sd_event_source_unref(bus->input_io_event_source);
3493 }
3494
3495 if (bus->output_io_event_source) {
3496 sd_event_source_set_enabled(bus->output_io_event_source, SD_EVENT_OFF);
3497 bus->output_io_event_source = sd_event_source_unref(bus->output_io_event_source);
3498 }
3499}
3500
3501int bus_attach_inotify_event(sd_bus *bus) {
3502 int r;
3503
3504 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3504, __PRETTY_FUNCTION__); } while (0);
3505
3506 if (bus->inotify_fd < 0)
3507 return 0;
3508
3509 if (!bus->event)
3510 return 0;
3511
3512 if (!bus->inotify_event_source) {
3513 r = sd_event_add_io(bus->event, &bus->inotify_event_source, bus->inotify_fd, EPOLLINEPOLLIN, io_callback, bus);
3514 if (r < 0)
3515 return r;
3516
3517 r = sd_event_source_set_priority(bus->inotify_event_source, bus->event_priority);
3518 if (r < 0)
3519 return r;
3520
3521 r = sd_event_source_set_description(bus->inotify_event_source, "bus-inotify");
3522 } else
3523 r = sd_event_source_set_io_fd(bus->inotify_event_source, bus->inotify_fd);
3524 if (r < 0)
3525 return r;
3526
3527 return 0;
3528}
3529
3530static void bus_detach_inotify_event(sd_bus *bus) {
3531 assert(bus)do { if ((__builtin_expect(!!(!(bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3531, __PRETTY_FUNCTION__); } while (0);
3532
3533 if (bus->inotify_event_source) {
3534 sd_event_source_set_enabled(bus->inotify_event_source, SD_EVENT_OFF);
3535 bus->inotify_event_source = sd_event_source_unref(bus->inotify_event_source);
3536 }
3537}
3538
3539_public___attribute__ ((visibility("default"))) int sd_bus_attach_event(sd_bus *bus, sd_event *event, int priority) {
3540 int r;
3541
3542 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3542, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3543 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3543, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3544 assert_return(!bus->event, -EBUSY)do { if (!(((__builtin_expect(!!(!bus->event),1))) ? (1) :
(log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus->event"
), "../src/libsystemd/sd-bus/sd-bus.c", 3544, __PRETTY_FUNCTION__
), 0))) return (-16); } while (0);
3545
3546 assert(!bus->input_io_event_source)do { if ((__builtin_expect(!!(!(!bus->input_io_event_source
)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("!bus->input_io_event_source"
), "../src/libsystemd/sd-bus/sd-bus.c", 3546, __PRETTY_FUNCTION__
); } while (0);
3547 assert(!bus->output_io_event_source)do { if ((__builtin_expect(!!(!(!bus->output_io_event_source
)),0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("!bus->output_io_event_source"
), "../src/libsystemd/sd-bus/sd-bus.c", 3547, __PRETTY_FUNCTION__
); } while (0);
3548 assert(!bus->time_event_source)do { if ((__builtin_expect(!!(!(!bus->time_event_source)),
0))) log_assert_failed_realm(LOG_REALM_SYSTEMD, ("!bus->time_event_source"
), "../src/libsystemd/sd-bus/sd-bus.c", 3548, __PRETTY_FUNCTION__
); } while (0);
3549
3550 if (event)
3551 bus->event = sd_event_ref(event);
3552 else {
3553 r = sd_event_default(&bus->event);
3554 if (r < 0)
3555 return r;
3556 }
3557
3558 bus->event_priority = priority;
3559
3560 r = sd_event_add_time(bus->event, &bus->time_event_source, CLOCK_MONOTONIC1, 0, 0, time_callback, bus);
3561 if (r < 0)
3562 goto fail;
3563
3564 r = sd_event_source_set_priority(bus->time_event_source, priority);
3565 if (r < 0)
3566 goto fail;
3567
3568 r = sd_event_source_set_description(bus->time_event_source, "bus-time");
3569 if (r < 0)
3570 goto fail;
3571
3572 r = sd_event_add_exit(bus->event, &bus->quit_event_source, quit_callback, bus);
3573 if (r < 0)
3574 goto fail;
3575
3576 r = sd_event_source_set_description(bus->quit_event_source, "bus-exit");
3577 if (r < 0)
3578 goto fail;
3579
3580 r = bus_attach_io_events(bus);
3581 if (r < 0)
3582 goto fail;
3583
3584 r = bus_attach_inotify_event(bus);
3585 if (r < 0)
3586 goto fail;
3587
3588 return 0;
3589
3590fail:
3591 sd_bus_detach_event(bus);
3592 return r;
3593}
3594
3595_public___attribute__ ((visibility("default"))) int sd_bus_detach_event(sd_bus *bus) {
3596 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3596, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3597 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3597, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3598
3599 if (!bus->event)
3600 return 0;
3601
3602 bus_detach_io_events(bus);
3603 bus_detach_inotify_event(bus);
3604
3605 if (bus->time_event_source) {
3606 sd_event_source_set_enabled(bus->time_event_source, SD_EVENT_OFF);
3607 bus->time_event_source = sd_event_source_unref(bus->time_event_source);
3608 }
3609
3610 if (bus->quit_event_source) {
3611 sd_event_source_set_enabled(bus->quit_event_source, SD_EVENT_OFF);
3612 bus->quit_event_source = sd_event_source_unref(bus->quit_event_source);
3613 }
3614
3615 bus->event = sd_event_unref(bus->event);
3616 return 1;
3617}
3618
3619_public___attribute__ ((visibility("default"))) sd_event* sd_bus_get_event(sd_bus *bus) {
3620 assert_return(bus, NULL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3620, __PRETTY_FUNCTION__), 0))) return (((void*)0)); } while
(0);
3621
3622 return bus->event;
3623}
3624
3625_public___attribute__ ((visibility("default"))) sd_bus_message* sd_bus_get_current_message(sd_bus *bus) {
3626 assert_return(bus, NULL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3626, __PRETTY_FUNCTION__), 0))) return (((void*)0)); } while
(0);
3627
3628 return bus->current_message;
3629}
3630
3631_public___attribute__ ((visibility("default"))) sd_bus_slot* sd_bus_get_current_slot(sd_bus *bus) {
3632 assert_return(bus, NULL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3632, __PRETTY_FUNCTION__), 0))) return (((void*)0)); } while
(0);
3633
3634 return bus->current_slot;
3635}
3636
3637_public___attribute__ ((visibility("default"))) sd_bus_message_handler_t sd_bus_get_current_handler(sd_bus *bus) {
3638 assert_return(bus, NULL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3638, __PRETTY_FUNCTION__), 0))) return (((void*)0)); } while
(0);
3639
3640 return bus->current_handler;
3641}
3642
3643_public___attribute__ ((visibility("default"))) void* sd_bus_get_current_userdata(sd_bus *bus) {
3644 assert_return(bus, NULL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3644, __PRETTY_FUNCTION__), 0))) return (((void*)0)); } while
(0);
3645
3646 return bus->current_userdata;
3647}
3648
3649static int bus_default(int (*bus_open)(sd_bus **), sd_bus **default_bus, sd_bus **ret) {
3650 sd_bus *b = NULL((void*)0);
3651 int r;
3652
3653 assert(bus_open)do { if ((__builtin_expect(!!(!(bus_open)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("bus_open"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3653, __PRETTY_FUNCTION__); } while (0);
3654 assert(default_bus)do { if ((__builtin_expect(!!(!(default_bus)),0))) log_assert_failed_realm
(LOG_REALM_SYSTEMD, ("default_bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3654, __PRETTY_FUNCTION__); } while (0);
3655
3656 if (!ret)
3657 return !!*default_bus;
3658
3659 if (*default_bus) {
3660 *ret = sd_bus_ref(*default_bus);
3661 return 0;
3662 }
3663
3664 r = bus_open(&b);
3665 if (r < 0)
3666 return r;
3667
3668 b->default_bus_ptr = default_bus;
3669 b->tid = gettid();
3670 *default_bus = b;
3671
3672 *ret = b;
3673 return 1;
3674}
3675
3676_public___attribute__ ((visibility("default"))) int sd_bus_default_system(sd_bus **ret) {
3677 return bus_default(sd_bus_open_system, &default_system_bus, ret);
3678}
3679
3680_public___attribute__ ((visibility("default"))) int sd_bus_default_user(sd_bus **ret) {
3681 return bus_default(sd_bus_open_user, &default_user_bus, ret);
3682}
3683
3684_public___attribute__ ((visibility("default"))) int sd_bus_default(sd_bus **ret) {
3685 int (*bus_open)(sd_bus **) = NULL((void*)0);
3686 sd_bus **busp;
3687
3688 busp = bus_choose_default(&bus_open);
3689 return bus_default(bus_open, busp, ret);
3690}
3691
3692_public___attribute__ ((visibility("default"))) int sd_bus_get_tid(sd_bus *b, pid_t *tid) {
3693 assert_return(b, -EINVAL)do { if (!(((__builtin_expect(!!(b),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("b"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3693, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3694 assert_return(tid, -EINVAL)do { if (!(((__builtin_expect(!!(tid),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("tid"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3694, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3695 assert_return(!bus_pid_changed(b), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(b)),1))) ? (
1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(b)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3695, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3696
3697 if (b->tid != 0) {
3698 *tid = b->tid;
3699 return 0;
3700 }
3701
3702 if (b->event)
3703 return sd_event_get_tid(b->event, tid);
3704
3705 return -ENXIO6;
3706}
3707
3708_public___attribute__ ((visibility("default"))) int sd_bus_path_encode(const char *prefix, const char *external_id, char **ret_path) {
3709 _cleanup_free___attribute__((cleanup(freep))) char *e = NULL((void*)0);
3710 char *ret;
3711
3712 assert_return(object_path_is_valid(prefix), -EINVAL)do { if (!(((__builtin_expect(!!(object_path_is_valid(prefix)
),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("object_path_is_valid(prefix)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3712, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3713 assert_return(external_id, -EINVAL)do { if (!(((__builtin_expect(!!(external_id),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("external_id"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3713, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3714 assert_return(ret_path, -EINVAL)do { if (!(((__builtin_expect(!!(ret_path),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret_path"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3714, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3715
3716 e = bus_label_escape(external_id);
3717 if (!e)
3718 return -ENOMEM12;
3719
3720 ret = strjoin(prefix, "/", e)strjoin_real((prefix), "/", e, ((void*)0));
3721 if (!ret)
3722 return -ENOMEM12;
3723
3724 *ret_path = ret;
3725 return 0;
3726}
3727
3728_public___attribute__ ((visibility("default"))) int sd_bus_path_decode(const char *path, const char *prefix, char **external_id) {
3729 const char *e;
3730 char *ret;
3731
3732 assert_return(object_path_is_valid(path), -EINVAL)do { if (!(((__builtin_expect(!!(object_path_is_valid(path)),
1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("object_path_is_valid(path)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3732, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3733 assert_return(object_path_is_valid(prefix), -EINVAL)do { if (!(((__builtin_expect(!!(object_path_is_valid(prefix)
),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("object_path_is_valid(prefix)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3733, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3734 assert_return(external_id, -EINVAL)do { if (!(((__builtin_expect(!!(external_id),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("external_id"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3734, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3735
3736 e = object_path_startswith(path, prefix);
3737 if (!e) {
3738 *external_id = NULL((void*)0);
3739 return 0;
3740 }
3741
3742 ret = bus_label_unescape(e);
3743 if (!ret)
3744 return -ENOMEM12;
3745
3746 *external_id = ret;
3747 return 1;
3748}
3749
3750_public___attribute__ ((visibility("default"))) int sd_bus_path_encode_many(char **out, const char *path_template, ...) {
3751 _cleanup_strv_free___attribute__((cleanup(strv_freep))) char **labels = NULL((void*)0);
3752 char *path, *path_pos, **label_pos;
3753 const char *sep, *template_pos;
3754 size_t path_length;
3755 va_list list;
3756 int r;
3757
3758 assert_return(out, -EINVAL)do { if (!(((__builtin_expect(!!(out),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("out"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3758, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3759 assert_return(path_template, -EINVAL)do { if (!(((__builtin_expect(!!(path_template),1))) ? (1) : (
log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("path_template"
), "../src/libsystemd/sd-bus/sd-bus.c", 3759, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
3760
3761 path_length = strlen(path_template);
3762
3763 va_start(list, path_template)__builtin_va_start(list, path_template);
3764 for (sep = strchr(path_template, '%'); sep; sep = strchr(sep + 1, '%')) {
3765 const char *arg;
3766 char *label;
3767
3768 arg = va_arg(list, const char *)__builtin_va_arg(list, const char *);
3769 if (!arg) {
3770 va_end(list)__builtin_va_end(list);
3771 return -EINVAL22;
3772 }
3773
3774 label = bus_label_escape(arg);
3775 if (!label) {
3776 va_end(list)__builtin_va_end(list);
3777 return -ENOMEM12;
3778 }
3779
3780 r = strv_consume(&labels, label);
3781 if (r < 0) {
3782 va_end(list)__builtin_va_end(list);
3783 return r;
3784 }
3785
3786 /* add label length, but account for the format character */
3787 path_length += strlen(label) - 1;
3788 }
3789 va_end(list)__builtin_va_end(list);
3790
3791 path = malloc(path_length + 1);
3792 if (!path)
3793 return -ENOMEM12;
3794
3795 path_pos = path;
3796 label_pos = labels;
3797
3798 for (template_pos = path_template; *template_pos; ) {
3799 sep = strchrnul(template_pos, '%');
3800 path_pos = mempcpy(path_pos, template_pos, sep - template_pos);
3801 if (!*sep)
3802 break;
3803
3804 path_pos = stpcpy(path_pos, *label_pos++);
3805 template_pos = sep + 1;
3806 }
3807
3808 *path_pos = 0;
3809 *out = path;
3810 return 0;
3811}
3812
3813_public___attribute__ ((visibility("default"))) int sd_bus_path_decode_many(const char *path, const char *path_template, ...) {
3814 _cleanup_strv_free___attribute__((cleanup(strv_freep))) char **labels = NULL((void*)0);
3815 const char *template_pos, *path_pos;
3816 char **label_pos;
3817 va_list list;
3818 int r;
3819
3820 /*
3821 * This decodes an object-path based on a template argument. The
3822 * template consists of a verbatim path, optionally including special
3823 * directives:
3824 *
3825 * - Each occurrence of '%' in the template matches an arbitrary
3826 * substring of a label in the given path. At most one such
3827 * directive is allowed per label. For each such directive, the
3828 * caller must provide an output parameter (char **) via va_arg. If
3829 * NULL is passed, the given label is verified, but not returned.
3830 * For each matched label, the *decoded* label is stored in the
3831 * passed output argument, and the caller is responsible to free
3832 * it. Note that the output arguments are only modified if the
3833 * actualy path matched the template. Otherwise, they're left
3834 * untouched.
3835 *
3836 * This function returns <0 on error, 0 if the path does not match the
3837 * template, 1 if it matched.
3838 */
3839
3840 assert_return(path, -EINVAL)do { if (!(((__builtin_expect(!!(path),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("path"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3840, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3841 assert_return(path_template, -EINVAL)do { if (!(((__builtin_expect(!!(path_template),1))) ? (1) : (
log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("path_template"
), "../src/libsystemd/sd-bus/sd-bus.c", 3841, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
3842
3843 path_pos = path;
3844
3845 for (template_pos = path_template; *template_pos; ) {
3846 const char *sep;
3847 size_t length;
3848 char *label;
3849
3850 /* verify everything until the next '%' matches verbatim */
3851 sep = strchrnul(template_pos, '%');
3852 length = sep - template_pos;
3853 if (strncmp(path_pos, template_pos, length))
3854 return 0;
3855
3856 path_pos += length;
3857 template_pos += length;
3858
3859 if (!*template_pos)
3860 break;
3861
3862 /* We found the next '%' character. Everything up until here
3863 * matched. We now skip ahead to the end of this label and make
3864 * sure it matches the tail of the label in the path. Then we
3865 * decode the string in-between and save it for later use. */
3866
3867 ++template_pos; /* skip over '%' */
3868
3869 sep = strchrnul(template_pos, '/');
3870 length = sep - template_pos; /* length of suffix to match verbatim */
3871
3872 /* verify the suffixes match */
3873 sep = strchrnul(path_pos, '/');
3874 if (sep - path_pos < (ssize_t)length ||
3875 strncmp(sep - length, template_pos, length))
3876 return 0;
3877
3878 template_pos += length; /* skip over matched label */
3879 length = sep - path_pos - length; /* length of sub-label to decode */
3880
3881 /* store unescaped label for later use */
3882 label = bus_label_unescape_n(path_pos, length);
3883 if (!label)
3884 return -ENOMEM12;
3885
3886 r = strv_consume(&labels, label);
3887 if (r < 0)
3888 return r;
3889
3890 path_pos = sep; /* skip decoded label and suffix */
3891 }
3892
3893 /* end of template must match end of path */
3894 if (*path_pos)
3895 return 0;
3896
3897 /* copy the labels over to the caller */
3898 va_start(list, path_template)__builtin_va_start(list, path_template);
3899 for (label_pos = labels; label_pos && *label_pos; ++label_pos) {
3900 char **arg;
3901
3902 arg = va_arg(list, char **)__builtin_va_arg(list, char **);
3903 if (arg)
3904 *arg = *label_pos;
3905 else
3906 free(*label_pos);
3907 }
3908 va_end(list)__builtin_va_end(list);
3909
3910 labels = mfree(labels);
3911 return 1;
3912}
3913
3914_public___attribute__ ((visibility("default"))) int sd_bus_try_close(sd_bus *bus) {
3915 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3915, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3916 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3916, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3917 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3917, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3918
3919 return -EOPNOTSUPP95;
3920}
3921
3922_public___attribute__ ((visibility("default"))) int sd_bus_get_description(sd_bus *bus, const char **description) {
3923 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3923, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3924 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3924, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3925 assert_return(description, -EINVAL)do { if (!(((__builtin_expect(!!(description),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("description"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3925, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3926 assert_return(bus->description, -ENXIO)do { if (!(((__builtin_expect(!!(bus->description),1))) ? (
1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("bus->description"
), "../src/libsystemd/sd-bus/sd-bus.c", 3926, __PRETTY_FUNCTION__
), 0))) return (-6); } while (0);
3927 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3927, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3928
3929 if (bus->description)
3930 *description = bus->description;
3931 else if (bus->is_system)
3932 *description = "system";
3933 else if (bus->is_user)
3934 *description = "user";
3935 else
3936 *description = NULL((void*)0);
3937
3938 return 0;
3939}
3940
3941int bus_get_root_path(sd_bus *bus) {
3942 int r;
3943
3944 if (bus->cgroup_root)
3945 return 0;
3946
3947 r = cg_get_root_path(&bus->cgroup_root);
3948 if (r == -ENOENT2) {
3949 bus->cgroup_root = strdup("/");
3950 if (!bus->cgroup_root)
3951 return -ENOMEM12;
3952
3953 r = 0;
3954 }
3955
3956 return r;
3957}
3958
3959_public___attribute__ ((visibility("default"))) int sd_bus_get_scope(sd_bus *bus, const char **scope) {
3960 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3960, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3961 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3961, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3962 assert_return(scope, -EINVAL)do { if (!(((__builtin_expect(!!(scope),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("scope"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3962, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3963 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3963, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3964
3965 if (bus->is_user) {
3966 *scope = "user";
3967 return 0;
3968 }
3969
3970 if (bus->is_system) {
3971 *scope = "system";
3972 return 0;
3973 }
3974
3975 return -ENODATA61;
3976}
3977
3978_public___attribute__ ((visibility("default"))) int sd_bus_get_address(sd_bus *bus, const char **address) {
3979
3980 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3980, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3981 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3981, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3982 assert_return(address, -EINVAL)do { if (!(((__builtin_expect(!!(address),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("address"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3982, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3983 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3983, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3984
3985 if (bus->address) {
3986 *address = bus->address;
3987 return 0;
3988 }
3989
3990 return -ENODATA61;
3991}
3992
3993_public___attribute__ ((visibility("default"))) int sd_bus_get_creds_mask(sd_bus *bus, uint64_t *mask) {
3994 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3994, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3995 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3995, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
3996 assert_return(mask, -EINVAL)do { if (!(((__builtin_expect(!!(mask),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("mask"), "../src/libsystemd/sd-bus/sd-bus.c"
, 3996, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
3997 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 3997, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
3998
3999 *mask = bus->creds_mask;
4000 return 0;
4001}
4002
4003_public___attribute__ ((visibility("default"))) int sd_bus_is_bus_client(sd_bus *bus) {
4004 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4004, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4005 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4005, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4006 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4006, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4007
4008 return bus->bus_client;
4009}
4010
4011_public___attribute__ ((visibility("default"))) int sd_bus_is_server(sd_bus *bus) {
4012 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4012, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4013 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4013, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4014 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4014, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4015
4016 return bus->is_server;
4017}
4018
4019_public___attribute__ ((visibility("default"))) int sd_bus_is_anonymous(sd_bus *bus) {
4020 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4020, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4021 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4021, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4022 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4022, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4023
4024 return bus->anonymous_auth;
4025}
4026
4027_public___attribute__ ((visibility("default"))) int sd_bus_is_trusted(sd_bus *bus) {
4028 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4028, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4029 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4029, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4030 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4030, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4031
4032 return bus->trusted;
4033}
4034
4035_public___attribute__ ((visibility("default"))) int sd_bus_is_monitor(sd_bus *bus) {
4036 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4036, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4037 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4037, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4038 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4038, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4039
4040 return bus->is_monitor;
4041}
4042
4043static void flush_close(sd_bus *bus) {
4044 if (!bus)
4045 return;
4046
4047 /* Flushes and closes the specified bus. We take a ref before,
4048 * to ensure the flushing does not cause the bus to be
4049 * unreferenced. */
4050
4051 sd_bus_flush_close_unref(sd_bus_ref(bus));
4052}
4053
4054_public___attribute__ ((visibility("default"))) void sd_bus_default_flush_close(void) {
4055 flush_close(default_starter_bus);
4056 flush_close(default_user_bus);
4057 flush_close(default_system_bus);
4058}
4059
4060_public___attribute__ ((visibility("default"))) int sd_bus_set_exit_on_disconnect(sd_bus *bus, int b) {
4061 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4061, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4062 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4062, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4063
4064 /* Turns on exit-on-disconnect, and triggers it immediately if the bus connection was already
4065 * disconnected. Note that this is triggered exclusively on disconnections triggered by the server side, never
4066 * from the client side. */
4067 bus->exit_on_disconnect = b;
4068
4069 /* If the exit condition was triggered already, exit immediately. */
4070 return bus_exit_now(bus);
4071}
4072
4073_public___attribute__ ((visibility("default"))) int sd_bus_get_exit_on_disconnect(sd_bus *bus) {
4074 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4074, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4075 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4075, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4076
4077 return bus->exit_on_disconnect;
4078}
4079
4080_public___attribute__ ((visibility("default"))) int sd_bus_set_sender(sd_bus *bus, const char *sender) {
4081 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4081, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4082 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4082, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4083 assert_return(!bus->bus_client, -EPERM)do { if (!(((__builtin_expect(!!(!bus->bus_client),1))) ? (
1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus->bus_client"
), "../src/libsystemd/sd-bus/sd-bus.c", 4083, __PRETTY_FUNCTION__
), 0))) return (-1); } while (0);
4084 assert_return(!sender || service_name_is_valid(sender), -EINVAL)do { if (!(((__builtin_expect(!!(!sender || service_name_is_valid
(sender)),1))) ? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD
, ("!sender || service_name_is_valid(sender)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4084, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4085
4086 return free_and_strdup(&bus->patch_sender, sender);
4087}
4088
4089_public___attribute__ ((visibility("default"))) int sd_bus_get_sender(sd_bus *bus, const char **ret) {
4090 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4090, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4091 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4091, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4092 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4092, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4093
4094 if (!bus->patch_sender)
4095 return -ENODATA61;
4096
4097 *ret = bus->patch_sender;
4098 return 0;
4099}
4100
4101_public___attribute__ ((visibility("default"))) int sd_bus_get_n_queued_read(sd_bus *bus, uint64_t *ret) {
4102 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4102, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4103 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4103, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4104 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4104, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4105 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4105, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4106
4107 *ret = bus->rqueue_size;
4108 return 0;
4109}
4110
4111_public___attribute__ ((visibility("default"))) int sd_bus_get_n_queued_write(sd_bus *bus, uint64_t *ret) {
4112 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4112, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4113 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4113, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4114 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4114, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4115 assert_return(ret, -EINVAL)do { if (!(((__builtin_expect(!!(ret),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("ret"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4115, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4116
4117 *ret = bus->wqueue_size;
4118 return 0;
4119}
4120
4121_public___attribute__ ((visibility("default"))) int sd_bus_enqueue_for_read(sd_bus *bus, sd_bus_message *m) {
4122 int r;
4123
4124 assert_return(bus, -EINVAL)do { if (!(((__builtin_expect(!!(bus),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("bus"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4124, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4125 assert_return(bus = bus_resolve(bus), -ENOPKG)do { if (!(((__builtin_expect(!!(bus = bus_resolve(bus)),1)))
? (1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, (
"bus = bus_resolve(bus)"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4125, __PRETTY_FUNCTION__), 0))) return (-65); } while (0);
4126 assert_return(m, -EINVAL)do { if (!(((__builtin_expect(!!(m),1))) ? (1) : (log_assert_failed_return_realm
(LOG_REALM_SYSTEMD, ("m"), "../src/libsystemd/sd-bus/sd-bus.c"
, 4126, __PRETTY_FUNCTION__), 0))) return (-22); } while (0);
4127 assert_return(m->sealed, -EINVAL)do { if (!(((__builtin_expect(!!(m->sealed),1))) ? (1) : (
log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("m->sealed"
), "../src/libsystemd/sd-bus/sd-bus.c", 4127, __PRETTY_FUNCTION__
), 0))) return (-22); } while (0);
4128 assert_return(!bus_pid_changed(bus), -ECHILD)do { if (!(((__builtin_expect(!!(!bus_pid_changed(bus)),1))) ?
(1) : (log_assert_failed_return_realm(LOG_REALM_SYSTEMD, ("!bus_pid_changed(bus)"
), "../src/libsystemd/sd-bus/sd-bus.c", 4128, __PRETTY_FUNCTION__
), 0))) return (-10); } while (0);
4129
4130 if (!BUS_IS_OPEN(bus->state))
4131 return -ENOTCONN107;
4132
4133 /* Re-enqeue a message for reading. This is primarily useful for PolicyKit-style authentication,
4134 * where we want accept a message, then determine we need to interactively authenticate the user, and
4135 * when we have that process the message again. */
4136
4137 r = bus_rqueue_make_room(bus);
4138 if (r < 0)
4139 return r;
4140
4141 bus->rqueue[bus->rqueue_size++] = bus_message_ref_queued(m, bus);
4142 return 0;
4143}