dbus-1/dconf-dbus-1.c

   1 /**
   2  * Copyright © 2010 Canonical Limited
   3  *
   4  * This program is free software: you can redistribute it and/or modify
   5  * it under the terms of the GNU General Public License as published by
   6  * the Free Software Foundation, either version 3 of the licence, or (at
   7  * your option) any later version.
   8  *
   9  * This program is distributed in the hope that it will be useful, but
  10  * WITHOUT ANY WARRANTY; without even the implied warranty of
  11  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
  12  * General Public License for more details.
  13  *
  14  * You should have received a copy of the GNU General Public License
  15  * along with this program.  If not, see <http://www.gnu.org/licenses/>.
  16  *
  17  * Author: Ryan Lortie <desrt@desrt.ca>
  18  **/
  19
  20 #include "config.h"
  21
  22 #include "dconf-dbus-1.h"
  23
  24 #include "../engine/dconf-engine.h"
  25 #include "dconf-libdbus-1.h"
  26
  27 #include <string.h>
  28
  29 struct _DConfDBusClient
  30 {
  31   DConfEngine *engine;
  32   GSList *watches;
  33   gint ref_count;
  34 };
  35
  36 typedef struct
  37 {
  38   gchar           *path;
  39   DConfDBusNotify  notify;
  40   gpointer         user_data;
  41 } Watch;
  42
  43 void
  44 dconf_engine_change_notify (DConfEngine         *engine,
  45                             const gchar         *prefix,
  46                             const gchar * const *changes,
  47                             const gchar         *tag,
  48                             gboolean             is_writability,
  49                             gpointer             origin_tag,
  50                             gpointer             user_data)
  51 {
  52   DConfDBusClient *dcdbc = user_data;
  53   gchar **my_changes;
  54   gint n_changes;
  55   GSList *iter;
  56   gint i;
  57
  58   n_changes = g_strv_length ((gchar **) changes);
  59   my_changes = g_new (gchar *, n_changes + 1);
  60
  61   for (i = 0; i < n_changes; i++)
  62     my_changes[i] = g_strconcat (prefix, changes[i], NULL);
  63   my_changes[i] = NULL;
  64
  65   for (iter = dcdbc->watches; iter; iter = iter->next)
  66     {
  67       Watch *watch = iter->data;
  68
  69       for (i = 0; i < n_changes; i++)
  70         if (g_str_has_prefix (my_changes[i], watch->path))
  71           watch->notify (dcdbc, my_changes[i], watch->user_data);
  72     }
  73
  74   g_strfreev (my_changes);
  75 }
  76
  77 GVariant *
  78 dconf_dbus_client_read (DConfDBusClient *dcdbc,
  79                         const gchar     *key)
  80 {
  81   return dconf_engine_read (dcdbc->engine, NULL, key);
  82 }
  83
  84 gboolean
  85 dconf_dbus_client_write (DConfDBusClient *dcdbc,
  86                          const gchar     *key,
  87                          GVariant        *value)
  88 {
  89   DConfChangeset *changeset;
  90   gboolean success;
  91
  92   changeset = dconf_changeset_new_write (key, value);
  93   success = dconf_engine_change_fast (dcdbc->engine, changeset, NULL, NULL);
  94   dconf_changeset_unref (changeset);
  95
  96   return success;
  97 }
  98
  99 void
 100 dconf_dbus_client_subscribe (DConfDBusClient *dcdbc,
 101                              const gchar     *path,
 102                              DConfDBusNotify  notify,
 103                              gpointer         user_data)
 104 {
 105   Watch *watch;
 106
 107   watch = g_slice_new (Watch);
 108   watch->path = g_strdup (path);
 109   watch->notify = notify;
 110   watch->user_data = user_data;
 111
 112   dcdbc->watches = g_slist_prepend (dcdbc->watches, watch);
 113
 114   dconf_engine_watch_fast (dcdbc->engine, path);
 115 }
 116
 117 void
 118 dconf_dbus_client_unsubscribe (DConfDBusClient *dcdbc,
 119                                DConfDBusNotify  notify,
 120                                gpointer         user_data)
 121 {
 122   GSList **ptr;
 123
 124   for (ptr = &dcdbc->watches; *ptr; ptr = &(*ptr)->next)
 125     {
 126       Watch *watch = (*ptr)->data;
 127
 128       if (watch->notify == notify && watch->user_data == user_data)
 129         {
 130           *ptr = g_slist_remove_link (*ptr, *ptr);
 131           dconf_engine_unwatch_fast (dcdbc->engine, watch->path);
 132           g_free (watch->path);
 133           g_slice_free (Watch, watch);
 134           return;
 135         }
 136     }
 137
 138   g_warning ("No matching watch found to unsubscribe");
 139 }
 140
 141 gboolean
 142 dconf_dbus_client_has_pending (DConfDBusClient *dcdbc)
 143 {
 144   return dconf_engine_has_outstanding (dcdbc->engine);
 145 }
 146
 147 DConfDBusClient *
 148 dconf_dbus_client_new (const gchar    *profile,
 149                        DBusConnection *session,
 150                        DBusConnection *system)
 151 {
 152   DConfDBusClient *dcdbc;
 153
 154   if (session == NULL)
 155     session = dbus_bus_get (DBUS_BUS_SESSION, NULL);
 156
 157   if (system == NULL)
 158     system = dbus_bus_get (DBUS_BUS_SYSTEM, NULL);
 159
 160   dconf_libdbus_1_provide_bus (G_BUS_TYPE_SESSION, session);
 161   dconf_libdbus_1_provide_bus (G_BUS_TYPE_SYSTEM, system);
 162
 163   dcdbc = g_slice_new (DConfDBusClient);
 164   dcdbc->engine = dconf_engine_new (NULL, dcdbc, NULL);
 165   dcdbc->watches = NULL;
 166   dcdbc->ref_count = 1;
 167
 168   return dcdbc;
 169 }
 170
 171 void
 172 dconf_dbus_client_unref (DConfDBusClient *dcdbc)
 173 {
 174   if (--dcdbc->ref_count == 0)
 175     {
 176       g_return_if_fail (dcdbc->watches == NULL);
 177
 178       g_slice_free (DConfDBusClient, dcdbc);
 179     }
 180 }
 181
 182 DConfDBusClient *
 183 dconf_dbus_client_ref (DConfDBusClient *dcdbc)
 184 {
 185   dcdbc->ref_count++;
 186
 187   return dcdbc;
 188 }