summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorCarlos Garnacho <carlosg@gnome.org>2022-08-28 11:44:14 +0200
committerCarlos Garnacho <carlosg@gnome.org>2022-08-30 16:56:47 +0000
commitfb8804dc1035175b4ecaf55c9cef7989598ef508 (patch)
treee00799156fcabe436a6be7de8f7e3ba013d31f9d /src
parent7818fbc60bf58fdf0ea6f555d5466bfe7bf7bffa (diff)
downloadtracker-fb8804dc1035175b4ecaf55c9cef7989598ef508.tar.gz
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.
Diffstat (limited to 'src')
-rw-r--r--src/libtracker-sparql/remote/tracker-http-module.c20
1 files changed, 18 insertions, 2 deletions
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);
}
}