sd-bus: allow passing NULL as bus parameter to sd_bus_send()
If NULL is specified for the bus it is now automatically derived from the passed in message. This commit also changes a number of invocations of sd_bus_send() to make use of this.
This commit is contained in:
parent
47ee3ee034
commit
9030ca462b
|
@ -916,7 +916,7 @@ static int list_units_filtered(sd_bus_message *message, void *userdata, sd_bus_e
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_list_units(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -985,7 +985,7 @@ static int method_list_jobs(sd_bus_message *message, void *userdata, sd_bus_erro
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_subscribe(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -1502,7 +1502,7 @@ static int method_list_unit_files(sd_bus_message *message, void *userdata, sd_bu
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
|
||||
fail:
|
||||
unit_file_list_free(h);
|
||||
|
@ -1620,7 +1620,7 @@ static int reply_unit_file_changes_and_free(
|
|||
if (r < 0)
|
||||
goto fail;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(message), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
|
||||
fail:
|
||||
unit_file_changes_free(changes, n_changes);
|
||||
|
|
|
@ -1064,7 +1064,7 @@ static int method_list_transfers(sd_bus_message *msg, void *userdata, sd_bus_err
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(msg), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_cancel(sd_bus_message *msg, void *userdata, sd_bus_error *error) {
|
||||
|
|
|
@ -1695,8 +1695,11 @@ static int bus_send_internal(sd_bus *bus, sd_bus_message *_m, uint64_t *cookie,
|
|||
_cleanup_bus_message_unref_ sd_bus_message *m = sd_bus_message_ref(_m);
|
||||
int r;
|
||||
|
||||
assert_return(bus, -EINVAL);
|
||||
assert_return(m, -EINVAL);
|
||||
|
||||
if (!bus)
|
||||
bus = m->bus;
|
||||
|
||||
assert_return(!bus_pid_changed(bus), -ECHILD);
|
||||
assert_return(!bus->is_kernel || !(bus->hello_flags & KDBUS_HELLO_MONITOR), -EROFS);
|
||||
|
||||
|
@ -1781,8 +1784,11 @@ _public_ int sd_bus_send(sd_bus *bus, sd_bus_message *m, uint64_t *cookie) {
|
|||
_public_ int sd_bus_send_to(sd_bus *bus, sd_bus_message *m, const char *destination, uint64_t *cookie) {
|
||||
int r;
|
||||
|
||||
assert_return(bus, -EINVAL);
|
||||
assert_return(m, -EINVAL);
|
||||
|
||||
if (!bus)
|
||||
bus = m->bus;
|
||||
|
||||
assert_return(!bus_pid_changed(bus), -ECHILD);
|
||||
|
||||
if (!BUS_IS_OPEN(bus->state))
|
||||
|
@ -1838,11 +1844,14 @@ _public_ int sd_bus_call_async(
|
|||
_cleanup_bus_slot_unref_ sd_bus_slot *s = NULL;
|
||||
int r;
|
||||
|
||||
assert_return(bus, -EINVAL);
|
||||
assert_return(m, -EINVAL);
|
||||
assert_return(m->header->type == SD_BUS_MESSAGE_METHOD_CALL, -EINVAL);
|
||||
assert_return(!(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED), -EINVAL);
|
||||
assert_return(callback, -EINVAL);
|
||||
|
||||
if (!bus)
|
||||
bus = m->bus;
|
||||
|
||||
assert_return(!bus_pid_changed(bus), -ECHILD);
|
||||
assert_return(!bus->is_kernel || !(bus->hello_flags & KDBUS_HELLO_MONITOR), -EROFS);
|
||||
|
||||
|
@ -1936,11 +1945,14 @@ _public_ int sd_bus_call(
|
|||
unsigned i;
|
||||
int r;
|
||||
|
||||
assert_return(bus, -EINVAL);
|
||||
assert_return(m, -EINVAL);
|
||||
assert_return(m->header->type == SD_BUS_MESSAGE_METHOD_CALL, -EINVAL);
|
||||
assert_return(!(m->header->flags & BUS_MESSAGE_NO_REPLY_EXPECTED), -EINVAL);
|
||||
assert_return(!bus_error_is_dirty(error), -EINVAL);
|
||||
|
||||
if (!bus)
|
||||
bus = m->bus;
|
||||
|
||||
assert_return(!bus_pid_changed(bus), -ECHILD);
|
||||
assert_return(!bus->is_kernel || !(bus->hello_flags & KDBUS_HELLO_MONITOR), -EROFS);
|
||||
|
||||
|
|
|
@ -428,7 +428,7 @@ static int method_list_sessions(sd_bus_message *message, void *userdata, sd_bus_
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_list_users(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -468,7 +468,7 @@ static int method_list_users(sd_bus_message *message, void *userdata, sd_bus_err
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_list_seats(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -505,7 +505,7 @@ static int method_list_seats(sd_bus_message *message, void *userdata, sd_bus_err
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_list_inhibitors(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -543,7 +543,7 @@ static int method_list_inhibitors(sd_bus_message *message, void *userdata, sd_bu
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_create_session(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
|
|
@ -335,7 +335,7 @@ int bus_machine_method_get_addresses(sd_bus_message *message, void *userdata, sd
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
int bus_machine_method_get_os_release(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -426,7 +426,7 @@ int bus_machine_method_get_os_release(sd_bus_message *message, void *userdata, s
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
int bus_machine_method_open_pty(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -458,7 +458,7 @@ int bus_machine_method_open_pty(sd_bus_message *message, void *userdata, sd_bus_
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
int bus_machine_method_open_login(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
@ -551,7 +551,7 @@ int bus_machine_method_open_login(sd_bus_message *message, void *userdata, sd_bu
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(reply), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
int bus_machine_method_bind_mount(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
|
|
@ -255,7 +255,7 @@ static int method_list_machines(sd_bus_message *message, void *userdata, sd_bus_
|
|||
if (r < 0)
|
||||
return sd_bus_error_set_errno(error, r);
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(message), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_create_or_register_machine(Manager *manager, sd_bus_message *message, bool read_network, Machine **_m, sd_bus_error *error) {
|
||||
|
@ -593,7 +593,7 @@ static int method_list_images(sd_bus_message *message, void *userdata, sd_bus_er
|
|||
if (r < 0)
|
||||
return r;
|
||||
|
||||
return sd_bus_send(sd_bus_message_get_bus(message), reply, NULL);
|
||||
return sd_bus_send(NULL, reply, NULL);
|
||||
}
|
||||
|
||||
static int method_open_machine_pty(sd_bus_message *message, void *userdata, sd_bus_error *error) {
|
||||
|
|
Loading…
Reference in New Issue