forked/ustreamer
1
0
Fork 0
mirror of https://github.com/pikvm/ustreamer.git synced 2026-03-13 19:13:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed mutex routine

Browse Source
This commit is contained in:
Devaev Maxim
2019-06-29 06:59:16 +03:00
parent 2ed3c4815b
commit 7a85774085
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/stream.c
View File

@@ -381,6 +381,8 @@ static struct _workers_pool_t *_workers_pool_init(struct stream_t *stream) {
WORKER(proc_stop) = &stream->proc->stop; WORKER(proc_stop) = &stream->proc->stop;
WORKER(workers_stop) = &pool->workers_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_mutex) = &pool->free_workers_mutex;
WORKER(free_workers) = &pool->free_workers; WORKER(free_workers) = &pool->free_workers;
WORKER(free_workers_cond) = &pool->free_workers_cond; 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_MUTEX_DESTROY(&WORKER(has_job_mutex));
A_COND_DESTROY(&WORKER(has_job_cond)); A_COND_DESTROY(&WORKER(has_job_cond));
A_MUTEX_DESTROY(&WORKER(last_comp_time_mutex));
# undef WORKER # undef WORKER
} }