From: Lennart Poettering Date: Thu, 17 Oct 2013 22:47:41 +0000 (+0200) Subject: hostnamed: port over from libdbus to libsystemd-bus X-Git-Tag: v209~1847 X-Git-Url: https://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?p=elogind.git;a=commitdiff_plain;h=66a4c743c070761ee8696aa6302445fecf358441;hp=fe8245eb3c4bc4c492168b861ce3b631479a9046 hostnamed: port over from libdbus to libsystemd-bus --- diff --git a/Makefile.am b/Makefile.am index 36828932e..b337f4f09 100644 --- a/Makefile.am +++ b/Makefile.am @@ -3511,15 +3511,11 @@ if ENABLE_HOSTNAMED systemd_hostnamed_SOURCES = \ src/hostname/hostnamed.c -systemd_hostnamed_CFLAGS = \ - $(AM_CFLAGS) \ - $(DBUS_CFLAGS) - systemd_hostnamed_LDADD = \ libsystemd-label.la \ libsystemd-shared.la \ libsystemd-daemon.la \ - libsystemd-dbus.la + libsystemd-bus.la rootlibexec_PROGRAMS += \ systemd-hostnamed diff --git a/src/hostname/hostnamed.c b/src/hostname/hostnamed.c index 6a43aeb84..a8f0574ec 100644 --- a/src/hostname/hostnamed.c +++ b/src/hostname/hostnamed.c @@ -19,8 +19,6 @@ along with systemd; If not, see . ***/ -#include - #include #include #include @@ -28,57 +26,13 @@ #include "util.h" #include "strv.h" -#include "dbus-common.h" -#include "polkit.h" #include "def.h" #include "virt.h" #include "env-util.h" #include "fileio-label.h" #include "label.h" - -#define INTERFACE \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" \ - " \n" - -#define INTROSPECTION \ - DBUS_INTROSPECT_1_0_XML_DOCTYPE_DECL_NODE \ - "\n" \ - INTERFACE \ - BUS_PROPERTIES_INTERFACE \ - BUS_INTROSPECTABLE_INTERFACE \ - BUS_PEER_INTERFACE \ - "\n" - -#define INTERFACES_LIST \ - BUS_GENERIC_INTERFACES_LIST \ - "org.freedesktop.hostname1\0" - -const char hostname_interface[] _introspect_("hostname1") = INTERFACE; +#include "bus-util.h" +#include "event-util.h" enum { PROP_HOSTNAME, @@ -89,42 +43,48 @@ enum { _PROP_MAX }; -static char *data[_PROP_MAX] = { - NULL, - NULL, - NULL, - NULL, - NULL -}; - -static usec_t remain_until = 0; +typedef struct Context { + char *data[_PROP_MAX]; + Hashmap *polkit_registry; +} Context; -static void free_data(void) { +static void context_reset(Context *c) { int p; + assert(c); + for (p = 0; p < _PROP_MAX; p++) { - free(data[p]); - data[p] = NULL; + free(c->data[p]); + c->data[p] = NULL; } } -static int read_data(void) { +static void context_free(Context *c, sd_bus *bus) { + assert(c); + + context_reset(c); + bus_verify_polkit_async_registry_free(bus, c->polkit_registry); +} + +static int context_read_data(Context *c) { int r; - free_data(); + assert(c); + + context_reset(c); - data[PROP_HOSTNAME] = gethostname_malloc(); - if (!data[PROP_HOSTNAME]) + c->data[PROP_HOSTNAME] = gethostname_malloc(); + if (!c->data[PROP_HOSTNAME]) return -ENOMEM; - r = read_one_line_file("/etc/hostname", &data[PROP_STATIC_HOSTNAME]); + r = read_one_line_file("/etc/hostname", &c->data[PROP_STATIC_HOSTNAME]); if (r < 0 && r != -ENOENT) return r; r = parse_env_file("/etc/machine-info", NEWLINE, - "PRETTY_HOSTNAME", &data[PROP_PRETTY_HOSTNAME], - "ICON_NAME", &data[PROP_ICON_NAME], - "CHASSIS", &data[PROP_CHASSIS], + "PRETTY_HOSTNAME", &c->data[PROP_PRETTY_HOSTNAME], + "ICON_NAME", &c->data[PROP_ICON_NAME], + "CHASSIS", &c->data[PROP_CHASSIS], NULL); if (r < 0 && r != -ENOENT) return r; @@ -253,11 +213,13 @@ try_dmi: return NULL; } -static char* fallback_icon_name(void) { +static char* context_fallback_icon_name(Context *c) { const char *chassis; - if (!isempty(data[PROP_CHASSIS])) - return strappend("computer-", data[PROP_CHASSIS]); + assert(c); + + if (!isempty(c->data[PROP_CHASSIS])) + return strappend("computer-", c->data[PROP_CHASSIS]); chassis = fallback_chassis(); if (chassis) @@ -266,13 +228,15 @@ static char* fallback_icon_name(void) { return strdup("computer"); } -static int write_data_hostname(void) { +static int context_write_data_hostname(Context *c) { const char *hn; - if (isempty(data[PROP_HOSTNAME])) + assert(c); + + if (isempty(c->data[PROP_HOSTNAME])) hn = "localhost"; else - hn = data[PROP_HOSTNAME]; + hn = c->data[PROP_HOSTNAME]; if (sethostname(hn, strlen(hn)) < 0) return -errno; @@ -280,19 +244,21 @@ static int write_data_hostname(void) { return 0; } -static int write_data_static_hostname(void) { +static int context_write_data_static_hostname(Context *c) { - if (isempty(data[PROP_STATIC_HOSTNAME])) { + assert(c); + + if (isempty(c->data[PROP_STATIC_HOSTNAME])) { if (unlink("/etc/hostname") < 0) return errno == ENOENT ? 0 : -errno; return 0; } - return write_string_file_atomic_label("/etc/hostname", data[PROP_STATIC_HOSTNAME]); + return write_string_file_atomic_label("/etc/hostname", c->data[PROP_STATIC_HOSTNAME]); } -static int write_data_other(void) { +static int context_write_data_other(Context *c) { static const char * const name[_PROP_MAX] = { [PROP_PRETTY_HOSTNAME] = "PRETTY_HOSTNAME", @@ -303,6 +269,8 @@ static int write_data_other(void) { char **l = NULL; int r, p; + assert(c); + r = load_env_file("/etc/machine-info", NULL, &l); if (r < 0 && r != -ENOENT) return r; @@ -312,12 +280,12 @@ static int write_data_other(void) { assert(name[p]); - if (isempty(data[p])) { + if (isempty(c->data[p])) { strv_env_unset(l, name[p]); continue; } - if (asprintf(&t, "%s=%s", name[p], strempty(data[p])) < 0) { + if (asprintf(&t, "%s=%s", name[p], strempty(c->data[p])) < 0) { strv_free(l); return -ENOMEM; } @@ -345,340 +313,313 @@ static int write_data_other(void) { return r; } -static int bus_hostname_append_icon_name(DBusMessageIter *i, const char *property, void *userdata) { - const char *name; - _cleanup_free_ char *n = NULL; +static int property_get_icon_name( + sd_bus *bus, + const char *path, + const char *interface, + const char *property, + sd_bus_message *reply, + sd_bus_error *error, + void *userdata) { - assert(i); - assert(property); + _cleanup_free_ char *n = NULL; + Context *c = userdata; + const char *name; + int r; - if (isempty(data[PROP_ICON_NAME])) - name = n = fallback_icon_name(); + if (isempty(c->data[PROP_ICON_NAME])) + name = n = context_fallback_icon_name(c); else - name = data[PROP_ICON_NAME]; + name = c->data[PROP_ICON_NAME]; + + if (!name) + return -ENOMEM; - return bus_property_append_string(i, property, (void*) name); + r = sd_bus_message_append(reply, "s", name); + if (r < 0) + return r; + + return 1; } -static int bus_hostname_append_chassis(DBusMessageIter *i, const char *property, void *userdata) { - const char *name; +static int property_get_chassis( + sd_bus *bus, + const char *path, + const char *interface, + const char *property, + sd_bus_message *reply, + sd_bus_error *error, + void *userdata) { - assert(i); - assert(property); + Context *c = userdata; + const char *name; + int r; - if (isempty(data[PROP_CHASSIS])) + if (isempty(c->data[PROP_CHASSIS])) name = fallback_chassis(); else - name = data[PROP_CHASSIS]; + name = c->data[PROP_CHASSIS]; - return bus_property_append_string(i, property, (void*) name); + r = sd_bus_message_append(reply, "s", name); + if (r < 0) + return r; + + return 1; } -static const BusProperty bus_hostname_properties[] = { - { "Hostname", bus_property_append_string, "s", sizeof(data[0])*PROP_HOSTNAME, true }, - { "StaticHostname", bus_property_append_string, "s", sizeof(data[0])*PROP_STATIC_HOSTNAME, true }, - { "PrettyHostname", bus_property_append_string, "s", sizeof(data[0])*PROP_PRETTY_HOSTNAME, true }, - { "IconName", bus_hostname_append_icon_name, "s", sizeof(data[0])*PROP_ICON_NAME, true }, - { "Chassis", bus_hostname_append_chassis, "s", sizeof(data[0])*PROP_CHASSIS, true }, - { NULL, } -}; +static int method_set_hostname(sd_bus *bus, sd_bus_message *m, void *userdata) { + _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL; + Context *c = userdata; + const char *name; + bool interactive; + char *h; + int r; -static const BusBoundProperties bps[] = { - { "org.freedesktop.hostname1", bus_hostname_properties, data }, - { NULL, } -}; + r = sd_bus_message_read(m, "sb", &name, &interactive); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, NULL); -static DBusHandlerResult hostname_message_handler( - DBusConnection *connection, - DBusMessage *message, - void *userdata) { + if (isempty(name)) + name = c->data[PROP_STATIC_HOSTNAME]; + if (isempty(name)) + name = "localhost"; - DBusMessage *reply = NULL, *changed = NULL; - DBusError error; - int r; + if (!hostname_is_valid(name)) + return sd_bus_reply_method_errorf(bus, m, SD_BUS_ERROR_INVALID_ARGS, "Invalid hostname '%s'", name); - assert(connection); - assert(message); + if (streq_ptr(name, c->data[PROP_HOSTNAME])) + return sd_bus_reply_method_return(bus, m, NULL); - dbus_error_init(&error); + r = bus_verify_polkit_async(bus, &c->polkit_registry, m, "org.freedesktop.hostname1.set-hostname", interactive, &error, method_set_hostname, c); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, &error); + if (r == 0) + return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */ - if (dbus_message_is_method_call(message, "org.freedesktop.hostname1", "SetHostname")) { - const char *name; - dbus_bool_t interactive; + h = strdup(name); + if (!h) + return log_oom(); - if (!dbus_message_get_args( - message, - &error, - DBUS_TYPE_STRING, &name, - DBUS_TYPE_BOOLEAN, &interactive, - DBUS_TYPE_INVALID)) - return bus_send_error_reply(connection, message, &error, -EINVAL); + free(c->data[PROP_HOSTNAME]); + c->data[PROP_HOSTNAME] = h; - if (isempty(name)) - name = data[PROP_STATIC_HOSTNAME]; + r = context_write_data_hostname(c); + if (r < 0) { + log_error("Failed to set host name: %s", strerror(-r)); + return sd_bus_reply_method_errnof(bus, m, r, "Failed to set hostname: %s", strerror(-r)); + } - if (isempty(name)) - name = "localhost"; + log_info("Changed host name to '%s'", strna(c->data[PROP_HOSTNAME])); - if (!hostname_is_valid(name)) - return bus_send_error_reply(connection, message, NULL, -EINVAL); + sd_bus_emit_properties_changed(bus, "/org/freedesktop/hostname1", "org.freedesktop.hostname1", "Hostname", NULL); - if (!streq_ptr(name, data[PROP_HOSTNAME])) { - char *h; + return sd_bus_reply_method_return(bus, m, NULL); +} - r = verify_polkit(connection, message, "org.freedesktop.hostname1.set-hostname", interactive, NULL, &error); - if (r < 0) - return bus_send_error_reply(connection, message, &error, r); +static int method_set_static_hostname(sd_bus *bus, sd_bus_message *m, void *userdata) { + _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL; + Context *c = userdata; + const char *name; + bool interactive; + int r; - h = strdup(name); - if (!h) - goto oom; + r = sd_bus_message_read(m, "sb", &name, &interactive); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, NULL); - free(data[PROP_HOSTNAME]); - data[PROP_HOSTNAME] = h; + if (isempty(name)) + name = NULL; - r = write_data_hostname(); - if (r < 0) { - log_error("Failed to set host name: %s", strerror(-r)); - return bus_send_error_reply(connection, message, NULL, r); - } + if (streq_ptr(name, c->data[PROP_STATIC_HOSTNAME])) + return sd_bus_reply_method_return(bus, m, NULL); - log_info("Changed host name to '%s'", strna(data[PROP_HOSTNAME])); + r = bus_verify_polkit_async(bus, &c->polkit_registry, m, "org.freedesktop.hostname1.set-static-hostname", interactive, &error, method_set_static_hostname, c); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, &error); + if (r == 0) + return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */ - changed = bus_properties_changed_new( - "/org/freedesktop/hostname1", - "org.freedesktop.hostname1", - "Hostname\0"); - if (!changed) - goto oom; - } + if (isempty(name)) { + free(c->data[PROP_STATIC_HOSTNAME]); + c->data[PROP_STATIC_HOSTNAME] = NULL; + } else { + char *h; - } else if (dbus_message_is_method_call(message, "org.freedesktop.hostname1", "SetStaticHostname")) { - const char *name; - dbus_bool_t interactive; - - if (!dbus_message_get_args( - message, - &error, - DBUS_TYPE_STRING, &name, - DBUS_TYPE_BOOLEAN, &interactive, - DBUS_TYPE_INVALID)) - return bus_send_error_reply(connection, message, &error, -EINVAL); - - if (isempty(name)) - name = NULL; - - if (!streq_ptr(name, data[PROP_STATIC_HOSTNAME])) { - - r = verify_polkit(connection, message, "org.freedesktop.hostname1.set-static-hostname", interactive, NULL, &error); - if (r < 0) - return bus_send_error_reply(connection, message, &error, r); - - if (isempty(name)) { - free(data[PROP_STATIC_HOSTNAME]); - data[PROP_STATIC_HOSTNAME] = NULL; - } else { - char *h; - - if (!hostname_is_valid(name)) - return bus_send_error_reply(connection, message, NULL, -EINVAL); - - h = strdup(name); - if (!h) - goto oom; - - free(data[PROP_STATIC_HOSTNAME]); - data[PROP_STATIC_HOSTNAME] = h; - } - - r = write_data_static_hostname(); - if (r < 0) { - log_error("Failed to write static host name: %s", strerror(-r)); - return bus_send_error_reply(connection, message, NULL, r); - } - - log_info("Changed static host name to '%s'", strna(data[PROP_STATIC_HOSTNAME])); - - changed = bus_properties_changed_new( - "/org/freedesktop/hostname1", - "org.freedesktop.hostname1", - "StaticHostname\0"); - if (!changed) - goto oom; - } + if (!hostname_is_valid(name)) + return sd_bus_reply_method_errorf(bus, m, SD_BUS_ERROR_INVALID_ARGS, "Invalid static hostname '%s'", name); - } else if (dbus_message_is_method_call(message, "org.freedesktop.hostname1", "SetPrettyHostname") || - dbus_message_is_method_call(message, "org.freedesktop.hostname1", "SetIconName") || - dbus_message_is_method_call(message, "org.freedesktop.hostname1", "SetChassis")) { - - const char *name; - dbus_bool_t interactive; - int k; - - if (!dbus_message_get_args( - message, - &error, - DBUS_TYPE_STRING, &name, - DBUS_TYPE_BOOLEAN, &interactive, - DBUS_TYPE_INVALID)) - return bus_send_error_reply(connection, message, &error, -EINVAL); - - if (isempty(name)) - name = NULL; - - k = streq(dbus_message_get_member(message), "SetPrettyHostname") ? PROP_PRETTY_HOSTNAME : - streq(dbus_message_get_member(message), "SetChassis") ? PROP_CHASSIS : PROP_ICON_NAME; - - if (!streq_ptr(name, data[k])) { - - /* Since the pretty hostname should always be - * changed at the same time as the static one, - * use the same policy action for both... */ - - r = verify_polkit(connection, message, k == PROP_PRETTY_HOSTNAME ? - "org.freedesktop.hostname1.set-static-hostname" : - "org.freedesktop.hostname1.set-machine-info", interactive, NULL, &error); - if (r < 0) - return bus_send_error_reply(connection, message, &error, r); - - if (isempty(name)) { - free(data[k]); - data[k] = NULL; - } else { - char *h; - - /* The icon name might ultimately be - * used as file name, so better be - * safe than sorry */ - if (k == PROP_ICON_NAME && !filename_is_safe(name)) - return bus_send_error_reply(connection, message, NULL, -EINVAL); - if (k == PROP_PRETTY_HOSTNAME && - (string_has_cc(name) || chars_intersect(name, "\t"))) - return bus_send_error_reply(connection, message, NULL, -EINVAL); - if (k == PROP_CHASSIS && !valid_chassis(name)) - return bus_send_error_reply(connection, message, NULL, -EINVAL); - - h = strdup(name); - if (!h) - goto oom; - - free(data[k]); - data[k] = h; - } - - r = write_data_other(); - if (r < 0) { - log_error("Failed to write machine info: %s", strerror(-r)); - return bus_send_error_reply(connection, message, NULL, r); - } - - log_info("Changed %s to '%s'", - k == PROP_PRETTY_HOSTNAME ? "pretty host name" : - k == PROP_CHASSIS ? "chassis" : "icon name", strna(data[k])); - - changed = bus_properties_changed_new( - "/org/freedesktop/hostname1", - "org.freedesktop.hostname1", - k == PROP_PRETTY_HOSTNAME ? "PrettyHostname\0" : - k == PROP_CHASSIS ? "Chassis\0" : "IconName\0"); - if (!changed) - goto oom; - } + h = strdup(name); + if (!h) + return log_oom(); - } else - return bus_default_message_handler(connection, message, INTROSPECTION, INTERFACES_LIST, bps); + free(c->data[PROP_STATIC_HOSTNAME]); + c->data[PROP_STATIC_HOSTNAME] = h; + } - reply = dbus_message_new_method_return(message); - if (!reply) - goto oom; + r = context_write_data_static_hostname(c); + if (r < 0) { + log_error("Failed to write static host name: %s", strerror(-r)); + return sd_bus_reply_method_errnof(bus, m, r, "Failed to set static hostname: %s", strerror(-r)); + } - if (!bus_maybe_send_reply(connection, message, reply)) - goto oom; + log_info("Changed static host name to '%s'", strna(c->data[PROP_STATIC_HOSTNAME])); - dbus_message_unref(reply); - reply = NULL; + sd_bus_emit_properties_changed(bus, "/org/freedesktop/hostname1", "org.freedesktop.hostname1", "StaticHostname", NULL); - if (changed) { + return sd_bus_reply_method_return(bus, m, NULL); +} - if (!dbus_connection_send(connection, changed, NULL)) - goto oom; +static int set_machine_info(Context *c, sd_bus *bus, sd_bus_message *m, int prop, sd_bus_message_handler_t cb) { + _cleanup_bus_error_free_ sd_bus_error error = SD_BUS_ERROR_NULL; + bool interactive; + const char *name; + int r; + + assert(c); + assert(bus); + assert(m); + + r = sd_bus_message_read(m, "sb", &name, &interactive); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, NULL); + + if (isempty(name)) + name = NULL; + + if (streq_ptr(name, c->data[prop])) + return sd_bus_reply_method_return(bus, m, NULL); - dbus_message_unref(changed); + /* Since the pretty hostname should always be changed at the + * same time as the static one, use the same policy action for + * both... */ + + r = bus_verify_polkit_async(bus, &c->polkit_registry, m, prop == PROP_PRETTY_HOSTNAME ? + "org.freedesktop.hostname1.set-static-hostname" : + "org.freedesktop.hostname1.set-machine-info", interactive, &error, cb, c); + if (r < 0) + return sd_bus_reply_method_errno(bus, m, r, &error); + if (r == 0) + return 1; /* No authorization for now, but the async polkit stuff will call us again when it has it */ + + if (isempty(name)) { + free(c->data[prop]); + c->data[prop] = NULL; + } else { + char *h; + + /* The icon name might ultimately be used as file + * name, so better be safe than sorry */ + + if (prop == PROP_ICON_NAME && !filename_is_safe(name)) + return sd_bus_reply_method_errorf(bus, m, SD_BUS_ERROR_INVALID_ARGS, "Invalid icon name '%s'", name); + if (prop == PROP_PRETTY_HOSTNAME && + (string_has_cc(name) || chars_intersect(name, "\t"))) + return sd_bus_reply_method_errorf(bus, m, SD_BUS_ERROR_INVALID_ARGS, "Invalid pretty host name '%s'", name); + if (prop == PROP_CHASSIS && !valid_chassis(name)) + return sd_bus_reply_method_errorf(bus, m, SD_BUS_ERROR_INVALID_ARGS, "Invalid chassis '%s'", name); + + h = strdup(name); + if (!h) + return log_oom(); + + free(c->data[prop]); + c->data[prop] = h; } - return DBUS_HANDLER_RESULT_HANDLED; + r = context_write_data_other(c); + if (r < 0) { + log_error("Failed to write machine info: %s", strerror(-r)); + return sd_bus_reply_method_errnof(bus, m, r, "Failed to write machine info: %s", strerror(-r)); + } -oom: - if (reply) - dbus_message_unref(reply); + log_info("Changed %s to '%s'", + prop == PROP_PRETTY_HOSTNAME ? "pretty host name" : + prop == PROP_CHASSIS ? "chassis" : "icon name", strna(c->data[prop])); - if (changed) - dbus_message_unref(changed); + sd_bus_emit_properties_changed(bus, "/org/freedesktop/hostname1", "org.freedesktop.hostname1", + prop == PROP_PRETTY_HOSTNAME ? "PrettyHostname" : + prop == PROP_CHASSIS ? "Chassis" : "IconName", NULL); - dbus_error_free(&error); + return sd_bus_reply_method_return(bus, m, NULL); +} - return DBUS_HANDLER_RESULT_NEED_MEMORY; +static int method_set_pretty_hostname(sd_bus *bus, sd_bus_message *m, void *userdata) { + return set_machine_info(userdata, bus, m, PROP_PRETTY_HOSTNAME, method_set_pretty_hostname); } -static int connect_bus(DBusConnection **_bus) { - static const DBusObjectPathVTable hostname_vtable = { - .message_function = hostname_message_handler - }; - DBusError error; - DBusConnection *bus = NULL; +static int method_set_icon_name(sd_bus *bus, sd_bus_message *m, void *userdata) { + return set_machine_info(userdata, bus, m, PROP_ICON_NAME, method_set_icon_name); +} + +static int method_set_chassis(sd_bus *bus, sd_bus_message *m, void *userdata) { + return set_machine_info(userdata, bus, m, PROP_CHASSIS, method_set_chassis); +} + +static const sd_bus_vtable hostname_vtable[] = { + SD_BUS_VTABLE_START(0), + SD_BUS_PROPERTY("Hostname", "s", NULL, offsetof(Context, data) + sizeof(char*) * PROP_HOSTNAME, 0), + SD_BUS_PROPERTY("StaticHostname", "s", NULL, offsetof(Context, data) + sizeof(char*) * PROP_STATIC_HOSTNAME, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE), + SD_BUS_PROPERTY("PrettyHostname", "s", NULL, offsetof(Context, data) + sizeof(char*) * PROP_PRETTY_HOSTNAME, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE), + SD_BUS_PROPERTY("IconName", "s", property_get_icon_name, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE), + SD_BUS_PROPERTY("Chassis", "s", property_get_chassis, 0, SD_BUS_VTABLE_PROPERTY_EMITS_CHANGE), + SD_BUS_METHOD("SetHostname", "sb", NULL, method_set_hostname, 0), + SD_BUS_METHOD("SetStaticHostname", "sb", NULL, method_set_static_hostname, 0), + SD_BUS_METHOD("SetPrettyHostname", "sb", NULL, method_set_pretty_hostname, 0), + SD_BUS_METHOD("SetIconName", "sb", NULL, method_set_icon_name, 0), + SD_BUS_METHOD("SetChassis", "sb", NULL, method_set_chassis, 0), + SD_BUS_VTABLE_END, +}; + +static int connect_bus(Context *c, sd_event *event, sd_bus **_bus) { + _cleanup_bus_unref_ sd_bus *bus = NULL; int r; + assert(c); + assert(event); assert(_bus); - dbus_error_init(&error); - - bus = dbus_bus_get_private(DBUS_BUS_SYSTEM, &error); - if (!bus) { - log_error("Failed to get system D-Bus connection: %s", bus_error_message(&error)); - r = -ECONNREFUSED; - goto fail; + r = sd_bus_open_system(&bus); + if (r < 0) { + log_error("Failed to get system bus connection: %s", strerror(-r)); + return r; } - dbus_connection_set_exit_on_disconnect(bus, FALSE); - - if (!dbus_connection_register_object_path(bus, "/org/freedesktop/hostname1", &hostname_vtable, NULL) || - !dbus_connection_add_filter(bus, bus_exit_idle_filter, &remain_until, NULL)) { - r = log_oom(); - goto fail; + r = sd_bus_add_object_vtable(bus, "/org/freedesktop/hostname1", "org.freedesktop.hostname1", hostname_vtable, c); + if (r < 0) { + log_error("Failed to register object: %s", strerror(-r)); + return r; } - r = dbus_bus_request_name(bus, "org.freedesktop.hostname1", DBUS_NAME_FLAG_DO_NOT_QUEUE, &error); - if (dbus_error_is_set(&error)) { - log_error("Failed to register name on bus: %s", bus_error_message(&error)); - r = -EEXIST; - goto fail; + r = sd_bus_request_name(bus, "org.freedesktop.hostname1", SD_BUS_NAME_DO_NOT_QUEUE); + if (r < 0) { + log_error("Failed to register name: %s", strerror(-r)); + return r; } - if (r != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) { + if (r != SD_BUS_NAME_PRIMARY_OWNER) { log_error("Failed to acquire name."); - r = -EEXIST; - goto fail; + return -EEXIST; } - if (_bus) - *_bus = bus; - - return 0; - -fail: - dbus_connection_close(bus); - dbus_connection_unref(bus); + r = sd_bus_attach_event(bus, event, 0); + if (r < 0) { + log_error("Failed to attach bus to event loop: %s", strerror(-r)); + return r; + } - dbus_error_free(&error); + *_bus = bus; + bus = NULL; - return r; + return 0; } int main(int argc, char *argv[]) { + Context context = {}; + + _cleanup_event_unref_ sd_event *event = NULL; + _cleanup_bus_unref_ sd_bus *bus = NULL; int r; - DBusConnection *bus = NULL; - bool exiting = false; log_set_target(LOG_TARGET_AUTO); log_parse_environment(); @@ -687,14 +628,6 @@ int main(int argc, char *argv[]) { umask(0022); label_init("/etc"); - if (argc == 2 && streq(argv[1], "--introspect")) { - fputs(DBUS_INTROSPECT_1_0_XML_DOCTYPE_DECL_NODE - "\n", stdout); - fputs(hostname_interface, stdout); - fputs("\n", stdout); - return 0; - } - if (argc != 1) { log_error("This program takes no arguments."); r = -EINVAL; @@ -704,38 +637,39 @@ int main(int argc, char *argv[]) { if (!check_nss()) log_warning("Warning: nss-myhostname is not installed. Changing the local hostname might make it unresolveable. Please install nss-myhostname!"); - r = read_data(); + if (argc != 1) { + log_error("This program takes no arguments."); + r = -EINVAL; + goto finish; + } + + r = sd_event_new(&event); if (r < 0) { - log_error("Failed to read hostname data: %s", strerror(-r)); + log_error("Failed to allocate event loop: %s", strerror(-r)); goto finish; } - r = connect_bus(&bus); + r = connect_bus(&context, event, &bus); if (r < 0) goto finish; - remain_until = now(CLOCK_MONOTONIC) + DEFAULT_EXIT_USEC; - for (;;) { - - if (!dbus_connection_read_write_dispatch(bus, exiting ? -1 : (int) (DEFAULT_EXIT_USEC/USEC_PER_MSEC))) - break; + r = context_read_data(&context); + if (r < 0) { + log_error("Failed to read timezone data: %s", strerror(-r)); + goto finish; + } - if (!exiting && remain_until < now(CLOCK_MONOTONIC)) { - exiting = true; - bus_async_unregister_and_exit(bus, "org.freedesktop.hostname1"); - } + r = bus_event_loop_with_idle(event, bus, "org.freedesktop.hostname1", DEFAULT_EXIT_USEC); + if (r < 0) { + log_error("Failed to run event loop: %s", strerror(-r)); + goto finish; } + sd_bus_flush(bus); r = 0; finish: - free_data(); - - if (bus) { - dbus_connection_flush(bus); - dbus_connection_close(bus); - dbus_connection_unref(bus); - } + context_free(&context, bus); return r < 0 ? EXIT_FAILURE : EXIT_SUCCESS; }