• Home
  • Raw
  • Download

Lines Matching refs:worker_thread

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