From cbc4600cc44aa1c19d40f6146600912ac33a0b9f Mon Sep 17 00:00:00 2001 From: Jaroslav Kysela Date: Sat, 15 Mar 2014 23:35:30 +0100 Subject: [PATCH] Remove waiting subscriptions in subscription_done() --- src/subscriptions.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/subscriptions.c b/src/subscriptions.c index 94193084..96cd7f27 100644 --- a/src/subscriptions.c +++ b/src/subscriptions.c @@ -763,6 +763,10 @@ subscription_init(void) void subscription_done(void) { + pthread_mutex_lock(&global_lock); + /* clear remaining subscriptions */ + subscription_reschedule(); + pthread_mutex_unlock(&global_lock); assert(LIST_FIRST(&subscriptions) == NULL); }