Lines Matching defs:jobs
318 job = queue->jobs[queue->read_idx];
319 memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job));
337 /* signal remaining jobs if all threads are being terminated */
342 if (queue->jobs[i].job) {
343 if (queue->jobs[i].fence)
344 util_queue_fence_signal(queue->jobs[i].fence);
345 queue->jobs[i].job = NULL;
471 queue->jobs = (struct util_queue_job*)
473 if (!queue->jobs)
500 if (queue->jobs) {
504 free(queue->jobs);
562 free(queue->jobs);
604 struct util_queue_job *jobs =
607 assert(jobs);
609 /* Copy all queued jobs into the new list. */
614 jobs[num_jobs++] = queue->jobs[i];
620 free(queue->jobs);
621 queue->jobs = jobs;
632 ptr = &queue->jobs[queue->write_idx];
670 if (queue->jobs[i].fence == fence) {
671 if (queue->jobs[i].cleanup)
672 queue->jobs[i].cleanup(queue->jobs[i].job, queue->global_data, -1);
675 memset(&queue->jobs[i], 0, sizeof(queue->jobs[i]));
689 * Wait until all previously added jobs have completed.
697 /* If 2 threads were adding jobs for 2 different barries at the same time,