Lines Matching defs:job
280 struct util_queue_job job;
295 job = queue->jobs[queue->read_idx];
301 if (job.job)
302 queue->total_jobs_size -= job.job_size;
305 if (job.job) {
306 job.execute(job.job, job.global_data, thread_index);
307 if (job.fence)
308 util_queue_fence_signal(job.fence);
309 if (job.cleanup)
310 job.cleanup(job.job, job.global_data, thread_index);
319 if (queue->jobs[i].job) {
322 queue->jobs[i].job = NULL;
546 void *job,
568 /* Scale the number of threads up if there's already one job waiting. */
612 assert(ptr->job == NULL);
613 ptr->job = job;
629 * Remove a queued job. If the job hasn't started execution, it's removed from
630 * the queue. If the job has started execution, the function waits for it to
635 * The function can be used when destroying an object associated with the job
636 * when you don't care about the job completion state.
651 queue->jobs[i].cleanup(queue->jobs[i].job, queue->global_data, -1);
653 /* Just clear it. The threads will treat as a no-op job. */