From 59abdbd2dd820069e1ca25e3c44c1b02f906087b Mon Sep 17 00:00:00 2001 From: Max Kellermann Date: Fri, 16 Sep 2011 20:12:35 +0200 Subject: input/soup: wait for _cancel_message() to complete Add the "complete" attribute, and set it in _session_callback(). _close() waits for it to become true. --- src/input/soup_input_plugin.c | 26 +++++++++++++++++++++----- 1 file changed, 21 insertions(+), 5 deletions(-) (limited to 'src') diff --git a/src/input/soup_input_plugin.c b/src/input/soup_input_plugin.c index 710800294..7f92113b4 100644 --- a/src/input/soup_input_plugin.c +++ b/src/input/soup_input_plugin.c @@ -59,6 +59,12 @@ struct input_soup { bool alive, pause, eof; + /** + * Set when the session callback has been invoked, when it is + * safe to free this object. + */ + bool completed; + GError *postponed_error; }; @@ -116,10 +122,14 @@ input_soup_session_callback(G_GNUC_UNUSED SoupSession *session, struct input_soup *s = user_data; assert(msg == s->msg); + assert(!s->completed); g_mutex_lock(s->mutex); + s->base.ready = true; s->alive = false; + s->completed = true; + g_cond_broadcast(s->cond); g_mutex_unlock(s->mutex); } @@ -242,6 +252,7 @@ input_soup_open(const char *uri, G_GNUC_UNUSED GError **error_r) s->alive = true; s->pause = false; s->eof = false; + s->completed = false; s->postponed_error = NULL; soup_session_queue_message(soup_session, s->msg, @@ -257,16 +268,21 @@ input_soup_close(struct input_stream *is) g_mutex_lock(s->mutex); - if (s->alive) { - assert(s->msg != NULL); + if (!s->completed) { + /* the messages's session callback hasn't been invoked + yet; cancel it and wait for completion */ - s->alive = false; g_mutex_unlock(s->mutex); soup_session_cancel_message(soup_session, s->msg, SOUP_STATUS_CANCELLED); - } else - g_mutex_unlock(s->mutex); + + g_mutex_lock(s->mutex); + while (!s->completed) + g_cond_wait(s->cond, s->mutex); + } + + g_mutex_unlock(s->mutex); g_mutex_free(s->mutex); g_cond_free(s->cond); -- cgit v1.2.3