X-Git-Url: http://www.chiark.greenend.org.uk/ucgi/~ianmdlvl/git?a=blobdiff_plain;f=src%2Fcore%2Fdbus-manager.c;h=efc626ad873b3210fbf3e92ec0425ffee4274a69;hb=5273510e9f228a300ec6207d4502f1c6253aed5e;hp=88945b5c64c214b0a778678033569c7f0534b29d;hpb=2dad62205f3412198769f227ac4a1130f7887eec;p=elogind.git diff --git a/src/core/dbus-manager.c b/src/core/dbus-manager.c index 88945b5c6..efc626ad8 100644 --- a/src/core/dbus-manager.c +++ b/src/core/dbus-manager.c @@ -30,6 +30,7 @@ #include "build.h" #include "dbus-common.h" #include "install.h" +#include "watchdog.h" #define BUS_MANAGER_INTERFACE_BEGIN \ " \n" @@ -241,8 +242,8 @@ " \n" \ " \n" \ " \n" \ - " \n" \ - " \n" \ + " \n" \ + " \n" \ " \n" #ifdef HAVE_SYSV_COMPAT @@ -508,6 +509,17 @@ static int bus_manager_append_have_watchdog(DBusMessageIter *i, const char *prop return 0; } +static int bus_manager_set_runtime_watchdog_usec(DBusMessageIter *i, const char *property, void *data) { + uint64_t *t = data; + + assert(i); + assert(property); + + dbus_message_iter_get_basic(i, t); + + return watchdog_set_timeout(t); +} + static const char systemd_property_string[] = PACKAGE_STRING "\0" DISTRIBUTION "\0" @@ -529,8 +541,8 @@ static const BusProperty bus_manager_properties[] = { { "StartupTimestampMonotonic", bus_property_append_uint64, "t", offsetof(Manager, startup_timestamp.monotonic) }, { "FinishTimestamp", bus_property_append_uint64, "t", offsetof(Manager, finish_timestamp.realtime) }, { "FinishTimestampMonotonic", bus_property_append_uint64, "t", offsetof(Manager, finish_timestamp.monotonic) }, - { "LogLevel", bus_manager_append_log_level, "s", 0, 0, bus_manager_set_log_level }, - { "LogTarget", bus_manager_append_log_target, "s", 0, 0, bus_manager_set_log_target }, + { "LogLevel", bus_manager_append_log_level, "s", 0, false, bus_manager_set_log_level }, + { "LogTarget", bus_manager_append_log_target, "s", 0, false, bus_manager_set_log_target }, { "NNames", bus_manager_append_n_names, "u", 0 }, { "NJobs", bus_manager_append_n_jobs, "u", 0 }, { "NInstalledJobs",bus_property_append_uint32, "u", offsetof(Manager, n_installed_jobs) }, @@ -547,8 +559,8 @@ static const BusProperty bus_manager_properties[] = { { "DefaultControllers", bus_property_append_strv, "as", offsetof(Manager, default_controllers), true }, { "DefaultStandardOutput", bus_manager_append_exec_output, "s", offsetof(Manager, default_std_output) }, { "DefaultStandardError", bus_manager_append_exec_output, "s", offsetof(Manager, default_std_error) }, - { "RuntimeWatchdogUSec", bus_property_append_usec, "t", offsetof(Manager, runtime_watchdog), }, - { "ShutdownWatchdogUSec", bus_property_append_usec, "t", offsetof(Manager, shutdown_watchdog), }, + { "RuntimeWatchdogUSec", bus_property_append_usec, "t", offsetof(Manager, runtime_watchdog), false, bus_manager_set_runtime_watchdog_usec }, + { "ShutdownWatchdogUSec", bus_property_append_usec, "t", offsetof(Manager, shutdown_watchdog), false, bus_property_set_usec }, { "HaveWatchdog", bus_manager_append_have_watchdog, "b", 0 }, #ifdef HAVE_SYSV_COMPAT { "SysVConsole", bus_property_append_bool, "b", offsetof(Manager, sysv_console) }, @@ -1458,6 +1470,7 @@ static DBusHandlerResult bus_manager_message_handler(DBusConnection *connection, const char *name, *smode, *old_name = NULL; JobMode mode; Job *j; + JobBusClient *cl; Unit *u; bool b; @@ -1515,10 +1528,11 @@ static DBusHandlerResult bus_manager_message_handler(DBusConnection *connection, if ((r = manager_add_job(m, job_type, u, mode, true, &error, &j)) < 0) return bus_send_error_reply(connection, message, &error, r); - if (!(j->bus_client = strdup(message_get_sender_with_fallback(message)))) + cl = job_bus_client_new(connection, message_get_sender_with_fallback(message)); + if (!cl) goto oom; - j->bus = connection; + LIST_PREPEND(JobBusClient, client, j->bus_client_list, cl); if (!(reply = dbus_message_new_method_return(message))) goto oom;