Lines Matching refs:worker_threads

606     opj_worker_thread_t*             worker_threads;  member
696 tp->worker_threads = (opj_worker_thread_t*) opj_calloc((size_t)num_threads, in opj_thread_pool_setup()
698 if (tp->worker_threads == NULL) { in opj_thread_pool_setup()
704 tp->worker_threads[i].tp = tp; in opj_thread_pool_setup()
706 tp->worker_threads[i].mutex = opj_mutex_create(); in opj_thread_pool_setup()
707 if (tp->worker_threads[i].mutex == NULL) { in opj_thread_pool_setup()
713 tp->worker_threads[i].cond = opj_cond_create(); in opj_thread_pool_setup()
714 if (tp->worker_threads[i].cond == NULL) { in opj_thread_pool_setup()
715 opj_mutex_destroy(tp->worker_threads[i].mutex); in opj_thread_pool_setup()
721 tp->worker_threads[i].marked_as_waiting = OPJ_FALSE; in opj_thread_pool_setup()
723 tp->worker_threads[i].thread = opj_thread_create(opj_worker_thread_function, in opj_thread_pool_setup()
724 &(tp->worker_threads[i])); in opj_thread_pool_setup()
725 if (tp->worker_threads[i].thread == NULL) { in opj_thread_pool_setup()
931 opj_mutex_lock(tp->worker_threads[i].mutex); in opj_thread_pool_destroy()
932 opj_cond_signal(tp->worker_threads[i].cond); in opj_thread_pool_destroy()
933 opj_mutex_unlock(tp->worker_threads[i].mutex); in opj_thread_pool_destroy()
934 opj_thread_join(tp->worker_threads[i].thread); in opj_thread_pool_destroy()
935 opj_cond_destroy(tp->worker_threads[i].cond); in opj_thread_pool_destroy()
936 opj_mutex_destroy(tp->worker_threads[i].mutex); in opj_thread_pool_destroy()
939 opj_free(tp->worker_threads); in opj_thread_pool_destroy()