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); }