Lines Matching refs:max_jobs
251 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_thread_func()
264 queue->read_idx = (queue->read_idx + 1) % queue->max_jobs; in util_queue_thread_func()
281 i = (i + 1) % queue->max_jobs) { in util_queue_thread_func()
296 unsigned max_jobs, in util_queue_init() argument
306 queue->max_jobs = max_jobs; in util_queue_init()
309 calloc(max_jobs, sizeof(struct util_queue_job)); in util_queue_init()
428 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_add_job()
430 if (queue->num_queued == queue->max_jobs) { in util_queue_add_job()
435 unsigned new_max_jobs = queue->max_jobs + 8; in util_queue_add_job()
447 i = (i + 1) % queue->max_jobs; in util_queue_add_job()
456 queue->max_jobs = new_max_jobs; in util_queue_add_job()
459 while (queue->num_queued == queue->max_jobs) in util_queue_add_job()
470 queue->write_idx = (queue->write_idx + 1) % queue->max_jobs; in util_queue_add_job()
497 i = (i + 1) % queue->max_jobs) { in util_queue_drop_job()