/* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- * * Copyright (C) 2009 Richard Hughes * * Licensed under the GNU General Public License Version 2 * * 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. */ #include "config.h" #include #include #include #include #include #include "up-wakeups.h" #include "up-daemon.h" #include "up-marshal.h" #include "up-wakeups-glue.h" #include "up-wakeup-item.h" static void up_wakeups_finalize (GObject *object); static gboolean up_wakeups_timerstats_enable (UpWakeups *wakeups); #define UP_WAKEUPS_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), UP_TYPE_WAKEUPS, UpWakeupsPrivate)) #define UP_WAKEUPS_REQUESTS_STRUCT_TYPE (dbus_g_type_get_struct ("GValueArray", \ G_TYPE_BOOLEAN, \ G_TYPE_UINT, \ G_TYPE_DOUBLE, \ G_TYPE_STRING, \ G_TYPE_STRING, \ G_TYPE_INVALID)) #define UP_WAKEUPS_POLL_INTERVAL_KERNEL 2 /* seconds */ #define UP_WAKEUPS_POLL_INTERVAL_USERSPACE 2 /* seconds */ #define UP_WAKEUPS_DISABLE_INTERVAL 30 /* seconds */ #define UP_WAKEUPS_SOURCE_KERNEL "/proc/interrupts" #define UP_WAKEUPS_SOURCE_USERSPACE "/proc/timer_stats" #define UP_WAKEUPS_SMALLEST_VALUE 0.1f /* seconds */ #define UP_WAKEUPS_TOTAL_SMOOTH_FACTOR 0.125f struct UpWakeupsPrivate { GPtrArray *data; DBusGConnection *connection; guint total_old; guint total_ave; guint poll_userspace_id; guint poll_kernel_id; guint disable_id; gboolean polling_enabled; gboolean has_capability; }; enum { PROP_0, PROP_HAS_CAPABILITY, }; enum { TOTAL_CHANGED, DATA_CHANGED, LAST_SIGNAL }; static guint signals [LAST_SIGNAL] = { 0 }; G_DEFINE_TYPE (UpWakeups, up_wakeups, G_TYPE_OBJECT) /** * up_wakeups_get_cmdline: **/ static gchar * up_wakeups_get_cmdline (guint pid) { gboolean ret; gchar *filename = NULL; gchar *cmdline = NULL; GError *error = NULL; /* get command line from proc */ filename = g_strdup_printf ("/proc/%i/cmdline", pid); ret = g_file_get_contents (filename, &cmdline, NULL, &error); if (!ret) { g_debug ("failed to get cmdline: %s", error->message); g_error_free (error); goto out; } out: g_free (filename); return cmdline; } /** * up_wakeups_data_item_compare: **/ static gint up_wakeups_data_item_compare (UpWakeupItem **item1, UpWakeupItem **item2) { gdouble val1; gdouble val2; val1 = up_wakeup_item_get_value (*item1); val2 = up_wakeup_item_get_value (*item2); if (val1 > val2) return -1; if (val1 < val2) return 1; return -0; } /** * up_wakeups_data_get_or_create: **/ static UpWakeupItem * up_wakeups_data_get_or_create (UpWakeups *wakeups, guint id) { guint i; UpWakeupItem *item; for (i=0; ipriv->data->len; i++) { item = g_ptr_array_index (wakeups->priv->data, i); if (up_wakeup_item_get_id (item) == id) goto out; } item = up_wakeup_item_new (); up_wakeup_item_set_id (item, id); g_ptr_array_add (wakeups->priv->data, item); out: return item; } /** * up_wakeups_data_get_total: **/ static guint up_wakeups_data_get_total (UpWakeups *wakeups) { guint i; gfloat total = 0; UpWakeupItem *item; for (i=0; ipriv->data->len; i++) { item = g_ptr_array_index (wakeups->priv->data, i); total += up_wakeup_item_get_value (item); } return (guint) total; } /** * up_wakeups_get_total: * * Gets the current latency **/ gboolean up_wakeups_get_total (UpWakeups *wakeups, guint *value, GError **error) { gboolean ret; /* no capability */ if (!wakeups->priv->has_capability) { g_set_error_literal (error, UP_DAEMON_ERROR, UP_DAEMON_ERROR_GENERAL, "no hardware support"); return FALSE; } /* start if not already started */ ret = up_wakeups_timerstats_enable (wakeups); /* no data */ if (!ret) { g_set_error_literal (error, UP_DAEMON_ERROR, UP_DAEMON_ERROR_GENERAL, "cannot enable timerstats"); return FALSE; } /* return total averaged */ *value = wakeups->priv->total_ave; return TRUE; } /** * up_wakeups_get_data: **/ gboolean up_wakeups_get_data (UpWakeups *wakeups, GPtrArray **data, GError **error) { guint i; GPtrArray *array; UpWakeupItem *item; /* no capability */ if (!wakeups->priv->has_capability) { g_set_error_literal (error, UP_DAEMON_ERROR, UP_DAEMON_ERROR_GENERAL, "no hardware support"); return FALSE; } /* start if not already started */ up_wakeups_timerstats_enable (wakeups); /* sort data */ g_ptr_array_sort (wakeups->priv->data, (GCompareFunc) up_wakeups_data_item_compare); *data = g_ptr_array_new (); array = wakeups->priv->data; for (i=0; ilen; i++) { GValue elem = {0}; item = g_ptr_array_index (array, i); if (up_wakeup_item_get_value (item) < UP_WAKEUPS_SMALLEST_VALUE) continue; g_value_init (&elem, UP_WAKEUPS_REQUESTS_STRUCT_TYPE); g_value_take_boxed (&elem, dbus_g_type_specialized_construct (UP_WAKEUPS_REQUESTS_STRUCT_TYPE)); dbus_g_type_struct_set (&elem, 0, up_wakeup_item_get_is_userspace (item), 1, up_wakeup_item_get_id (item), 2, up_wakeup_item_get_value (item), 3, up_wakeup_item_get_cmdline (item), 4, up_wakeup_item_get_details (item), G_MAXUINT); g_ptr_array_add (*data, g_value_get_boxed (&elem)); } // dbus_g_method_return (context, data); // g_ptr_array_foreach (*data, (GFunc) g_value_array_free, NULL); // g_ptr_array_unref (*data); return TRUE; } /** * up_is_in: **/ static gboolean up_is_in (gchar needle, const gchar *delimiters) { guint i; for (i=0; delimiters[i] != '\0'; i++) { if (delimiters[i] == needle) return TRUE; } return FALSE; } /** * up_strsplit_complete_set: **/ static GPtrArray * up_strsplit_complete_set (const gchar *string, const gchar *delimiters, guint max_tokens) { guint i; gboolean ret; const gchar *start = NULL; gchar temp_data[100]; guint len; guint tokens = 0; GPtrArray *array; /* find sections not delimited by space */ array = g_ptr_array_new_with_free_func (g_free); for (i=0; string[i] != '\0'; i++) { ret = up_is_in (string[i], delimiters); if (ret) { /* no character data yet */ if (start == NULL) continue; if (tokens == max_tokens - 1) { g_ptr_array_add (array, g_strdup (start)); break; } /* find length of string */ len = &string[i] - start; if (len > 100) len = 100; strncpy (temp_data, start, len); temp_data[len] = '\0'; /* add to array */ g_ptr_array_add (array, g_strdup (temp_data)); tokens++; start = NULL; continue; } /* we've got character data */ if (start == NULL) start = &string[i]; } return array; } /** * up_wakeups_perhaps_data_changed: **/ static void up_wakeups_perhaps_data_changed (UpWakeups *wakeups) { guint total; /* total has changed */ total = up_wakeups_data_get_total (wakeups); if (total != wakeups->priv->total_old) { /* no old data, assume this is true */ if (wakeups->priv->total_old == 0) wakeups->priv->total_ave = total; else wakeups->priv->total_ave = UP_WAKEUPS_TOTAL_SMOOTH_FACTOR * (gfloat) (total - wakeups->priv->total_old); g_signal_emit (wakeups, signals [TOTAL_CHANGED], 0, wakeups->priv->total_ave); } /* unconditionally emit */ g_signal_emit (wakeups, signals [DATA_CHANGED], 0); } /** * up_wakeups_poll_kernel_cb: **/ static gboolean up_wakeups_poll_kernel_cb (UpWakeups *wakeups) { guint i; guint j; gboolean ret; gboolean special_ipi; gchar *data = NULL; gchar **lines = NULL; GError *error = NULL; guint cpus = 0; const gchar *found; const gchar *found2; guint irq; guint interrupts; GPtrArray *sections; UpWakeupItem *item; g_debug ("event"); /* set all kernel data objs to zero */ for (i=0; ipriv->data->len; i++) { item = g_ptr_array_index (wakeups->priv->data, i); if (!up_wakeup_item_get_is_userspace (item)) up_wakeup_item_set_value (item, 0.0f); } /* get the data */ ret = g_file_get_contents (UP_WAKEUPS_SOURCE_KERNEL, &data, NULL, &error); if (!ret) { g_warning ("failed to get data: %s", error->message); g_error_free (error); goto out; } /* split */ lines = g_strsplit (data, "\n", 0); /* find out how many processors we have */ sections = up_strsplit_complete_set (lines[0], " ", 0); cpus = sections->len; g_ptr_array_unref (sections); /* get the data from " 9: 29730 365 IO-APIC-fasteoi acpi" */ for (i=1; lines[i] != NULL; i++) { /* get sections and check correct length */ sections = up_strsplit_complete_set (lines[i], " :", 2 + cpus); if (sections->len != 2 + cpus) goto skip; /* get irq */ special_ipi = TRUE; found = g_ptr_array_index (sections, 0); if (strcmp (found, "NMI") == 0) irq = 0xff0; else if (strcmp (found, "LOC") == 0) irq = 0xff1; else if (strcmp (found, "RES") == 0) irq = 0xff2; else if (strcmp (found, "CAL") == 0) irq = 0xff3; else if (strcmp (found, "TLB") == 0) irq = 0xff4; else if (strcmp (found, "TRM") == 0) irq = 0xff5; else if (strcmp (found, "SPU") == 0) irq = 0xff6; else if (strcmp (found, "ERR") == 0) irq = 0xff7; else if (strcmp (found, "MIS") == 0) irq = 0xff8; else { irq = atoi (found); special_ipi = FALSE; } /* get the number of interrupts over all processors */ interrupts = 0; for (j=1; j 0) up_wakeup_item_set_value (item, (interrupts - up_wakeup_item_get_old (item)) / (gfloat) UP_WAKEUPS_POLL_INTERVAL_KERNEL); up_wakeup_item_set_old (item, interrupts); skip: g_ptr_array_unref (sections); } /* tell GUI we've changed */ up_wakeups_perhaps_data_changed (wakeups); out: g_free (data); g_strfreev (lines); return TRUE; } /** * up_wakeups_poll_userspace_cb: **/ static gboolean up_wakeups_poll_userspace_cb (UpWakeups *wakeups) { guint i; gboolean ret; GError *error = NULL; gchar *data = NULL; gchar **lines = NULL; const gchar *string; UpWakeupItem *item; GPtrArray *sections; guint pid; guint interrupts; gfloat interval = 5.0f; g_debug ("event"); /* set all userspace data objs to zero */ for (i=0; ipriv->data->len; i++) { item = g_ptr_array_index (wakeups->priv->data, i); if (up_wakeup_item_get_is_userspace (item)) up_wakeup_item_set_value (item, 0.0f); } /* get the data */ ret = g_file_get_contents (UP_WAKEUPS_SOURCE_USERSPACE, &data, NULL, &error); if (!ret) { g_warning ("failed to get data: %s", error->message); g_error_free (error); goto out; } /* split */ lines = g_strsplit (data, "\n", 0); /* get the data from " 9: 29730 365 IO-APIC-fasteoi acpi" */ for (i=0; lines[i] != NULL; i++) { if (strstr (lines[i], "Timer Stats Version:") != NULL) continue; if (strstr (lines[i], "events/sec") != NULL) continue; /* get sections */ sections = up_strsplit_complete_set (lines[i], " :", 4); /* get timeout */ if (strstr (lines[i], "Sample period:") != NULL) { string = g_ptr_array_index (sections, 2); interval = atof (string); g_debug ("interval=%f", interval); goto skip; } /* check correct length */ if (sections->len != 4) goto skip; /* if deferred */ string = g_ptr_array_index (sections, 0); if (strstr (string, "D") != NULL) goto skip; interrupts = atoi (string); if (interrupts == 0) goto skip; /* get pid */ string = g_ptr_array_index (sections, 1); pid = atoi (string); /* ignore scheduled */ string = g_ptr_array_index (sections, 3); if (g_str_has_prefix (string, "tick_nohz_")) goto skip; if (g_str_has_prefix (string, "tick_setup_sched_timer")) goto skip; /* get details */ /* save in database */ item = up_wakeups_data_get_or_create (wakeups, pid); if (up_wakeup_item_get_details (item) == NULL) { /* get process name (truncated) */ string = g_ptr_array_index (sections, 2); if (strcmp (string, "insmod") == 0 || strcmp (string, "modprobe") == 0 || strcmp (string, "swapper") == 0) { up_wakeup_item_set_cmdline (item, string); up_wakeup_item_set_is_userspace (item, FALSE); } else { /* try to get a better command line */ up_wakeup_item_set_cmdline (item, up_wakeups_get_cmdline (pid)); if (up_wakeup_item_get_cmdline (item) == NULL || up_wakeup_item_get_cmdline (item)[0] == '\0') up_wakeup_item_set_cmdline (item, string); up_wakeup_item_set_is_userspace (item, TRUE); } string = g_ptr_array_index (sections, 3); up_wakeup_item_set_details (item, string); } /* we report this in minutes, not seconds */ up_wakeup_item_set_value (item, (gfloat) interrupts / interval); skip: g_ptr_array_unref (sections); } /* tell GUI we've changed */ up_wakeups_perhaps_data_changed (wakeups); out: g_free (data); g_strfreev (lines); return TRUE; } /** * up_wakeups_timerstats_disable: **/ static gboolean up_wakeups_timerstats_disable (UpWakeups *wakeups) { FILE *file; /* already same state */ if (!wakeups->priv->polling_enabled) return TRUE; g_debug ("disabling timer stats"); /* clear polling */ if (wakeups->priv->poll_kernel_id != 0) { g_source_remove (wakeups->priv->poll_kernel_id); wakeups->priv->poll_kernel_id = 0; } if (wakeups->priv->poll_userspace_id != 0) { g_source_remove (wakeups->priv->poll_userspace_id); wakeups->priv->poll_userspace_id = 0; } if (wakeups->priv->disable_id != 0) { g_source_remove (wakeups->priv->disable_id); wakeups->priv->disable_id = 0; } file = fopen (UP_WAKEUPS_SOURCE_USERSPACE, "w"); if (file == NULL) return FALSE; fprintf (file, "0\n"); fclose (file); wakeups->priv->polling_enabled = FALSE; return TRUE; } /** * up_wakeups_disable_cb: **/ static gboolean up_wakeups_disable_cb (UpWakeups *wakeups) { g_debug ("disabling timer stats as we are idle"); up_wakeups_timerstats_disable (wakeups); /* never repeat */ return FALSE; } /** * up_wakeups_timerstats_enable: **/ static gboolean up_wakeups_timerstats_enable (UpWakeups *wakeups) { FILE *file; /* reset timeout */ if (wakeups->priv->disable_id != 0) g_source_remove (wakeups->priv->disable_id); wakeups->priv->disable_id = g_timeout_add_seconds (UP_WAKEUPS_DISABLE_INTERVAL, (GSourceFunc) up_wakeups_disable_cb, wakeups); #if GLIB_CHECK_VERSION(2,25,8) g_source_set_name_by_id (wakeups->priv->disable_id, "[UpWakeups] disable"); #endif /* already same state */ if (wakeups->priv->polling_enabled) return TRUE; g_debug ("enabling timer stats"); /* setup polls */ wakeups->priv->poll_kernel_id = g_timeout_add_seconds (UP_WAKEUPS_POLL_INTERVAL_KERNEL, (GSourceFunc) up_wakeups_poll_kernel_cb, wakeups); #if GLIB_CHECK_VERSION(2,25,8) g_source_set_name_by_id (wakeups->priv->poll_kernel_id, "[UpWakeups] kernel"); #endif wakeups->priv->poll_userspace_id = g_timeout_add_seconds (UP_WAKEUPS_POLL_INTERVAL_USERSPACE, (GSourceFunc) up_wakeups_poll_userspace_cb, wakeups); #if GLIB_CHECK_VERSION(2,25,8) g_source_set_name_by_id (wakeups->priv->poll_userspace_id, "[UpWakeups] userspace"); #endif file = fopen (UP_WAKEUPS_SOURCE_USERSPACE, "w"); if (file == NULL) return FALSE; fprintf (file, "1\n"); fclose (file); wakeups->priv->polling_enabled = TRUE; return TRUE; } /** * up_wakeups_get_property: **/ static void up_wakeups_get_property (GObject *object, guint prop_id, GValue *value, GParamSpec *pspec) { UpWakeups *wakeups; wakeups = UP_WAKEUPS (object); switch (prop_id) { case PROP_HAS_CAPABILITY: g_value_set_boolean (value, wakeups->priv->has_capability); break; default: G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); break; } } /** * up_wakeups_class_init: **/ static void up_wakeups_class_init (UpWakeupsClass *klass) { GObjectClass *object_class = G_OBJECT_CLASS (klass); object_class->finalize = up_wakeups_finalize; object_class->get_property = up_wakeups_get_property; signals [TOTAL_CHANGED] = g_signal_new ("total-changed", G_TYPE_FROM_CLASS (object_class), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (UpWakeupsClass, total_changed), NULL, NULL, g_cclosure_marshal_VOID__UINT, G_TYPE_NONE, 1, G_TYPE_UINT); signals [DATA_CHANGED] = g_signal_new ("data-changed", G_TYPE_FROM_CLASS (object_class), G_SIGNAL_RUN_LAST, G_STRUCT_OFFSET (UpWakeupsClass, data_changed), NULL, NULL, g_cclosure_marshal_VOID__VOID, G_TYPE_NONE, 0); g_object_class_install_property (object_class, PROP_HAS_CAPABILITY, g_param_spec_boolean ("has-capability", "Has capability", "If wakeups functionality is available", FALSE, G_PARAM_READABLE)); /* introspection */ dbus_g_object_type_install_info (UP_TYPE_WAKEUPS, &dbus_glib_up_wakeups_object_info); g_type_class_add_private (klass, sizeof (UpWakeupsPrivate)); } /** * up_wakeups_init: **/ static void up_wakeups_init (UpWakeups *wakeups) { GError *error = NULL; wakeups->priv = UP_WAKEUPS_GET_PRIVATE (wakeups); wakeups->priv->data = g_ptr_array_new_with_free_func ((GDestroyNotify) g_object_unref); wakeups->priv->total_old = 0; wakeups->priv->total_ave = 0; wakeups->priv->poll_userspace_id = 0; wakeups->priv->poll_kernel_id = 0; wakeups->priv->has_capability = FALSE; wakeups->priv->polling_enabled = FALSE; wakeups->priv->connection = dbus_g_bus_get (up_daemon_get_bus_type (), &error); if (error != NULL) { g_warning ("Cannot connect to bus: %s", error->message); g_error_free (error); return; } /* test if we have an interface */ if (g_file_test (UP_WAKEUPS_SOURCE_KERNEL, G_FILE_TEST_EXISTS) || g_file_test (UP_WAKEUPS_SOURCE_KERNEL, G_FILE_TEST_EXISTS)) { wakeups->priv->has_capability = TRUE; } /* register on the bus */ dbus_g_connection_register_g_object (wakeups->priv->connection, "/org/freedesktop/UPower/Wakeups", G_OBJECT (wakeups)); } /** * up_wakeups_finalize: **/ static void up_wakeups_finalize (GObject *object) { UpWakeups *wakeups; g_return_if_fail (object != NULL); g_return_if_fail (UP_IS_WAKEUPS (object)); wakeups = UP_WAKEUPS (object); wakeups->priv = UP_WAKEUPS_GET_PRIVATE (wakeups); /* stop timerstats */ up_wakeups_timerstats_disable (wakeups); g_ptr_array_unref (wakeups->priv->data); G_OBJECT_CLASS (up_wakeups_parent_class)->finalize (object); } /** * up_wakeups_new: **/ UpWakeups * up_wakeups_new (void) { UpWakeups *wakeups; wakeups = g_object_new (UP_TYPE_WAKEUPS, NULL); return UP_WAKEUPS (wakeups); }