27 #include "qemu/job.h"
28 #include "qapi/qapi-commands-job.h"
33  * Get a job using its ID. Called with job_mutex held.
35 static Job *find_job_locked(const char *id, Error **errp)  in find_job_locked()
37     Job *job;  in find_job_locked()  local
39     job = job_get_locked(id);  in find_job_locked()
40     if (!job) {  in find_job_locked()
41         error_setg(errp, "Job not found");  in find_job_locked()
45     return job;  in find_job_locked()
50     Job *job;  in qmp_job_cancel()  local
53     job = find_job_locked(id, errp);  in qmp_job_cancel()
55     if (!job) {  in qmp_job_cancel()
59     trace_qmp_job_cancel(job);  in qmp_job_cancel()
60     job_user_cancel_locked(job, true, errp);  in qmp_job_cancel()
65     Job *job;  in qmp_job_pause()  local
68     job = find_job_locked(id, errp);  in qmp_job_pause()
70     if (!job) {  in qmp_job_pause()
74     trace_qmp_job_pause(job);  in qmp_job_pause()
75     job_user_pause_locked(job, errp);  in qmp_job_pause()
80     Job *job;  in qmp_job_resume()  local
83     job = find_job_locked(id, errp);  in qmp_job_resume()
85     if (!job) {  in qmp_job_resume()
89     trace_qmp_job_resume(job);  in qmp_job_resume()
90     job_user_resume_locked(job, errp);  in qmp_job_resume()
95     Job *job;  in qmp_job_complete()  local
98     job = find_job_locked(id, errp);  in qmp_job_complete()
100     if (!job) {  in qmp_job_complete()
104     trace_qmp_job_complete(job);  in qmp_job_complete()
105     job_complete_locked(job, errp);  in qmp_job_complete()
110     Job *job;  in qmp_job_finalize()  local
113     job = find_job_locked(id, errp);  in qmp_job_finalize()
115     if (!job) {  in qmp_job_finalize()
119     trace_qmp_job_finalize(job);  in qmp_job_finalize()
120     job_ref_locked(job);  in qmp_job_finalize()
121     job_finalize_locked(job, errp);  in qmp_job_finalize()
123     job_unref_locked(job);  in qmp_job_finalize()
128     Job *job;  in qmp_job_dismiss()  local
131     job = find_job_locked(id, errp);  in qmp_job_dismiss()
133     if (!job) {  in qmp_job_dismiss()
137     trace_qmp_job_dismiss(job);  in qmp_job_dismiss()
138     job_dismiss_locked(&job, errp);  in qmp_job_dismiss()
142 static JobInfo *job_query_single_locked(Job *job, Error **errp)  in job_query_single_locked()  argument
148     assert(!job_is_internal(job));  in job_query_single_locked()
149     progress_get_snapshot(&job->progress, &progress_current,  in job_query_single_locked()
154         .id                 = g_strdup(job->id),  in job_query_single_locked()
155         .type               = job_type(job),  in job_query_single_locked()
156         .status             = job->status,  in job_query_single_locked()
159         .error              = job->err ?  in job_query_single_locked()
160                               g_strdup(error_get_pretty(job->err)) : NULL,  in job_query_single_locked()
169     Job *job;  in qmp_query_jobs()  local
173     for (job = job_next_locked(NULL); job; job = job_next_locked(job)) {  in qmp_query_jobs()
176         if (job_is_internal(job)) {  in qmp_query_jobs()
179         value = job_query_single_locked(job, errp);  in qmp_query_jobs()