sl@0: /* -*- mode: C; c-file-style: "gnu" -*- */
sl@0: /* dbus-gmain.c GLib main loop integration
sl@0:  *
sl@0:  * Copyright (C) 2002, 2003 CodeFactory AB
sl@0:  * Copyright (C) 2005 Red Hat, Inc.
sl@0:  * Portion Copyright © 2008 Nokia Corporation and/or its subsidiary(-ies). All rights reserved.
sl@0:  * Licensed under the Academic Free License version 2.1
sl@0:  * 
sl@0:  * This program is free software; you can redistribute it and/or modify
sl@0:  * it under the terms of the GNU General Public License as published by
sl@0:  * the Free Software Foundation; either version 2 of the License, or
sl@0:  * (at your option) any later version.
sl@0:  *
sl@0:  * This program is distributed in the hope that it will be useful,
sl@0:  * but WITHOUT ANY WARRANTY; without even the implied warranty of
sl@0:  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
sl@0:  * GNU General Public License for more details.
sl@0:  * 
sl@0:  * You should have received a copy of the GNU General Public License
sl@0:  * along with this program; if not, write to the Free Software
sl@0:  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
sl@0:  *
sl@0:  */
sl@0: 
sl@0: #ifndef __SYMBIAN32__
sl@0: #include <config.h>
sl@0: #else
sl@0: #include "config.h"
sl@0: #endif //__SYMBIAN32__
sl@0: #include <dbus/dbus-glib.h>
sl@0: #include <dbus/dbus-glib-lowlevel.h>
sl@0: #include "dbus-gtest.h"
sl@0: #include "dbus-gutils.h"
sl@0: #include "dbus-gvalue.h"
sl@0: #include "dbus-gobject.h"
sl@0: #include "dbus-gvalue-utils.h"
sl@0: #include "dbus-gsignature.h"
sl@0: #include <string.h>
sl@0: #ifndef __SYMBIAN32__
sl@0: #include <libintl.h>
sl@0: #define _(x) dgettext (GETTEXT_PACKAGE, x)
sl@0: #define N_(x) x
sl@0: #else
sl@0: 
sl@0: #define _(x) x
sl@0: #define N_(x) x
sl@0: #endif
sl@0: 
sl@0: #ifdef __SYMBIAN32__
sl@0: #include "libdbus_glib_wsd_solution.h"
sl@0: #endif
sl@0: /**
sl@0:  * @defgroup DBusGLibInternals GLib bindings implementation details
sl@0:  * @ingroup  DBusInternals
sl@0:  * @brief Implementation details of GLib bindings
sl@0:  *
sl@0:  * @{
sl@0:  */
sl@0: 
sl@0: /**
sl@0:  * DBusGMessageQueue:
sl@0:  * A GSource subclass for dispatching DBusConnection messages.
sl@0:  * We need this on top of the IO handlers, because sometimes
sl@0:  * there are messages to dispatch queued up but no IO pending.
sl@0:  */
sl@0: typedef struct
sl@0: {
sl@0:   GSource source; /**< the parent GSource */
sl@0:   DBusConnection *connection; /**< the connection to dispatch */
sl@0: } DBusGMessageQueue;
sl@0: 
sl@0: static gboolean message_queue_prepare  (GSource     *source,
sl@0:                                         gint        *timeout);
sl@0: static gboolean message_queue_check    (GSource     *source);
sl@0: static gboolean message_queue_dispatch (GSource     *source,
sl@0:                                         GSourceFunc  callback,
sl@0:                                         gpointer     user_data);
sl@0: 
sl@0: static const GSourceFuncs message_queue_funcs = {
sl@0:   message_queue_prepare,
sl@0:   message_queue_check,
sl@0:   message_queue_dispatch,
sl@0:   NULL
sl@0: };
sl@0: 
sl@0: static gboolean
sl@0: message_queue_prepare (GSource *source,
sl@0:                        gint    *timeout)
sl@0: {
sl@0:   DBusConnection *connection = ((DBusGMessageQueue *)source)->connection;
sl@0:   
sl@0:   *timeout = -1;
sl@0: 
sl@0:   return (dbus_connection_get_dispatch_status (connection) == DBUS_DISPATCH_DATA_REMAINS);  
sl@0: }
sl@0: 
sl@0: static gboolean
sl@0: message_queue_check (GSource *source)
sl@0: {
sl@0:   return FALSE;
sl@0: }
sl@0: 
sl@0: static gboolean
sl@0: message_queue_dispatch (GSource     *source,
sl@0:                         GSourceFunc  callback,
sl@0:                         gpointer     user_data)
sl@0: {
sl@0:   DBusConnection *connection = ((DBusGMessageQueue *)source)->connection;
sl@0: 
sl@0:   dbus_connection_ref (connection);
sl@0: 
sl@0:   /* Only dispatch once - we don't want to starve other GSource */
sl@0:   dbus_connection_dispatch (connection);
sl@0:   
sl@0:   dbus_connection_unref (connection);
sl@0: 
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: typedef struct
sl@0: {
sl@0:   GMainContext *context;      /**< the main context */
sl@0:   GSList *ios;                /**< all IOHandler */
sl@0:   GSList *timeouts;           /**< all TimeoutHandler */
sl@0:   DBusConnection *connection; /**< NULL if this is really for a server not a connection */
sl@0:   GSource *message_queue_source; /**< DBusGMessageQueue */
sl@0: } ConnectionSetup;
sl@0: 
sl@0: 
sl@0: typedef struct
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0:   GSource *source;
sl@0:   DBusWatch *watch;
sl@0: } IOHandler;
sl@0: 
sl@0: typedef struct
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0:   GSource *source;
sl@0:   DBusTimeout *timeout;
sl@0: } TimeoutHandler;
sl@0: 
sl@0: 
sl@0: #if EMULATOR
sl@0: GET_GLOBAL_VAR_FROM_TLS(_dbus_gmain_connection_slot,dbus_gmain,dbus_int32_t)
sl@0: #define _dbus_gmain_connection_slot (*GET_DBUS_WSD_VAR_NAME(_dbus_gmain_connection_slot,dbus_gmain,g)())
sl@0: 
sl@0: GET_STATIC_VAR_FROM_TLS(server_slot,dbus_gmain,dbus_int32_t)
sl@0: #define server_slot (*GET_DBUS_WSD_VAR_NAME(server_slot,dbus_gmain,s)())
sl@0: 
sl@0: #else
sl@0: 
sl@0: dbus_int32_t _dbus_gmain_connection_slot = -1;
sl@0: 
sl@0: static dbus_int32_t server_slot = -1;
sl@0: #endif
sl@0: 
sl@0: 
sl@0: 
sl@0: static ConnectionSetup*
sl@0: connection_setup_new (GMainContext   *context,
sl@0:                       DBusConnection *connection)
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   cs = g_new0 (ConnectionSetup, 1);
sl@0: 
sl@0:   g_assert (context != NULL);
sl@0:   
sl@0:   cs->context = context;
sl@0:   g_main_context_ref (cs->context);  
sl@0: 
sl@0:   if (connection)
sl@0:     {
sl@0:       cs->connection = connection;
sl@0: 
sl@0:       cs->message_queue_source = g_source_new ((GSourceFuncs *) &message_queue_funcs,
sl@0:                                                sizeof (DBusGMessageQueue));
sl@0:       ((DBusGMessageQueue*)cs->message_queue_source)->connection = connection;
sl@0:       g_source_attach (cs->message_queue_source, cs->context);
sl@0:     }
sl@0:   
sl@0:   return cs;
sl@0: }
sl@0: 
sl@0: static void
sl@0: io_handler_source_finalized (gpointer data)
sl@0: {
sl@0:   IOHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   if (handler->watch)
sl@0:     dbus_watch_set_data (handler->watch, NULL, NULL);
sl@0:   
sl@0:   g_free (handler);
sl@0: }
sl@0: 
sl@0: static void
sl@0: io_handler_destroy_source (void *data)
sl@0: {
sl@0:   IOHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   if (handler->source)
sl@0:     {
sl@0:       GSource *source = handler->source;
sl@0:       handler->source = NULL;
sl@0:       handler->cs->ios = g_slist_remove (handler->cs->ios, handler);
sl@0:       g_source_destroy (source);
sl@0:       g_source_unref (source);
sl@0:     }
sl@0: }
sl@0: 
sl@0: static void
sl@0: io_handler_watch_freed (void *data)
sl@0: {
sl@0:   IOHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   handler->watch = NULL;
sl@0: 
sl@0:   io_handler_destroy_source (handler);
sl@0: }
sl@0: 
sl@0: static gboolean
sl@0: io_handler_dispatch (GIOChannel   *source,
sl@0:                      GIOCondition  condition,
sl@0:                      gpointer      data)
sl@0: {
sl@0:   IOHandler *handler;
sl@0:   guint dbus_condition = 0;
sl@0:   DBusConnection *connection;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   connection = handler->cs->connection;
sl@0:   
sl@0:   if (connection)
sl@0:     dbus_connection_ref (connection);
sl@0:   
sl@0:   if (condition & G_IO_IN)
sl@0:     dbus_condition |= DBUS_WATCH_READABLE;
sl@0:   if (condition & G_IO_OUT)
sl@0:     dbus_condition |= DBUS_WATCH_WRITABLE;
sl@0:   if (condition & G_IO_ERR)
sl@0:     dbus_condition |= DBUS_WATCH_ERROR;
sl@0:   if (condition & G_IO_HUP)
sl@0:     dbus_condition |= DBUS_WATCH_HANGUP;
sl@0: 
sl@0:   /* Note that we don't touch the handler after this, because
sl@0:    * dbus may have disabled the watch and thus killed the
sl@0:    * handler.
sl@0:    */
sl@0:   dbus_watch_handle (handler->watch, dbus_condition);
sl@0:   handler = NULL;
sl@0: 
sl@0:   if (connection)
sl@0:     dbus_connection_unref (connection);
sl@0:   
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: static void
sl@0: connection_setup_add_watch (ConnectionSetup *cs,
sl@0:                             DBusWatch       *watch)
sl@0: {
sl@0:   guint flags;
sl@0:   GIOCondition condition;
sl@0:   GIOChannel *channel;
sl@0:   IOHandler *handler;
sl@0:   
sl@0:   if (!dbus_watch_get_enabled (watch))
sl@0:     return;
sl@0:   
sl@0:   g_assert (dbus_watch_get_data (watch) == NULL);
sl@0:   
sl@0:   flags = dbus_watch_get_flags (watch);
sl@0: 
sl@0:   condition = G_IO_ERR | G_IO_HUP;
sl@0:   if (flags & DBUS_WATCH_READABLE)
sl@0:     condition |= G_IO_IN;
sl@0:   if (flags & DBUS_WATCH_WRITABLE)
sl@0:     condition |= G_IO_OUT;
sl@0: 
sl@0:   handler = g_new0 (IOHandler, 1);
sl@0:   handler->cs = cs;
sl@0:   handler->watch = watch;
sl@0:   
sl@0:   channel = g_io_channel_unix_new (dbus_watch_get_fd (watch));
sl@0:   
sl@0:   handler->source = g_io_create_watch (channel, condition);
sl@0:   g_source_set_callback (handler->source, (GSourceFunc) io_handler_dispatch, handler,
sl@0:                          io_handler_source_finalized);
sl@0:   g_source_attach (handler->source, cs->context);
sl@0: 
sl@0:   cs->ios = g_slist_prepend (cs->ios, handler);
sl@0:   
sl@0:   dbus_watch_set_data (watch, handler, io_handler_watch_freed);
sl@0:   g_io_channel_unref (channel);
sl@0: }
sl@0: 
sl@0: static void
sl@0: connection_setup_remove_watch (ConnectionSetup *cs,
sl@0:                                DBusWatch       *watch)
sl@0: {
sl@0:   IOHandler *handler;
sl@0: 
sl@0:   handler = dbus_watch_get_data (watch);
sl@0: 
sl@0:   if (handler == NULL)
sl@0:     return;
sl@0:   
sl@0:   io_handler_destroy_source (handler);
sl@0: }
sl@0: 
sl@0: static void
sl@0: timeout_handler_source_finalized (gpointer data)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   if (handler->timeout)
sl@0:     dbus_timeout_set_data (handler->timeout, NULL, NULL);
sl@0:   
sl@0:   g_free (handler);
sl@0: }
sl@0: 
sl@0: static void
sl@0: timeout_handler_destroy_source (void *data)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   if (handler->source)
sl@0:     {
sl@0:       GSource *source = handler->source;
sl@0:       handler->source = NULL;
sl@0:       handler->cs->timeouts = g_slist_remove (handler->cs->timeouts, handler);
sl@0:       g_source_destroy (source);
sl@0:       g_source_unref (source);
sl@0:     }
sl@0: }
sl@0: 
sl@0: static void
sl@0: timeout_handler_timeout_freed (void *data)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   handler->timeout = NULL;
sl@0: 
sl@0:   timeout_handler_destroy_source (handler);
sl@0: }
sl@0: 
sl@0: static gboolean
sl@0: timeout_handler_dispatch (gpointer      data)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0: 
sl@0:   handler = data;
sl@0: 
sl@0:   dbus_timeout_handle (handler->timeout);
sl@0:   
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: static void
sl@0: connection_setup_add_timeout (ConnectionSetup *cs,
sl@0:                               DBusTimeout     *timeout)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0:   
sl@0:   if (!dbus_timeout_get_enabled (timeout))
sl@0:     return;
sl@0:   
sl@0:   g_assert (dbus_timeout_get_data (timeout) == NULL);
sl@0: 
sl@0:   handler = g_new0 (TimeoutHandler, 1);
sl@0:   handler->cs = cs;
sl@0:   handler->timeout = timeout;
sl@0: 
sl@0:   handler->source = g_timeout_source_new (dbus_timeout_get_interval (timeout));
sl@0:   g_source_set_callback (handler->source, timeout_handler_dispatch, handler,
sl@0:                          timeout_handler_source_finalized);
sl@0:   g_source_attach (handler->source, handler->cs->context);
sl@0: 
sl@0:   cs->timeouts = g_slist_prepend (cs->timeouts, handler);
sl@0: 
sl@0:   dbus_timeout_set_data (timeout, handler, timeout_handler_timeout_freed);
sl@0: }
sl@0: 
sl@0: static void
sl@0: connection_setup_remove_timeout (ConnectionSetup *cs,
sl@0:                                  DBusTimeout       *timeout)
sl@0: {
sl@0:   TimeoutHandler *handler;
sl@0:   
sl@0:   handler = dbus_timeout_get_data (timeout);
sl@0: 
sl@0:   if (handler == NULL)
sl@0:     return;
sl@0:   
sl@0:   timeout_handler_destroy_source (handler);
sl@0: }
sl@0: 
sl@0: static void
sl@0: connection_setup_free (ConnectionSetup *cs)
sl@0: {
sl@0:   while (cs->ios)
sl@0:     io_handler_destroy_source (cs->ios->data);
sl@0: 
sl@0:   while (cs->timeouts)
sl@0:     timeout_handler_destroy_source (cs->timeouts->data);
sl@0: 
sl@0:   if (cs->message_queue_source)
sl@0:     {
sl@0:       GSource *source;
sl@0: 
sl@0:       source = cs->message_queue_source;
sl@0:       cs->message_queue_source = NULL;
sl@0: 
sl@0:       g_source_destroy (source);
sl@0:       g_source_unref (source);
sl@0:     }
sl@0:   
sl@0:   g_main_context_unref (cs->context);
sl@0:   g_free (cs);
sl@0: }
sl@0: 
sl@0: static dbus_bool_t
sl@0: add_watch (DBusWatch *watch,
sl@0: 	   gpointer   data)
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   cs = data;
sl@0: 
sl@0:   connection_setup_add_watch (cs, watch);
sl@0:   
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: static void
sl@0: remove_watch (DBusWatch *watch,
sl@0: 	      gpointer   data)
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   cs = data;
sl@0: 
sl@0:   connection_setup_remove_watch (cs, watch);
sl@0: }
sl@0: 
sl@0: static void
sl@0: watch_toggled (DBusWatch *watch,
sl@0:                void      *data)
sl@0: {
sl@0:   /* Because we just exit on OOM, enable/disable is
sl@0:    * no different from add/remove
sl@0:    */
sl@0:   if (dbus_watch_get_enabled (watch))
sl@0:     add_watch (watch, data);
sl@0:   else
sl@0:     remove_watch (watch, data);
sl@0: }
sl@0: 
sl@0: static dbus_bool_t
sl@0: add_timeout (DBusTimeout *timeout,
sl@0: 	     void        *data)
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   cs = data;
sl@0:   
sl@0:   if (!dbus_timeout_get_enabled (timeout))
sl@0:     return TRUE;
sl@0: 
sl@0:   connection_setup_add_timeout (cs, timeout);
sl@0: 
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: static void
sl@0: remove_timeout (DBusTimeout *timeout,
sl@0: 		void        *data)
sl@0: {
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   cs = data;
sl@0: 
sl@0:   connection_setup_remove_timeout (cs, timeout);
sl@0: }
sl@0: 
sl@0: static void
sl@0: timeout_toggled (DBusTimeout *timeout,
sl@0:                  void        *data)
sl@0: {
sl@0:   /* Because we just exit on OOM, enable/disable is
sl@0:    * no different from add/remove
sl@0:    */
sl@0:   if (dbus_timeout_get_enabled (timeout))
sl@0:     add_timeout (timeout, data);
sl@0:   else
sl@0:     remove_timeout (timeout, data);
sl@0: }
sl@0: 
sl@0: static void
sl@0: wakeup_main (void *data)
sl@0: {
sl@0:   ConnectionSetup *cs = data;
sl@0: 
sl@0:   g_main_context_wakeup (cs->context);
sl@0: }
sl@0: 
sl@0: 
sl@0: /* Move to a new context */
sl@0: static ConnectionSetup*
sl@0: connection_setup_new_from_old (GMainContext    *context,
sl@0:                                ConnectionSetup *old)
sl@0: {
sl@0:   GSList *tmp;
sl@0:   ConnectionSetup *cs;
sl@0: 
sl@0:   g_assert (old->context != context);
sl@0:   
sl@0:   cs = connection_setup_new (context, old->connection);
sl@0:   
sl@0:   tmp = old->ios;
sl@0:   while (tmp != NULL)
sl@0:     {
sl@0:       IOHandler *handler = tmp->data;
sl@0: 
sl@0:       connection_setup_add_watch (cs, handler->watch);
sl@0:       
sl@0:       tmp = tmp->next;
sl@0:     }
sl@0: 
sl@0:   tmp = old->timeouts;
sl@0:   while (tmp != NULL)
sl@0:     {
sl@0:       TimeoutHandler *handler = tmp->data;
sl@0: 
sl@0:       connection_setup_add_timeout (cs, handler->timeout);
sl@0:       
sl@0:       tmp = tmp->next;
sl@0:     }
sl@0: 
sl@0:   return cs;
sl@0: }
sl@0: 
sl@0: /** @} */ /* End of GLib bindings internals */
sl@0: 
sl@0: /** @addtogroup DBusGLib
sl@0:  * @{
sl@0:  */
sl@0: 
sl@0: /**
sl@0:  * dbus_connection_setup_with_g_main:
sl@0:  * @connection: the connection
sl@0:  * @context: the #GMainContext or #NULL for default context
sl@0:  *
sl@0:  * Sets the watch and timeout functions of a #DBusConnection
sl@0:  * to integrate the connection with the GLib main loop.
sl@0:  * Pass in #NULL for the #GMainContext unless you're
sl@0:  * doing something specialized.
sl@0:  *
sl@0:  * If called twice for the same context, does nothing the second
sl@0:  * time. If called once with context A and once with context B,
sl@0:  * context B replaces context A as the context monitoring the
sl@0:  * connection.
sl@0:  */
sl@0:  #ifdef __SYMBIAN32__
sl@0: EXPORT_C
sl@0: #endif
sl@0: void
sl@0: dbus_connection_setup_with_g_main (DBusConnection *connection,
sl@0: 				   GMainContext   *context)
sl@0: {
sl@0:   ConnectionSetup *old_setup;
sl@0:   ConnectionSetup *cs;
sl@0:   
sl@0:   /* FIXME we never free the slot, so its refcount just keeps growing,
sl@0:    * which is kind of broken.
sl@0:    */
sl@0:   dbus_connection_allocate_data_slot (&_dbus_gmain_connection_slot);
sl@0:   if (_dbus_gmain_connection_slot < 0)
sl@0:     goto nomem;
sl@0: 
sl@0:   if (context == NULL)
sl@0:     context = g_main_context_default ();
sl@0: 
sl@0:   cs = NULL;
sl@0:   
sl@0:   old_setup = dbus_connection_get_data (connection, _dbus_gmain_connection_slot);
sl@0:   if (old_setup != NULL)
sl@0:     {
sl@0:       if (old_setup->context == context)
sl@0:         return; /* nothing to do */
sl@0: 
sl@0:       cs = connection_setup_new_from_old (context, old_setup);
sl@0:       
sl@0:       /* Nuke the old setup */
sl@0:       dbus_connection_set_data (connection, _dbus_gmain_connection_slot, NULL, NULL);
sl@0:       old_setup = NULL;
sl@0:     }
sl@0: 
sl@0:   if (cs == NULL)
sl@0:     cs = connection_setup_new (context, connection);
sl@0: 
sl@0:   if (!dbus_connection_set_data (connection, _dbus_gmain_connection_slot, cs,
sl@0:                                  (DBusFreeFunction)connection_setup_free))
sl@0:     goto nomem;
sl@0:   
sl@0:   if (!dbus_connection_set_watch_functions (connection,
sl@0:                                             add_watch,
sl@0:                                             remove_watch,
sl@0:                                             watch_toggled,
sl@0:                                             cs, NULL))
sl@0:     goto nomem;
sl@0: 
sl@0:   if (!dbus_connection_set_timeout_functions (connection,
sl@0:                                               add_timeout,
sl@0:                                               remove_timeout,
sl@0:                                               timeout_toggled,
sl@0:                                               cs, NULL))
sl@0:     goto nomem;
sl@0:     
sl@0:   dbus_connection_set_wakeup_main_function (connection,
sl@0: 					    wakeup_main,
sl@0: 					    cs, NULL);
sl@0:       
sl@0:   return;
sl@0: 
sl@0:  nomem:
sl@0:   g_error ("Not enough memory to set up DBusConnection for use with GLib");
sl@0: }
sl@0: 
sl@0: /**
sl@0:  * dbus_server_setup_with_g_main:
sl@0:  * @server: the server
sl@0:  * @context: the #GMainContext or #NULL for default
sl@0:  *
sl@0:  * Sets the watch and timeout functions of a #DBusServer
sl@0:  * to integrate the server with the GLib main loop.
sl@0:  * In most cases the context argument should be #NULL.
sl@0:  *
sl@0:  * If called twice for the same context, does nothing the second
sl@0:  * time. If called once with context A and once with context B,
sl@0:  * context B replaces context A as the context monitoring the
sl@0:  * connection.
sl@0:  */
sl@0:  	#ifdef __SYMBIAN32__
sl@0: 	EXPORT_C
sl@0: 	#endif
sl@0: void
sl@0: dbus_server_setup_with_g_main (DBusServer   *server,
sl@0:                                GMainContext *context)
sl@0: {
sl@0:   ConnectionSetup *old_setup;
sl@0:   ConnectionSetup *cs;
sl@0:   
sl@0:   /* FIXME we never free the slot, so its refcount just keeps growing,
sl@0:    * which is kind of broken.
sl@0:    */
sl@0:   dbus_server_allocate_data_slot (&server_slot);
sl@0:   if (server_slot < 0)
sl@0:     goto nomem;
sl@0: 
sl@0:   if (context == NULL)
sl@0:     context = g_main_context_default ();
sl@0: 
sl@0:   cs = NULL;
sl@0:   
sl@0:   old_setup = dbus_server_get_data (server, server_slot);
sl@0:   if (old_setup != NULL)
sl@0:     {
sl@0:       if (old_setup->context == context)
sl@0:         return; /* nothing to do */
sl@0: 
sl@0:       cs = connection_setup_new_from_old (context, old_setup);
sl@0:       
sl@0:       /* Nuke the old setup */
sl@0:       dbus_server_set_data (server, server_slot, NULL, NULL);
sl@0:       old_setup = NULL;
sl@0:     }
sl@0: 
sl@0:   if (cs == NULL)
sl@0:     cs = connection_setup_new (context, NULL);
sl@0: 
sl@0:   if (!dbus_server_set_data (server, server_slot, cs,
sl@0:                              (DBusFreeFunction)connection_setup_free))
sl@0:     goto nomem;
sl@0:   
sl@0:   if (!dbus_server_set_watch_functions (server,
sl@0:                                         add_watch,
sl@0:                                         remove_watch,
sl@0:                                         watch_toggled,
sl@0:                                         cs, NULL))
sl@0:     goto nomem;
sl@0: 
sl@0:   if (!dbus_server_set_timeout_functions (server,
sl@0:                                           add_timeout,
sl@0:                                           remove_timeout,
sl@0:                                           timeout_toggled,
sl@0:                                           cs, NULL))
sl@0:     goto nomem;
sl@0:       
sl@0:   return;
sl@0: 
sl@0:  nomem:
sl@0:   g_error ("Not enough memory to set up DBusServer for use with GLib");
sl@0: }
sl@0: 
sl@0: /**
sl@0:  * dbus_g_connection_open:
sl@0:  * @address: address of the connection to open
sl@0:  * @error: address where an error can be returned.
sl@0:  *
sl@0:  * Returns a connection to the given address.
sl@0:  *
sl@0:  * (Internally, calls dbus_connection_open() then calls
sl@0:  * dbus_connection_setup_with_g_main() on the result.)
sl@0:  *
sl@0:  * Returns: a DBusConnection
sl@0:  */
sl@0:  	#ifdef __SYMBIAN32__
sl@0: 	EXPORT_C
sl@0: 	#endif
sl@0: DBusGConnection*
sl@0: dbus_g_connection_open (const gchar  *address,
sl@0:                         GError      **error)
sl@0: {
sl@0:   DBusConnection *connection;
sl@0:   DBusError derror;
sl@0: 
sl@0:   g_return_val_if_fail (error == NULL || *error == NULL, NULL);
sl@0: 
sl@0:   _dbus_g_value_types_init ();
sl@0: 
sl@0:   dbus_error_init (&derror);
sl@0: 
sl@0:   connection = dbus_connection_open (address, &derror);
sl@0:   if (connection == NULL)
sl@0:     {
sl@0:       dbus_set_g_error (error, &derror);
sl@0:       dbus_error_free (&derror);
sl@0:       return NULL;
sl@0:     }
sl@0: 
sl@0:   /* does nothing if it's already been done */
sl@0:   dbus_connection_setup_with_g_main (connection, NULL);
sl@0: 
sl@0:   return DBUS_G_CONNECTION_FROM_CONNECTION (connection);
sl@0: }
sl@0: 
sl@0: /**
sl@0:  * dbus_g_bus_get:
sl@0:  * @type: bus type
sl@0:  * @error: address where an error can be returned.
sl@0:  *
sl@0:  * Returns a connection to the given bus. The connection is a global variable
sl@0:  * shared with other callers of this function.
sl@0:  * 
sl@0:  * (Internally, calls dbus_bus_get() then calls
sl@0:  * dbus_connection_setup_with_g_main() on the result.)
sl@0:  *
sl@0:  * Returns: a DBusConnection
sl@0:  */
sl@0:  #ifdef __SYMBIAN32__
sl@0: EXPORT_C
sl@0: #endif
sl@0: DBusGConnection*
sl@0: dbus_g_bus_get (DBusBusType     type,
sl@0:                 GError        **error)
sl@0: {
sl@0:   DBusConnection *connection;
sl@0:   DBusError derror;
sl@0: 
sl@0:   g_return_val_if_fail (error == NULL || *error == NULL, NULL);
sl@0: 
sl@0:   _dbus_g_value_types_init ();
sl@0:   
sl@0:   dbus_error_init (&derror);
sl@0: 
sl@0:   connection = dbus_bus_get (type, &derror);
sl@0:   if (connection == NULL)
sl@0:     {
sl@0:       dbus_set_g_error (error, &derror);
sl@0:       dbus_error_free (&derror);
sl@0:       return NULL;
sl@0:     }
sl@0: 
sl@0:   /* does nothing if it's already been done */
sl@0:   dbus_connection_setup_with_g_main (connection, NULL);
sl@0: 
sl@0:   return DBUS_G_CONNECTION_FROM_CONNECTION (connection);
sl@0: }
sl@0: 
sl@0: /** @} */ /* end of public API */
sl@0: 
sl@0: #ifdef DBUS_BUILD_TESTS
sl@0: 
sl@0: /**
sl@0:  * @ingroup DBusGLibInternals
sl@0:  * Unit test for GLib main loop integration
sl@0:  * Returns: #TRUE on success.
sl@0:  */
sl@0:   	#ifdef __SYMBIAN32__
sl@0: 	EXPORT_C
sl@0: 	#endif
sl@0: gboolean
sl@0: _dbus_gmain_test (const char *test_data_dir)
sl@0: {
sl@0:   GType type;
sl@0:   GType rectype;
sl@0: 
sl@0:   g_type_init ();
sl@0:   _dbus_g_value_types_init ();
sl@0: 
sl@0:   rectype = dbus_g_type_get_collection ("GArray", G_TYPE_UINT);
sl@0:   g_assert (rectype != G_TYPE_INVALID);
sl@0:   g_assert (!strcmp (g_type_name (rectype), "GArray_guint_"));
sl@0: 
sl@0:   type = _dbus_gtype_from_signature ("au", TRUE);
sl@0:   g_assert (type == rectype);
sl@0: 
sl@0:   rectype = dbus_g_type_get_map ("GHashTable", G_TYPE_STRING, G_TYPE_STRING);
sl@0:   g_assert (rectype != G_TYPE_INVALID);
sl@0:   g_assert (!strcmp (g_type_name (rectype), "GHashTable_gchararray+gchararray_"));
sl@0: 
sl@0:   type = _dbus_gtype_from_signature ("a{ss}", TRUE);
sl@0:   g_assert (type == rectype);
sl@0: 
sl@0:   type = _dbus_gtype_from_signature ("o", FALSE);
sl@0:   g_assert (type == DBUS_TYPE_G_OBJECT_PATH);
sl@0:   type = _dbus_gtype_from_signature ("o", TRUE);
sl@0:   g_assert (type == DBUS_TYPE_G_OBJECT_PATH);
sl@0:   
sl@0:   return TRUE;
sl@0: }
sl@0: 
sl@0: #endif /* DBUS_BUILD_TESTS */