From 7a85774085bd2c97edf156484b3c061780a00534 Mon Sep 17 00:00:00 2001 From: Devaev Maxim Date: Sat, 29 Jun 2019 06:59:16 +0300 Subject: [PATCH] fixed mutex routine --- src/stream.c | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/stream.c b/src/stream.c index 8a47363..e070599 100644 --- a/src/stream.c +++ b/src/stream.c @@ -381,6 +381,8 @@ static struct _workers_pool_t *_workers_pool_init(struct stream_t *stream) { WORKER(proc_stop) = &stream->proc->stop; WORKER(workers_stop) = &pool->workers_stop; + A_MUTEX_INIT(&WORKER(last_comp_time_mutex)); + WORKER(free_workers_mutex) = &pool->free_workers_mutex; WORKER(free_workers) = &pool->free_workers; WORKER(free_workers_cond) = &pool->free_workers_cond; @@ -413,6 +415,8 @@ static void _workers_pool_destroy(struct _workers_pool_t *pool) { A_MUTEX_DESTROY(&WORKER(has_job_mutex)); A_COND_DESTROY(&WORKER(has_job_cond)); + A_MUTEX_DESTROY(&WORKER(last_comp_time_mutex)); + # undef WORKER }