Lines Matching refs:jobs
309 job = queue->jobs[queue->read_idx];
310 memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job));
325 /* signal remaining jobs if all threads are being terminated */
330 if (queue->jobs[i].job) {
331 util_queue_fence_signal(queue->jobs[i].fence);
332 queue->jobs[i].job = NULL;
448 queue->jobs = (struct util_queue_job*)
450 if (!queue->jobs)
484 if (queue->jobs) {
488 free(queue->jobs);
536 free(queue->jobs);
568 struct util_queue_job *jobs =
571 assert(jobs);
573 /* Copy all queued jobs into the new list. */
578 jobs[num_jobs++] = queue->jobs[i];
584 free(queue->jobs);
585 queue->jobs = jobs;
596 ptr = &queue->jobs[queue->write_idx];
630 if (queue->jobs[i].fence == fence) {
631 if (queue->jobs[i].cleanup)
632 queue->jobs[i].cleanup(queue->jobs[i].job, -1);
635 memset(&queue->jobs[i], 0, sizeof(queue->jobs[i]));
656 * Wait until all previously added jobs have completed.
664 /* If 2 threads were adding jobs for 2 different barries at the same time,