• 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()
759 opj_worker_thread_t* worker_thread, in opj_thread_pool_get_next_job() argument
792 if (!worker_thread->marked_as_waiting) { in opj_thread_pool_get_next_job()
795 worker_thread->marked_as_waiting = OPJ_TRUE; in opj_thread_pool_get_next_job()
808 item->worker_thread = worker_thread; in opj_thread_pool_get_next_job()
816 opj_mutex_lock(worker_thread->mutex); in opj_thread_pool_get_next_job()
820 opj_cond_wait(worker_thread->cond, worker_thread->mutex); in opj_thread_pool_get_next_job()
822 opj_mutex_unlock(worker_thread->mutex); in opj_thread_pool_get_next_job()
867 opj_worker_thread_t* worker_thread; in opj_thread_pool_submit_job() local
871 worker_thread = tp->waiting_worker_thread_list->worker_thread; in opj_thread_pool_submit_job()
873 assert(worker_thread->marked_as_waiting); in opj_thread_pool_submit_job()
874 worker_thread->marked_as_waiting = OPJ_FALSE; in opj_thread_pool_submit_job()
881 opj_mutex_lock(worker_thread->mutex); in opj_thread_pool_submit_job()
883 opj_cond_signal(worker_thread->cond); in opj_thread_pool_submit_job()
884 opj_mutex_unlock(worker_thread->mutex); in opj_thread_pool_submit_job()