295       job = queue->jobs[queue->read_idx];  in util_queue_thread_func()
296       memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job));  in util_queue_thread_func()
314    /* signal remaining jobs if all threads are being terminated */  in util_queue_thread_func()
319          if (queue->jobs[i].job) {  in util_queue_thread_func()
320             if (queue->jobs[i].fence)  in util_queue_thread_func()
321                util_queue_fence_signal(queue->jobs[i].fence);  in util_queue_thread_func()
322             queue->jobs[i].job = NULL;  in util_queue_thread_func()
448    queue->jobs = (struct util_queue_job*)  in util_queue_init()
450    if (!queue->jobs)  in util_queue_init()
477    if (queue->jobs) {  in util_queue_init()
481       free(queue->jobs);  in util_queue_init()
540    free(queue->jobs);  in util_queue_destroy()
583          struct util_queue_job *jobs =  in util_queue_add_job()  local
586          assert(jobs);  in util_queue_add_job()
588          /* Copy all queued jobs into the new list. */  in util_queue_add_job()
593             jobs[num_jobs++] = queue->jobs[i];  in util_queue_add_job()
599          free(queue->jobs);  in util_queue_add_job()
600          queue->jobs = jobs;  in util_queue_add_job()
611    ptr = &queue->jobs[queue->write_idx];  in util_queue_add_job()
649       if (queue->jobs[i].fence == fence) {  in util_queue_drop_job()
650          if (queue->jobs[i].cleanup)  in util_queue_drop_job()
651             queue->jobs[i].cleanup(queue->jobs[i].job, queue->global_data, -1);  in util_queue_drop_job()
654          memset(&queue->jobs[i], 0, sizeof(queue->jobs[i]));  in util_queue_drop_job()
668  * Wait until all previously added jobs have completed.
676    /* If 2 threads were adding jobs for 2 different barries at the same time,  in util_queue_finish()