summaryrefslogtreecommitdiff
path: root/src/gs-listener-dbus.c
diff options
context:
space:
mode:
authorPerberos <[email protected]>2011-11-04 22:16:15 -0300
committerPerberos <[email protected]>2011-11-04 22:16:15 -0300
commitfff4ecc82f2bcfa7427596e7ad9c3769fcab040b (patch)
treeac4f1812a7991609c9c32c776daede2d8492f7b5 /src/gs-listener-dbus.c
downloadmate-screensaver-fff4ecc82f2bcfa7427596e7ad9c3769fcab040b.tar.bz2
mate-screensaver-fff4ecc82f2bcfa7427596e7ad9c3769fcab040b.tar.xz
first commit
Diffstat (limited to 'src/gs-listener-dbus.c')
-rw-r--r--src/gs-listener-dbus.c2272
1 files changed, 2272 insertions, 0 deletions
diff --git a/src/gs-listener-dbus.c b/src/gs-listener-dbus.c
new file mode 100644
index 0000000..601689c
--- /dev/null
+++ b/src/gs-listener-dbus.c
@@ -0,0 +1,2272 @@
+/* -*- Mode: C; tab-width: 8; indent-tabs-mode: nil; c-basic-offset: 8 -*-
+ *
+ * Copyright (C) 2004-2006 William Jon McCann <[email protected]>
+ *
+ * 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., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
+ *
+ * Authors: William Jon McCann <[email protected]>
+ *
+ */
+
+#include "config.h"
+#include <stdlib.h>
+#include <stdio.h>
+#include <time.h>
+#include <string.h>
+
+#include <glib/gi18n.h>
+
+#include <dbus/dbus.h>
+#include <dbus/dbus-glib.h>
+#include <dbus/dbus-glib-lowlevel.h>
+
+#include "gs-listener-dbus.h"
+#include "gs-marshal.h"
+#include "gs-debug.h"
+
+/* this is for dbus < 0.3 */
+#if ((DBUS_VERSION_MAJOR == 0) && (DBUS_VERSION_MINOR < 30))
+#define dbus_bus_name_has_owner(connection, name, err) dbus_bus_service_exists(connection, name, err)
+#define dbus_bus_request_name(connection, name, flags, err) dbus_bus_acquire_service(connection, name, flags, err)
+#endif
+
+static void gs_listener_class_init (GSListenerClass *klass);
+static void gs_listener_init (GSListener *listener);
+static void gs_listener_finalize (GObject *object);
+
+static void gs_listener_unregister_handler (DBusConnection *connection,
+ void *data);
+
+static DBusHandlerResult gs_listener_message_handler (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data);
+
+#define GS_LISTENER_SERVICE "org.mate.ScreenSaver"
+#define GS_LISTENER_PATH "/org/mate/ScreenSaver"
+#define GS_LISTENER_INTERFACE "org.mate.ScreenSaver"
+
+#define HAL_DEVICE_INTERFACE "org.freedesktop.Hal.Device"
+
+#define CK_NAME "org.freedesktop.ConsoleKit"
+#define CK_MANAGER_PATH "/org/freedesktop/ConsoleKit/Manager"
+#define CK_MANAGER_INTERFACE "org.freedesktop.ConsoleKit.Manager"
+#define CK_SESSION_INTERFACE "org.freedesktop.ConsoleKit.Session"
+
+#define SESSION_NAME "org.mate.SessionManager"
+#define SESSION_PATH "/org/mate/SessionManager"
+#define SESSION_INTERFACE "org.mate.SessionManager"
+
+#define TYPE_MISMATCH_ERROR GS_LISTENER_INTERFACE ".TypeMismatch"
+
+#define GS_LISTENER_GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), GS_TYPE_LISTENER, GSListenerPrivate))
+
+struct GSListenerPrivate
+{
+ DBusConnection *connection;
+ DBusConnection *system_connection;
+
+ guint session_idle : 1;
+ guint active : 1;
+ guint activation_enabled : 1;
+ guint throttled : 1;
+ GHashTable *inhibitors;
+ GHashTable *throttlers;
+ time_t active_start;
+ time_t session_idle_start;
+ char *session_id;
+
+ guint32 ck_throttle_cookie;
+};
+
+typedef struct
+{
+ int entry_type;
+ char *application;
+ char *reason;
+ char *connection;
+ guint32 cookie;
+ guint32 foreign_cookie;
+ GTimeVal since;
+} GSListenerRefEntry;
+
+enum
+{
+ LOCK,
+ CYCLE,
+ QUIT,
+ SIMULATE_USER_ACTIVITY,
+ ACTIVE_CHANGED,
+ THROTTLE_CHANGED,
+ SHOW_MESSAGE,
+ LAST_SIGNAL
+};
+
+enum
+{
+ PROP_0,
+ PROP_ACTIVE,
+ PROP_SESSION_IDLE,
+ PROP_ACTIVATION_ENABLED,
+};
+
+enum
+{
+ REF_ENTRY_TYPE_INHIBIT,
+ REF_ENTRY_TYPE_THROTTLE
+};
+
+static DBusObjectPathVTable
+gs_listener_vtable = { &gs_listener_unregister_handler,
+ &gs_listener_message_handler,
+ NULL,
+ NULL,
+ NULL,
+ NULL
+ };
+
+static guint signals [LAST_SIGNAL] = { 0, };
+
+G_DEFINE_TYPE (GSListener, gs_listener, G_TYPE_OBJECT)
+
+GQuark
+gs_listener_error_quark (void)
+{
+ static GQuark quark = 0;
+ if (!quark)
+ {
+ quark = g_quark_from_static_string ("gs_listener_error");
+ }
+
+ return quark;
+}
+
+static void
+gs_listener_ref_entry_free (GSListenerRefEntry *entry)
+{
+ g_free (entry->connection);
+ g_free (entry->application);
+ g_free (entry->reason);
+ g_free (entry);
+ entry = NULL;
+}
+
+static void
+gs_listener_unregister_handler (DBusConnection *connection,
+ void *data)
+{
+}
+
+static gboolean
+send_dbus_message (DBusConnection *connection,
+ DBusMessage *message)
+{
+ gboolean is_connected;
+ gboolean sent;
+
+ g_return_val_if_fail (message != NULL, FALSE);
+
+ if (! connection)
+ {
+ gs_debug ("There is no valid connection to the message bus");
+ return FALSE;
+ }
+
+ is_connected = dbus_connection_get_is_connected (connection);
+ if (! is_connected)
+ {
+ gs_debug ("Not connected to the message bus");
+ return FALSE;
+ }
+
+ sent = dbus_connection_send (connection, message, NULL);
+
+ return sent;
+}
+
+static void
+send_dbus_boolean_signal (GSListener *listener,
+ const char *name,
+ gboolean value)
+{
+ DBusMessage *message;
+ DBusMessageIter iter;
+
+ g_return_if_fail (listener != NULL);
+
+ message = dbus_message_new_signal (GS_LISTENER_PATH,
+ GS_LISTENER_SERVICE,
+ name);
+
+ dbus_message_iter_init_append (message, &iter);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_BOOLEAN, &value);
+
+ if (! send_dbus_message (listener->priv->connection, message))
+ {
+ gs_debug ("Could not send %s signal", name);
+ }
+
+ dbus_message_unref (message);
+}
+
+static void
+gs_listener_send_signal_active_changed (GSListener *listener)
+{
+ g_return_if_fail (listener != NULL);
+
+ gs_debug ("Sending the ActiveChanged(%s) signal on the session bus",
+ listener->priv->active ? "TRUE" : "FALSE");
+
+ send_dbus_boolean_signal (listener, "ActiveChanged", listener->priv->active);
+}
+
+static const char *
+get_name_for_entry_type (int entry_type)
+{
+ const char *name;
+
+ switch (entry_type)
+ {
+ case REF_ENTRY_TYPE_INHIBIT:
+ name = "inhibitor";
+ break;
+ case REF_ENTRY_TYPE_THROTTLE:
+ name = "throttler";
+ break;
+ default:
+ g_assert_not_reached ();
+ break;
+ }
+
+ return name;
+}
+
+static GHashTable *
+get_hash_for_entry_type (GSListener *listener,
+ int entry_type)
+{
+ GHashTable *hash;
+
+ switch (entry_type)
+ {
+ case REF_ENTRY_TYPE_INHIBIT:
+ hash = listener->priv->inhibitors;
+ break;
+ case REF_ENTRY_TYPE_THROTTLE:
+ hash = listener->priv->throttlers;
+ break;
+ default:
+ g_assert_not_reached ();
+ break;
+ }
+
+ return hash;
+}
+
+static void
+list_ref_entry (gpointer key,
+ gpointer value,
+ gpointer user_data)
+{
+ GSListenerRefEntry *entry;
+
+ entry = (GSListenerRefEntry *)value;
+
+ gs_debug ("%s: %s for reason: %s",
+ get_name_for_entry_type (entry->entry_type),
+ entry->application,
+ entry->reason);
+}
+
+static gboolean
+listener_ref_entry_is_present (GSListener *listener,
+ int entry_type)
+{
+ guint n_entries;
+ gboolean is_set;
+ GHashTable *hash;
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+
+ /* if we aren't inhibited then activate */
+ n_entries = 0;
+ if (hash != NULL)
+ {
+ n_entries = g_hash_table_size (hash);
+
+ g_hash_table_foreach (hash, list_ref_entry, NULL);
+ }
+
+ is_set = (n_entries > 0);
+
+ return is_set;
+}
+
+static gboolean
+listener_check_activation (GSListener *listener)
+{
+ gboolean inhibited;
+ gboolean res;
+
+ gs_debug ("Checking for activation");
+
+ if (! listener->priv->activation_enabled)
+ {
+ return TRUE;
+ }
+
+ if (! listener->priv->session_idle)
+ {
+ return TRUE;
+ }
+
+ /* if we aren't inhibited then activate */
+ inhibited = listener_ref_entry_is_present (listener, REF_ENTRY_TYPE_INHIBIT);
+
+ res = FALSE;
+ if (! inhibited)
+ {
+ gs_debug ("Trying to activate");
+ res = gs_listener_set_active (listener, TRUE);
+ }
+
+ return res;
+}
+
+static void
+gs_listener_set_throttle (GSListener *listener,
+ gboolean throttled)
+{
+ g_return_if_fail (GS_IS_LISTENER (listener));
+
+ if (listener->priv->throttled != throttled)
+ {
+ gs_debug ("Changing throttle status: %d", throttled);
+
+ listener->priv->throttled = throttled;
+
+ g_signal_emit (listener, signals [THROTTLE_CHANGED], 0, throttled);
+ }
+}
+
+static gboolean
+listener_check_throttle (GSListener *listener)
+{
+ gboolean throttled;
+
+ gs_debug ("Checking for throttle");
+
+ throttled = listener_ref_entry_is_present (listener, REF_ENTRY_TYPE_THROTTLE);
+
+ if (throttled != listener->priv->throttled)
+ {
+ gs_listener_set_throttle (listener, throttled);
+ }
+
+ return TRUE;
+}
+
+static gboolean
+listener_set_session_idle_internal (GSListener *listener,
+ gboolean idle)
+{
+ listener->priv->session_idle = idle;
+
+ if (idle)
+ {
+ listener->priv->session_idle_start = time (NULL);
+ }
+ else
+ {
+ listener->priv->session_idle_start = 0;
+ }
+
+ return TRUE;
+}
+
+static gboolean
+listener_set_active_internal (GSListener *listener,
+ gboolean active)
+{
+ listener->priv->active = active;
+
+ /* if idle not in sync with active, change it */
+ if (listener->priv->session_idle != active)
+ {
+ listener_set_session_idle_internal (listener, active);
+ }
+
+ if (active)
+ {
+ listener->priv->active_start = time (NULL);
+ }
+ else
+ {
+ listener->priv->active_start = 0;
+ }
+
+ gs_listener_send_signal_active_changed (listener);
+
+ return TRUE;
+}
+
+gboolean
+gs_listener_set_active (GSListener *listener,
+ gboolean active)
+{
+ gboolean res;
+
+ g_return_val_if_fail (GS_IS_LISTENER (listener), FALSE);
+
+ if (listener->priv->active == active)
+ {
+ gs_debug ("Trying to set active state when already: %s",
+ active ? "active" : "inactive");
+ return FALSE;
+ }
+
+ res = FALSE;
+ g_signal_emit (listener, signals [ACTIVE_CHANGED], 0, active, &res);
+ if (! res)
+ {
+ /* if the signal is not handled then we haven't changed state */
+ gs_debug ("Active-changed signal not handled");
+
+ /* clear the idle state */
+ if (active)
+ {
+ listener_set_session_idle_internal (listener, FALSE);
+ }
+
+ return FALSE;
+ }
+
+ listener_set_active_internal (listener, active);
+
+ return TRUE;
+}
+
+gboolean
+gs_listener_set_session_idle (GSListener *listener,
+ gboolean idle)
+{
+ gboolean res;
+
+ g_return_val_if_fail (GS_IS_LISTENER (listener), FALSE);
+
+ gs_debug ("Setting session idle: %d", idle);
+
+ if (listener->priv->session_idle == idle)
+ {
+ gs_debug ("Trying to set idle state when already %s",
+ idle ? "idle" : "not idle");
+ return FALSE;
+ }
+
+ if (idle)
+ {
+ gboolean inhibited;
+
+ inhibited = listener_ref_entry_is_present (listener, REF_ENTRY_TYPE_INHIBIT);
+
+ /* if we are inhibited then do nothing */
+ if (inhibited)
+ {
+ return FALSE;
+ }
+ }
+
+ listener->priv->session_idle = idle;
+ res = listener_check_activation (listener);
+
+ /* if activation fails then don't set idle */
+ if (res)
+ {
+ listener_set_session_idle_internal (listener, idle);
+ }
+ else
+ {
+ gs_debug ("Idle activation failed");
+ listener->priv->session_idle = !idle;
+ }
+
+ return res;
+}
+
+gboolean
+gs_listener_get_activation_enabled (GSListener *listener)
+{
+ g_return_val_if_fail (GS_IS_LISTENER (listener), FALSE);
+
+ return listener->priv->activation_enabled;
+}
+
+gboolean
+gs_listener_is_inhibited (GSListener *listener)
+{
+ gboolean inhibited;
+
+ g_return_val_if_fail (GS_IS_LISTENER (listener), FALSE);
+
+ inhibited = listener_ref_entry_is_present (listener, REF_ENTRY_TYPE_INHIBIT);
+
+ return inhibited;
+}
+
+void
+gs_listener_set_activation_enabled (GSListener *listener,
+ gboolean enabled)
+{
+ g_return_if_fail (GS_IS_LISTENER (listener));
+
+ if (listener->priv->activation_enabled != enabled)
+ {
+ listener->priv->activation_enabled = enabled;
+ }
+}
+
+static dbus_bool_t
+listener_property_set_bool (GSListener *listener,
+ guint prop_id,
+ dbus_bool_t value)
+{
+ dbus_bool_t ret;
+
+ ret = FALSE;
+
+ switch (prop_id)
+ {
+ case PROP_ACTIVE:
+ gs_listener_set_active (listener, value);
+ ret = TRUE;
+ break;
+ default:
+ break;
+ }
+
+ return ret;
+}
+
+static void
+raise_error (DBusConnection *connection,
+ DBusMessage *in_reply_to,
+ const char *error_name,
+ char *format, ...)
+{
+ char buf[512];
+ DBusMessage *reply;
+
+ va_list args;
+ va_start (args, format);
+ vsnprintf (buf, sizeof (buf), format, args);
+ va_end (args);
+
+ gs_debug (buf);
+ reply = dbus_message_new_error (in_reply_to, error_name, buf);
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+}
+
+static void
+raise_syntax (DBusConnection *connection,
+ DBusMessage *in_reply_to,
+ const char *method_name)
+{
+ raise_error (connection, in_reply_to,
+ GS_LISTENER_SERVICE ".SyntaxError",
+ "There is a syntax error in the invocation of the method %s",
+ method_name);
+}
+
+static guint32
+generate_cookie (void)
+{
+ guint32 cookie;
+
+ cookie = (guint32)g_random_int_range (1, G_MAXINT32);
+
+ return cookie;
+}
+
+static guint32
+listener_generate_unique_key (GSListener *listener,
+ int entry_type)
+{
+ guint32 cookie;
+ GHashTable *hash;
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+
+ do
+ {
+ cookie = generate_cookie ();
+ }
+ while (g_hash_table_lookup (hash, &cookie) != NULL);
+
+ return cookie;
+}
+
+static void
+listener_ref_entry_check (GSListener *listener,
+ int entry_type)
+{
+ switch (entry_type)
+ {
+ case REF_ENTRY_TYPE_INHIBIT:
+ listener_check_activation (listener);
+ break;
+ case REF_ENTRY_TYPE_THROTTLE:
+ listener_check_throttle (listener);
+ break;
+ default:
+ g_assert_not_reached ();
+ break;
+ }
+}
+
+static void
+add_session_inhibit (GSListener *listener,
+ GSListenerRefEntry *entry)
+{
+ DBusMessage *message;
+ DBusMessage *reply;
+ DBusMessageIter iter;
+ DBusMessageIter reply_iter;
+ DBusError error;
+ guint xid;
+ guint flags;
+
+ g_return_if_fail (listener != NULL);
+
+ dbus_error_init (&error);
+
+ message = dbus_message_new_method_call (SESSION_NAME,
+ SESSION_PATH,
+ SESSION_INTERFACE,
+ "Inhibit");
+ if (message == NULL)
+ {
+ gs_debug ("Couldn't allocate the dbus message");
+ return;
+ }
+
+ dbus_message_iter_init_append (message, &iter);
+ xid = 0;
+ flags = 8;
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_STRING, &entry->application);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_UINT32, &xid);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_STRING, &entry->reason);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_UINT32, &flags);
+
+ /* FIXME: use async? */
+ reply = dbus_connection_send_with_reply_and_block (listener->priv->connection,
+ message,
+ -1,
+ &error);
+ dbus_message_unref (message);
+
+ if (dbus_error_is_set (&error))
+ {
+ gs_debug ("%s raised:\n %s\n\n", error.name, error.message);
+ dbus_error_free (&error);
+ return;
+ }
+
+ dbus_message_iter_init (reply, &reply_iter);
+ dbus_message_iter_get_basic (&reply_iter, &entry->foreign_cookie);
+
+ dbus_message_unref (reply);
+}
+
+static void
+remove_session_inhibit (GSListener *listener,
+ GSListenerRefEntry *entry)
+{
+ DBusMessage *message;
+ DBusMessage *reply;
+ DBusMessageIter iter;
+ DBusError error;
+
+ g_return_if_fail (listener != NULL);
+
+ if (entry->foreign_cookie == 0)
+ {
+ gs_debug ("Can't remove inhibitor from session: Session cookie not set");
+ return;
+ }
+
+ dbus_error_init (&error);
+
+ message = dbus_message_new_method_call (SESSION_NAME,
+ SESSION_PATH,
+ SESSION_INTERFACE,
+ "Uninhibit");
+ if (message == NULL)
+ {
+ gs_debug ("Couldn't allocate the dbus message");
+ return;
+ }
+
+ dbus_message_iter_init_append (message, &iter);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_UINT32, &entry->foreign_cookie);
+
+ /* FIXME: use async? */
+ reply = dbus_connection_send_with_reply_and_block (listener->priv->connection,
+ message,
+ -1,
+ &error);
+ dbus_message_unref (message);
+
+ if (dbus_error_is_set (&error))
+ {
+ gs_debug ("%s raised:\n %s\n\n", error.name, error.message);
+ dbus_error_free (&error);
+ return;
+ }
+
+ dbus_message_unref (reply);
+}
+
+static void
+listener_add_ref_entry (GSListener *listener,
+ int entry_type,
+ GSListenerRefEntry *entry)
+{
+ GHashTable *hash;
+
+ gs_debug ("adding %s from %s for reason '%s' on connection %s",
+ get_name_for_entry_type (entry_type),
+ entry->application,
+ entry->reason,
+ entry->connection);
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+ g_hash_table_insert (hash, &entry->cookie, entry);
+
+ if (entry_type == REF_ENTRY_TYPE_INHIBIT)
+ {
+ /* proxy inhibit over to mate session */
+ add_session_inhibit (listener, entry);
+ }
+
+ listener_ref_entry_check (listener, entry_type);
+}
+
+static gboolean
+listener_remove_ref_entry (GSListener *listener,
+ int entry_type,
+ guint32 cookie)
+{
+ GHashTable *hash;
+ gboolean removed;
+ GSListenerRefEntry *entry;
+
+ removed = FALSE;
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+
+ entry = g_hash_table_lookup (hash, &cookie);
+ if (entry == NULL)
+ {
+ goto out;
+ }
+
+ gs_debug ("removing %s from %s for reason '%s' on connection %s",
+ get_name_for_entry_type (entry_type),
+ entry->application,
+ entry->reason,
+ entry->connection);
+
+ if (entry_type == REF_ENTRY_TYPE_INHIBIT)
+ {
+ /* remove inhibit from mate session */
+ remove_session_inhibit (listener, entry);
+ }
+
+ removed = g_hash_table_remove (hash, &cookie);
+out:
+ if (removed)
+ {
+ listener_ref_entry_check (listener, entry_type);
+ }
+ else
+ {
+ gs_debug ("Cookie %u was not in the list!", cookie);
+ }
+
+ return removed;
+}
+
+#if GLIB_CHECK_VERSION(2,12,0)
+#define _g_time_val_to_iso8601(t) g_time_val_to_iso8601(t)
+#else
+/* copied from GLib */
+static gchar *
+_g_time_val_to_iso8601 (GTimeVal *time_)
+{
+ gchar *retval;
+
+ g_return_val_if_fail (time_->tv_usec >= 0 && time_->tv_usec < G_USEC_PER_SEC, NULL);
+
+#define ISO_8601_LEN 21
+#define ISO_8601_FORMAT "%Y-%m-%dT%H:%M:%SZ"
+ retval = g_new0 (gchar, ISO_8601_LEN + 1);
+
+ strftime (retval, ISO_8601_LEN,
+ ISO_8601_FORMAT,
+ gmtime (&(time_->tv_sec)));
+
+ return retval;
+}
+#endif
+
+static void
+accumulate_ref_entry (gpointer key,
+ GSListenerRefEntry *entry,
+ DBusMessageIter *iter)
+{
+ char *description;
+ char *time;
+
+ time = _g_time_val_to_iso8601 (&entry->since);
+
+ description = g_strdup_printf ("Application=\"%s\"; Since=\"%s\"; Reason=\"%s\";",
+ entry->application,
+ time,
+ entry->reason);
+
+ dbus_message_iter_append_basic (iter, DBUS_TYPE_STRING, &description);
+
+ g_free (description);
+ g_free (time);
+}
+
+static DBusHandlerResult
+listener_dbus_get_ref_entries (GSListener *listener,
+ int entry_type,
+ DBusConnection *connection,
+ DBusMessage *message)
+{
+ DBusMessage *reply;
+ GHashTable *hash;
+ DBusMessageIter iter;
+ DBusMessageIter iter_array;
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+
+ reply = dbus_message_new_method_return (message);
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_iter_init_append (reply, &iter);
+ dbus_message_iter_open_container (&iter,
+ DBUS_TYPE_ARRAY,
+ DBUS_TYPE_STRING_AS_STRING,
+ &iter_array);
+
+ if (hash != NULL)
+ {
+ g_hash_table_foreach (hash,
+ (GHFunc)accumulate_ref_entry,
+ &iter_array);
+ }
+
+ dbus_message_iter_close_container (&iter, &iter_array);
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static void
+listener_add_ck_ref_entry (GSListener *listener,
+ int entry_type,
+ DBusConnection *connection,
+ DBusMessage *message,
+ guint32 *cookiep)
+{
+ GSListenerRefEntry *entry;
+
+ entry = g_new0 (GSListenerRefEntry, 1);
+ entry->entry_type = entry_type;
+ entry->connection = g_strdup (dbus_message_get_sender (message));
+ entry->cookie = listener_generate_unique_key (listener, entry_type);
+ entry->application = g_strdup ("ConsoleKit");
+ entry->reason = g_strdup ("Session is not active");
+ g_get_current_time (&entry->since);
+
+ /* takes ownership of entry */
+ listener_add_ref_entry (listener, entry_type, entry);
+
+ if (cookiep != NULL)
+ {
+ *cookiep = entry->cookie;
+ }
+}
+
+static void
+listener_remove_ck_ref_entry (GSListener *listener,
+ int entry_type,
+ guint32 cookie)
+{
+ listener_remove_ref_entry (listener, entry_type, cookie);
+}
+
+static DBusHandlerResult
+listener_dbus_add_ref_entry (GSListener *listener,
+ int entry_type,
+ DBusConnection *connection,
+ DBusMessage *message)
+{
+ DBusMessage *reply;
+ DBusError error;
+ const char *application;
+ const char *reason;
+ GSListenerRefEntry *entry;
+ DBusMessageIter iter;
+
+ dbus_error_init (&error);
+ if (! dbus_message_get_args (message, &error,
+ DBUS_TYPE_STRING, &application,
+ DBUS_TYPE_STRING, &reason,
+ DBUS_TYPE_INVALID))
+ {
+ if (entry_type == REF_ENTRY_TYPE_INHIBIT)
+ {
+ raise_syntax (connection, message, "Inhibit");
+ }
+ else if (entry_type == REF_ENTRY_TYPE_THROTTLE)
+ {
+ raise_syntax (connection, message, "Throttle");
+ }
+ else
+ {
+ g_assert_not_reached ();
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ reply = dbus_message_new_method_return (message);
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ entry = g_new0 (GSListenerRefEntry, 1);
+ entry->entry_type = entry_type;
+ entry->connection = g_strdup (dbus_message_get_sender (message));
+ entry->cookie = listener_generate_unique_key (listener, entry_type);
+ entry->application = g_strdup (application);
+ entry->reason = g_strdup (reason);
+ g_get_current_time (&entry->since);
+
+ listener_add_ref_entry (listener, entry_type, entry);
+
+ dbus_message_iter_init_append (reply, &iter);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_UINT32, &entry->cookie);
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_dbus_remove_ref_entry (GSListener *listener,
+ int entry_type,
+ DBusConnection *connection,
+ DBusMessage *message)
+{
+ DBusMessage *reply;
+ DBusError error;
+ const char *sender;
+ guint32 cookie;
+
+ dbus_error_init (&error);
+ if (! dbus_message_get_args (message, &error,
+ DBUS_TYPE_UINT32, &cookie,
+ DBUS_TYPE_INVALID))
+ {
+ if (entry_type == REF_ENTRY_TYPE_INHIBIT)
+ {
+ raise_syntax (connection, message, "UnInhibit");
+ }
+ else if (entry_type == REF_ENTRY_TYPE_THROTTLE)
+ {
+ raise_syntax (connection, message, "UnThrottle");
+ }
+ else
+ {
+ g_assert_not_reached ();
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ reply = dbus_message_new_method_return (message);
+ if (reply == NULL)
+ g_error ("No memory");
+
+ /* FIXME: check sender is from same connection as entry */
+ sender = dbus_message_get_sender (message);
+
+ listener_remove_ref_entry (listener, entry_type, cookie);
+
+ /* FIXME: Pointless? */
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static gboolean
+listener_ref_entry_remove_for_connection (GSListener *listener,
+ int entry_type,
+ const char *connection)
+{
+ gboolean removed;
+ GHashTable *hash;
+ GHashTableIter iter;
+ GSListenerRefEntry *entry;
+
+ if (connection == NULL)
+ return FALSE;
+
+ hash = get_hash_for_entry_type (listener, entry_type);
+
+ removed = FALSE;
+ g_hash_table_iter_init (&iter, hash);
+ while (g_hash_table_iter_next (&iter, NULL, (gpointer *)&entry))
+ {
+ if (entry->connection != NULL &&
+ strcmp (connection, entry->connection) == 0)
+ {
+ gs_debug ("removing %s from %s for reason '%s' on connection %s",
+ get_name_for_entry_type (entry->entry_type),
+ entry->application,
+ entry->reason,
+ entry->connection);
+
+ if (entry->entry_type == REF_ENTRY_TYPE_INHIBIT)
+ {
+ /* remove inhibit from mate session */
+ remove_session_inhibit (listener, entry);
+ }
+
+ g_hash_table_iter_remove (&iter);
+ removed = TRUE;
+ }
+ }
+
+ return removed;
+}
+
+static void
+listener_service_deleted (GSListener *listener,
+ DBusMessage *message)
+{
+ const char *old_service_name;
+ const char *new_service_name;
+ gboolean removed;
+
+ if (! dbus_message_get_args (message, NULL,
+ DBUS_TYPE_STRING, &old_service_name,
+ DBUS_TYPE_STRING, &new_service_name,
+ DBUS_TYPE_INVALID))
+ {
+ g_error ("Invalid NameOwnerChanged signal from bus!");
+ return;
+ }
+
+ gs_debug ("DBUS service deleted: %s", new_service_name);
+
+ removed = listener_ref_entry_remove_for_connection (listener, REF_ENTRY_TYPE_THROTTLE, new_service_name);
+ if (removed)
+ {
+ listener_ref_entry_check (listener, REF_ENTRY_TYPE_THROTTLE);
+ }
+
+ removed = listener_ref_entry_remove_for_connection (listener, REF_ENTRY_TYPE_INHIBIT, new_service_name);
+ if (removed)
+ {
+ listener_ref_entry_check (listener, REF_ENTRY_TYPE_INHIBIT);
+ }
+
+}
+
+static void
+raise_property_type_error (DBusConnection *connection,
+ DBusMessage *in_reply_to,
+ const char *device_id)
+{
+ char buf [512];
+ DBusMessage *reply;
+
+ snprintf (buf, 511,
+ "Type mismatch setting property with id %s",
+ device_id);
+ gs_debug (buf);
+
+ reply = dbus_message_new_error (in_reply_to,
+ TYPE_MISMATCH_ERROR,
+ buf);
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+}
+
+static DBusHandlerResult
+listener_set_property (GSListener *listener,
+ DBusConnection *connection,
+ DBusMessage *message,
+ guint prop_id)
+{
+ const char *path;
+ int type;
+ gboolean rc;
+ DBusMessageIter iter;
+ DBusMessage *reply;
+
+ path = dbus_message_get_path (message);
+
+ dbus_message_iter_init (message, &iter);
+ type = dbus_message_iter_get_arg_type (&iter);
+ rc = FALSE;
+
+ switch (type)
+ {
+ case DBUS_TYPE_BOOLEAN:
+ {
+ dbus_bool_t v;
+ dbus_message_iter_get_basic (&iter, &v);
+ rc = listener_property_set_bool (listener, prop_id, v);
+ break;
+ }
+ default:
+ gs_debug ("Unsupported property type %d", type);
+ break;
+ }
+
+ if (! rc)
+ {
+ raise_property_type_error (connection, message, path);
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ reply = dbus_message_new_method_return (message);
+
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_get_property (GSListener *listener,
+ DBusConnection *connection,
+ DBusMessage *message,
+ guint prop_id)
+{
+ DBusMessageIter iter;
+ DBusMessage *reply;
+
+ reply = dbus_message_new_method_return (message);
+
+ dbus_message_iter_init_append (reply, &iter);
+
+ if (reply == NULL)
+ g_error ("No memory");
+
+ switch (prop_id)
+ {
+ case PROP_ACTIVE:
+ {
+ dbus_bool_t b;
+ b = listener->priv->active;
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_BOOLEAN, &b);
+ }
+ break;
+ default:
+ gs_debug ("Unsupported property id %u", prop_id);
+ break;
+ }
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_get_active_time (GSListener *listener,
+ DBusConnection *connection,
+ DBusMessage *message)
+{
+ DBusMessageIter iter;
+ DBusMessage *reply;
+ dbus_uint32_t secs;
+
+ reply = dbus_message_new_method_return (message);
+
+ dbus_message_iter_init_append (reply, &iter);
+
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ if (listener->priv->active)
+ {
+ time_t now = time (NULL);
+
+ if (now < listener->priv->active_start)
+ {
+ /* shouldn't happen */
+ gs_debug ("Active start time is in the future");
+ secs = 0;
+ }
+ else if (listener->priv->active_start <= 0)
+ {
+ /* shouldn't happen */
+ gs_debug ("Active start time was not set");
+ secs = 0;
+ }
+ else
+ {
+ secs = now - listener->priv->active_start;
+ }
+ }
+ else
+ {
+ secs = 0;
+ }
+
+ gs_debug ("Returning screensaver active for %u seconds", secs);
+ dbus_message_iter_append_basic (&iter, DBUS_TYPE_UINT32, &secs);
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_show_message (GSListener *listener,
+ DBusConnection *connection,
+ DBusMessage *message)
+{
+ DBusMessageIter iter;
+ DBusMessage *reply;
+ DBusError error;
+
+ reply = dbus_message_new_method_return (message);
+
+ dbus_message_iter_init_append (reply, &iter);
+
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ if (listener->priv->active)
+ {
+ char *summary;
+ char *body;
+ char *icon;
+
+ /* if we're not active we ignore the request */
+
+ dbus_error_init (&error);
+ if (! dbus_message_get_args (message, &error,
+ DBUS_TYPE_STRING, &summary,
+ DBUS_TYPE_STRING, &body,
+ DBUS_TYPE_STRING, &icon,
+ DBUS_TYPE_INVALID))
+ {
+ raise_syntax (connection, message, "ShowMessage");
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ g_signal_emit (listener, signals [SHOW_MESSAGE], 0, summary, body, icon);
+ }
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+do_introspect (DBusConnection *connection,
+ DBusMessage *message,
+ dbus_bool_t local_interface)
+{
+ DBusMessage *reply;
+ GString *xml;
+ char *xml_string;
+
+ /* standard header */
+ xml = g_string_new ("<!DOCTYPE node PUBLIC \"-//freedesktop//DTD D-BUS Object Introspection 1.0//EN\"\n"
+ "\"http://www.freedesktop.org/standards/dbus/1.0/introspect.dtd\">\n"
+ "<node>\n"
+ " <interface name=\"org.freedesktop.DBus.Introspectable\">\n"
+ " <method name=\"Introspect\">\n"
+ " <arg name=\"data\" direction=\"out\" type=\"s\"/>\n"
+ " </method>\n"
+ " </interface>\n");
+
+ /* ScreenSaver interface */
+ xml = g_string_append (xml,
+ " <interface name=\"org.mate.ScreenSaver\">\n"
+ " <method name=\"Lock\">\n"
+ " </method>\n"
+ " <method name=\"Cycle\">\n"
+ " </method>\n"
+ " <method name=\"SimulateUserActivity\">\n"
+ " </method>\n"
+ " <method name=\"Inhibit\">\n"
+ " <arg name=\"application_name\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"reason\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"cookie\" direction=\"out\" type=\"u\"/>\n"
+ " </method>\n"
+ " <method name=\"UnInhibit\">\n"
+ " <arg name=\"cookie\" direction=\"in\" type=\"u\"/>\n"
+ " </method>\n"
+ " <method name=\"GetInhibitors\">\n"
+ " <arg name=\"list\" direction=\"out\" type=\"as\"/>\n"
+ " </method>\n"
+ " <method name=\"Throttle\">\n"
+ " <arg name=\"application_name\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"reason\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"cookie\" direction=\"out\" type=\"u\"/>\n"
+ " </method>\n"
+ " <method name=\"UnThrottle\">\n"
+ " <arg name=\"cookie\" direction=\"in\" type=\"u\"/>\n"
+ " </method>\n"
+ " <method name=\"GetActive\">\n"
+ " <arg name=\"value\" direction=\"out\" type=\"b\"/>\n"
+ " </method>\n"
+ " <method name=\"GetActiveTime\">\n"
+ " <arg name=\"seconds\" direction=\"out\" type=\"u\"/>\n"
+ " </method>\n"
+ " <method name=\"SetActive\">\n"
+ " <arg name=\"value\" direction=\"in\" type=\"b\"/>\n"
+ " </method>\n"
+ " <method name=\"ShowMessage\">\n"
+ " <arg name=\"summary\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"body\" direction=\"in\" type=\"s\"/>\n"
+ " <arg name=\"icon\" direction=\"in\" type=\"s\"/>\n"
+ " </method>\n"
+ " <signal name=\"ActiveChanged\">\n"
+ " <arg name=\"new_value\" type=\"b\"/>\n"
+ " </signal>\n"
+ " </interface>\n");
+
+ reply = dbus_message_new_method_return (message);
+
+ xml = g_string_append (xml, "</node>\n");
+ xml_string = g_string_free (xml, FALSE);
+
+ dbus_message_append_args (reply,
+ DBUS_TYPE_STRING, &xml_string,
+ DBUS_TYPE_INVALID);
+
+ g_free (xml_string);
+
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_dbus_handle_session_message (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data,
+ dbus_bool_t local_interface)
+{
+ GSListener *listener = GS_LISTENER (user_data);
+
+#if 0
+ g_message ("obj_path=%s interface=%s method=%s destination=%s",
+ dbus_message_get_path (message),
+ dbus_message_get_interface (message),
+ dbus_message_get_member (message),
+ dbus_message_get_destination (message));
+#endif
+
+ g_return_val_if_fail (connection != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+ g_return_val_if_fail (message != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "Lock"))
+ {
+ g_signal_emit (listener, signals [LOCK], 0);
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "Quit"))
+ {
+ g_signal_emit (listener, signals [QUIT], 0);
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "Cycle"))
+ {
+ g_signal_emit (listener, signals [CYCLE], 0);
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "Inhibit"))
+ {
+ return listener_dbus_add_ref_entry (listener, REF_ENTRY_TYPE_INHIBIT, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "UnInhibit"))
+ {
+ return listener_dbus_remove_ref_entry (listener, REF_ENTRY_TYPE_INHIBIT, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "GetInhibitors"))
+ {
+ return listener_dbus_get_ref_entries (listener, REF_ENTRY_TYPE_INHIBIT, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "Throttle"))
+ {
+ return listener_dbus_add_ref_entry (listener, REF_ENTRY_TYPE_THROTTLE, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "UnThrottle"))
+ {
+ return listener_dbus_remove_ref_entry (listener, REF_ENTRY_TYPE_THROTTLE, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "SetActive"))
+ {
+ return listener_set_property (listener, connection, message, PROP_ACTIVE);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "GetActive"))
+ {
+ return listener_get_property (listener, connection, message, PROP_ACTIVE);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "GetActiveTime"))
+ {
+ return listener_get_active_time (listener, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "ShowMessage"))
+ {
+ return listener_show_message (listener, connection, message);
+ }
+ if (dbus_message_is_method_call (message, GS_LISTENER_SERVICE, "SimulateUserActivity"))
+ {
+ g_signal_emit (listener, signals [SIMULATE_USER_ACTIVITY], 0);
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ if (dbus_message_is_method_call (message, "org.freedesktop.DBus.Introspectable", "Introspect"))
+ {
+ return do_introspect (connection, message, local_interface);
+ }
+
+ return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+}
+
+static gboolean
+_listener_message_path_is_our_session (GSListener *listener,
+ DBusMessage *message)
+{
+ const char *ssid;
+ gboolean ours;
+
+ ours = FALSE;
+
+ ssid = dbus_message_get_path (message);
+ if (ssid != NULL
+ && listener->priv->session_id != NULL
+ && strcmp (ssid, listener->priv->session_id) == 0)
+ {
+ ours = TRUE;
+ }
+
+ return ours;
+}
+
+static DBusHandlerResult
+listener_dbus_handle_system_message (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data,
+ dbus_bool_t local_interface)
+{
+ GSListener *listener = GS_LISTENER (user_data);
+
+ g_return_val_if_fail (connection != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+ g_return_val_if_fail (message != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+
+#if 1
+ gs_debug ("obj_path=%s interface=%s method=%s destination=%s",
+ dbus_message_get_path (message),
+ dbus_message_get_interface (message),
+ dbus_message_get_member (message),
+ dbus_message_get_destination (message));
+#endif
+
+ if (dbus_message_is_signal (message, HAL_DEVICE_INTERFACE, "Condition"))
+ {
+ DBusError error;
+ const char *event;
+ const char *keyname;
+
+ dbus_error_init (&error);
+ if (dbus_message_get_args (message, &error,
+ DBUS_TYPE_STRING, &event,
+ DBUS_TYPE_STRING, &keyname,
+ DBUS_TYPE_INVALID))
+ {
+ if ((event && strcmp (event, "ButtonPressed") == 0) &&
+ (keyname && strcmp (keyname, "coffee") == 0))
+ {
+ gs_debug ("Coffee key was pressed - locking");
+ g_signal_emit (listener, signals [LOCK], 0);
+ }
+ }
+
+ if (dbus_error_is_set (&error))
+ {
+ dbus_error_free (&error);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ else if (dbus_message_is_signal (message, CK_SESSION_INTERFACE, "Unlock"))
+ {
+ if (_listener_message_path_is_our_session (listener, message))
+ {
+ gs_debug ("Console kit requested session unlock");
+ gs_listener_set_active (listener, FALSE);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ else if (dbus_message_is_signal (message, CK_SESSION_INTERFACE, "Lock"))
+ {
+ if (_listener_message_path_is_our_session (listener, message))
+ {
+ gs_debug ("ConsoleKit requested session lock");
+ g_signal_emit (listener, signals [LOCK], 0);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ else if (dbus_message_is_signal (message, CK_SESSION_INTERFACE, "ActiveChanged"))
+ {
+ /* NB that `ActiveChanged' refers to the active
+ * session in ConsoleKit terminology - ie which
+ * session is currently displayed on the screen.
+ * mate-screensaver uses `active' to mean `is the
+ * screensaver active' (ie, is the screen locked) but
+ * that's not what we're referring to here.
+ */
+
+ if (_listener_message_path_is_our_session (listener, message))
+ {
+ DBusError error;
+ dbus_bool_t new_active;
+
+ dbus_error_init (&error);
+ if (dbus_message_get_args (message, &error,
+ DBUS_TYPE_BOOLEAN, &new_active,
+ DBUS_TYPE_INVALID))
+ {
+ gs_debug ("ConsoleKit notified ActiveChanged %d", new_active);
+
+ /* when we aren't active add an implicit throttle from CK
+ * when we become active remove the throttle and poke the lock */
+ if (new_active)
+ {
+ if (listener->priv->ck_throttle_cookie != 0)
+ {
+ listener_remove_ck_ref_entry (listener,
+ REF_ENTRY_TYPE_THROTTLE,
+ listener->priv->ck_throttle_cookie);
+ listener->priv->ck_throttle_cookie = 0;
+ }
+
+ g_signal_emit (listener, signals [SIMULATE_USER_ACTIVITY], 0);
+ }
+ else
+ {
+ if (listener->priv->ck_throttle_cookie != 0)
+ {
+ g_warning ("ConsoleKit throttle already set");
+ listener_remove_ck_ref_entry (listener,
+ REF_ENTRY_TYPE_THROTTLE,
+ listener->priv->ck_throttle_cookie);
+ listener->priv->ck_throttle_cookie = 0;
+ }
+
+ listener_add_ck_ref_entry (listener,
+ REF_ENTRY_TYPE_THROTTLE,
+ connection,
+ message,
+ &listener->priv->ck_throttle_cookie);
+ }
+ }
+
+ if (dbus_error_is_set (&error))
+ {
+ dbus_error_free (&error);
+ }
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+
+ return DBUS_HANDLER_RESULT_NOT_YET_HANDLED;
+}
+
+static DBusHandlerResult
+gs_listener_message_handler (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data)
+{
+ g_return_val_if_fail (connection != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+ g_return_val_if_fail (message != NULL, DBUS_HANDLER_RESULT_NOT_YET_HANDLED);
+
+#if 0
+ g_message ("obj_path=%s interface=%s method=%s destination=%s",
+ dbus_message_get_path (message),
+ dbus_message_get_interface (message),
+ dbus_message_get_member (message),
+ dbus_message_get_destination (message));
+#endif
+
+ if (dbus_message_is_method_call (message, "org.freedesktop.DBus", "AddMatch"))
+ {
+ DBusMessage *reply;
+
+ reply = dbus_message_new_method_return (message);
+
+ if (reply == NULL)
+ {
+ g_error ("No memory");
+ }
+
+ if (! dbus_connection_send (connection, reply, NULL))
+ {
+ g_error ("No memory");
+ }
+
+ dbus_message_unref (reply);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ else if (dbus_message_is_signal (message, DBUS_INTERFACE_LOCAL, "Disconnected") &&
+ strcmp (dbus_message_get_path (message), DBUS_PATH_LOCAL) == 0)
+ {
+ dbus_connection_unref (connection);
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+ }
+ else
+ {
+ return listener_dbus_handle_session_message (connection, message, user_data, TRUE);
+ }
+}
+
+static gboolean
+gs_listener_dbus_init (GSListener *listener)
+{
+ DBusError error;
+
+ dbus_error_init (&error);
+
+ if (listener->priv->connection == NULL)
+ {
+ listener->priv->connection = dbus_bus_get (DBUS_BUS_SESSION, &error);
+ if (listener->priv->connection == NULL)
+ {
+ if (dbus_error_is_set (&error))
+ {
+ gs_debug ("couldn't connect to session bus: %s",
+ error.message);
+ dbus_error_free (&error);
+ }
+ return FALSE;
+ }
+
+ dbus_connection_setup_with_g_main (listener->priv->connection, NULL);
+ dbus_connection_set_exit_on_disconnect (listener->priv->connection, FALSE);
+ }
+
+ if (listener->priv->system_connection == NULL)
+ {
+ listener->priv->system_connection = dbus_bus_get (DBUS_BUS_SYSTEM, &error);
+ if (listener->priv->system_connection == NULL)
+ {
+ if (dbus_error_is_set (&error))
+ {
+ gs_debug ("couldn't connect to system bus: %s",
+ error.message);
+ dbus_error_free (&error);
+ }
+ return FALSE;
+ }
+
+ dbus_connection_setup_with_g_main (listener->priv->system_connection, NULL);
+ dbus_connection_set_exit_on_disconnect (listener->priv->system_connection, FALSE);
+ }
+
+ return TRUE;
+}
+
+static gboolean
+reinit_dbus (GSListener *listener)
+{
+ gboolean initialized;
+ gboolean try_again;
+
+ initialized = gs_listener_dbus_init (listener);
+
+ /* if we didn't initialize then try again */
+ /* FIXME: Should we keep trying forever? If we fail more than
+ once or twice then the session bus may have died. The
+ problem is that if it is restarted it will likely have a
+ different bus address and we won't be able to find it */
+ try_again = !initialized;
+
+ return try_again;
+}
+
+static DBusHandlerResult
+listener_dbus_filter_function (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data)
+{
+ GSListener *listener = GS_LISTENER (user_data);
+ const char *path;
+
+ path = dbus_message_get_path (message);
+
+ /*
+ g_message ("obj_path=%s interface=%s method=%s",
+ dbus_message_get_path (message),
+ dbus_message_get_interface (message),
+ dbus_message_get_member (message));
+ */
+
+ if (dbus_message_is_signal (message, DBUS_INTERFACE_LOCAL, "Disconnected")
+ && strcmp (path, DBUS_PATH_LOCAL) == 0)
+ {
+
+ g_message ("Got disconnected from the session message bus; "
+ "retrying to reconnect every 10 seconds");
+
+ dbus_connection_unref (connection);
+ listener->priv->connection = NULL;
+
+ g_timeout_add (10000, (GSourceFunc)reinit_dbus, listener);
+ }
+ else if (dbus_message_is_signal (message,
+ DBUS_INTERFACE_DBUS,
+ "NameOwnerChanged"))
+ {
+
+ if (listener->priv->inhibitors != NULL)
+ {
+ listener_service_deleted (listener, message);
+ }
+ }
+ else
+ {
+ return listener_dbus_handle_session_message (connection, message, user_data, FALSE);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static DBusHandlerResult
+listener_dbus_system_filter_function (DBusConnection *connection,
+ DBusMessage *message,
+ void *user_data)
+{
+ GSListener *listener = GS_LISTENER (user_data);
+ const char *path;
+
+ path = dbus_message_get_path (message);
+
+ if (dbus_message_is_signal (message, DBUS_INTERFACE_LOCAL, "Disconnected")
+ && strcmp (path, DBUS_PATH_LOCAL) == 0)
+ {
+
+ g_message ("Got disconnected from the system message bus; "
+ "retrying to reconnect every 10 seconds");
+
+ dbus_connection_unref (connection);
+ listener->priv->system_connection = NULL;
+
+ g_timeout_add (10000, (GSourceFunc)reinit_dbus, listener);
+ }
+ else
+ {
+ return listener_dbus_handle_system_message (connection, message, user_data, FALSE);
+ }
+
+ return DBUS_HANDLER_RESULT_HANDLED;
+}
+
+static void
+gs_listener_set_property (GObject *object,
+ guint prop_id,
+ const GValue *value,
+ GParamSpec *pspec)
+{
+ GSListener *self;
+
+ self = GS_LISTENER (object);
+
+ switch (prop_id)
+ {
+ case PROP_ACTIVE:
+ gs_listener_set_active (self, g_value_get_boolean (value));
+ break;
+ case PROP_SESSION_IDLE:
+ gs_listener_set_session_idle (self, g_value_get_boolean (value));
+ break;
+ case PROP_ACTIVATION_ENABLED:
+ gs_listener_set_activation_enabled (self, g_value_get_boolean (value));
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+gs_listener_get_property (GObject *object,
+ guint prop_id,
+ GValue *value,
+ GParamSpec *pspec)
+{
+ GSListener *self;
+
+ self = GS_LISTENER (object);
+
+ switch (prop_id)
+ {
+ case PROP_ACTIVE:
+ g_value_set_boolean (value, self->priv->active);
+ break;
+ case PROP_SESSION_IDLE:
+ g_value_set_boolean (value, self->priv->session_idle);
+ break;
+ case PROP_ACTIVATION_ENABLED:
+ g_value_set_boolean (value, self->priv->activation_enabled);
+ break;
+ default:
+ G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+ break;
+ }
+}
+
+static void
+gs_listener_class_init (GSListenerClass *klass)
+{
+ GObjectClass *object_class = G_OBJECT_CLASS (klass);
+
+ object_class->finalize = gs_listener_finalize;
+ object_class->get_property = gs_listener_get_property;
+ object_class->set_property = gs_listener_set_property;
+
+ signals [LOCK] =
+ g_signal_new ("lock",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, lock),
+ NULL,
+ NULL,
+ g_cclosure_marshal_VOID__VOID,
+ G_TYPE_NONE,
+ 0);
+ signals [QUIT] =
+ g_signal_new ("quit",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, quit),
+ NULL,
+ NULL,
+ g_cclosure_marshal_VOID__VOID,
+ G_TYPE_NONE,
+ 0);
+ signals [CYCLE] =
+ g_signal_new ("cycle",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, cycle),
+ NULL,
+ NULL,
+ g_cclosure_marshal_VOID__VOID,
+ G_TYPE_NONE,
+ 0);
+ signals [SIMULATE_USER_ACTIVITY] =
+ g_signal_new ("simulate-user-activity",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, simulate_user_activity),
+ NULL,
+ NULL,
+ g_cclosure_marshal_VOID__VOID,
+ G_TYPE_NONE,
+ 0);
+ signals [ACTIVE_CHANGED] =
+ g_signal_new ("active-changed",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, active_changed),
+ NULL,
+ NULL,
+ gs_marshal_BOOLEAN__BOOLEAN,
+ G_TYPE_BOOLEAN,
+ 1,
+ G_TYPE_BOOLEAN);
+ signals [THROTTLE_CHANGED] =
+ g_signal_new ("throttle-changed",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, throttle_changed),
+ NULL,
+ NULL,
+ g_cclosure_marshal_VOID__BOOLEAN,
+ G_TYPE_NONE,
+ 1,
+ G_TYPE_BOOLEAN);
+ signals [SHOW_MESSAGE] =
+ g_signal_new ("show-message",
+ G_TYPE_FROM_CLASS (object_class),
+ G_SIGNAL_RUN_LAST,
+ G_STRUCT_OFFSET (GSListenerClass, show_message),
+ NULL,
+ NULL,
+ gs_marshal_VOID__STRING_STRING_STRING,
+ G_TYPE_NONE,
+ 3,
+ G_TYPE_STRING,
+ G_TYPE_STRING,
+ G_TYPE_STRING);
+
+ g_object_class_install_property (object_class,
+ PROP_ACTIVE,
+ g_param_spec_boolean ("active",
+ NULL,
+ NULL,
+ FALSE,
+ G_PARAM_READWRITE));
+ g_object_class_install_property (object_class,
+ PROP_ACTIVATION_ENABLED,
+ g_param_spec_boolean ("activation-enabled",
+ NULL,
+ NULL,
+ TRUE,
+ G_PARAM_READWRITE));
+
+ g_type_class_add_private (klass, sizeof (GSListenerPrivate));
+}
+
+
+static gboolean
+screensaver_is_running (DBusConnection *connection)
+{
+ DBusError error;
+ gboolean exists;
+
+ g_return_val_if_fail (connection != NULL, FALSE);
+
+ dbus_error_init (&error);
+ exists = dbus_bus_name_has_owner (connection, GS_LISTENER_SERVICE, &error);
+ if (dbus_error_is_set (&error))
+ {
+ dbus_error_free (&error);
+ }
+
+ return exists;
+}
+
+gboolean
+gs_listener_acquire (GSListener *listener,
+ GError **error)
+{
+ gboolean acquired;
+ DBusError buserror;
+ gboolean is_connected;
+
+ g_return_val_if_fail (listener != NULL, FALSE);
+
+ if (! listener->priv->connection)
+ {
+ g_set_error (error,
+ GS_LISTENER_ERROR,
+ GS_LISTENER_ERROR_ACQUISITION_FAILURE,
+ "%s",
+ _("failed to register with the message bus"));
+ return FALSE;
+ }
+
+ is_connected = dbus_connection_get_is_connected (listener->priv->connection);
+ if (! is_connected)
+ {
+ g_set_error (error,
+ GS_LISTENER_ERROR,
+ GS_LISTENER_ERROR_ACQUISITION_FAILURE,
+ "%s",
+ _("not connected to the message bus"));
+ return FALSE;
+ }
+
+ if (screensaver_is_running (listener->priv->connection))
+ {
+ g_set_error (error,
+ GS_LISTENER_ERROR,
+ GS_LISTENER_ERROR_ACQUISITION_FAILURE,
+ "%s",
+ _("screensaver already running in this session"));
+ return FALSE;
+ }
+
+ dbus_error_init (&buserror);
+
+ if (dbus_connection_register_object_path (listener->priv->connection,
+ GS_LISTENER_PATH,
+ &gs_listener_vtable,
+ listener) == FALSE)
+ {
+ g_critical ("out of memory registering object path");
+ return FALSE;
+ }
+
+ acquired = dbus_bus_request_name (listener->priv->connection,
+ GS_LISTENER_SERVICE,
+ 0, &buserror) != -1;
+ if (dbus_error_is_set (&buserror))
+ {
+ g_set_error (error,
+ GS_LISTENER_ERROR,
+ GS_LISTENER_ERROR_ACQUISITION_FAILURE,
+ "%s",
+ buserror.message);
+ }
+
+ dbus_error_free (&buserror);
+
+ dbus_connection_add_filter (listener->priv->connection, listener_dbus_filter_function, listener, NULL);
+
+ dbus_bus_add_match (listener->priv->connection,
+ "type='signal'"
+ ",interface='"DBUS_INTERFACE_DBUS"'"
+ ",sender='"DBUS_SERVICE_DBUS"'"
+ ",member='NameOwnerChanged'",
+ NULL);
+
+ if (listener->priv->system_connection != NULL)
+ {
+ dbus_connection_add_filter (listener->priv->system_connection,
+ listener_dbus_system_filter_function,
+ listener,
+ NULL);
+
+ dbus_bus_add_match (listener->priv->system_connection,
+ "type='signal'"
+ ",interface='"HAL_DEVICE_INTERFACE"'"
+ ",member='Condition'",
+ NULL);
+ dbus_bus_add_match (listener->priv->system_connection,
+ "type='signal'"
+ ",interface='"CK_SESSION_INTERFACE"'"
+ ",member='Unlock'",
+ NULL);
+ dbus_bus_add_match (listener->priv->system_connection,
+ "type='signal'"
+ ",interface='"CK_SESSION_INTERFACE"'"
+ ",member='Lock'",
+ NULL);
+ dbus_bus_add_match (listener->priv->system_connection,
+ "type='signal'"
+ ",interface='"CK_SESSION_INTERFACE"'"
+ ",member='ActiveChanged'",
+ NULL);
+ }
+
+ return acquired;
+}
+
+static char *
+query_session_id (GSListener *listener)
+{
+ DBusMessage *message;
+ DBusMessage *reply;
+ DBusError error;
+ DBusMessageIter reply_iter;
+ char *ssid;
+
+ if (listener->priv->system_connection == NULL)
+ {
+ gs_debug ("No connection to the system bus");
+ return NULL;
+ }
+
+ ssid = NULL;
+
+ dbus_error_init (&error);
+
+ message = dbus_message_new_method_call (CK_NAME, CK_MANAGER_PATH, CK_MANAGER_INTERFACE, "GetCurrentSession");
+ if (message == NULL)
+ {
+ gs_debug ("Couldn't allocate the dbus message");
+ return NULL;
+ }
+
+ /* FIXME: use async? */
+ reply = dbus_connection_send_with_reply_and_block (listener->priv->system_connection,
+ message,
+ -1, &error);
+ dbus_message_unref (message);
+
+ if (dbus_error_is_set (&error))
+ {
+ gs_debug ("%s raised:\n %s\n\n", error.name, error.message);
+ dbus_error_free (&error);
+ return NULL;
+ }
+
+ dbus_message_iter_init (reply, &reply_iter);
+ dbus_message_iter_get_basic (&reply_iter, &ssid);
+
+ dbus_message_unref (reply);
+
+ return g_strdup (ssid);
+}
+
+static void
+init_session_id (GSListener *listener)
+{
+ g_free (listener->priv->session_id);
+ listener->priv->session_id = query_session_id (listener);
+ gs_debug ("Got session-id: %s", listener->priv->session_id);
+}
+
+static void
+gs_listener_init (GSListener *listener)
+{
+ listener->priv = GS_LISTENER_GET_PRIVATE (listener);
+
+ gs_listener_dbus_init (listener);
+
+ init_session_id (listener);
+
+ listener->priv->inhibitors = g_hash_table_new_full (g_int_hash,
+ g_int_equal,
+ NULL,
+ (GDestroyNotify)gs_listener_ref_entry_free);
+ listener->priv->throttlers = g_hash_table_new_full (g_int_hash,
+ g_int_equal,
+ NULL,
+ (GDestroyNotify)gs_listener_ref_entry_free);
+}
+
+static void
+gs_listener_finalize (GObject *object)
+{
+ GSListener *listener;
+
+ g_return_if_fail (object != NULL);
+ g_return_if_fail (GS_IS_LISTENER (object));
+
+ listener = GS_LISTENER (object);
+
+ g_return_if_fail (listener->priv != NULL);
+
+ if (listener->priv->inhibitors)
+ {
+ g_hash_table_destroy (listener->priv->inhibitors);
+ }
+
+ if (listener->priv->throttlers)
+ {
+ g_hash_table_destroy (listener->priv->throttlers);
+ }
+
+ g_free (listener->priv->session_id);
+
+ G_OBJECT_CLASS (gs_listener_parent_class)->finalize (object);
+}
+
+GSListener *
+gs_listener_new (void)
+{
+ GSListener *listener;
+
+ listener = g_object_new (GS_TYPE_LISTENER, NULL);
+
+ return GS_LISTENER (listener);
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-04-19 04:48:24 +0000