29 def pause_wait(vm, job_id):  argument
32             result = vm.qmp('query-jobs')
38 def test_pause_resume(vm):  argument
45             iotests.log(vm.qmp(pause_cmd, **{pause_arg: 'job0'}))
46             pause_wait(vm, 'job0')
47             iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
48             result = vm.qmp('query-jobs')
54             iotests.log(vm.qmp(resume_cmd, **{resume_arg: 'job0'}))
55             iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
59                     result = vm.qmp('query-jobs')
65                 iotests.log(vm.qmp('query-jobs'))
67 def test_job_lifecycle(vm, job, job_args, has_ready=False, is_mirror=False):  argument
76     iotests.log(vm.qmp(job, job_id='job0', **job_args))
82     result = vm.qmp('query-jobs')
89     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
90     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
93     while vm.qmp('query-jobs')['return'][0]['total-progress'] < img_size:
100     test_pause_resume(vm)
102     iotests.log(vm.qmp('job-complete', id='job0'))
103     iotests.log(vm.qmp('job-finalize', id='job0'))
104     iotests.log(vm.qmp('job-dismiss', id='job0'))
106     iotests.log(vm.qmp('block-job-complete', device='job0'))
107     iotests.log(vm.qmp('block-job-finalize', id='job0'))
108     iotests.log(vm.qmp('block-job-dismiss', id='job0'))
111     iotests.log(vm.qmp('block-job-set-speed', device='job0', speed=0))
115         vm.event_wait('BLOCK_JOB_READY')
116         iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
117         iotests.log(vm.qmp('query-jobs'))
123         test_pause_resume(vm)
125         iotests.log(vm.qmp('job-finalize', id='job0'))
126         iotests.log(vm.qmp('job-dismiss', id='job0'))
128         iotests.log(vm.qmp('block-job-finalize', id='job0'))
129         iotests.log(vm.qmp('block-job-dismiss', id='job0'))
132         iotests.log(vm.qmp('job-complete', id='job0'))
137     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
138     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
140         iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
141         iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
146         iotests.log(vm.qmp('query-jobs'))
148         iotests.log(vm.qmp('job-pause', id='job0'))
149         iotests.log(vm.qmp('job-complete', id='job0'))
150         iotests.log(vm.qmp('job-dismiss', id='job0'))
152         iotests.log(vm.qmp('block-job-pause', device='job0'))
153         iotests.log(vm.qmp('block-job-complete', device='job0'))
154         iotests.log(vm.qmp('block-job-dismiss', id='job0'))
157         iotests.log(vm.qmp('job-finalize', id='job0'))
161     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
166         iotests.log(vm.qmp('query-jobs'))
168         iotests.log(vm.qmp('job-pause', id='job0'))
169         iotests.log(vm.qmp('job-complete', id='job0'))
170         iotests.log(vm.qmp('job-finalize', id='job0'))
172         iotests.log(vm.qmp('block-job-pause', device='job0'))
173         iotests.log(vm.qmp('block-job-complete', device='job0'))
174         iotests.log(vm.qmp('block-job-finalize', id='job0'))
177         iotests.log(vm.qmp('job-dismiss', id='job0'))
180     iotests.log(iotests.filter_qmp_event(vm.event_wait('JOB_STATUS_CHANGE')))
181     iotests.log(vm.qmp('query-jobs'))
186      iotests.VM() as vm:
192     iotests.log('Launching VM...')
193     vm.add_blockdev(vm.qmp_to_opts({
201     vm.launch()
215     test_job_lifecycle(vm, 'drive-mirror', has_ready=True, job_args={
225             test_job_lifecycle(vm, 'drive-backup', is_mirror=True, job_args={
235     vm.shutdown()