diff options
Diffstat (limited to 'callouts/nm-dispatcher-action.c')
| -rw-r--r-- | callouts/nm-dispatcher-action.c | 798 |
1 files changed, 798 insertions, 0 deletions
diff --git a/callouts/nm-dispatcher-action.c b/callouts/nm-dispatcher-action.c new file mode 100644 index 00000000..828d8be1 --- /dev/null +++ b/callouts/nm-dispatcher-action.c @@ -0,0 +1,798 @@ +/* -*- Mode: C; tab-width: 4; indent-tabs-mode: t; c-basic-offset: 4 -*- */ +/* NetworkManager -- Network link manager + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2 of the License, or + * (at your option) any later version. + * + * This program is distributed in the hope that it will be useful, + * but WITHOUT ANY WARRANTY; without even the implied warranty of + * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the + * GNU General Public License for more details. + * + * You should have received a copy of the GNU General Public License along + * with this program; if not, write to the Free Software Foundation, Inc., + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + * + * Copyright (C) 2008 Red Hat, Inc. + */ + +#include <syslog.h> +#include <stdio.h> +#include <unistd.h> +#include <stdlib.h> +#include <string.h> +#include <sys/types.h> +#include <signal.h> +#include <sys/stat.h> +#include <sys/wait.h> +#include <errno.h> +#include <arpa/inet.h> + +#include <glib.h> +#include <dbus/dbus.h> +#include <dbus/dbus-glib-lowlevel.h> +#include <dbus/dbus-glib.h> + +#include <NetworkManager.h> +#include "nm-glib-compat.h" +#include <libnm-util/nm-connection.h> +#include <libnm-util/nm-setting-ip4-config.h> +#include <libnm-util/nm-setting-connection.h> +#include <libnm-glib/nm-dhcp4-config.h> +#include <libnm-glib/nm-device.h> + +#include "nm-dispatcher-action.h" + +#define NMD_SCRIPT_DIR SYSCONFDIR "/NetworkManager/dispatcher.d" + +static GMainLoop *loop = NULL; +static gboolean debug = FALSE; + +static gboolean quit_timeout_cb (gpointer user_data); + +typedef struct Handler Handler; +typedef struct HandlerClass HandlerClass; + +GType handler_get_type (void); + +struct Handler { + GObject parent; +}; + +struct HandlerClass { + GObjectClass parent; +}; + +#define HANDLER_TYPE (handler_get_type ()) +#define HANDLER(object) (G_TYPE_CHECK_INSTANCE_CAST ((object), HANDLER_TYPE, Handler)) +#define HANDLER_CLASS(klass) (G_TYPE_CHECK_CLASS_CAST ((klass), HANDLER_TYPE, HandlerClass)) +#define IS_HANDLER(object) (G_TYPE_CHECK_INSTANCE_TYPE ((object), HANDLER_TYPE)) +#define IS_HANDLER_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE ((klass), HANDLER_TYPE)) +#define HANDLER_GET_CLASS(obj) (G_TYPE_INSTANCE_GET_CLASS ((obj), HANDLER_TYPE, HandlerClass)) + +G_DEFINE_TYPE(Handler, handler, G_TYPE_OBJECT) + +typedef struct { + DBusGConnection *g_connection; + DBusGProxy *bus_proxy; + guint quit_timeout; + gboolean persist; + + Handler *handler; +} Dispatcher; + +static gboolean +nm_dispatcher_action (Handler *obj, + const char *action, + GHashTable *connection, + GHashTable *connection_props, + GHashTable *device_props, + GError **error); + +#include "nm-dispatcher-glue.h" + + +static void +handler_init (Handler *h) +{ +} + +static void +handler_finalize (GObject *object) +{ + G_OBJECT_CLASS (handler_parent_class)->finalize (object); +} + +static void +handler_class_init (HandlerClass *h_class) +{ + GObjectClass *gobject_class = G_OBJECT_CLASS (h_class); + + gobject_class->finalize = handler_finalize; +} + +/* + * nmd_permission_check + * + * Verify that the given script has the permissions we want. Specifically, + * ensure that the file is + * - A regular file. + * - Owned by root. + * - Not writable by the group or by other. + * - Not setuid. + * - Executable by the owner. + * + */ +static inline gboolean +nmd_permission_check (struct stat *s, GError **error) +{ + g_return_val_if_fail (s != NULL, FALSE); + g_return_val_if_fail (error != NULL, FALSE); + g_return_val_if_fail (*error == NULL, FALSE); + + /* Only accept regular files */ + if (!S_ISREG (s->st_mode)) { + g_set_error (error, 0, 0, "not a regular file."); + return FALSE; + } + + /* Only accept files owned by root */ + if (s->st_uid != 0) { + g_set_error (error, 0, 0, "not owned by root."); + return FALSE; + } + + /* Only accept files not writable by group or other, and not SUID */ + if (s->st_mode & (S_IWGRP | S_IWOTH | S_ISUID)) { + g_set_error (error, 0, 0, "writable by group or other, or set-UID."); + return FALSE; + } + + /* Only accept files executable by the owner */ + if (!(s->st_mode & S_IXUSR)) { + g_set_error (error, 0, 0, "not executable by owner."); + return FALSE; + } + + return TRUE; +} + + +/* + * nmd_is_valid_filename + * + * Verify that the given script is a valid file name. Specifically, + * ensure that the file: + * - is not a editor backup file + * - is not a package management file + * - does not start with '.' + */ +static inline gboolean +nmd_is_valid_filename (const char *file_name) +{ + char *bad_suffixes[] = { "~", ".rpmsave", ".rpmorig", ".rpmnew", NULL }; + char *tmp; + int i; + + if (file_name[0] == '.') + return FALSE; + for (i = 0; bad_suffixes[i]; i++) { + if (g_str_has_suffix(file_name, bad_suffixes[i])) + return FALSE; + } + tmp = g_strrstr(file_name, ".dpkg-"); + if (tmp && (tmp == strrchr(file_name,'.'))) + return FALSE; + return TRUE; +} + +static gint +sort_files (gconstpointer a, gconstpointer b) +{ + char *a_base = NULL, *b_base = NULL; + int ret = 0; + + if (a && !b) + return 1; + if (!a && !b) + return 0; + if (!a && b) + return -1; + + a_base = g_path_get_basename (a); + b_base = g_path_get_basename (b); + + ret = strcmp (a_base, b_base); + + g_free (a_base); + g_free (b_base); + return ret; +} + +static void +child_setup (gpointer user_data G_GNUC_UNUSED) +{ + /* We are in the child process at this point */ + /* Give child a different process group to ensure signal separation. */ + pid_t pid = getpid (); + setpgid (pid, pid); +} + +typedef struct { + char **envp; + guint32 i; +} EnvAddInfo; + +static void +add_one_option_to_envp (gpointer key, gpointer value, gpointer user_data) +{ + EnvAddInfo *info = (EnvAddInfo *) user_data; + char *ucased; + + ucased = g_ascii_strup (key, -1); + info->envp[info->i++] = g_strdup_printf ("DHCP4_%s=%s", ucased, (char *) value); + g_free (ucased); +} + +static char ** +construct_envp (const char *uuid, NMIP4Config *ip4_config, NMDHCP4Config *dhcp4_config) +{ + guint32 env_size = 0; + char **envp; + guint32 envp_idx = 0; + GHashTable *options = NULL; + GSList *addresses, *routes, *iter; + GArray *nameservers; + GPtrArray *domains; + guint32 num, i; + GString *tmp; + + if (!ip4_config) + return g_new0 (char *, 1); + + addresses = (GSList *) nm_ip4_config_get_addresses (ip4_config); + nameservers = (GArray *) nm_ip4_config_get_nameservers (ip4_config); + domains = (GPtrArray *) nm_ip4_config_get_domains (ip4_config); + routes = (GSList *) nm_ip4_config_get_routes (ip4_config); + + env_size = g_slist_length (addresses) + + 1 /* addresses length */ + + 1 /* nameservers */ + + 1 /* domains */ + + 1 /* hostname */ + + g_slist_length (routes) + + 1 /* routes length */ + + 1 /* connection UUID */; + + if (dhcp4_config) { + options = nm_dhcp4_config_get_options (dhcp4_config); + env_size += g_hash_table_size (options); + } + + envp = g_new0 (char *, env_size + 1); + + if (uuid) + envp[envp_idx++] = g_strdup_printf ("CONNECTION_UUID=%s", uuid); + + /* IP4 config stuff */ + for (iter = addresses, num = 0; iter; iter = g_slist_next (iter)) { + NMIP4Address *addr = (NMIP4Address *) iter->data; + char str_addr[INET_ADDRSTRLEN + 1]; + char str_gw[INET_ADDRSTRLEN + 1]; + struct in_addr tmp_addr; + guint32 prefix = nm_ip4_address_get_prefix (addr); + + memset (str_addr, 0, sizeof (str_addr)); + tmp_addr.s_addr = nm_ip4_address_get_address (addr); + if (!inet_ntop (AF_INET, &tmp_addr, str_addr, sizeof (str_addr))) + continue; + + memset (str_gw, 0, sizeof (str_gw)); + tmp_addr.s_addr = nm_ip4_address_get_gateway (addr); + inet_ntop (AF_INET, &tmp_addr, str_gw, sizeof (str_gw)); + + tmp = g_string_sized_new (25 + strlen (str_addr) + strlen (str_gw)); + g_string_append_printf (tmp, "IP4_ADDRESS_%d=%s/%d %s", num++, str_addr, prefix, str_gw); + envp[envp_idx++] = tmp->str; + g_string_free (tmp, FALSE); + } + if (num) + envp[envp_idx++] = g_strdup_printf ("IP4_NUM_ADDRESSES=%d", num); + + if (nameservers && nameservers->len) { + gboolean first = TRUE; + + tmp = g_string_new ("IP4_NAMESERVERS="); + for (i = 0; i < nameservers->len; i++) { + struct in_addr addr; + char buf[INET_ADDRSTRLEN + 1]; + + addr.s_addr = g_array_index (nameservers, guint32, i); + memset (buf, 0, sizeof (buf)); + if (inet_ntop (AF_INET, &addr, buf, sizeof (buf))) { + if (!first) + g_string_append_c (tmp, ' '); + g_string_append (tmp, buf); + first = FALSE; + } + } + envp[envp_idx++] = tmp->str; + g_string_free (tmp, FALSE); + } + + if (domains && domains->len) { + tmp = g_string_new ("IP4_DOMAINS="); + for (i = 0; i < domains->len; i++) { + if (i > 0) + g_string_append_c (tmp, ' '); + g_string_append (tmp, (char *) g_ptr_array_index (domains, i)); + } + envp[envp_idx++] = tmp->str; + g_string_free (tmp, FALSE); + } + + for (iter = routes, num = 0; iter; iter = g_slist_next (iter)) { + NMIP4Route *route = (NMIP4Route *) iter->data; + char str_addr[INET_ADDRSTRLEN + 1]; + char str_nh[INET_ADDRSTRLEN + 1]; + struct in_addr tmp_addr; + guint32 prefix = nm_ip4_route_get_prefix (route); + guint32 metric = nm_ip4_route_get_metric (route); + + memset (str_addr, 0, sizeof (str_addr)); + tmp_addr.s_addr = nm_ip4_route_get_dest (route); + if (!inet_ntop (AF_INET, &tmp_addr, str_addr, sizeof (str_addr))) + continue; + + memset (str_nh, 0, sizeof (str_nh)); + tmp_addr.s_addr = nm_ip4_route_get_next_hop (route); + inet_ntop (AF_INET, &tmp_addr, str_nh, sizeof (str_nh)); + + tmp = g_string_sized_new (30 + strlen (str_addr) + strlen (str_nh)); + g_string_append_printf (tmp, "IP4_ROUTE_%d=%s/%d %s %d", num++, str_addr, prefix, str_nh, metric); + envp[envp_idx++] = tmp->str; + g_string_free (tmp, FALSE); + } + envp[envp_idx++] = g_strdup_printf ("IP4_NUM_ROUTES=%d", num); + + /* DHCP stuff */ + if (dhcp4_config && options) { + EnvAddInfo info; + + info.envp = envp; + info.i = envp_idx; + g_hash_table_foreach (options, add_one_option_to_envp, &info); + } + + if (debug) { + char **p; + + g_message ("------------ Script Environment ------------"); + for (p = envp; *p; p++) + g_message (" %s", *p); + g_message ("\n"); + } + + return envp; +} + +static void +dispatch_scripts (const char *action, + const char *iface, + const char *parent_iface, + NMDeviceType type, + const char *uuid, + NMIP4Config *ip4_config, + NMDHCP4Config *dhcp4_config) +{ + GDir *dir; + const char *filename; + GSList *scripts = NULL, *iter; + GError *error = NULL; + char **envp = NULL; + + if (!(dir = g_dir_open (NMD_SCRIPT_DIR, 0, &error))) { + g_warning ("g_dir_open() could not open '" NMD_SCRIPT_DIR "'. '%s'", + error->message); + g_error_free (error); + return; + } + + while ((filename = g_dir_read_name (dir))) { + char *file_path; + struct stat s; + GError *pc_error = NULL; + int err; + + if (!nmd_is_valid_filename (filename)) + continue; + + file_path = g_build_filename (NMD_SCRIPT_DIR, filename, NULL); + + err = stat (file_path, &s); + if (err) { + g_warning ("Script '%s' could not be stated: %d", file_path, err); + g_free (file_path); + continue; + } + + if (!nmd_permission_check (&s, &pc_error)) { + g_warning ("Script '%s' could not be executed: %s", file_path, pc_error->message); + g_error_free (pc_error); + g_free (file_path); + } else { + /* success */ + scripts = g_slist_insert_sorted (scripts, file_path, sort_files); + } + } + g_dir_close (dir); + + envp = construct_envp (uuid, ip4_config, dhcp4_config); + + for (iter = scripts; iter; iter = g_slist_next (iter)) { + gchar *argv[4]; + gint status = -1; + + argv[0] = (char *) iter->data; + argv[1] = iface ? (char *) iface : "none"; + argv[2] = (char *) action; + argv[3] = NULL; + + if (debug) + g_message ("Script: %s %s %s", (char *) iter->data, iface ? (char *) iface : "(none)", (char *) action); + + error = NULL; + if (g_spawn_sync ("/", argv, envp, 0, child_setup, NULL, NULL, NULL, &status, &error)) { + if (WIFEXITED (status)) { + if (WEXITSTATUS (status) != 0) + g_warning ("Script '%s' exited with error status %d.", + (char *) iter->data, WEXITSTATUS (status)); + } else + g_warning ("Script '%s' exited abnormally.", (char *) iter->data); + } else { + g_warning ("Could not run script '%s': (%d) %s", + (char *) iter->data, error->code, error->message); + g_error_free (error); + } + } + + g_strfreev (envp); + + g_slist_foreach (scripts, (GFunc) g_free, NULL); + g_slist_free (scripts); +} + +static gboolean +nm_dispatcher_action (Handler *h, + const char *action, + GHashTable *connection_hash, + GHashTable *connection_props, + GHashTable *device_props, + GError **error) +{ + Dispatcher *d = g_object_get_data (G_OBJECT (h), "dispatcher"); + NMConnection *connection; + char *iface = NULL, *parent_iface = NULL; + const char *uuid = NULL; + NMDeviceType type = NM_DEVICE_TYPE_UNKNOWN; + NMDeviceState dev_state = NM_DEVICE_STATE_UNKNOWN; + NMDevice *device = NULL; + NMDHCP4Config *dhcp4_config = NULL; + NMIP4Config *ip4_config = NULL; + GValue *value; + + /* Back off the quit timeout */ + if (d->quit_timeout) + g_source_remove (d->quit_timeout); + if (!d->persist) + d->quit_timeout = g_timeout_add_seconds (10, quit_timeout_cb, NULL); + + connection = nm_connection_new_from_hash (connection_hash, error); + if (connection) { + NMSettingConnection *s_con; + + s_con = NM_SETTING_CONNECTION (nm_connection_get_setting (connection, NM_TYPE_SETTING_CONNECTION)); + if (s_con) + uuid = nm_setting_connection_get_uuid (s_con); + } else { + g_warning ("%s: Invalid connection: '%s' / '%s' invalid: %d", + __func__, + g_type_name (nm_connection_lookup_setting_type_by_quark ((*error)->domain)), + (*error)->message, (*error)->code); + /* Don't fail on this error yet */ + g_error_free (*error); + *error = NULL; + } + + /* Hostname changes don't require a device */ + if (!strcmp (action, "hostname")) + goto dispatch; + + /* interface name */ + value = g_hash_table_lookup (device_props, NMD_DEVICE_PROPS_INTERFACE); + if (!value || !G_VALUE_HOLDS_STRING (value)) { + g_warning ("Missing or invalid required value " NMD_DEVICE_PROPS_INTERFACE "!"); + goto out; + } + iface = (char *) g_value_get_string (value); + + /* IP interface name */ + value = g_hash_table_lookup (device_props, NMD_DEVICE_PROPS_IP_INTERFACE); + if (value) { + if (!G_VALUE_HOLDS_STRING (value)) { + g_warning ("Invalid required value " NMD_DEVICE_PROPS_IP_INTERFACE "!"); + goto out; + } + parent_iface = iface; + iface = (char *) g_value_get_string (value); + } + + /* Device type */ + value = g_hash_table_lookup (device_props, NMD_DEVICE_PROPS_TYPE); + if (!value || !G_VALUE_HOLDS_UINT (value)) { + g_warning ("Missing or invalid required value " NMD_DEVICE_PROPS_TYPE "!"); + goto out; + } + type = g_value_get_uint (value); + + /* Device state */ + value = g_hash_table_lookup (device_props, NMD_DEVICE_PROPS_STATE); + if (!value || !G_VALUE_HOLDS_UINT (value)) { + g_warning ("Missing or invalid required value " NMD_DEVICE_PROPS_STATE "!"); + goto out; + } + dev_state = g_value_get_uint (value); + + /* device itself */ + value = g_hash_table_lookup (device_props, NMD_DEVICE_PROPS_PATH); + if (!value || (G_VALUE_TYPE (value) != DBUS_TYPE_G_OBJECT_PATH)) { + g_warning ("Missing or invalid required value " NMD_DEVICE_PROPS_PATH "!"); + goto out; + } + device = NM_DEVICE (nm_device_new (d->g_connection, (const char *) g_value_get_boxed (value))); + + /* Get the DHCP4 config */ + if (device && (dev_state == NM_DEVICE_STATE_ACTIVATED)) { + dhcp4_config = nm_device_get_dhcp4_config (device); + ip4_config = nm_device_get_ip4_config (device); + } + +dispatch: + dispatch_scripts (action, iface, parent_iface, type, uuid, ip4_config, dhcp4_config); + + if (device) + g_object_unref (device); + +out: + return TRUE; +} + +static gboolean +start_dbus_service (Dispatcher *d) +{ + int request_name_result; + GError *err = NULL; + gboolean success = FALSE; + + if (!dbus_g_proxy_call (d->bus_proxy, "RequestName", &err, + G_TYPE_STRING, NM_DISPATCHER_DBUS_SERVICE, + G_TYPE_UINT, DBUS_NAME_FLAG_DO_NOT_QUEUE, + G_TYPE_INVALID, + G_TYPE_UINT, &request_name_result, + G_TYPE_INVALID)) { + g_warning ("Could not acquire the " NM_DISPATCHER_DBUS_SERVICE " service.\n" + " Message: '%s'", err->message); + g_error_free (err); + goto out; + } + + if (request_name_result != DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER) { + g_warning ("Could not acquire the " NM_DISPATCHER_DBUS_SERVICE " service " + "as it is already taken. Return: %d", + request_name_result); + goto out; + } + success = TRUE; + +out: + return success; +} + +static void +destroy_cb (DBusGProxy *proxy, gpointer user_data) +{ + g_warning ("Disconnected from the system bus, exiting."); + g_main_loop_quit (loop); +} + +static gboolean +dbus_init (Dispatcher *d) +{ + GError *err = NULL; + DBusConnection *connection; + + dbus_connection_set_change_sigpipe (TRUE); + + d->g_connection = dbus_g_bus_get (DBUS_BUS_SYSTEM, &err); + if (!d->g_connection) { + g_warning ("Could not get the system bus. Make sure " + "the message bus daemon is running! Message: %s", + err->message); + g_error_free (err); + return FALSE; + } + + /* Clean up nicely if we get kicked off the bus */ + connection = dbus_g_connection_get_connection (d->g_connection); + dbus_connection_set_exit_on_disconnect (connection, FALSE); + + d->bus_proxy = dbus_g_proxy_new_for_name (d->g_connection, + "org.freedesktop.DBus", + "/org/freedesktop/DBus", + "org.freedesktop.DBus"); + if (!d->bus_proxy) { + g_warning ("Could not get the DBus object!"); + goto error; + } + + g_signal_connect (d->bus_proxy, "destroy", G_CALLBACK (destroy_cb), NULL); + + return TRUE; + +error: + return FALSE; +} + +static void +log_handler (const gchar *log_domain, + GLogLevelFlags log_level, + const gchar *message, + gpointer ignored) +{ + int syslog_priority; + + switch (log_level) { + case G_LOG_LEVEL_ERROR: + syslog_priority = LOG_CRIT; + break; + + case G_LOG_LEVEL_CRITICAL: + syslog_priority = LOG_ERR; + break; + + case G_LOG_LEVEL_WARNING: + syslog_priority = LOG_WARNING; + break; + + case G_LOG_LEVEL_MESSAGE: + syslog_priority = LOG_NOTICE; + break; + + case G_LOG_LEVEL_DEBUG: + syslog_priority = LOG_DEBUG; + break; + + case G_LOG_LEVEL_INFO: + default: + syslog_priority = LOG_INFO; + break; + } + + syslog (syslog_priority, "%s", message); +} + + +static void +logging_setup (void) +{ + openlog (G_LOG_DOMAIN, LOG_CONS, LOG_DAEMON); + g_log_set_handler (G_LOG_DOMAIN, + G_LOG_LEVEL_MASK | G_LOG_FLAG_FATAL | G_LOG_FLAG_RECURSION, + log_handler, + NULL); +} + +static void +logging_shutdown (void) +{ + closelog (); +} + +static void +signal_handler (int signo) +{ + if (signo == SIGINT || signo == SIGTERM) { + g_message ("Caught signal %d, shutting down...", signo); + g_main_loop_quit (loop); + } +} + +static void +setup_signals (void) +{ + struct sigaction action; + sigset_t mask; + + sigemptyset (&mask); + action.sa_handler = signal_handler; + action.sa_mask = mask; + action.sa_flags = 0; + sigaction (SIGTERM, &action, NULL); + sigaction (SIGINT, &action, NULL); +} + +static gboolean +quit_timeout_cb (gpointer user_data) +{ + g_main_loop_quit (loop); + return FALSE; +} + +int +main (int argc, char **argv) +{ + Dispatcher *d = g_malloc0 (sizeof (Dispatcher)); + GOptionContext *opt_ctx; + GError *error = NULL; + gboolean persist = FALSE; + + GOptionEntry entries[] = { + { "debug", 0, 0, G_OPTION_ARG_NONE, &debug, "Output to console rather than syslog", NULL }, + { "persist", 0, 0, G_OPTION_ARG_NONE, &persist, "Don't quit after a short timeout", NULL }, + { NULL } + }; + + opt_ctx = g_option_context_new (NULL); + g_option_context_set_summary (opt_ctx, "Executes scripts upon actions by NetworkManager."); + g_option_context_add_main_entries (opt_ctx, entries, NULL); + + if (!g_option_context_parse (opt_ctx, &argc, &argv, &error)) { + g_warning ("%s\n", error->message); + g_error_free (error); + g_free (d); + return 1; + } + + g_option_context_free (opt_ctx); + + g_type_init (); + setup_signals (); + + if (!debug) + logging_setup (); + + loop = g_main_loop_new (NULL, FALSE); + + if (!dbus_init (d)) + return -1; + if (!start_dbus_service (d)) + return -1; + + d->persist = persist; + d->handler = g_object_new (HANDLER_TYPE, NULL); + if (!d->handler) + return -1; + g_object_set_data (G_OBJECT (d->handler), "dispatcher", d); + + dbus_g_object_type_install_info (HANDLER_TYPE, &dbus_glib_nm_dispatcher_object_info); + dbus_g_connection_register_g_object (d->g_connection, + NM_DISPATCHER_DBUS_PATH, + G_OBJECT (d->handler)); + + if (!persist) + d->quit_timeout = g_timeout_add_seconds (10, quit_timeout_cb, NULL); + + g_main_loop_run (loop); + + g_object_unref (d->handler); + dbus_g_connection_unref (d->g_connection); + g_free (d); + + if (!debug) + logging_shutdown (); + + return 0; +} + |