summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorCarlos Garcia Campos <cgarcia@igalia.com>2022-08-12 14:38:32 +0200
committerCarlos Garcia Campos <cgarcia@igalia.com>2022-08-12 14:38:32 +0200
commit7dff11b52374af868d105bf790b2d9166341cb3a (patch)
tree69e1373bd0002931655a70258174edae1cb859f6
parent4cccd0cf0d122247f1c82c98f0ad489f37e42aff (diff)
downloadlibsoup-7dff11b52374af868d105bf790b2d9166341cb3a.tar.gz
server: do not try to use server io after soup_server_message_finish()
Message finish can destroy the server io.
-rw-r--r--libsoup/server/http1/soup-server-message-io-http1.c14
1 files changed, 8 insertions, 6 deletions
diff --git a/libsoup/server/http1/soup-server-message-io-http1.c b/libsoup/server/http1/soup-server-message-io-http1.c
index d783bde2..8d1be9ab 100644
--- a/libsoup/server/http1/soup-server-message-io-http1.c
+++ b/libsoup/server/http1/soup-server-message-io-http1.c
@@ -908,6 +908,7 @@ io_run (SoupServerMessageIOHTTP1 *server_io)
{
SoupServerMessage *msg = server_io->msg_io->msg;
SoupMessageIOData *io = &server_io->msg_io->base;
+ gboolean success;
GError *error = NULL;
g_assert (!server_io->in_io_run);
@@ -920,10 +921,13 @@ io_run (SoupServerMessageIOHTTP1 *server_io)
}
g_object_ref (msg);
- if (io_run_until (server_io,
- SOUP_MESSAGE_IO_STATE_DONE,
- SOUP_MESSAGE_IO_STATE_DONE,
- &error)) {
+ success = io_run_until (server_io,
+ SOUP_MESSAGE_IO_STATE_DONE,
+ SOUP_MESSAGE_IO_STATE_DONE,
+ &error);
+ server_io->in_io_run = FALSE;
+
+ if (success) {
soup_server_message_finish (msg);
} else if (g_error_matches (error, G_IO_ERROR, G_IO_ERROR_WOULD_BLOCK)) {
g_clear_error (&error);
@@ -940,8 +944,6 @@ io_run (SoupServerMessageIOHTTP1 *server_io)
}
g_object_unref (msg);
g_clear_error (&error);
-
- server_io->in_io_run = FALSE;
}
static void