Signed-off-by: Andre Heider <a.heider@gmail.com>
Reviewed-by: Axel Davy <davyaxel0@gmail.com>
nine_queue_delete(struct nine_queue_pool *ctx)
{
unsigned i;
+
mtx_destroy(&ctx->mutex_pop);
+ cnd_destroy(&ctx->event_pop);
+
mtx_destroy(&ctx->mutex_push);
+ cnd_destroy(&ctx->event_push);
for (i = 0; i < NINE_CMD_BUFS; i++)
FREE(ctx->pool[i].mem_pool);
nine_csmt_wait_processed(ctx);
nine_queue_delete(ctx->pool);
+
+ mtx_destroy(&ctx->thread_resume);
+ mtx_destroy(&ctx->thread_running);
+
mtx_destroy(&ctx->mutex_processed);
+ cnd_destroy(&ctx->event_processed);
FREE(ctx);