From 8e32b8e87f855a8d0a1bf8903ff2d0a6ae5fc984 Mon Sep 17 00:00:00 2001 From: Philip Withnall Date: Mon, 28 Oct 2019 20:42:19 +0000 Subject: [PATCH 1/2] gdbusserver: Delete socket and nonce file when stopping server Rather than when finalising it. They should be automatically recreated if the server is re-started. This is important for ensuring that all externally visible behaviour of the `GDBusServer` is synchronised with calls to g_dbus_server_{start,stop}(). Finalisation of the server object could happen an arbitrarily long time after g_dbus_server_stop() is called. Signed-off-by: Philip Withnall Helps: #1318 --- gio/gdbusserver.c | 29 ++++++++++++++++------------- 1 file changed, 16 insertions(+), 13 deletions(-) diff --git a/gio/gdbusserver.c b/gio/gdbusserver.c index 26f8dadd0..377ad4456 100644 --- a/gio/gdbusserver.c +++ b/gio/gdbusserver.c @@ -179,6 +179,8 @@ g_dbus_server_finalize (GObject *object) { GDBusServer *server = G_DBUS_SERVER (object); + g_assert (!server->active); + if (server->authentication_observer != NULL) g_object_unref (server->authentication_observer); @@ -197,19 +199,8 @@ g_dbus_server_finalize (GObject *object) g_free (server->nonce); } - if (server->unix_socket_path) - { - if (g_unlink (server->unix_socket_path) != 0) - g_warning ("Failed to delete %s: %s", server->unix_socket_path, g_strerror (errno)); - g_free (server->unix_socket_path); - } - - if (server->nonce_file) - { - if (g_unlink (server->nonce_file) != 0) - g_warning ("Failed to delete %s: %s", server->nonce_file, g_strerror (errno)); - g_free (server->nonce_file); - } + g_free (server->unix_socket_path); + g_free (server->nonce_file); g_main_context_unref (server->main_context_at_construction); @@ -648,6 +639,18 @@ g_dbus_server_stop (GDBusServer *server) g_socket_service_stop (G_SOCKET_SERVICE (server->listener)); server->active = FALSE; g_object_notify (G_OBJECT (server), "active"); + + if (server->unix_socket_path) + { + if (g_unlink (server->unix_socket_path) != 0) + g_warning ("Failed to delete %s: %s", server->unix_socket_path, g_strerror (errno)); + } + + if (server->nonce_file) + { + if (g_unlink (server->nonce_file) != 0) + g_warning ("Failed to delete %s: %s", server->nonce_file, g_strerror (errno)); + } } /* ---------------------------------------------------------------------------------------------------- */ From 0c07e672a28f8ee740ac61921c5e86c071909475 Mon Sep 17 00:00:00 2001 From: Philip Withnall Date: Mon, 28 Oct 2019 20:44:07 +0000 Subject: [PATCH 2/2] gdbusserver: Keep a strong reference to the server in callbacks MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit The `on_run()` function could be executed in any worker thread from the `GThreadedSocketListener`, but didn’t previously hold a strong reference to the `GDBusServer`, which meant the server could be finalised in another thread while `on_run()` was still running. This was not ideal. Hold a strong reference to the `GDBusServer` while the socket listener is listening, i.e. between every paired call to `g_dbus_server_start()` and `g_dbus_server_stop()`. Signed-off-by: Philip Withnall Fixes: #1318 --- gio/gdbusserver.c | 16 +++++++--------- 1 file changed, 7 insertions(+), 9 deletions(-) diff --git a/gio/gdbusserver.c b/gio/gdbusserver.c index 377ad4456..4a8dab0ea 100644 --- a/gio/gdbusserver.c +++ b/gio/gdbusserver.c @@ -613,6 +613,12 @@ g_dbus_server_start (GDBusServer *server) return; /* Right now we don't have any transport not using the listener... */ g_assert (server->is_using_listener); + server->run_signal_handler_id = g_signal_connect_data (G_SOCKET_SERVICE (server->listener), + "run", + G_CALLBACK (on_run), + g_object_ref (server), + (GClosureNotify) g_object_unref, + 0 /* flags */); g_socket_service_start (G_SOCKET_SERVICE (server->listener)); server->active = TRUE; g_object_notify (G_OBJECT (server), "active"); @@ -1162,15 +1168,7 @@ initable_init (GInitable *initable, if (ret) { - if (last_error != NULL) - g_error_free (last_error); - - /* Right now we don't have any transport not using the listener... */ - g_assert (server->is_using_listener); - server->run_signal_handler_id = g_signal_connect (G_SOCKET_SERVICE (server->listener), - "run", - G_CALLBACK (on_run), - server); + g_clear_error (&last_error); } else {