Searched refs:threadqueue_queue_t (Results 1 – 3 of 3) sorted by relevance
46 typedef struct threadqueue_queue_t threadqueue_queue_t; typedef48 threadqueue_queue_t * kvz_threadqueue_init(int thread_count);51 int kvz_threadqueue_submit(threadqueue_queue_t * threadqueue, threadqueue_job_t *job);59 int kvz_threadqueue_waitfor(threadqueue_queue_t * threadqueue, threadqueue_job_t * job);60 int kvz_threadqueue_stop(threadqueue_queue_t * threadqueue);61 void kvz_threadqueue_free(threadqueue_queue_t * threadqueue);
178 struct threadqueue_queue_t { struct233 static void threadqueue_push_job(threadqueue_queue_t * threadqueue, in threadqueue_push_job() argument256 static threadqueue_job_t * threadqueue_pop_job(threadqueue_queue_t * threadqueue) in threadqueue_pop_job()277 threadqueue_queue_t * const threadqueue = (threadqueue_queue_t *) threadqueue_opaque; in threadqueue_worker()357 threadqueue_queue_t * kvz_threadqueue_init(int thread_count) in kvz_threadqueue_init()359 threadqueue_queue_t *threadqueue = MALLOC(threadqueue_queue_t, 1); in kvz_threadqueue_init()446 int kvz_threadqueue_submit(threadqueue_queue_t * const threadqueue, threadqueue_job_t *job) in kvz_threadqueue_submit()561 int kvz_threadqueue_waitfor(threadqueue_queue_t * threadqueue, threadqueue_job_t * job) in kvz_threadqueue_waitfor()580 int kvz_threadqueue_stop(threadqueue_queue_t * const threadqueue) in kvz_threadqueue_stop()613 void kvz_threadqueue_free(threadqueue_queue_t *threadqueue) in kvz_threadqueue_free()
122 threadqueue_queue_t *threadqueue;