Lines Matching full:max_jobs
285 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_thread_func()
299 queue->read_idx = (queue->read_idx + 1) % queue->max_jobs; in util_queue_thread_func()
319 i = (i + 1) % queue->max_jobs) { in util_queue_thread_func()
400 unsigned max_jobs, in util_queue_init() argument
437 queue->max_jobs = max_jobs; in util_queue_init()
440 calloc(max_jobs, sizeof(struct util_queue_job)); in util_queue_init()
552 assert(queue->num_queued >= 0 && queue->num_queued <= queue->max_jobs); in util_queue_add_job()
554 if (queue->num_queued == queue->max_jobs) { in util_queue_add_job()
560 unsigned new_max_jobs = queue->max_jobs + 8; in util_queue_add_job()
572 i = (i + 1) % queue->max_jobs; in util_queue_add_job()
581 queue->max_jobs = new_max_jobs; in util_queue_add_job()
584 while (queue->num_queued == queue->max_jobs) in util_queue_add_job()
597 queue->write_idx = (queue->write_idx + 1) % queue->max_jobs; in util_queue_add_job()
625 i = (i + 1) % queue->max_jobs) { in util_queue_drop_job()