From fb8804dc1035175b4ecaf55c9cef7989598ef508 Mon Sep 17 00:00:00 2001 From: Carlos Garnacho Date: Sun, 28 Aug 2022 11:44:14 +0200 Subject: remote: Support newer soup API to pause/unpause messages There is new API scheduled for 3.2.0 to pause/unpause messages for deferred processing. Follow these API updates and handle it, without bumping to such newer version so far. --- src/libtracker-sparql/remote/tracker-http-module.c | 20 ++++++++++++++++++-- 1 file changed, 18 insertions(+), 2 deletions(-) (limited to 'src') diff --git a/src/libtracker-sparql/remote/tracker-http-module.c b/src/libtracker-sparql/remote/tracker-http-module.c index 421005001..0c6c17dc7 100644 --- a/src/libtracker-sparql/remote/tracker-http-module.c +++ b/src/libtracker-sparql/remote/tracker-http-module.c @@ -141,7 +141,12 @@ server_callback (SoupServer *server, request = g_new0 (TrackerHttpRequest, 1); request->server = http_server; request->message = message; + +#if SOUP_CHECK_VERSION (3, 1, 3) + soup_server_message_pause (message); +#else soup_server_pause_message (server, message); +#endif g_signal_emit_by_name (http_server, "request", remote_address, @@ -193,7 +198,7 @@ tracker_http_server_soup_error (TrackerHttpServer *server, gint code, const gchar *message) { - TrackerHttpServerSoup *server_soup = + G_GNUC_UNUSED TrackerHttpServerSoup *server_soup = TRACKER_HTTP_SERVER_SOUP (server); g_assert (request->server == server); @@ -203,7 +208,12 @@ tracker_http_server_soup_error (TrackerHttpServer *server, #else soup_message_set_status_full (request->message, code, message); #endif + +#if SOUP_CHECK_VERSION (3, 1, 3) + soup_server_message_unpause (request->message); +#else soup_server_unpause_message (server_soup->server, request->message); +#endif g_free (request); } @@ -256,7 +266,7 @@ write_finished_cb (GObject *object, gpointer user_data) { TrackerHttpRequest *request = user_data; - TrackerHttpServerSoup *server = + G_GNUC_UNUSED TrackerHttpServerSoup *server = TRACKER_HTTP_SERVER_SOUP (request->server); GError *error = NULL; @@ -272,7 +282,13 @@ write_finished_cb (GObject *object, #else soup_message_set_status (request->message, 200); #endif + +#if SOUP_CHECK_VERSION (3, 1, 3) + soup_server_message_unpause (request->message); +#else soup_server_unpause_message (server->server, request->message); +#endif + g_free (request); } } -- cgit v1.2.1