luc14n0/glib
1
0
Fork 0
mirror of https://gitlab.gnome.org/GNOME/glib.git synced 2025-02-04 02:06:18 +01:00
Code Issues Packages Projects Releases Wiki Activity

tests: Wait until unsubscribing from a signal has completed

Browse Source 
As with the previous commit, don’t stop iterating the `context` in
`test_delivery_in_thread_func()` until the unsubscription from a signal
is complete, and hence there’s a guarantee that no callbacks are pending
in the `thread_context`.

This commit uses the `GDestroyNotify` for
`g_dbus_connection_signal_subscribe()` as a synchronisation message from
the D-Bus worker thread to the `test_delivery_in_thread_func()` thread
to notify of signal unsubscription.

Signed-off-by: Philip Withnall <withnall@endlessm.com>

Fixes: #1515
This commit is contained in:
Philip Withnall 2020-02-21 12:08:57 +00:00
parent af6dbece87
commit 79ef610f03
1 changed files with 19 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
gio/tests/gdbus-threading.c
View File

@ -82,6 +82,7 @@ typedef struct {
GThread *thread;
GMainLoop *thread_loop;
guint signal_count;
gboolean unsubscribe_complete;
} DeliveryData;
static void
@ -147,6 +148,18 @@ signal_handler (GDBusConnection *connection,
g_main_loop_quit (data->thread_loop);
}
static void
signal_data_free_cb (gpointer user_data)
{
DeliveryData *data = user_data;
g_assert_true (g_thread_self () == data->thread);
data->unsubscribe_complete = TRUE;
g_main_loop_quit (data->thread_loop);
}
static gpointer
test_delivery_in_thread_func (gpointer _data)
{
@ -167,6 +180,7 @@ test_delivery_in_thread_func (gpointer _data)
data.thread = g_thread_self ();
data.thread_loop = thread_loop;
data.signal_count = 0;
data.unsubscribe_complete = FALSE;
/* ---------------------------------------------------------------------------------------------------- */
@ -242,7 +256,7 @@ test_delivery_in_thread_func (gpointer _data)
G_DBUS_SIGNAL_FLAGS_NONE,
signal_handler,
&data,
NULL);
signal_data_free_cb);
g_assert_cmpuint (subscription_id, !=, 0);
g_assert_cmpuint (data.signal_count, ==, 0);
@ -256,6 +270,10 @@ test_delivery_in_thread_func (gpointer _data)
g_object_unref (priv_c);
g_dbus_connection_signal_unsubscribe (c, subscription_id);
subscription_id = 0;
g_main_loop_run (thread_loop);
g_assert_true (data.unsubscribe_complete);
/* ---------------------------------------------------------------------------------------------------- */