X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=gio%2Fgdbusnamewatching.c;h=adf53c3815c4dd764bc11349c0b1e4e22a6f0694;hb=7fd6f07d498063470903a886b4805a13bd333908;hp=cb087a8499a492fad7d0c355e375a8842fe0aff6;hpb=73007021796f33d7ccec4e5f2bb2b2f8660347f2;p=platform%2Fupstream%2Fglib.git diff --git a/gio/gdbusnamewatching.c b/gio/gdbusnamewatching.c index cb087a8..adf53c3 100644 --- a/gio/gdbusnamewatching.c +++ b/gio/gdbusnamewatching.c @@ -13,9 +13,7 @@ * Lesser General Public License for more details. * * You should have received a copy of the GNU Lesser General - * Public License along with this library; if not, write to the - * Free Software Foundation, Inc., 59 Temple Place, Suite 330, - * Boston, MA 02111-1307, USA. + * Public License along with this library; if not, see . * * Author: David Zeuthen */ @@ -32,7 +30,6 @@ #include "gdbusconnection.h" #include "glibintl.h" -#include "gioalias.h" /** * SECTION:gdbusnamewatching @@ -42,7 +39,8 @@ * * Convenience API for watching bus names. * - * Simple application watching a nameFIXME: MISSING XINCLUDE CONTENT + * A simple example for watching a name can be found in + * [gdbus-example-watch-name.c](https://git.gnome.org/browse/glib/tree/gio/tests/gdbus-example-watch-name.c) */ G_LOCK_DEFINE_STATIC (lock); @@ -104,8 +102,7 @@ client_unref (Client *client) } g_free (client->name); g_free (client->name_owner); - if (client->main_context != NULL) - g_main_context_unref (client->main_context); + g_main_context_unref (client->main_context); if (client->user_data_free_func != NULL) client->user_data_free_func (client->user_data); g_free (client); @@ -201,6 +198,7 @@ schedule_call_in_idle (Client *client, CallType call_type) call_in_idle_cb, data, (GDestroyNotify) call_handler_data_free); + g_source_set_name (idle_source, "[gio] call_in_idle_cb"); g_source_attach (idle_source, client->main_context); g_source_unref (idle_source); } @@ -208,11 +206,15 @@ schedule_call_in_idle (Client *client, CallType call_type) static void do_call (Client *client, CallType call_type) { + GMainContext *current_context; + /* only schedule in idle if we're not in the right thread */ - if (g_main_context_get_thread_default () != client->main_context) + current_context = g_main_context_ref_thread_default (); + if (current_context != client->main_context) schedule_call_in_idle (client, call_type); else actually_do_call (client, client->connection, client->name_owner, call_type); + g_main_context_unref (current_context); } static void @@ -448,6 +450,7 @@ has_connection (Client *client) "NameOwnerChanged", /* signal */ "/org/freedesktop/DBus", /* path */ client->name, + G_DBUS_SIGNAL_FLAGS_NONE, on_name_owner_changed, client, NULL); @@ -502,17 +505,17 @@ connection_get_cb (GObject *source_object, * @bus_type: The type of bus to watch a name on. * @name: The name (well-known or unique) to watch. * @flags: Flags from the #GBusNameWatcherFlags enumeration. - * @name_appeared_handler: Handler to invoke when @name is known to exist or %NULL. - * @name_vanished_handler: Handler to invoke when @name is known to not exist or %NULL. + * @name_appeared_handler: (allow-none): Handler to invoke when @name is known to exist or %NULL. + * @name_vanished_handler: (allow-none): Handler to invoke when @name is known to not exist or %NULL. * @user_data: User data to pass to handlers. - * @user_data_free_func: Function for freeing @user_data or %NULL. + * @user_data_free_func: (allow-none): Function for freeing @user_data or %NULL. * * Starts watching @name on the bus specified by @bus_type and calls * @name_appeared_handler and @name_vanished_handler when the name is * known to have a owner respectively known to lose its - * owner. Callbacks will be invoked in the thread-default main - * loop of the thread you are calling this function from. + * owner. Callbacks will be invoked in the + * [thread-default main context][g-main-context-push-thread-default] + * of the thread you are calling this function from. * * You are guaranteed that one of the handlers will be invoked after * calling this function. When you are done watching the name, just @@ -531,11 +534,11 @@ connection_get_cb (GObject *source_object, * guaranteed that the next time one of the handlers is invoked, it * will be @name_vanished_handler. The reverse is also true. * - * This behavior makes it very simple to write applications that wants - * to take action when a certain name exists, see . Basically, the application - * should create object proxies in @name_appeared_handler and destroy - * them again (if any) in @name_vanished_handler. + * This behavior makes it very simple to write applications that want + * to take action when a certain [name exists][gdbus-watching-names]. + * Basically, the application should create object proxies in + * @name_appeared_handler and destroy them again (if any) in + * @name_vanished_handler. * * Returns: An identifier (never 0) that an be used with * g_bus_unwatch_name() to stop watching the name. @@ -566,9 +569,7 @@ g_bus_watch_name (GBusType bus_type, client->name_vanished_handler = name_vanished_handler; client->user_data = user_data; client->user_data_free_func = user_data_free_func; - client->main_context = g_main_context_get_thread_default (); - if (client->main_context != NULL) - g_main_context_ref (client->main_context); + client->main_context = g_main_context_ref_thread_default (); if (map_id_to_client == NULL) { @@ -590,13 +591,13 @@ g_bus_watch_name (GBusType bus_type, /** * g_bus_watch_name_on_connection: - * @connection: A #GDBusConnection that is not closed. + * @connection: A #GDBusConnection. * @name: The name (well-known or unique) to watch. * @flags: Flags from the #GBusNameWatcherFlags enumeration. - * @name_appeared_handler: Handler to invoke when @name is known to exist or %NULL. - * @name_vanished_handler: Handler to invoke when @name is known to not exist or %NULL. + * @name_appeared_handler: (allow-none): Handler to invoke when @name is known to exist or %NULL. + * @name_vanished_handler: (allow-none): Handler to invoke when @name is known to not exist or %NULL. * @user_data: User data to pass to handlers. - * @user_data_free_func: Function for freeing @user_data or %NULL. + * @user_data_free_func: (allow-none): Function for freeing @user_data or %NULL. * * Like g_bus_watch_name() but takes a #GDBusConnection instead of a * #GBusType. @@ -630,14 +631,11 @@ guint g_bus_watch_name_on_connection (GDBusConnection *connection, client->name_vanished_handler = name_vanished_handler; client->user_data = user_data; client->user_data_free_func = user_data_free_func; - client->main_context = g_main_context_get_thread_default (); - if (client->main_context != NULL) - g_main_context_ref (client->main_context); + client->main_context = g_main_context_ref_thread_default (); if (map_id_to_client == NULL) - { - map_id_to_client = g_hash_table_new (g_direct_hash, g_direct_equal); - } + map_id_to_client = g_hash_table_new (g_direct_hash, g_direct_equal); + g_hash_table_insert (map_id_to_client, GUINT_TO_POINTER (client->id), client); @@ -655,6 +653,33 @@ typedef struct { GClosure *name_vanished_closure; } WatchNameData; +static WatchNameData * +watch_name_data_new (GClosure *name_appeared_closure, + GClosure *name_vanished_closure) +{ + WatchNameData *data; + + data = g_new0 (WatchNameData, 1); + + if (name_appeared_closure != NULL) + { + data->name_appeared_closure = g_closure_ref (name_appeared_closure); + g_closure_sink (name_appeared_closure); + if (G_CLOSURE_NEEDS_MARSHAL (name_appeared_closure)) + g_closure_set_marshal (name_appeared_closure, g_cclosure_marshal_generic); + } + + if (name_vanished_closure != NULL) + { + data->name_vanished_closure = g_closure_ref (name_vanished_closure); + g_closure_sink (name_vanished_closure); + if (G_CLOSURE_NEEDS_MARSHAL (name_vanished_closure)) + g_closure_set_marshal (name_vanished_closure, g_cclosure_marshal_generic); + } + + return data; +} + static void watch_with_closures_on_name_appeared (GDBusConnection *connection, const gchar *name, @@ -662,7 +687,7 @@ watch_with_closures_on_name_appeared (GDBusConnection *connection, gpointer user_data) { WatchNameData *data = user_data; - GValue params[3] = { { 0, }, { 0, }, { 0, } }; + GValue params[3] = { G_VALUE_INIT, G_VALUE_INIT, G_VALUE_INIT }; g_value_init (¶ms[0], G_TYPE_DBUS_CONNECTION); g_value_set_object (¶ms[0], connection); @@ -674,6 +699,10 @@ watch_with_closures_on_name_appeared (GDBusConnection *connection, g_value_set_string (¶ms[2], name_owner); g_closure_invoke (data->name_appeared_closure, NULL, 3, params, NULL); + + g_value_unset (params + 0); + g_value_unset (params + 1); + g_value_unset (params + 2); } static void @@ -682,7 +711,7 @@ watch_with_closures_on_name_vanished (GDBusConnection *connection, gpointer user_data) { WatchNameData *data = user_data; - GValue params[2] = { { 0, }, { 0, } }; + GValue params[2] = { G_VALUE_INIT, G_VALUE_INIT }; g_value_init (¶ms[0], G_TYPE_DBUS_CONNECTION); g_value_set_object (¶ms[0], connection); @@ -691,6 +720,9 @@ watch_with_closures_on_name_vanished (GDBusConnection *connection, g_value_set_string (¶ms[1], name); g_closure_invoke (data->name_vanished_closure, NULL, 2, params, NULL); + + g_value_unset (params + 0); + g_value_unset (params + 1); } static void @@ -734,28 +766,18 @@ g_bus_watch_name_with_closures (GBusType bus_type, GClosure *name_appeared_closure, GClosure *name_vanished_closure) { - WatchNameData *data; - - data = g_new0 (WatchNameData, 1); - - if (name_appeared_closure != NULL) - data->name_appeared_closure = g_closure_ref (name_appeared_closure); - - if (name_vanished_closure != NULL) - data->name_vanished_closure = g_closure_ref (name_vanished_closure); - return g_bus_watch_name (bus_type, name, flags, name_appeared_closure != NULL ? watch_with_closures_on_name_appeared : NULL, name_vanished_closure != NULL ? watch_with_closures_on_name_vanished : NULL, - data, + watch_name_data_new (name_appeared_closure, name_vanished_closure), bus_watch_name_free_func); } /** * g_bus_watch_name_on_connection_with_closures: - * @connection: A #GDBusConnection that is not closed. + * @connection: A #GDBusConnection. * @name: The name (well-known or unique) to watch. * @flags: Flags from the #GBusNameWatcherFlags enumeration. * @name_appeared_closure: (allow-none): #GClosure to invoke when @name is known @@ -780,22 +802,12 @@ guint g_bus_watch_name_on_connection_with_closures ( GClosure *name_appeared_closure, GClosure *name_vanished_closure) { - WatchNameData *data; - - data = g_new0 (WatchNameData, 1); - - if (name_appeared_closure != NULL) - data->name_appeared_closure = g_closure_ref (name_appeared_closure); - - if (name_vanished_closure != NULL) - data->name_vanished_closure = g_closure_ref (name_vanished_closure); - return g_bus_watch_name_on_connection (connection, name, flags, name_appeared_closure != NULL ? watch_with_closures_on_name_appeared : NULL, name_vanished_closure != NULL ? watch_with_closures_on_name_vanished : NULL, - data, + watch_name_data_new (name_appeared_closure, name_vanished_closure), bus_watch_name_free_func); } @@ -837,6 +849,3 @@ g_bus_unwatch_name (guint watcher_id) client_unref (client); } } - -#define __G_DBUS_NAME_WATCHING_C__ -#include "gioaliasdef.c"