lib: Add g_task_set_source_tag() everywhere

This makes it easier to identify what a `GTask` instance is when
debugging a running process.

Signed-off-by: Philip Withnall <pwithnall@endlessos.org>

8 files changed, 16 insertions, 0 deletions

diff --git a/libsoup/auth/soup-tls-interaction.c b/libsoup/auth/soup-tls-interaction.c
index 6e333935..d6511fa5 100644
--- a/libsoup/auth/soup-tls-interaction.c
+++ b/libsoup/auth/soup-tls-interaction.c
@@ -34,6 +34,7 @@ soup_tls_interaction_request_certificate_async (GTlsInteraction             *tls
         SoupConnection *conn = g_weak_ref_get (&priv->conn);
 
         task = g_task_new (tls_interaction, cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_tls_interaction_request_certificate_async);
         if (conn) {
                 soup_connection_request_tls_certificate (conn, connection, task);
                 g_object_unref (conn);
@@ -66,6 +67,7 @@ soup_tls_interaction_ask_password_async (GTlsInteraction    *tls_interaction,
         SoupConnection *conn = g_weak_ref_get (&priv->conn);
 
         task = g_task_new (tls_interaction, cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_tls_interaction_ask_password_async);
         if (conn) {
                 soup_connection_request_tls_certificate_password (conn, password, task);
                 g_object_unref (conn);
diff --git a/libsoup/http1/soup-client-message-io-http1.c b/libsoup/http1/soup-client-message-io-http1.c
index d4152ec5..ee5738e0 100644
--- a/libsoup/http1/soup-client-message-io-http1.c
+++ b/libsoup/http1/soup-client-message-io-http1.c
@@ -973,6 +973,7 @@ soup_client_message_io_http1_run_until_read_async (SoupClientMessageIO *iface,
         GTask *task;
 
         task = g_task_new (msg, cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_client_message_io_http1_run_until_read_async);
         g_task_set_priority (task, io_priority);
         io_run_until_read_async (io, task);
 }
diff --git a/libsoup/http2/soup-client-message-io-http2.c b/libsoup/http2/soup-client-message-io-http2.c
index 450b0a8d..13dcde20 100644
--- a/libsoup/http2/soup-client-message-io-http2.c
+++ b/libsoup/http2/soup-client-message-io-http2.c
@@ -1744,6 +1744,7 @@ soup_client_message_io_http2_run_until_read_async (SoupClientMessageIO *iface,
         SoupHTTP2MessageData *data = get_data_for_message (io, msg);
 
         data->task = g_task_new (msg, cancellable, callback, user_data);
+        g_task_set_source_tag (data->task, soup_client_message_io_http2_run_until_read_async);
         g_task_set_priority (data->task, io_priority);
         io->pending_io_messages = g_list_prepend (io->pending_io_messages, data);
         if (data->error)
@@ -1790,6 +1791,7 @@ soup_client_message_io_http2_close_async (SoupClientMessageIO *iface,
         if (io->async) {
                 g_assert (!io->close_task);
                 io->close_task = g_task_new (conn, NULL, callback, NULL);
+                g_task_set_source_tag (io->close_task, soup_client_message_io_http2_close_async);
         }
 
         soup_client_message_io_http2_terminate_session (io);
diff --git a/libsoup/soup-client-input-stream.c b/libsoup/soup-client-input-stream.c
index 217c822d..2e7c1093 100644
--- a/libsoup/soup-client-input-stream.c
+++ b/libsoup/soup-client-input-stream.c
@@ -225,6 +225,7 @@ soup_client_input_stream_close_async (GInputStream        *stream,
 	GSource *source;
 
 	task = g_task_new (stream, cancellable, callback, user_data);
+	g_task_set_source_tag (task, soup_client_input_stream_close_async);
 	g_task_set_priority (task, priority);
 
 	if (close_async_ready (priv->msg, task) == G_SOURCE_CONTINUE) {
diff --git a/libsoup/soup-connection.c b/libsoup/soup-connection.c
index 5deb3d35..d764ceca 100644
--- a/libsoup/soup-connection.c
+++ b/libsoup/soup-connection.c
@@ -794,6 +794,7 @@ soup_connection_connect_async (SoupConnection      *conn,
 
         priv->cancellable = cancellable ? g_object_ref (cancellable) : g_cancellable_new ();
         task = g_task_new (conn, priv->cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_connection_connect_async);
         g_task_set_priority (task, io_priority);
 
         client = new_socket_client (conn);
@@ -919,6 +920,7 @@ soup_connection_tunnel_handshake_async (SoupConnection     *conn,
 
         priv->cancellable = cancellable ? g_object_ref (cancellable) : g_cancellable_new ();
         task = g_task_new (conn, priv->cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_connection_tunnel_handshake_async);
         g_task_set_priority (task, io_priority);
 
         tls_connection = new_tls_connection (conn, G_SOCKET_CONNECTION (priv->connection), &error);
diff --git a/libsoup/soup-io-stream.c b/libsoup/soup-io-stream.c
index afd064b6..776ef279 100644
--- a/libsoup/soup-io-stream.c
+++ b/libsoup/soup-io-stream.c
@@ -178,6 +178,7 @@ soup_io_stream_close_async (GIOStream           *stream,
         SoupIOStreamPrivate *priv = soup_io_stream_get_instance_private (siostream);
 
 	task = g_task_new (stream, cancellable, callback, user_data);
+	g_task_set_source_tag (task, soup_io_stream_close_async);
 	g_io_stream_close_async (priv->base_iostream,
 				 io_priority, cancellable,
 				 close_async_complete, task);
diff --git a/libsoup/soup-multipart-input-stream.c b/libsoup/soup-multipart-input-stream.c
index c5d4af7e..99999ea1 100644
--- a/libsoup/soup-multipart-input-stream.c
+++ b/libsoup/soup-multipart-input-stream.c
@@ -539,6 +539,7 @@ soup_multipart_input_stream_next_part_async (SoupMultipartInputStream *multipart
 	g_return_if_fail (SOUP_IS_MULTIPART_INPUT_STREAM (multipart));
 
 	task = g_task_new (multipart, cancellable, callback, data);
+	g_task_set_source_tag (task, soup_multipart_input_stream_next_part_async);
 	g_task_set_priority (task, io_priority);
 
 	if (!g_input_stream_set_pending (stream, &error)) {
diff --git a/libsoup/soup-session.c b/libsoup/soup-session.c
index 78dacd03..42ea1a87 100644
--- a/libsoup/soup-session.c
+++ b/libsoup/soup-session.c
@@ -3039,6 +3039,7 @@ soup_session_return_error_if_message_already_in_queue (SoupSession         *sess
                                            SOUP_SESSION_ERROR_MESSAGE_ALREADY_IN_QUEUE,
                                            _("Message is already in session queue"));
         task = g_task_new (session, cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_session_return_error_if_message_already_in_queue);
         g_task_set_task_data (task, item, (GDestroyNotify)soup_message_queue_item_unref);
         g_task_return_error (task, g_error_copy (item->error));
         g_object_unref (task);
@@ -3087,6 +3088,7 @@ soup_session_send_async (SoupSession         *session,
 			  G_CALLBACK (async_send_request_finished), item);
 
 	item->task = g_task_new (session, item->cancellable, callback, user_data);
+	g_task_set_source_tag (item->task, soup_session_send_async);
 	g_task_set_priority (item->task, io_priority);
 	g_task_set_task_data (item->task, item, (GDestroyNotify) soup_message_queue_item_unref);
 	if (async_respond_from_cache (session, item))
@@ -3333,6 +3335,7 @@ soup_session_send_and_read_async (SoupSession        *session,
 
         ostream = g_memory_output_stream_new_resizable ();
 	task = g_task_new (session, cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_session_send_and_read_async);
 	g_task_set_priority (task, io_priority);
         g_task_set_task_data (task, ostream, g_object_unref);
 
@@ -3506,6 +3509,7 @@ soup_session_send_and_splice_async (SoupSession             *session,
         data->out_stream = g_object_ref (out_stream);
         data->flags = flags;
         data->task = g_task_new (session, cancellable, callback, user_data);
+        g_task_set_source_tag (data->task, soup_session_send_and_splice_async);
         g_task_set_priority (data->task, io_priority);
 
         soup_session_send_async (session, msg,
@@ -3770,6 +3774,7 @@ soup_session_websocket_connect_async (SoupSession          *session,
 	item->io_priority = io_priority;
 
         task = g_task_new (session, item->cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_session_websocket_connect_async);
 	g_task_set_task_data (task, item, (GDestroyNotify) soup_message_queue_item_unref);
 
 	soup_message_add_status_code_handler (msg, "got-informational",
@@ -3880,6 +3885,7 @@ soup_session_preconnect_async (SoupSession        *session,
         soup_message_set_is_preconnect (msg, TRUE);
 
         task = g_task_new (session, item->cancellable, callback, user_data);
+        g_task_set_source_tag (task, soup_session_preconnect_async);
         g_task_set_priority (task, io_priority);
         g_task_set_task_data (task, item, (GDestroyNotify)soup_message_queue_item_unref);