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