Lines Matching full:client
79 } Client; typedef
85 static Client *
86 client_ref (Client *client) in client_ref() argument
88 g_atomic_int_inc (&client->ref_count); in client_ref()
89 return client; in client_ref()
93 client_unref (Client *client) in client_unref() argument
95 if (g_atomic_int_dec_and_test (&client->ref_count)) in client_unref()
97 if (client->connection != NULL) in client_unref()
99 if (client->disconnected_signal_handler_id > 0) in client_unref()
100 … g_signal_handler_disconnect (client->connection, client->disconnected_signal_handler_id); in client_unref()
101 if (client->name_acquired_subscription_id > 0) in client_unref()
102 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_acquired_subscription_id); in client_unref()
103 if (client->name_lost_subscription_id > 0) in client_unref()
104 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_lost_subscription_id); in client_unref()
105 g_object_unref (client->connection); in client_unref()
107 g_main_context_unref (client->main_context); in client_unref()
108 g_free (client->name); in client_unref()
109 if (client->user_data_free_func != NULL) in client_unref()
110 client->user_data_free_func (client->user_data); in client_unref()
111 g_free (client); in client_unref()
126 Client *client; member
128 /* keep this separate because client->connection may
142 client_unref (data->client); in call_handler_data_free()
147 actually_do_call (Client *client, GDBusConnection *connection, CallType call_type) in actually_do_call() argument
152 if (client->name_acquired_handler != NULL) in actually_do_call()
154 client->name_acquired_handler (connection, in actually_do_call()
155 client->name, in actually_do_call()
156 client->user_data); in actually_do_call()
161 if (client->name_lost_handler != NULL) in actually_do_call()
163 client->name_lost_handler (connection, in actually_do_call()
164 client->name, in actually_do_call()
165 client->user_data); in actually_do_call()
179 actually_do_call (data->client, data->connection, data->call_type); in call_in_idle_cb()
184 schedule_call_in_idle (Client *client, CallType call_type) in schedule_call_in_idle() argument
190 data->client = client_ref (client); in schedule_call_in_idle()
191 data->connection = client->connection != NULL ? g_object_ref (client->connection) : NULL; in schedule_call_in_idle()
201 g_source_attach (idle_source, client->main_context); in schedule_call_in_idle()
206 do_call (Client *client, CallType call_type) in do_call() argument
212 if (current_context != client->main_context) in do_call()
213 schedule_call_in_idle (client, call_type); in do_call()
215 actually_do_call (client, client->connection, call_type); in do_call()
220 call_acquired_handler (Client *client) in call_acquired_handler() argument
223 if (client->previous_call != PREVIOUS_CALL_ACQUIRED) in call_acquired_handler()
225 client->previous_call = PREVIOUS_CALL_ACQUIRED; in call_acquired_handler()
226 if (!client->cancelled) in call_acquired_handler()
229 do_call (client, CALL_TYPE_NAME_ACQUIRED); in call_acquired_handler()
239 call_lost_handler (Client *client) in call_lost_handler() argument
242 if (client->previous_call != PREVIOUS_CALL_LOST) in call_lost_handler()
244 client->previous_call = PREVIOUS_CALL_LOST; in call_lost_handler()
245 if (!client->cancelled) in call_lost_handler()
248 do_call (client, CALL_TYPE_NAME_LOST); in call_lost_handler()
268 Client *client = user_data; in on_name_lost_or_acquired() local
286 if (g_strcmp0 (name, client->name) == 0) in on_name_lost_or_acquired()
288 call_lost_handler (client); in on_name_lost_or_acquired()
294 if (g_strcmp0 (name, client->name) == 0) in on_name_lost_or_acquired()
296 call_acquired_handler (client); in on_name_lost_or_acquired()
310 Client *client = user_data; in request_name_cb() local
318 /* don't use client->connection - it may be NULL already */ in request_name_cb()
334 call_acquired_handler (client); in request_name_cb()
339 call_lost_handler (client); in request_name_cb()
347 call_lost_handler (client); in request_name_cb()
349 client->needs_release = FALSE; in request_name_cb()
363 if (!client->cancelled) in request_name_cb()
364 connection = g_object_ref (client->connection); in request_name_cb()
369 if (client->name_acquired_subscription_id > 0) in request_name_cb()
370 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_acquired_subscription_id); in request_name_cb()
371 if (client->name_lost_subscription_id > 0) in request_name_cb()
372 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_lost_subscription_id); in request_name_cb()
373 client->name_acquired_subscription_id = 0; in request_name_cb()
374 client->name_lost_subscription_id = 0; in request_name_cb()
380 client_unref (client); in request_name_cb()
391 Client *client = user_data; in on_connection_disconnected() local
393 if (client->disconnected_signal_handler_id > 0) in on_connection_disconnected()
394 g_signal_handler_disconnect (client->connection, client->disconnected_signal_handler_id); in on_connection_disconnected()
395 if (client->name_acquired_subscription_id > 0) in on_connection_disconnected()
396 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_acquired_subscription_id); in on_connection_disconnected()
397 if (client->name_lost_subscription_id > 0) in on_connection_disconnected()
398 g_dbus_connection_signal_unsubscribe (client->connection, client->name_lost_subscription_id); in on_connection_disconnected()
399 g_object_unref (client->connection); in on_connection_disconnected()
400 client->disconnected_signal_handler_id = 0; in on_connection_disconnected()
401 client->name_acquired_subscription_id = 0; in on_connection_disconnected()
402 client->name_lost_subscription_id = 0; in on_connection_disconnected()
403 client->connection = NULL; in on_connection_disconnected()
405 call_lost_handler (client); in on_connection_disconnected()
411 has_connection (Client *client) in has_connection() argument
414 client->disconnected_signal_handler_id = g_signal_connect (client->connection, in has_connection()
417 client); in has_connection()
420 * references to the Client in the signal closures, since it’s possible in has_connection()
430 client->name_lost_subscription_id = in has_connection()
431 g_dbus_connection_signal_subscribe (client->connection, in has_connection()
436 client->name, in has_connection()
439 client_ref (client), in has_connection()
441 client->name_acquired_subscription_id = in has_connection()
442 g_dbus_connection_signal_subscribe (client->connection, in has_connection()
447 client->name, in has_connection()
450 client_ref (client), in has_connection()
454 client->needs_release = TRUE; in has_connection()
455 g_dbus_connection_call (client->connection, in has_connection()
461 client->name, in has_connection()
462 client->flags), in has_connection()
468 client_ref (client)); in has_connection()
477 Client *client = user_data; in connection_get_cb() local
481 if (client->cancelled) in connection_get_cb()
488 client->connection = g_bus_get_finish (res, NULL); in connection_get_cb()
489 if (client->connection == NULL) in connection_get_cb()
491 call_lost_handler (client); in connection_get_cb()
502 if (client->bus_acquired_handler != NULL) in connection_get_cb()
504 client->bus_acquired_handler (client->connection, in connection_get_cb()
505 client->name, in connection_get_cb()
506 client->user_data); in connection_get_cb()
509 has_connection (client); in connection_get_cb()
512 client_unref (client); in connection_get_cb()
544 Client *client; in g_bus_own_name_on_connection() local
551 client = g_new0 (Client, 1); in g_bus_own_name_on_connection()
552 client->ref_count = 1; in g_bus_own_name_on_connection()
553 client->id = next_global_id++; /* TODO: uh oh, handle overflow */ in g_bus_own_name_on_connection()
554 client->name = g_strdup (name); in g_bus_own_name_on_connection()
555 client->flags = flags; in g_bus_own_name_on_connection()
556 client->name_acquired_handler = name_acquired_handler; in g_bus_own_name_on_connection()
557 client->name_lost_handler = name_lost_handler; in g_bus_own_name_on_connection()
558 client->user_data = user_data; in g_bus_own_name_on_connection()
559 client->user_data_free_func = user_data_free_func; in g_bus_own_name_on_connection()
560 client->main_context = g_main_context_ref_thread_default (); in g_bus_own_name_on_connection()
562 client->connection = g_object_ref (connection); in g_bus_own_name_on_connection()
569 GUINT_TO_POINTER (client->id), in g_bus_own_name_on_connection()
570 client); in g_bus_own_name_on_connection()
574 has_connection (client); in g_bus_own_name_on_connection()
576 return client->id; in g_bus_own_name_on_connection()
655 Client *client; in g_bus_own_name() local
661 client = g_new0 (Client, 1); in g_bus_own_name()
662 client->ref_count = 1; in g_bus_own_name()
663 client->id = next_global_id++; /* TODO: uh oh, handle overflow */ in g_bus_own_name()
664 client->name = g_strdup (name); in g_bus_own_name()
665 client->flags = flags; in g_bus_own_name()
666 client->bus_acquired_handler = bus_acquired_handler; in g_bus_own_name()
667 client->name_acquired_handler = name_acquired_handler; in g_bus_own_name()
668 client->name_lost_handler = name_lost_handler; in g_bus_own_name()
669 client->user_data = user_data; in g_bus_own_name()
670 client->user_data_free_func = user_data_free_func; in g_bus_own_name()
671 client->main_context = g_main_context_ref_thread_default (); in g_bus_own_name()
678 GUINT_TO_POINTER (client->id), in g_bus_own_name()
679 client); in g_bus_own_name()
684 client_ref (client)); in g_bus_own_name()
688 return client->id; in g_bus_own_name()
904 Client *client; in g_bus_unown_name() local
908 client = NULL; in g_bus_unown_name()
912 (client = g_hash_table_lookup (map_id_to_client, GUINT_TO_POINTER (owner_id))) == NULL) in g_bus_unown_name()
918 client->cancelled = TRUE; in g_bus_unown_name()
925 if (client != NULL) in g_bus_unown_name()
928 if (client->needs_release && in g_bus_unown_name()
929 client->connection != NULL && in g_bus_unown_name()
930 !g_dbus_connection_is_closed (client->connection)) in g_bus_unown_name()
943 result = g_dbus_connection_call_sync (client->connection, in g_bus_unown_name()
948 g_variant_new ("(s)", client->name), in g_bus_unown_name()
956 g_warning ("Error releasing name %s: %s", client->name, error->message); in g_bus_unown_name()
964 … g_warning ("Unexpected reply %d when releasing name %s", release_name_reply, client->name); in g_bus_unown_name()
968 client->needs_release = FALSE; in g_bus_unown_name()
974 if (client->disconnected_signal_handler_id > 0) in g_bus_unown_name()
975 g_signal_handler_disconnect (client->connection, client->disconnected_signal_handler_id); in g_bus_unown_name()
976 if (client->name_acquired_subscription_id > 0) in g_bus_unown_name()
977 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_acquired_subscription_id); in g_bus_unown_name()
978 if (client->name_lost_subscription_id > 0) in g_bus_unown_name()
979 … g_dbus_connection_signal_unsubscribe (client->connection, client->name_lost_subscription_id); in g_bus_unown_name()
980 client->disconnected_signal_handler_id = 0; in g_bus_unown_name()
981 client->name_acquired_subscription_id = 0; in g_bus_unown_name()
982 client->name_lost_subscription_id = 0; in g_bus_unown_name()
983 if (client->connection != NULL) in g_bus_unown_name()
985 g_object_unref (client->connection); in g_bus_unown_name()
986 client->connection = NULL; in g_bus_unown_name()
989 client_unref (client); in g_bus_unown_name()