Lines Matching defs:worker_thread
600 opj_worker_thread_t* worker_thread;
622 opj_worker_thread_t* worker_thread,
658 opj_worker_thread_t* worker_thread;
663 worker_thread = (opj_worker_thread_t*) user_data;
664 tp = worker_thread->tp;
668 opj_worker_thread_job_t* job = opj_thread_pool_get_next_job(tp, worker_thread,
757 opj_worker_thread_t* worker_thread,
790 if (!worker_thread->marked_as_waiting) {
793 worker_thread->marked_as_waiting = OPJ_TRUE;
806 item->worker_thread = worker_thread;
814 opj_mutex_lock(worker_thread->mutex);
818 opj_cond_wait(worker_thread->cond, worker_thread->mutex);
820 opj_mutex_unlock(worker_thread->mutex);
865 opj_worker_thread_t* worker_thread;
869 worker_thread = tp->waiting_worker_thread_list->worker_thread;
871 assert(worker_thread->marked_as_waiting);
872 worker_thread->marked_as_waiting = OPJ_FALSE;
879 opj_mutex_lock(worker_thread->mutex);
881 opj_cond_signal(worker_thread->cond);
882 opj_mutex_unlock(worker_thread->mutex);
