gio/gdbusdaemon.c

   1 #include "config.h"
   2
   3 #include <string.h>
   4 #include <stdlib.h>
   5
   6 #include <gstdio.h>
   7 #include <gio/gio.h>
   8 #include <gio/gunixsocketaddress.h>
   9 #include "gdbusdaemon.h"
  10
  11 #include "gdbus-daemon-generated.h"
  12
  13 #define DBUS_SERVICE_NAME  "org.freedesktop.DBus"
  14
  15 /* Owner flags */
  16 #define DBUS_NAME_FLAG_ALLOW_REPLACEMENT 0x1 /**< Allow another service to become the primary owner if requested */
  17 #define DBUS_NAME_FLAG_REPLACE_EXISTING  0x2 /**< Request to replace the current primary owner */
  18 #define DBUS_NAME_FLAG_DO_NOT_QUEUE      0x4 /**< If we can not become the primary owner do not place us in the queue */
  19
  20 /* Replies to request for a name */
  21 #define DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER  1 /**< Service has become the primary owner of the requested name */
  22 #define DBUS_REQUEST_NAME_REPLY_IN_QUEUE       2 /**< Service could not become the primary owner and has been placed in the queue */
  23 #define DBUS_REQUEST_NAME_REPLY_EXISTS         3 /**< Service is already in the queue */
  24 #define DBUS_REQUEST_NAME_REPLY_ALREADY_OWNER  4 /**< Service is already the primary owner */
  25
  26 /* Replies to releasing a name */
  27 #define DBUS_RELEASE_NAME_REPLY_RELEASED        1 /**< Service was released from the given name */
  28 #define DBUS_RELEASE_NAME_REPLY_NON_EXISTENT    2 /**< The given name does not exist on the bus */
  29 #define DBUS_RELEASE_NAME_REPLY_NOT_OWNER       3 /**< Service is not an owner of the given name */
  30
  31 /* Replies to service starts */
  32 #define DBUS_START_REPLY_SUCCESS         1 /**< Service was auto started */
  33 #define DBUS_START_REPLY_ALREADY_RUNNING 2 /**< Service was already running */
  34
  35 #define IDLE_TIMEOUT_MSEC 3000
  36
  37 struct _GDBusDaemon
  38 {
  39   _GFreedesktopDBusSkeleton parent_instance;
  40
  41   gchar *address;
  42   guint timeout;
  43   gchar *tmpdir;
  44   GDBusServer *server;
  45   gchar *guid;
  46   GHashTable *clients;
  47   GHashTable *names;
  48   guint32 next_major_id;
  49   guint32 next_minor_id;
  50 };
  51
  52 struct _GDBusDaemonClass
  53 {
  54   _GFreedesktopDBusSkeletonClass parent_class;
  55 };
  56
  57 enum {
  58   PROP_0,
  59   PROP_ADDRESS,
  60 };
  61
  62 enum
  63 {
  64   SIGNAL_IDLE_TIMEOUT,
  65   NR_SIGNALS
  66 };
  67
  68 static guint g_dbus_daemon_signals[NR_SIGNALS];
  69
  70
  71 static void initable_iface_init      (GInitableIface         *initable_iface);
  72 static void g_dbus_daemon_iface_init (_GFreedesktopDBusIface *iface);
  73
  74 #define g_dbus_daemon_get_type _g_dbus_daemon_get_type
  75 G_DEFINE_TYPE_WITH_CODE (GDBusDaemon, g_dbus_daemon, _G_TYPE_FREEDESKTOP_DBUS_SKELETON,
  76                          G_IMPLEMENT_INTERFACE (G_TYPE_INITABLE, initable_iface_init)
  77                          G_IMPLEMENT_INTERFACE (_G_TYPE_FREEDESKTOP_DBUS, g_dbus_daemon_iface_init));
  78
  79 typedef struct {
  80   GDBusDaemon *daemon;
  81   char *id;
  82   GDBusConnection *connection;
  83   GList *matches;
  84 } Client;
  85
  86 typedef struct {
  87   Client *client;
  88   guint32 flags;
  89 } NameOwner;
  90
  91 typedef struct {
  92   int refcount;
  93
  94   char *name;
  95   GDBusDaemon *daemon;
  96
  97   NameOwner *owner;
  98   GList *queue;
  99 } Name;
 100
 101 enum {
 102   MATCH_ELEMENT_TYPE,
 103   MATCH_ELEMENT_SENDER,
 104   MATCH_ELEMENT_INTERFACE,
 105   MATCH_ELEMENT_MEMBER,
 106   MATCH_ELEMENT_PATH,
 107   MATCH_ELEMENT_PATH_NAMESPACE,
 108   MATCH_ELEMENT_DESTINATION,
 109   MATCH_ELEMENT_ARG0NAMESPACE,
 110   MATCH_ELEMENT_EAVESDROP,
 111   MATCH_ELEMENT_ARGN,
 112   MATCH_ELEMENT_ARGNPATH,
 113 };
 114
 115 typedef struct {
 116   guint16 type;
 117   guint16 arg;
 118   char *value;
 119 } MatchElement;
 120
 121 typedef struct {
 122   gboolean eavesdrop;
 123   GDBusMessageType type;
 124   int n_elements;
 125   MatchElement *elements;
 126 } Match;
 127
 128 static GDBusMessage *filter_function   (GDBusConnection *connection,
 129                                         GDBusMessage    *message,
 130                                         gboolean         incoming,
 131                                         gpointer         user_data);
 132 static void          connection_closed (GDBusConnection *connection,
 133                                         gboolean         remote_peer_vanished,
 134                                         GError          *error,
 135                                         Client          *client);
 136
 137 static NameOwner *
 138 name_owner_new (Client *client, guint32 flags)
 139 {
 140   NameOwner *owner;
 141
 142   owner = g_new0 (NameOwner, 1);
 143   owner->client = client;
 144   owner->flags = flags;
 145   return owner;
 146 }
 147
 148 static void
 149 name_owner_free (NameOwner *owner)
 150 {
 151   g_free (owner);
 152 }
 153
 154 static Name *
 155 name_new (GDBusDaemon *daemon, const char *str)
 156 {
 157   Name *name;
 158
 159   name = g_new0 (Name, 1);
 160   name->refcount = 1;
 161   name->daemon = daemon;
 162   name->name = g_strdup (str);
 163
 164   g_hash_table_insert (daemon->names, name->name, name);
 165
 166   return name;
 167 }
 168
 169 static Name *
 170 name_ref (Name *name)
 171 {
 172   name->refcount++;
 173   return name;
 174 }
 175
 176 static void
 177 name_unref (Name *name)
 178 {
 179   if (--name->refcount == 0)
 180     {
 181       g_hash_table_remove (name->daemon->names, name->name);
 182       g_free (name->name);
 183       g_free (name);
 184     }
 185 }
 186
 187 static Name *
 188 name_ensure (GDBusDaemon *daemon, const char *str)
 189 {
 190   Name *name;
 191
 192   name = g_hash_table_lookup (daemon->names, str);
 193
 194   if (name != NULL)
 195     return name_ref (name);
 196   return name_new (daemon, str);
 197 }
 198
 199 static Name *
 200 name_lookup (GDBusDaemon *daemon, const char *str)
 201 {
 202   return g_hash_table_lookup (daemon->names, str);
 203 }
 204
 205 static gboolean
 206 is_key (const char *key_start, const char *key_end, char *value)
 207 {
 208   gsize len = strlen (value);
 209
 210   if (len != key_end - key_start)
 211     return FALSE;
 212
 213   return strncmp (key_start, value, len) == 0;
 214 }
 215
 216 static gboolean
 217 parse_key (MatchElement *element, const char *key_start, const char *key_end)
 218 {
 219   gboolean res = TRUE;
 220
 221   if (is_key (key_start, key_end, "type"))
 222     {
 223       element->type = MATCH_ELEMENT_TYPE;
 224     }
 225   else if (is_key (key_start, key_end, "sender"))
 226     {
 227       element->type = MATCH_ELEMENT_SENDER;
 228     }
 229   else if (is_key (key_start, key_end, "interface"))
 230     {
 231       element->type = MATCH_ELEMENT_INTERFACE;
 232     }
 233   else if (is_key (key_start, key_end, "member"))
 234     {
 235       element->type = MATCH_ELEMENT_MEMBER;
 236     }
 237   else if (is_key (key_start, key_end, "path"))
 238     {
 239       element->type = MATCH_ELEMENT_PATH;
 240     }
 241   else if (is_key (key_start, key_end, "path_namespace"))
 242     {
 243       element->type = MATCH_ELEMENT_PATH_NAMESPACE;
 244     }
 245   else if (is_key (key_start, key_end, "destination"))
 246     {
 247       element->type = MATCH_ELEMENT_DESTINATION;
 248     }
 249   else if (is_key (key_start, key_end, "arg0namespace"))
 250     {
 251       element->type = MATCH_ELEMENT_ARG0NAMESPACE;
 252     }
 253   else if (is_key (key_start, key_end, "eavesdrop"))
 254     {
 255       element->type = MATCH_ELEMENT_EAVESDROP;
 256     }
 257   else if (key_end - key_start > 3 && is_key (key_start, key_start + 3, "arg"))
 258     {
 259       const char *digits = key_start + 3;
 260       const char *end_digits = digits;
 261
 262       while (end_digits < key_end && g_ascii_isdigit (*end_digits))
 263         end_digits++;
 264
 265       if (end_digits == key_end) /* argN */
 266         {
 267           element->type = MATCH_ELEMENT_ARGN;
 268           element->arg = atoi (digits);
 269         }
 270       else if (is_key (end_digits, key_end, "path")) /* argNpath */
 271         {
 272           element->type = MATCH_ELEMENT_ARGNPATH;
 273           element->arg = atoi (digits);
 274         }
 275       else
 276         res = FALSE;
 277     }
 278   else
 279     res = FALSE;
 280
 281   return res;
 282 }
 283
 284 static const char *
 285 parse_value (MatchElement *element, const char *s)
 286 {
 287   char quote_char;
 288   GString *value;
 289
 290   value = g_string_new ("");
 291
 292   quote_char = 0;
 293
 294   for (;*s; s++)
 295     {
 296       if (quote_char == 0)
 297         {
 298           switch (*s)
 299             {
 300             case '\'':
 301               quote_char = '\'';
 302               break;
 303
 304             case ',':
 305               s++;
 306               goto out;
 307
 308             case '\\':
 309               quote_char = '\\';
 310               break;
 311
 312             default:
 313               g_string_append_c (value, *s);
 314               break;
 315             }
 316         }
 317       else if (quote_char == '\\')
 318         {
 319           /* \ only counts as an escape if escaping a quote mark */
 320           if (*s != '\'')
 321             g_string_append_c (value, '\\');
 322
 323           g_string_append_c (value, *s);
 324           quote_char = 0;
 325         }
 326       else /* quote_char == ' */
 327         {
 328           if (*s == '\'')
 329             quote_char = 0;
 330           else
 331             g_string_append_c (value, *s);
 332         }
 333     }
 334
 335  out:
 336
 337   if (quote_char == '\\')
 338     g_string_append_c (value, '\\');
 339   else if (quote_char == '\'')
 340     {
 341       g_string_free (value, TRUE);
 342       return NULL;
 343     }
 344
 345   element->value = g_string_free (value, FALSE);
 346   return s;
 347 }
 348
 349 static Match *
 350 match_new (const char *str)
 351 {
 352   Match *match;
 353   GArray *elements;
 354   const char *p;
 355   const char *key_start;
 356   const char *key_end;
 357   MatchElement element;
 358   gboolean eavesdrop;
 359   GDBusMessageType type;
 360   int i;
 361
 362   eavesdrop = FALSE;
 363   type = G_DBUS_MESSAGE_TYPE_INVALID;
 364   elements = g_array_new (TRUE, TRUE, sizeof (MatchElement));
 365
 366   p = str;
 367
 368   while (*p != 0)
 369     {
 370       memset (&element, 0, sizeof (element));
 371
 372       /* Skip initial whitespace */
 373       while (*p && g_ascii_isspace (*p))
 374         p++;
 375
 376       key_start = p;
 377
 378       /* Read non-whitespace non-equals chars */
 379       while (*p && *p != '=' && !g_ascii_isspace (*p))
 380         p++;
 381
 382       key_end = p;
 383
 384       /* Skip any whitespace after key */
 385       while (*p && g_ascii_isspace (*p))
 386         p++;
 387
 388       if (key_start == key_end)
 389         continue; /* Allow trailing whitespace */
 390
 391       if (*p != '=')
 392         goto error;
 393
 394       ++p;
 395
 396       if (!parse_key (&element, key_start, key_end))
 397         goto error;
 398
 399       p = parse_value (&element, p);
 400       if (p == NULL)
 401         goto error;
 402
 403       if (element.type == MATCH_ELEMENT_EAVESDROP)
 404         {
 405           if (strcmp (element.value, "true") == 0)
 406             eavesdrop = TRUE;
 407           else if (strcmp (element.value, "false") == 0)
 408             eavesdrop = FALSE;
 409           else
 410             {
 411               g_free (element.value);
 412               goto error;
 413             }
 414           g_free (element.value);
 415         }
 416       else if (element.type == MATCH_ELEMENT_TYPE)
 417         {
 418           if (strcmp (element.value, "signal") == 0)
 419             type = G_DBUS_MESSAGE_TYPE_SIGNAL;
 420           else if (strcmp (element.value, "method_call") == 0)
 421             type = G_DBUS_MESSAGE_TYPE_METHOD_CALL;
 422           else if (strcmp (element.value, "method_return") == 0)
 423             type = G_DBUS_MESSAGE_TYPE_METHOD_RETURN;
 424           else if (strcmp (element.value, "error") == 0)
 425             type = G_DBUS_MESSAGE_TYPE_ERROR;
 426           else
 427             {
 428               g_free (element.value);
 429               goto error;
 430             }
 431           g_free (element.value);
 432         }
 433       else
 434         g_array_append_val (elements, element);
 435     }
 436
 437   match = g_new0 (Match, 1);
 438   match->n_elements = elements->len;
 439   match->elements = (MatchElement *)g_array_free (elements, FALSE);
 440   match->eavesdrop = eavesdrop;
 441   match->type = type;
 442
 443   return match;
 444
 445  error:
 446   for (i = 0; i < elements->len; i++)
 447     g_free (g_array_index (elements, MatchElement, i).value);
 448   g_array_free (elements, TRUE);
 449   return NULL;
 450 }
 451
 452 static void
 453 match_free (Match *match)
 454 {
 455   int i;
 456   for (i = 0; i < match->n_elements; i++)
 457     g_free (match->elements[i].value);
 458   g_free (match->elements);
 459   g_free (match);
 460 }
 461
 462 static gboolean
 463 match_equal (Match *a, Match *b)
 464 {
 465   int i;
 466
 467   if (a->eavesdrop != b->eavesdrop)
 468     return FALSE;
 469   if (a->type != b->type)
 470     return FALSE;
 471  if (a->n_elements != b->n_elements)
 472     return FALSE;
 473   for (i = 0; i < a->n_elements; i++)
 474     {
 475       if (a->elements[i].type != b->elements[i].type ||
 476           a->elements[i].arg != b->elements[i].arg ||
 477           strcmp (a->elements[i].value, b->elements[i].value) != 0)
 478         return FALSE;
 479     }
 480   return TRUE;
 481 }
 482
 483 static const gchar *
 484 message_get_argN (GDBusMessage *message, int n, gboolean allow_path)
 485 {
 486   const gchar *ret;
 487   GVariant *body;
 488
 489   ret = NULL;
 490
 491   body = g_dbus_message_get_body (message);
 492
 493   if (body != NULL && g_variant_is_of_type (body, G_VARIANT_TYPE_TUPLE))
 494     {
 495       GVariant *item;
 496       item = g_variant_get_child_value (body, n);
 497       if (g_variant_is_of_type (item, G_VARIANT_TYPE_STRING) ||
 498           (allow_path && g_variant_is_of_type (item, G_VARIANT_TYPE_OBJECT_PATH)))
 499         ret = g_variant_get_string (item, NULL);
 500       g_variant_unref (item);
 501     }
 502
 503   return ret;
 504 }
 505
 506 enum {
 507   CHECK_TYPE_STRING,
 508   CHECK_TYPE_NAME,
 509   CHECK_TYPE_PATH_PREFIX,
 510   CHECK_TYPE_PATH_RELATED,
 511   CHECK_TYPE_NAMESPACE_PREFIX
 512 };
 513
 514 static gboolean
 515 match_matches (GDBusDaemon *daemon,
 516                Match *match, GDBusMessage *message,
 517                gboolean has_destination)
 518 {
 519   MatchElement *element;
 520   Name *name;
 521   int i, len, len2;
 522   const char *value;
 523   int check_type;
 524
 525   if (has_destination && !match->eavesdrop)
 526     return FALSE;
 527
 528   if (match->type != G_DBUS_MESSAGE_TYPE_INVALID &&
 529       g_dbus_message_get_message_type (message) != match->type)
 530     return FALSE;
 531
 532   for (i = 0; i < match->n_elements; i++)
 533     {
 534       element = &match->elements[i];
 535       check_type = CHECK_TYPE_STRING;
 536       switch (element->type)
 537         {
 538         case MATCH_ELEMENT_SENDER:
 539           check_type = CHECK_TYPE_NAME;
 540           value = g_dbus_message_get_sender (message);
 541           if (value == NULL)
 542             value = DBUS_SERVICE_NAME;
 543           break;
 544         case MATCH_ELEMENT_DESTINATION:
 545           check_type = CHECK_TYPE_NAME;
 546           value = g_dbus_message_get_destination (message);
 547           break;
 548         case MATCH_ELEMENT_INTERFACE:
 549           value = g_dbus_message_get_interface (message);
 550           break;
 551         case MATCH_ELEMENT_MEMBER:
 552           value = g_dbus_message_get_member (message);
 553           break;
 554         case MATCH_ELEMENT_PATH:
 555           value = g_dbus_message_get_path (message);
 556           break;
 557         case MATCH_ELEMENT_PATH_NAMESPACE:
 558           check_type = CHECK_TYPE_PATH_PREFIX;
 559           value = g_dbus_message_get_path (message);
 560           break;
 561         case MATCH_ELEMENT_ARG0NAMESPACE:
 562           check_type = CHECK_TYPE_NAMESPACE_PREFIX;
 563           value = message_get_argN (message, 0, FALSE);
 564           break;
 565         case MATCH_ELEMENT_ARGN:
 566           value = message_get_argN (message, element->arg, FALSE);
 567           break;
 568         case MATCH_ELEMENT_ARGNPATH:
 569           check_type = CHECK_TYPE_PATH_RELATED;
 570           value = message_get_argN (message, element->arg, TRUE);
 571           break;
 572         default:
 573         case MATCH_ELEMENT_TYPE:
 574         case MATCH_ELEMENT_EAVESDROP:
 575           g_assert_not_reached ();
 576         }
 577
 578       if (value == NULL)
 579         return FALSE;
 580
 581       switch (check_type)
 582         {
 583         case CHECK_TYPE_STRING:
 584           if (strcmp (element->value, value) != 0)
 585             return FALSE;
 586           break;
 587         case CHECK_TYPE_NAME:
 588           name = name_lookup (daemon, element->value);
 589           if (name != NULL && name->owner != NULL)
 590             {
 591               if (strcmp (name->owner->client->id, value) != 0)
 592                 return FALSE;
 593             }
 594           else if (strcmp (element->value, value) != 0)
 595             return FALSE;
 596           break;
 597         case CHECK_TYPE_PATH_PREFIX:
 598           len = strlen (element->value);
 599           if (!(g_str_has_prefix (value, element->value) &&
 600                 (value[len] == 0 || value[len] == '/')))
 601             return FALSE;
 602           break;
 603         case CHECK_TYPE_PATH_RELATED:
 604           len = strlen (element->value);
 605           len2 = strlen (value);
 606
 607           if (!(strcmp (value, element->value) == 0 ||
 608                 (len2 > 0 && value[len2-1] == '/' && g_str_has_prefix (element->value, value)) ||
 609                 (len > 0 && element->value[len-1] == '/' && g_str_has_prefix (value, element->value))))
 610             return FALSE;
 611           break;
 612         case CHECK_TYPE_NAMESPACE_PREFIX:
 613           len = strlen (element->value);
 614           if (!(g_str_has_prefix (value, element->value) &&
 615                 (value[len] == 0 || value[len] == '.')))
 616             return FALSE;
 617           break;
 618         default:
 619           g_assert_not_reached ();
 620         }
 621     }
 622
 623   return TRUE;
 624 }
 625
 626 static void
 627 broadcast_message (GDBusDaemon *daemon,
 628                    GDBusMessage *message,
 629                    gboolean has_destination,
 630                    gboolean preserve_serial,
 631                    Client *not_to)
 632 {
 633   GList *clients, *l, *ll;
 634   GDBusMessage *copy;
 635
 636   clients = g_hash_table_get_values (daemon->clients);
 637   for (l = clients; l != NULL; l = l->next)
 638     {
 639       Client *client = l->data;
 640
 641       if (client == not_to)
 642         continue;
 643
 644       for (ll = client->matches; ll != NULL; ll = ll->next)
 645         {
 646           Match *match = ll->data;
 647
 648           if (match_matches (daemon, match, message, has_destination))
 649             break;
 650         }
 651
 652       if (ll != NULL)
 653         {
 654           copy = g_dbus_message_copy (message, NULL);
 655           if (copy)
 656             {
 657               g_dbus_connection_send_message (client->connection, copy,
 658                                               preserve_serial?G_DBUS_SEND_MESSAGE_FLAGS_PRESERVE_SERIAL:0, NULL, NULL);
 659               g_object_unref (copy);
 660             }
 661         }
 662     }
 663
 664   g_list_free (clients);
 665 }
 666
 667 static void
 668 send_name_owner_changed (GDBusDaemon *daemon,
 669                          const char *name,
 670                          const char *old_owner,
 671                          const char *new_owner)
 672 {
 673   GDBusMessage *signal_message;
 674
 675   signal_message = g_dbus_message_new_signal ("/org/freedesktop/DBus",
 676                                               "org.freedesktop.DBus",
 677                                               "NameOwnerChanged");
 678   g_dbus_message_set_body (signal_message,
 679                            g_variant_new ("(sss)",
 680                                           name,
 681                                           old_owner ? old_owner : "",
 682                                           new_owner ? new_owner : ""));
 683
 684   broadcast_message (daemon, signal_message, FALSE, FALSE, NULL);
 685   g_object_unref (signal_message);
 686
 687 }
 688
 689 static gboolean
 690 name_unqueue_owner (Name *name, Client *client)
 691 {
 692   GList *l;
 693
 694   for (l = name->queue; l != NULL; l = l->next)
 695     {
 696       NameOwner *other = l->data;
 697
 698       if (other->client == client)
 699         {
 700           name->queue = g_list_delete_link (name->queue, l);
 701           name_unref (name);
 702           name_owner_free (other);
 703           return TRUE;
 704         }
 705     }
 706
 707   return FALSE;
 708 }
 709
 710 static void
 711 name_replace_owner (Name *name, NameOwner *owner)
 712 {
 713   GDBusDaemon *daemon = name->daemon;
 714   NameOwner *old_owner;
 715   char *old_name = NULL, *new_name = NULL;
 716   Client *new_client = NULL;
 717
 718   if (owner)
 719     new_client = owner->client;
 720
 721   name_ref (name);
 722
 723   old_owner = name->owner;
 724   if (old_owner)
 725     {
 726       Client *old_client = old_owner->client;
 727
 728       g_assert (old_owner->client != new_client);
 729
 730       g_dbus_connection_emit_signal (old_client->connection,
 731                                      NULL, "/org/freedesktop/DBus",
 732                                      "org.freedesktop.DBus", "NameLost",
 733                                      g_variant_new ("(s)",
 734                                                     name->name), NULL);
 735
 736       old_name = g_strdup (old_client->id);
 737       if (old_owner->flags & DBUS_NAME_FLAG_DO_NOT_QUEUE)
 738         {
 739           name_unref (name);
 740           name_owner_free (old_owner);
 741         }
 742       else
 743         name->queue = g_list_prepend (name->queue, old_owner);
 744     }
 745
 746   name->owner = owner;
 747   if (owner)
 748     {
 749       name_unqueue_owner (name, owner->client);
 750       name_ref (name);
 751       new_name = new_client->id;
 752
 753       g_dbus_connection_emit_signal (new_client->connection,
 754                                      NULL, "/org/freedesktop/DBus",
 755                                      "org.freedesktop.DBus", "NameAcquired",
 756                                      g_variant_new ("(s)",
 757                                                     name->name), NULL);
 758     }
 759
 760   send_name_owner_changed (daemon, name->name, old_name, new_name);
 761
 762   g_free (old_name);
 763
 764   name_unref (name);
 765 }
 766
 767 static void
 768 name_release_owner (Name *name)
 769 {
 770   NameOwner *next_owner = NULL;
 771
 772   name_ref (name);
 773
 774   /* Will someone else take over? */
 775   if (name->queue)
 776     {
 777       next_owner = name->queue->data;
 778       name_unref (name);
 779       name->queue = g_list_delete_link (name->queue, name->queue);
 780     }
 781
 782   name->owner->flags |= DBUS_NAME_FLAG_DO_NOT_QUEUE;
 783   name_replace_owner (name, next_owner);
 784
 785   name_unref (name);
 786 }
 787
 788 static void
 789 name_queue_owner (Name *name, NameOwner *owner)
 790 {
 791   GList *l;
 792
 793   for (l = name->queue; l != NULL; l = l->next)
 794     {
 795       NameOwner *other = l->data;
 796
 797       if (other->client == owner->client)
 798         {
 799           other->flags = owner->flags;
 800           name_owner_free (owner);
 801           return;
 802         }
 803     }
 804
 805   name->queue = g_list_append (name->queue, owner);
 806   name_ref (name);
 807 }
 808
 809 static Client *
 810 client_new (GDBusDaemon *daemon, GDBusConnection *connection)
 811 {
 812   Client *client;
 813   GError *error = NULL;
 814
 815   client = g_new0 (Client, 1);
 816   client->daemon = daemon;
 817   client->id = g_strdup_printf (":%d.%d", daemon->next_major_id, daemon->next_minor_id);
 818   client->connection = g_object_ref (connection);
 819
 820   if (daemon->next_minor_id == G_MAXUINT32)
 821     {
 822       daemon->next_minor_id = 0;
 823       daemon->next_major_id++;
 824     }
 825   else
 826     daemon->next_minor_id++;
 827
 828   g_object_set_data (G_OBJECT (connection), "client", client);
 829   g_hash_table_insert (daemon->clients, client->id, client);
 830
 831   g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (daemon), connection,
 832                                     "/org/freedesktop/DBus", &error);
 833   g_assert_no_error (error);
 834
 835   g_signal_connect (connection, "closed", G_CALLBACK (connection_closed), client);
 836   g_dbus_connection_add_filter (connection,
 837                                 filter_function,
 838                                 client, NULL);
 839
 840   send_name_owner_changed (daemon, client->id, NULL, client->id);
 841
 842   return client;
 843 }
 844
 845 static void
 846 client_free (Client *client)
 847 {
 848   GDBusDaemon *daemon = client->daemon;
 849   GList *l, *names;
 850
 851   g_dbus_interface_skeleton_unexport_from_connection (G_DBUS_INTERFACE_SKELETON (daemon),
 852                                                       client->connection);
 853
 854   g_hash_table_remove (daemon->clients, client->id);
 855
 856   names = g_hash_table_get_values (daemon->names);
 857   for (l = names; l != NULL; l = l->next)
 858     {
 859       Name *name = l->data;
 860
 861       name_ref (name);
 862
 863       if (name->owner && name->owner->client == client)
 864         name_release_owner (name);
 865
 866       name_unqueue_owner (name, client);
 867
 868       name_unref (name);
 869     }
 870   g_list_free (names);
 871
 872   send_name_owner_changed (daemon, client->id, client->id, NULL);
 873
 874   g_object_unref (client->connection);
 875
 876   for (l = client->matches; l != NULL; l = l->next)
 877     match_free (l->data);
 878   g_list_free (client->matches);
 879
 880   g_free (client->id);
 881   g_free (client);
 882 }
 883
 884 static gboolean
 885 idle_timeout_cb (gpointer user_data)
 886 {
 887   GDBusDaemon *daemon = user_data;
 888
 889   daemon->timeout = 0;
 890
 891   g_signal_emit (daemon,
 892                  g_dbus_daemon_signals[SIGNAL_IDLE_TIMEOUT],
 893                  0);
 894
 895   return G_SOURCE_REMOVE;
 896 }
 897
 898 static void
 899 connection_closed (GDBusConnection *connection,
 900                    gboolean remote_peer_vanished,
 901                    GError *error,
 902                    Client *client)
 903 {
 904   GDBusDaemon *daemon = client->daemon;
 905
 906   client_free (client);
 907
 908   if (g_hash_table_size (daemon->clients) == 0)
 909     daemon->timeout = g_timeout_add (IDLE_TIMEOUT_MSEC,
 910                                      idle_timeout_cb,
 911                                      daemon);
 912 }
 913
 914 static gboolean
 915 handle_add_match (_GFreedesktopDBus *object,
 916                   GDBusMethodInvocation *invocation,
 917                   const gchar *arg_rule)
 918 {
 919   Client *client = g_object_get_data (G_OBJECT (g_dbus_method_invocation_get_connection (invocation)), "client");
 920   Match *match;
 921
 922   match = match_new (arg_rule);
 923
 924   if (match == NULL)
 925     g_dbus_method_invocation_return_error (invocation,
 926                                            G_DBUS_ERROR, G_DBUS_ERROR_MATCH_RULE_INVALID,
 927                                            "Invalid rule: %s", arg_rule);
 928   else
 929     {
 930       client->matches = g_list_prepend (client->matches, match);
 931       _g_freedesktop_dbus_complete_add_match (object, invocation);
 932     }
 933   return TRUE;
 934 }
 935
 936 static gboolean
 937 handle_get_connection_selinux_security_context (_GFreedesktopDBus *object,
 938                                                 GDBusMethodInvocation *invocation,
 939                                                 const gchar *arg_name)
 940 {
 941   g_dbus_method_invocation_return_error (invocation,
 942                                          G_DBUS_ERROR, G_DBUS_ERROR_SELINUX_SECURITY_CONTEXT_UNKNOWN,
 943                                          "selinux context not supported");
 944   _g_freedesktop_dbus_complete_get_connection_selinux_security_context (object, invocation, "");
 945   return TRUE;
 946 }
 947
 948 static gboolean
 949 handle_get_connection_unix_process_id (_GFreedesktopDBus *object,
 950                                        GDBusMethodInvocation *invocation,
 951                                        const gchar *arg_name)
 952 {
 953   g_dbus_method_invocation_return_error (invocation,
 954                                          G_DBUS_ERROR, G_DBUS_ERROR_UNIX_PROCESS_ID_UNKNOWN,
 955                                          "connection pid not supported");
 956   return TRUE;
 957 }
 958
 959 static gboolean
 960 handle_get_connection_unix_user (_GFreedesktopDBus *object,
 961                                  GDBusMethodInvocation *invocation,
 962                                  const gchar *arg_name)
 963 {
 964   g_dbus_method_invocation_return_error (invocation,
 965                                          G_DBUS_ERROR, G_DBUS_ERROR_UNIX_PROCESS_ID_UNKNOWN,
 966                                          "connection user not supported");
 967   return TRUE;
 968 }
 969
 970 static gboolean
 971 handle_get_id (_GFreedesktopDBus *object,
 972                GDBusMethodInvocation *invocation)
 973 {
 974   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
 975   _g_freedesktop_dbus_complete_get_id (object, invocation,
 976                                        daemon->guid);
 977   return TRUE;
 978 }
 979
 980 static gboolean
 981 handle_get_name_owner (_GFreedesktopDBus *object,
 982                        GDBusMethodInvocation *invocation,
 983                        const gchar *arg_name)
 984 {
 985   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
 986   Name *name;
 987
 988   if (strcmp (arg_name, DBUS_SERVICE_NAME) == 0)
 989     {
 990       _g_freedesktop_dbus_complete_get_name_owner (object, invocation, DBUS_SERVICE_NAME);
 991       return TRUE;
 992     }
 993
 994   if (arg_name[0] == ':')
 995     {
 996       if (g_hash_table_lookup (daemon->clients, arg_name) == NULL)
 997         g_dbus_method_invocation_return_error (invocation,
 998                                                G_DBUS_ERROR, G_DBUS_ERROR_NAME_HAS_NO_OWNER,
 999                                                "Could not get owner of name '%s': no such name", arg_name);
1000       else
1001         _g_freedesktop_dbus_complete_get_name_owner (object, invocation, arg_name);
1002       return TRUE;
1003     }
1004
1005   name = name_lookup (daemon, arg_name);
1006   if (name == NULL || name->owner == NULL)
1007     {
1008       g_dbus_method_invocation_return_error (invocation,
1009                                              G_DBUS_ERROR, G_DBUS_ERROR_NAME_HAS_NO_OWNER,
1010                                              "Could not get owner of name '%s': no such name", arg_name);
1011       return TRUE;
1012     }
1013
1014   _g_freedesktop_dbus_complete_get_name_owner (object, invocation, name->owner->client->id);
1015   return TRUE;
1016 }
1017
1018 static gboolean
1019 handle_hello (_GFreedesktopDBus *object,
1020               GDBusMethodInvocation *invocation)
1021 {
1022   Client *client = g_object_get_data (G_OBJECT (g_dbus_method_invocation_get_connection (invocation)), "client");
1023   _g_freedesktop_dbus_complete_hello (object, invocation, client->id);
1024
1025   g_dbus_connection_emit_signal (client->connection,
1026                                  NULL, "/org/freedesktop/DBus",
1027                                  "org.freedesktop.DBus", "NameAcquired",
1028                                  g_variant_new ("(s)",
1029                                                 client->id), NULL);
1030
1031   return TRUE;
1032 }
1033
1034 static gboolean
1035 handle_list_activatable_names (_GFreedesktopDBus *object,
1036                                GDBusMethodInvocation *invocation)
1037 {
1038   const char *names[] = { NULL };
1039
1040   _g_freedesktop_dbus_complete_list_activatable_names (object,
1041                                                        invocation,
1042                                                        names);
1043   return TRUE;
1044 }
1045
1046 static gboolean
1047 handle_list_names (_GFreedesktopDBus *object,
1048                    GDBusMethodInvocation *invocation)
1049 {
1050   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1051   GPtrArray *array;
1052   GList *clients, *names, *l;
1053
1054   array = g_ptr_array_new ();
1055
1056   clients = g_hash_table_get_values (daemon->clients);
1057   for (l = clients; l != NULL; l = l->next)
1058     {
1059       Client *client = l->data;
1060
1061       g_ptr_array_add (array, client->id);
1062     }
1063
1064   g_list_free (clients);
1065
1066   names = g_hash_table_get_values (daemon->names);
1067   for (l = names; l != NULL; l = l->next)
1068     {
1069       Name *name = l->data;
1070
1071       g_ptr_array_add (array, name->name);
1072     }
1073
1074   g_list_free (names);
1075
1076   g_ptr_array_add (array, NULL);
1077
1078   _g_freedesktop_dbus_complete_list_names (object,
1079                                            invocation,
1080                                            (const gchar * const*)array->pdata);
1081   g_ptr_array_free (array, TRUE);
1082   return TRUE;
1083 }
1084
1085 static gboolean
1086 handle_list_queued_owners (_GFreedesktopDBus *object,
1087                            GDBusMethodInvocation *invocation,
1088                            const gchar *arg_name)
1089 {
1090   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1091   GPtrArray *array;
1092   Name *name;
1093   GList *l;
1094
1095   array = g_ptr_array_new ();
1096
1097   name = name_lookup (daemon, arg_name);
1098   if (name && name->owner)
1099     {
1100       for (l = name->queue; l != NULL; l = l->next)
1101         {
1102           Client *client = l->data;
1103
1104           g_ptr_array_add (array, client->id);
1105         }
1106     }
1107
1108   g_ptr_array_add (array, NULL);
1109
1110   _g_freedesktop_dbus_complete_list_queued_owners (object,
1111                                                    invocation,
1112                                                    (const gchar * const*)array->pdata);
1113   g_ptr_array_free (array, TRUE);
1114   return TRUE;
1115 }
1116
1117 static gboolean
1118 handle_name_has_owner (_GFreedesktopDBus *object,
1119                        GDBusMethodInvocation *invocation,
1120                        const gchar *arg_name)
1121 {
1122   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1123   Name *name;
1124   Client *client;
1125
1126   name = name_lookup (daemon, arg_name);
1127   client = g_hash_table_lookup (daemon->clients, arg_name);
1128
1129   _g_freedesktop_dbus_complete_name_has_owner (object, invocation,
1130                                                name != NULL || client != NULL);
1131   return TRUE;
1132 }
1133
1134 static gboolean
1135 handle_release_name (_GFreedesktopDBus *object,
1136                      GDBusMethodInvocation *invocation,
1137                      const gchar *arg_name)
1138 {
1139   Client *client = g_object_get_data (G_OBJECT (g_dbus_method_invocation_get_connection (invocation)), "client");
1140   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1141   Name *name;
1142   guint32 result;
1143
1144   if (!g_dbus_is_name (arg_name))
1145     {
1146       g_dbus_method_invocation_return_error (invocation,
1147                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1148                                              "Given bus name \"%s\" is not valid", arg_name);
1149       return TRUE;
1150     }
1151
1152   if (*arg_name == ':')
1153     {
1154       g_dbus_method_invocation_return_error (invocation,
1155                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1156                                              "Cannot release a service starting with ':' such as \"%s\"", arg_name);
1157       return TRUE;
1158     }
1159
1160   if (strcmp (arg_name, DBUS_SERVICE_NAME) == 0)
1161     {
1162       g_dbus_method_invocation_return_error (invocation,
1163                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1164                                              "Cannot release a service named " DBUS_SERVICE_NAME ", because that is owned by the bus");
1165       return TRUE;
1166     }
1167
1168   name = name_lookup (daemon, arg_name);
1169
1170   if (name == NULL)
1171     result = DBUS_RELEASE_NAME_REPLY_NON_EXISTENT;
1172   else if (name->owner && name->owner->client == client)
1173     {
1174       name_release_owner (name);
1175       result = DBUS_RELEASE_NAME_REPLY_RELEASED;
1176     }
1177   else if (name_unqueue_owner (name, client))
1178     result = DBUS_RELEASE_NAME_REPLY_RELEASED;
1179   else
1180     result = DBUS_RELEASE_NAME_REPLY_NOT_OWNER;
1181
1182   _g_freedesktop_dbus_complete_release_name (object, invocation, result);
1183   return TRUE;
1184 }
1185
1186 static gboolean
1187 handle_reload_config (_GFreedesktopDBus *object,
1188                       GDBusMethodInvocation *invocation)
1189 {
1190   _g_freedesktop_dbus_complete_reload_config (object, invocation);
1191   return TRUE;
1192 }
1193
1194 static gboolean
1195 handle_update_activation_environment (_GFreedesktopDBus *object,
1196                                       GDBusMethodInvocation *invocation,
1197                                       GVariant *arg_environment)
1198 {
1199   g_dbus_method_invocation_return_error (invocation,
1200                                          G_DBUS_ERROR, G_DBUS_ERROR_FAILED,
1201                                          "UpdateActivationEnvironment not implemented");
1202   return TRUE;
1203 }
1204
1205 static gboolean
1206 handle_remove_match (_GFreedesktopDBus *object,
1207                      GDBusMethodInvocation *invocation,
1208                      const gchar *arg_rule)
1209 {
1210   Client *client = g_object_get_data (G_OBJECT (g_dbus_method_invocation_get_connection (invocation)), "client");
1211   Match *match, *other_match;
1212   GList *l;
1213
1214   match = match_new (arg_rule);
1215
1216   if (match == NULL)
1217     g_dbus_method_invocation_return_error (invocation,
1218                                            G_DBUS_ERROR, G_DBUS_ERROR_MATCH_RULE_INVALID,
1219                                            "Invalid rule: %s", arg_rule);
1220   else
1221     {
1222       for (l = client->matches; l != NULL; l = l->next)
1223         {
1224           other_match = l->data;
1225           if (match_equal (match, other_match))
1226             {
1227               match_free (other_match);
1228               client->matches = g_list_delete_link (client->matches, l);
1229               break;
1230             }
1231         }
1232
1233       if (l == NULL)
1234         g_dbus_method_invocation_return_error (invocation,
1235                                                G_DBUS_ERROR, G_DBUS_ERROR_MATCH_RULE_NOT_FOUND,
1236                                                "The given match rule wasn't found and can't be removed");
1237       else
1238         _g_freedesktop_dbus_complete_remove_match (object, invocation);
1239     }
1240
1241   match_free (match);
1242
1243   return TRUE;
1244 }
1245
1246 static gboolean
1247 handle_request_name (_GFreedesktopDBus *object,
1248                      GDBusMethodInvocation *invocation,
1249                      const gchar *arg_name,
1250                      guint flags)
1251 {
1252   Client *client = g_object_get_data (G_OBJECT (g_dbus_method_invocation_get_connection (invocation)), "client");
1253   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1254   Name *name;
1255   NameOwner *owner;
1256   guint32 result;
1257
1258   if (!g_dbus_is_name (arg_name))
1259     {
1260       g_dbus_method_invocation_return_error (invocation,
1261                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1262                                              "Requested bus name \"%s\" is not valid", arg_name);
1263       return TRUE;
1264     }
1265
1266   if (*arg_name == ':')
1267     {
1268       g_dbus_method_invocation_return_error (invocation,
1269                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1270                                              "Cannot acquire a service starting with ':' such as \"%s\"", arg_name);
1271       return TRUE;
1272     }
1273
1274   if (strcmp (arg_name, DBUS_SERVICE_NAME) == 0)
1275     {
1276       g_dbus_method_invocation_return_error (invocation,
1277                                              G_DBUS_ERROR, G_DBUS_ERROR_INVALID_ARGS,
1278                                              "Cannot acquire a service named " DBUS_SERVICE_NAME ", because that is reserved");
1279       return TRUE;
1280     }
1281
1282   name = name_ensure (daemon, arg_name);
1283   if (name->owner == NULL)
1284     {
1285       owner = name_owner_new (client, flags);
1286       name_replace_owner (name, owner);
1287
1288       result = DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER;
1289     }
1290   else if (name->owner && name->owner->client == client)
1291     {
1292       name->owner->flags = flags;
1293       result = DBUS_REQUEST_NAME_REPLY_ALREADY_OWNER;
1294     }
1295   else if ((flags & DBUS_NAME_FLAG_DO_NOT_QUEUE) &&
1296            (!(flags & DBUS_NAME_FLAG_REPLACE_EXISTING) ||
1297             !(name->owner->flags & DBUS_NAME_FLAG_ALLOW_REPLACEMENT)))
1298     {
1299       /* Unqueue if queued */
1300       name_unqueue_owner (name, client);
1301       result = DBUS_REQUEST_NAME_REPLY_EXISTS;
1302     }
1303   else if (!(flags & DBUS_NAME_FLAG_DO_NOT_QUEUE) &&
1304            (!(flags & DBUS_NAME_FLAG_REPLACE_EXISTING) ||
1305             !(name->owner->flags & DBUS_NAME_FLAG_ALLOW_REPLACEMENT)))
1306     {
1307       /* Queue the connection */
1308       owner = name_owner_new (client, flags);
1309       name_queue_owner (name, owner);
1310       result = DBUS_REQUEST_NAME_REPLY_IN_QUEUE;
1311     }
1312   else
1313     {
1314       /* Replace the current owner */
1315
1316       owner = name_owner_new (client, flags);
1317       name_replace_owner (name, owner);
1318
1319       result = DBUS_REQUEST_NAME_REPLY_PRIMARY_OWNER;
1320     }
1321
1322   name_unref (name);
1323
1324   _g_freedesktop_dbus_complete_request_name (object, invocation, result);
1325   return TRUE;
1326 }
1327
1328 static gboolean
1329 handle_start_service_by_name (_GFreedesktopDBus *object,
1330                               GDBusMethodInvocation *invocation,
1331                               const gchar *arg_name,
1332                               guint arg_flags)
1333 {
1334   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1335   Name *name;
1336
1337   name = name_lookup (daemon, arg_name);
1338   if (name)
1339     _g_freedesktop_dbus_complete_start_service_by_name (object, invocation,
1340                                                         DBUS_START_REPLY_ALREADY_RUNNING);
1341   else
1342     g_dbus_method_invocation_return_error (invocation,
1343                                            G_DBUS_ERROR, G_DBUS_ERROR_SERVICE_UNKNOWN,
1344                                            "No support for activation for name: %s", arg_name);
1345
1346   return TRUE;
1347 }
1348
1349 static void
1350 return_error (Client *client, GDBusMessage *message,
1351               GQuark                 domain,
1352               gint                   code,
1353               const gchar           *format,
1354               ...)
1355 {
1356   GDBusMessage *reply;
1357   va_list var_args;
1358   char *error_message;
1359   GError *error;
1360   gchar *dbus_error_name;
1361
1362   va_start (var_args, format);
1363   error_message = g_strdup_vprintf (format, var_args);
1364   va_end (var_args);
1365
1366   error = g_error_new_literal (domain, code, "");
1367   dbus_error_name = g_dbus_error_encode_gerror (error);
1368
1369   reply = g_dbus_message_new_method_error_literal (message,
1370                                                    dbus_error_name,
1371                                                    error_message);
1372
1373   g_error_free (error);
1374   g_free (dbus_error_name);
1375   g_free (error_message);
1376
1377   if (!g_dbus_connection_send_message (client->connection, reply, G_DBUS_SEND_MESSAGE_FLAGS_NONE, NULL, NULL))
1378       g_warning ("Error sending reply");
1379   g_object_unref (reply);
1380 }
1381
1382 static GDBusMessage *
1383 route_message (Client *source_client, GDBusMessage *message)
1384 {
1385   const char *dest;
1386   Client *dest_client;
1387   GDBusDaemon *daemon;
1388
1389   daemon = source_client->daemon;
1390
1391   dest_client = NULL;
1392   dest = g_dbus_message_get_destination (message);
1393   if (dest != NULL && strcmp (dest, DBUS_SERVICE_NAME) != 0)
1394     {
1395       dest_client = g_hash_table_lookup (daemon->clients, dest);
1396
1397       if (dest_client == NULL)
1398         {
1399           Name *name;
1400           name = name_lookup (daemon, dest);
1401           if (name && name->owner)
1402             dest_client = name->owner->client;
1403         }
1404
1405       if (dest_client == NULL)
1406         {
1407           if (g_dbus_message_get_message_type (message) == G_DBUS_MESSAGE_TYPE_METHOD_CALL)
1408             return_error (source_client, message,
1409                           G_DBUS_ERROR, G_DBUS_ERROR_SERVICE_UNKNOWN,
1410                           "The name %s is unknown", dest);
1411         }
1412       else
1413         {
1414           GError *error = NULL;
1415
1416           if (!g_dbus_connection_send_message (dest_client->connection, message, G_DBUS_SEND_MESSAGE_FLAGS_PRESERVE_SERIAL, NULL, &error))
1417             {
1418               g_warning ("Error forwarding message: %s", error->message);
1419               g_error_free (error);
1420             }
1421         }
1422     }
1423
1424   broadcast_message (daemon, message, dest_client != NULL, TRUE, dest_client);
1425
1426   /* Swallow messages not for the bus */
1427   if (dest == NULL || strcmp (dest, DBUS_SERVICE_NAME) != 0)
1428     {
1429       g_object_unref (message);
1430       message = NULL;
1431     }
1432
1433   return message;
1434 }
1435
1436 static GDBusMessage *
1437 copy_if_locked (GDBusMessage *message)
1438 {
1439   if (g_dbus_message_get_locked (message))
1440     {
1441       GDBusMessage *copy = g_dbus_message_copy (message, NULL);
1442       g_object_unref (message);
1443       message = copy;
1444     }
1445   return message;
1446 }
1447
1448 static GDBusMessage *
1449 filter_function (GDBusConnection *connection,
1450                  GDBusMessage    *message,
1451                  gboolean         incoming,
1452                  gpointer         user_data)
1453 {
1454   Client *client = user_data;
1455   char *types[] = {"invalid", "method_call", "method_return", "error", "signal" };
1456
1457   if (0)
1458     g_printerr ("%s%s %s %d(%d) sender: %s destination: %s %s %s.%s\n",
1459                 client->id,
1460                 incoming? "->" : "<-",
1461                 types[g_dbus_message_get_message_type (message)],
1462                 g_dbus_message_get_serial (message),
1463                 g_dbus_message_get_reply_serial (message),
1464                 g_dbus_message_get_sender (message),
1465                 g_dbus_message_get_destination (message),
1466                 g_dbus_message_get_path (message),
1467                 g_dbus_message_get_interface (message),
1468                 g_dbus_message_get_member (message));
1469
1470   if (incoming)
1471     {
1472       /* Ensure its not locked so we can set the sender */
1473       message = copy_if_locked (message);
1474       if (message == NULL)
1475         {
1476           g_warning ("Failed to copy incoming message");
1477           return NULL;
1478         }
1479       g_dbus_message_set_sender (message, client->id);
1480
1481       return route_message (client, message);
1482     }
1483   else
1484     {
1485       if (g_dbus_message_get_sender (message) == NULL)
1486         {
1487           message = copy_if_locked (message);
1488           g_dbus_message_set_sender (message, DBUS_SERVICE_NAME);
1489         }
1490       if (g_dbus_message_get_destination (message) == NULL)
1491         {
1492           message = copy_if_locked (message);
1493           g_dbus_message_set_destination (message, client->id);
1494         }
1495     }
1496
1497   return message;
1498 }
1499
1500 static gboolean
1501 on_new_connection (GDBusServer *server,
1502                    GDBusConnection *connection,
1503                    gpointer user_data)
1504 {
1505   GDBusDaemon *daemon = user_data;
1506
1507   g_dbus_connection_set_exit_on_close (connection, FALSE);
1508
1509   if (daemon->timeout)
1510     {
1511       g_source_remove (daemon->timeout);
1512       daemon->timeout = 0;
1513     }
1514
1515   client_new (daemon, connection);
1516
1517   return TRUE;
1518 }
1519
1520 static gboolean
1521 on_authorize_authenticated_peer (GDBusAuthObserver *observer,
1522                                  GIOStream         *stream,
1523                                  GCredentials      *credentials,
1524                                  gpointer           user_data)
1525 {
1526   gboolean authorized = TRUE;
1527
1528   if (credentials != NULL)
1529     {
1530       GCredentials *own_credentials;
1531
1532       own_credentials = g_credentials_new ();
1533       authorized = g_credentials_is_same_user (credentials, own_credentials, NULL);
1534       g_object_unref (own_credentials);
1535     }
1536
1537   return authorized;
1538 }
1539
1540 static void
1541 g_dbus_daemon_finalize (GObject *object)
1542 {
1543   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1544   GList *clients, *l;
1545
1546   if (daemon->timeout)
1547     g_source_remove (daemon->timeout);
1548
1549   clients = g_hash_table_get_values (daemon->clients);
1550   for (l = clients; l != NULL; l = l->next)
1551     client_free (l->data);
1552   g_list_free (clients);
1553
1554   g_assert (g_hash_table_size (daemon->clients) == 0);
1555   g_assert (g_hash_table_size (daemon->names) == 0);
1556
1557   g_hash_table_destroy (daemon->clients);
1558   g_hash_table_destroy (daemon->names);
1559
1560   g_object_unref (daemon->server);
1561
1562   if (daemon->tmpdir)
1563     {
1564       g_rmdir (daemon->tmpdir);
1565       g_free (daemon->tmpdir);
1566     }
1567
1568   g_free (daemon->guid);
1569   g_free (daemon->address);
1570
1571   G_OBJECT_CLASS (g_dbus_daemon_parent_class)->finalize (object);
1572 }
1573
1574 static void
1575 g_dbus_daemon_init (GDBusDaemon *daemon)
1576 {
1577   daemon->next_major_id = 1;
1578   daemon->clients = g_hash_table_new_full (g_str_hash, g_str_equal, NULL, NULL);
1579   daemon->names = g_hash_table_new_full (g_str_hash, g_str_equal, NULL, NULL);
1580   daemon->guid = g_dbus_generate_guid ();
1581 }
1582
1583 static gboolean
1584 initable_init (GInitable     *initable,
1585                GCancellable  *cancellable,
1586                GError       **error)
1587 {
1588   GDBusDaemon *daemon = G_DBUS_DAEMON (initable);
1589   GDBusAuthObserver *observer;
1590   GDBusServerFlags flags;
1591
1592   flags = G_DBUS_SERVER_FLAGS_NONE;
1593   if (daemon->address == NULL)
1594     {
1595 #ifdef G_OS_UNIX
1596       if (g_unix_socket_address_abstract_names_supported ())
1597         daemon->address = g_strdup ("unix:tmpdir=/tmp/gdbus-daemon");
1598       else
1599         {
1600           daemon->tmpdir = g_dir_make_tmp ("gdbus-daemon-XXXXXX", NULL);
1601           daemon->address = g_strdup_printf ("unix:tmpdir=%s", daemon->tmpdir);
1602         }
1603 #else
1604       daemon->address = g_strdup ("nonce-tcp:");
1605       flags |= G_DBUS_SERVER_FLAGS_AUTHENTICATION_ALLOW_ANONYMOUS;
1606 #endif
1607     }
1608
1609   observer = g_dbus_auth_observer_new ();
1610   daemon->server = g_dbus_server_new_sync (daemon->address,
1611                                            flags,
1612                                            daemon->guid,
1613                                            observer,
1614                                            cancellable,
1615                                            error);
1616   if (daemon->server == NULL)
1617     {
1618       g_object_unref (observer);
1619       return FALSE;
1620     }
1621
1622
1623   g_dbus_server_start (daemon->server);
1624
1625   g_signal_connect (daemon->server, "new-connection",
1626                     G_CALLBACK (on_new_connection),
1627                     daemon);
1628   g_signal_connect (observer,
1629                     "authorize-authenticated-peer",
1630                     G_CALLBACK (on_authorize_authenticated_peer),
1631                     daemon);
1632
1633   g_object_unref (observer);
1634
1635   return TRUE;
1636 }
1637
1638 static void
1639 g_dbus_daemon_set_property (GObject      *object,
1640                             guint         prop_id,
1641                             const GValue *value,
1642                             GParamSpec   *pspec)
1643 {
1644   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1645
1646   switch (prop_id)
1647     {
1648     case PROP_ADDRESS:
1649       g_free (daemon->address);
1650       daemon->address = g_value_dup_string (value);
1651       break;
1652
1653     default:
1654       G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
1655     }
1656 }
1657
1658 static void
1659 g_dbus_daemon_get_property (GObject    *object,
1660                             guint       prop_id,
1661                             GValue     *value,
1662                             GParamSpec *pspec)
1663 {
1664   GDBusDaemon *daemon = G_DBUS_DAEMON (object);
1665
1666   switch (prop_id)
1667     {
1668       case PROP_ADDRESS:
1669         g_value_set_string (value, daemon->address);
1670         break;
1671
1672     default:
1673         G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
1674     }
1675 }
1676
1677 static void
1678 g_dbus_daemon_class_init (GDBusDaemonClass *klass)
1679 {
1680   GObjectClass *gobject_class;
1681
1682   gobject_class = G_OBJECT_CLASS (klass);
1683   gobject_class->finalize = g_dbus_daemon_finalize;
1684   gobject_class->set_property = g_dbus_daemon_set_property;
1685   gobject_class->get_property = g_dbus_daemon_get_property;
1686
1687   g_dbus_daemon_signals[SIGNAL_IDLE_TIMEOUT] =
1688     g_signal_new ("idle-timeout",
1689                   G_TYPE_DBUS_DAEMON,
1690                   G_SIGNAL_RUN_LAST,
1691                   0,
1692                   NULL, NULL,
1693                   g_cclosure_marshal_VOID__VOID,
1694                   G_TYPE_NONE, 0);
1695
1696   g_object_class_install_property (gobject_class,
1697                                    PROP_ADDRESS,
1698                                    g_param_spec_string ("address",
1699                                                         "Bus Address",
1700                                                         "The address the bus should use",
1701                                                         NULL,
1702                                                         G_PARAM_READWRITE |
1703                                                         G_PARAM_CONSTRUCT_ONLY |
1704                                                         G_PARAM_STATIC_STRINGS));
1705 }
1706
1707 static void
1708 g_dbus_daemon_iface_init (_GFreedesktopDBusIface *iface)
1709 {
1710   iface->handle_add_match = handle_add_match;
1711   iface->handle_get_connection_selinux_security_context = handle_get_connection_selinux_security_context;
1712   iface->handle_get_connection_unix_process_id = handle_get_connection_unix_process_id;
1713   iface->handle_get_connection_unix_user = handle_get_connection_unix_user;
1714   iface->handle_get_id = handle_get_id;
1715   iface->handle_get_name_owner = handle_get_name_owner;
1716   iface->handle_hello = handle_hello;
1717   iface->handle_list_activatable_names = handle_list_activatable_names;
1718   iface->handle_list_names = handle_list_names;
1719   iface->handle_list_queued_owners = handle_list_queued_owners;
1720   iface->handle_name_has_owner = handle_name_has_owner;
1721   iface->handle_release_name = handle_release_name;
1722   iface->handle_reload_config = handle_reload_config;
1723   iface->handle_update_activation_environment = handle_update_activation_environment;
1724   iface->handle_remove_match = handle_remove_match;
1725   iface->handle_request_name = handle_request_name;
1726   iface->handle_start_service_by_name = handle_start_service_by_name;
1727 }
1728
1729 static void
1730 initable_iface_init (GInitableIface *initable_iface)
1731 {
1732   initable_iface->init = initable_init;
1733 }
1734
1735 GDBusDaemon *
1736 _g_dbus_daemon_new (const char *address,
1737                     GCancellable *cancellable,
1738                     GError **error)
1739 {
1740   return g_initable_new (G_TYPE_DBUS_DAEMON,
1741                          cancellable,
1742                          error,
1743                          "address", address,
1744                          NULL);
1745 }
1746
1747 const char *
1748 _g_dbus_daemon_get_address (GDBusDaemon *daemon)
1749 {
1750   return g_dbus_server_get_client_address (daemon->server);
1751 }