Lines Matching refs:jobs
262 job = queue->jobs[queue->read_idx];
263 memset(&queue->jobs[queue->read_idx], 0, sizeof(struct util_queue_job));
278 /* signal remaining jobs before terminating */
282 if (queue->jobs[i].job) {
283 util_queue_fence_signal(queue->jobs[i].fence);
284 queue->jobs[i].job = NULL;
308 queue->jobs = (struct util_queue_job*)
310 if (!queue->jobs)
367 if (queue->jobs) {
371 free(queue->jobs);
404 free(queue->jobs);
436 struct util_queue_job *jobs =
439 assert(jobs);
441 /* Copy all queued jobs into the new list. */
446 jobs[num_jobs++] = queue->jobs[i];
452 free(queue->jobs);
453 queue->jobs = jobs;
464 ptr = &queue->jobs[queue->write_idx];
498 if (queue->jobs[i].fence == fence) {
499 if (queue->jobs[i].cleanup)
500 queue->jobs[i].cleanup(queue->jobs[i].job, -1);
503 memset(&queue->jobs[i], 0, sizeof(queue->jobs[i]));
524 * Wait until all previously added jobs have completed.
534 /* If 2 threads were adding jobs for 2 different barries at the same time,
