64 static int bus_poll(sd_bus *bus, bool need_more, uint64_t timeout_usec);
65 static void bus_detach_io_events(sd_bus *b);
67 static thread_local sd_bus *default_system_bus = NULL;
68 static thread_local sd_bus *default_user_bus = NULL;
69 static thread_local sd_bus *default_starter_bus = NULL;
71 static sd_bus **bus_choose_default(int (**bus_open)(sd_bus **)) {  in bus_choose_default()  argument
116 sd_bus *bus_resolve(sd_bus *bus) {  in bus_resolve()
129 void bus_close_io_fds(sd_bus *b) {  in bus_close_io_fds()
139 void bus_close_inotify_fd(sd_bus *b) {  in bus_close_inotify_fd()
149 static void bus_reset_queues(sd_bus *b) {  in bus_reset_queues()
163 static sd_bus* bus_free(sd_bus *b) {  in bus_free()
229 DEFINE_TRIVIAL_CLEANUP_FUNC(sd_bus*, bus_free);
231 _public_ int sd_bus_new(sd_bus **ret) {  in sd_bus_new()
232         _cleanup_free_ sd_bus *b = NULL;  in sd_bus_new()
236         b = new(sd_bus, 1);  in sd_bus_new()
240         *b = (sd_bus) {  in sd_bus_new()
264 _public_ int sd_bus_set_address(sd_bus *bus, const char *address) {  in sd_bus_set_address()
274 _public_ int sd_bus_set_fd(sd_bus *bus, int input_fd, int output_fd) {  in sd_bus_set_fd()
287 _public_ int sd_bus_set_exec(sd_bus *bus, const char *path, char *const *argv) {  in sd_bus_set_exec()
309 _public_ int sd_bus_set_bus_client(sd_bus *bus, int b) {  in sd_bus_set_bus_client()
320 _public_ int sd_bus_set_monitor(sd_bus *bus, int b) {  in sd_bus_set_monitor()
330 _public_ int sd_bus_negotiate_fds(sd_bus *bus, int b) {  in sd_bus_negotiate_fds()
340 _public_ int sd_bus_negotiate_timestamp(sd_bus *bus, int b) {  in sd_bus_negotiate_timestamp()
353 _public_ int sd_bus_negotiate_creds(sd_bus *bus, int b, uint64_t mask) {  in sd_bus_negotiate_creds()
368 _public_ int sd_bus_set_server(sd_bus *bus, int b, sd_id128_t server_id) {  in sd_bus_set_server()
380 _public_ int sd_bus_set_anonymous(sd_bus *bus, int b) {  in sd_bus_set_anonymous()
390 _public_ int sd_bus_set_trusted(sd_bus *bus, int b) {  in sd_bus_set_trusted()
400 _public_ int sd_bus_set_description(sd_bus *bus, const char *description) {  in sd_bus_set_description()
409 _public_ int sd_bus_set_allow_interactive_authorization(sd_bus *bus, int b) {  in sd_bus_set_allow_interactive_authorization()
418 _public_ int sd_bus_get_allow_interactive_authorization(sd_bus *bus) {  in sd_bus_get_allow_interactive_authorization()
426 _public_ int sd_bus_set_watch_bind(sd_bus *bus, int b) {  in sd_bus_set_watch_bind()
436 _public_ int sd_bus_get_watch_bind(sd_bus *bus) {  in sd_bus_get_watch_bind()
444 _public_ int sd_bus_set_connected_signal(sd_bus *bus, int b) {  in sd_bus_set_connected_signal()
454 _public_ int sd_bus_get_connected_signal(sd_bus *bus) {  in sd_bus_get_connected_signal()
462 static int synthesize_connected_signal(sd_bus *bus) {  in synthesize_connected_signal()
506 void bus_set_state(sd_bus *bus, enum bus_state state) {  in bus_set_state()
530         sd_bus *bus;  in hello_callback()
576 static int bus_send_hello(sd_bus *bus) {  in bus_send_hello()
598 int bus_start_running(sd_bus *bus) {  in bus_start_running()
710 static int parse_unix_address(sd_bus *b, const char **p, char **guid) {  in parse_unix_address()
780 static int parse_tcp_address(sd_bus *b, const char **p, char **guid) {  in parse_tcp_address()
845 static int parse_exec_address(sd_bus *b, const char **p, char **guid) {  in parse_exec_address()
937 static int parse_container_unix_address(sd_bus *b, const char **p, char **guid) {  in parse_container_unix_address()
997 static void bus_reset_parsed_address(sd_bus *b) {  in bus_reset_parsed_address()
1009 static int bus_parse_next_address(sd_bus *b) {  in bus_parse_next_address()
1083 static void bus_kill_exec(sd_bus *bus) {  in bus_kill_exec()
1090 static int bus_start_address(sd_bus *b) {  in bus_start_address()
1139 int bus_next_address(sd_bus *b) {  in bus_next_address()
1146 static int bus_start_fd(sd_bus *b) {  in bus_start_fd()
1188 _public_ int sd_bus_start(sd_bus *bus) {  in sd_bus_start()
1216 _public_ int sd_bus_open_with_description(sd_bus **ret, const char *description) {  in sd_bus_open_with_description()
1218         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_with_description()
1267 _public_ int sd_bus_open(sd_bus **ret) {  in sd_bus_open()
1271 int bus_set_address_system(sd_bus *b) {  in bus_set_address_system()
1285 _public_ int sd_bus_open_system_with_description(sd_bus **ret, const char *description) {  in sd_bus_open_system_with_description()
1286         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_system_with_description()
1321 _public_ int sd_bus_open_system(sd_bus **ret) {  in sd_bus_open_system()
1325 int bus_set_address_user(sd_bus *b) {  in bus_set_address_user()
1357 _public_ int sd_bus_open_user_with_description(sd_bus **ret, const char *description) {  in sd_bus_open_user_with_description()
1358         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_user_with_description()
1391 _public_ int sd_bus_open_user(sd_bus **ret) {  in sd_bus_open_user()
1395 int bus_set_address_system_remote(sd_bus *b, const char *host) {  in bus_set_address_system_remote()
1485 _public_ int sd_bus_open_system_remote(sd_bus **ret, const char *host) {  in sd_bus_open_system_remote()
1486         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_system_remote()
1513 int bus_set_address_machine(sd_bus *b, bool user, const char *machine) {  in bus_set_address_machine()
1675 _public_ int sd_bus_open_system_machine(sd_bus **ret, const char *user_and_machine) {  in sd_bus_open_system_machine()
1676         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_system_machine()
1710 _public_ int sd_bus_open_user_machine(sd_bus **ret, const char *user_and_machine) {  in sd_bus_open_user_machine()
1711         _cleanup_(bus_freep) sd_bus *b = NULL;  in sd_bus_open_user_machine()
1746 _public_ void sd_bus_close(sd_bus *bus) {  in sd_bus_close()
1769 _public_ sd_bus *sd_bus_close_unref(sd_bus *bus) {  in sd_bus_close_unref()
1778 _public_ sd_bus* sd_bus_flush_close_unref(sd_bus *bus) {  in sd_bus_flush_close_unref()
1789 void bus_enter_closing(sd_bus *bus) {  in bus_enter_closing()
1798 DEFINE_PUBLIC_TRIVIAL_REF_UNREF_FUNC(sd_bus, sd_bus, bus_free);
1800 _public_ int sd_bus_is_open(sd_bus *bus) {  in sd_bus_is_open()
1810 _public_ int sd_bus_is_ready(sd_bus *bus) {  in sd_bus_is_ready()
1820 _public_ int sd_bus_can_send(sd_bus *bus, char type) {  in sd_bus_can_send()
1845 _public_ int sd_bus_get_bus_id(sd_bus *bus, sd_id128_t *id) {  in sd_bus_get_bus_id()
1873 static int next_cookie(sd_bus *b) {  in next_cookie()
1902 static int bus_seal_message(sd_bus *b, sd_bus_message *m, usec_t timeout) {  in bus_seal_message()
1935 static int bus_remarshal_message(sd_bus *b, sd_bus_message **m) {  in bus_remarshal_message()
1951 int bus_seal_synthetic_message(sd_bus *b, sd_bus_message *m) {  in bus_seal_synthetic_message()
1975 static int bus_write_message(sd_bus *bus, sd_bus_message *m, size_t *idx) {  in bus_write_message()
2002 static int dispatch_wqueue(sd_bus *bus) {  in dispatch_wqueue()
2039 static int bus_read_message(sd_bus *bus) {  in bus_read_message()
2045 int bus_rqueue_make_room(sd_bus *bus) {  in bus_rqueue_make_room()
2057 static void rqueue_drop_one(sd_bus *bus, size_t i) {  in rqueue_drop_one()
2066 static int dispatch_rqueue(sd_bus *bus, sd_bus_message **m) {  in dispatch_rqueue()
2094 _public_ int sd_bus_send(sd_bus *bus, sd_bus_message *_m, uint64_t *cookie) {  in sd_bus_send()
2180 _public_ int sd_bus_send_to(sd_bus *bus, sd_bus_message *m, const char *destination, uint64_t *cook…  in sd_bus_send_to()
2207 static usec_t calc_elapse(sd_bus *bus, uint64_t usec) {  in calc_elapse()
2238                 sd_bus *bus,  in sd_bus_call_async()
2317 int bus_ensure_running(sd_bus *bus) {  in bus_ensure_running()
2344                 sd_bus *bus,  in sd_bus_call()
2490 _public_ int sd_bus_get_fd(sd_bus *bus) {  in sd_bus_get_fd()
2508 _public_ int sd_bus_get_events(sd_bus *bus) {  in sd_bus_get_events()
2554 _public_ int sd_bus_get_timeout(sd_bus *bus, uint64_t *timeout_usec) {  in sd_bus_get_timeout()
2611 static int process_timeout(sd_bus *bus) {  in process_timeout()
2680 static int process_hello(sd_bus *bus, sd_bus_message *m) {  in process_hello()
2701 static int process_reply(sd_bus *bus, sd_bus_message *m) {  in process_reply()
2784 static int process_filter(sd_bus *bus, sd_bus_message *m) {  in process_filter()
2831 static int process_match(sd_bus *bus, sd_bus_message *m) {  in process_match()
2849 static int process_builtin(sd_bus *bus, sd_bus_message *m) {  in process_builtin()
2901 static int process_fd_check(sd_bus *bus, sd_bus_message *m) {  in process_fd_check()
2927 static int process_message(sd_bus *bus, sd_bus_message *m) {  in process_message()
2969 static int dispatch_track(sd_bus *bus) {  in dispatch_track()
2979 static int process_running(sd_bus *bus, sd_bus_message **ret) {  in process_running()
3042 static int bus_exit_now(sd_bus *bus) {  in bus_exit_now()
3067 static int process_closing_reply_callback(sd_bus *bus, struct reply_callback *c) {  in process_closing_reply_callback()
3120 static int process_closing(sd_bus *bus, sd_bus_message **ret) {  in process_closing()
3184 static int bus_process_internal(sd_bus *bus, sd_bus_message **ret) {  in bus_process_internal()
3250 _public_ int sd_bus_process(sd_bus *bus, sd_bus_message **ret) {  in sd_bus_process()
3254 _public_ int sd_bus_process_priority(sd_bus *bus, int64_t priority, sd_bus_message **ret) {  in sd_bus_process_priority()
3258 static int bus_poll(sd_bus *bus, bool need_more, uint64_t timeout_usec) {  in bus_poll()
3323 _public_ int sd_bus_wait(sd_bus *bus, uint64_t timeout_usec) {  in sd_bus_wait()
3341 _public_ int sd_bus_flush(sd_bus *bus) {  in sd_bus_flush()
3386                 sd_bus *bus,  in sd_bus_add_filter()
3438                 sd_bus *bus;  in add_match_callback()
3478                 sd_bus *bus,  in bus_add_match_full()
3565                 sd_bus *bus,  in sd_bus_add_match()
3575                 sd_bus *bus,  in sd_bus_add_match_async()
3585 bool bus_pid_changed(sd_bus *bus) {  in bus_pid_changed()
3595         sd_bus *bus = userdata;  in io_callback()
3612         sd_bus *bus = userdata;  in time_callback()
3627         sd_bus *bus = userdata;  in prepare_callback()
3679         sd_bus *bus = userdata;  in quit_callback()
3691 int bus_attach_io_events(sd_bus *bus) {  in bus_attach_io_events()
3745 static void bus_detach_io_events(sd_bus *bus) {  in bus_detach_io_events()
3752 int bus_attach_inotify_event(sd_bus *bus) {  in bus_attach_inotify_event()
3781 _public_ int sd_bus_attach_event(sd_bus *bus, sd_event *event, int priority) {  in sd_bus_attach_event()
3837 _public_ int sd_bus_detach_event(sd_bus *bus) {  in sd_bus_detach_event()
3853 _public_ sd_event* sd_bus_get_event(sd_bus *bus) {  in sd_bus_get_event()
3859 _public_ sd_bus_message* sd_bus_get_current_message(sd_bus *bus) {  in sd_bus_get_current_message()
3865 _public_ sd_bus_slot* sd_bus_get_current_slot(sd_bus *bus) {  in sd_bus_get_current_slot()
3871 _public_ sd_bus_message_handler_t sd_bus_get_current_handler(sd_bus *bus) {  in sd_bus_get_current_handler()
3877 _public_ void* sd_bus_get_current_userdata(sd_bus *bus) {  in sd_bus_get_current_userdata()
3883 static int bus_default(int (*bus_open)(sd_bus **), sd_bus **default_bus, sd_bus **ret) {  in bus_default()  argument
3884         sd_bus *b = NULL;  in bus_default()
3910 _public_ int sd_bus_default_system(sd_bus **ret) {  in sd_bus_default_system()
3914 _public_ int sd_bus_default_user(sd_bus **ret) {  in sd_bus_default_user()
3918 _public_ int sd_bus_default(sd_bus **ret) {  in sd_bus_default()
3919         int (*bus_open)(sd_bus **) = NULL;  in sd_bus_default()
3920         sd_bus **busp;  in sd_bus_default()
3926 _public_ int sd_bus_get_tid(sd_bus *b, pid_t *tid) {  in sd_bus_get_tid()
4152 _public_ int sd_bus_try_close(sd_bus *bus) {  in sd_bus_try_close()
4160 _public_ int sd_bus_get_description(sd_bus *bus, const char **description) {  in sd_bus_get_description()
4179 _public_ int sd_bus_get_scope(sd_bus *bus, const char **scope) {  in sd_bus_get_scope()
4198 _public_ int sd_bus_get_address(sd_bus *bus, const char **address) {  in sd_bus_get_address()
4212 _public_ int sd_bus_get_creds_mask(sd_bus *bus, uint64_t *mask) {  in sd_bus_get_creds_mask()
4222 _public_ int sd_bus_is_bus_client(sd_bus *bus) {  in sd_bus_is_bus_client()
4230 _public_ int sd_bus_is_server(sd_bus *bus) {  in sd_bus_is_server()
4238 _public_ int sd_bus_is_anonymous(sd_bus *bus) {  in sd_bus_is_anonymous()
4246 _public_ int sd_bus_is_trusted(sd_bus *bus) {  in sd_bus_is_trusted()
4254 _public_ int sd_bus_is_monitor(sd_bus *bus) {  in sd_bus_is_monitor()
4262 static void flush_close(sd_bus *bus) {  in flush_close()
4279 _public_ int sd_bus_set_exit_on_disconnect(sd_bus *bus, int b) {  in sd_bus_set_exit_on_disconnect()
4292 _public_ int sd_bus_get_exit_on_disconnect(sd_bus *bus) {  in sd_bus_get_exit_on_disconnect()
4299 _public_ int sd_bus_set_sender(sd_bus *bus, const char *sender) {  in sd_bus_set_sender()
4308 _public_ int sd_bus_get_sender(sd_bus *bus, const char **ret) {  in sd_bus_get_sender()
4320 _public_ int sd_bus_get_n_queued_read(sd_bus *bus, uint64_t *ret) {  in sd_bus_get_n_queued_read()
4330 _public_ int sd_bus_get_n_queued_write(sd_bus *bus, uint64_t *ret) {  in sd_bus_get_n_queued_write()
4340 _public_ int sd_bus_set_method_call_timeout(sd_bus *bus, uint64_t usec) {  in sd_bus_set_method_call_timeout()
4348 _public_ int sd_bus_get_method_call_timeout(sd_bus *bus, uint64_t *ret) {  in sd_bus_get_method_call_timeout()
4373 _public_ int sd_bus_set_close_on_exit(sd_bus *bus, int b) {  in sd_bus_set_close_on_exit()
4381 _public_ int sd_bus_get_close_on_exit(sd_bus *bus) {  in sd_bus_get_close_on_exit()
4388 _public_ int sd_bus_enqueue_for_read(sd_bus *bus, sd_bus_message *m) {  in sd_bus_enqueue_for_read()