[gnome-online-accounts/wip/rishi/simplify-cleanup: 3/3] httpclient: Ensure that the GTask is always cleaned up
- From: Debarshi Ray <debarshir src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gnome-online-accounts/wip/rishi/simplify-cleanup: 3/3] httpclient: Ensure that the GTask is always cleaned up
- Date: Mon, 26 Nov 2018 15:47:24 +0000 (UTC)
commit f6d13eae9c04d343a3f2c527fc547266479f0408
Author: Debarshi Ray <debarshir gnome org>
Date: Mon Nov 26 16:38:19 2018 +0100
httpclient: Ensure that the GTask is always cleaned up
The synchronous variant of goa_http_client_check runs a thread-specific
GMainContext until the asynchronous variant invokes its callback. Once
the callback is invoked, the GMainLoop is quit. This means that there
won't be any further iterations of the loop and no new GSources will
be dispatched.
Therefore, when the synchronous HttpClient was aborted by the
GCancellable or due to an SSL error, then the following
http_client_check_response_cb might not have been invoked due to the
lack of a running GMainLoop to drive the GMainContext; as a result,
leaking the GTask.
Solve this by tracking the GError and returning the GTask only when
everything is complete.
This was fixed in commit 3b35bd716dfe91ee0c1ac4b375de9dcf6e897bae, but
broke in commit 73242fa2fe5d4b18342d33b95fa449086728aa5c when porting
to GTask.
https://bugzilla.gnome.org/show_bug.cgi?id=764157
src/goabackend/goahttpclient.c | 47 ++++++++++++++++++++++++++----------------
1 file changed, 29 insertions(+), 18 deletions(-)
---
diff --git a/src/goabackend/goahttpclient.c b/src/goabackend/goahttpclient.c
index c1cbc044..a3f6310b 100644
--- a/src/goabackend/goahttpclient.c
+++ b/src/goabackend/goahttpclient.c
@@ -56,6 +56,7 @@ goa_http_client_new (void)
typedef struct
{
GCancellable *cancellable;
+ GError *error;
SoupMessage *msg;
SoupSession *session;
gboolean accept_ssl_errors;
@@ -79,6 +80,8 @@ http_client_check_data_free (gpointer user_data)
g_object_unref (data->cancellable);
}
+ g_clear_error (&data->error);
+
/* soup_session_queue_message stole the references to data->msg */
g_object_unref (data->session);
g_slice_free (CheckData, data);
@@ -114,18 +117,16 @@ http_client_request_started (SoupSession *session, SoupMessage *msg, SoupSocket
{
CheckData *data;
GTask *task = G_TASK (user_data);
- GError *error;
GTlsCertificateFlags cert_flags;
data = (CheckData *) g_task_get_task_data (task);
- error = NULL;
if (!data->accept_ssl_errors
&& soup_message_get_https_status (msg, NULL, &cert_flags)
- && cert_flags != 0)
+ && cert_flags != 0
+ && data->error == NULL)
{
- goa_utils_set_error_ssl (&error, cert_flags);
- g_task_return_error (task, error);
+ goa_utils_set_error_ssl (&data->error, cert_flags);
soup_session_abort (data->session);
}
}
@@ -135,41 +136,51 @@ http_client_check_cancelled_cb (GCancellable *cancellable, gpointer user_data)
{
CheckData *data;
GTask *task = G_TASK (user_data);
- gboolean cancelled;
data = g_task_get_task_data (task);
- cancelled = g_task_return_error_if_cancelled (task);
- soup_session_abort (data->session);
+ if (data->error == NULL)
+ {
+ gboolean cancelled;
+
+ cancelled = g_cancellable_set_error_if_cancelled (cancellable, &data->error);
+ soup_session_abort (data->session);
- g_return_if_fail (cancelled);
+ g_return_if_fail (cancelled);
+ }
}
static void
http_client_check_response_cb (SoupSession *session, SoupMessage *msg, gpointer user_data)
{
- GError *error;
+ CheckData *data;
GTask *task = G_TASK (user_data);
- error = NULL;
+ data = (CheckData *) g_task_get_task_data (task);
/* status == SOUP_STATUS_CANCELLED, if we are being aborted by the
- * GCancellable or due to an SSL error. The GTask was already
- * 'returned' by the respective callbacks.
+ * GCancellable or due to an SSL error.
*/
if (msg->status_code == SOUP_STATUS_CANCELLED)
- goto out;
+ {
+ g_return_if_fail (data->error != NULL);
+ goto out;
+ }
else if (msg->status_code != SOUP_STATUS_OK)
{
g_warning ("goa_http_client_check() failed: %u — %s", msg->status_code, msg->reason_phrase);
- goa_utils_set_error_soup (&error, msg);
- g_task_return_error (task, error);
+ g_return_if_fail (data->error == NULL);
+
+ goa_utils_set_error_soup (&data->error, msg);
goto out;
}
- g_task_return_boolean (task, TRUE);
-
out:
+ if (data->error != NULL)
+ g_task_return_error (task, g_steal_pointer (&data->error));
+ else
+ g_task_return_boolean (task, TRUE);
+
g_object_unref (task);
}
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]