Remove waiting subscriptions in subscription_done()

diff --git a/src/subscriptions.c b/src/subscriptions.c
index 9419308424b99b2e22536d2443e66fc673dfb2e8..96cd7f278ffcce098be261d769e5957a41592fa8 100644 (file)
--- 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);
 }