31     def setUp(self):  argument
32         iotests.qemu_img('create', '-f', iotests.imgfmt, self.base_img, "1G")
33         iotests.qemu_img('create', '-f', iotests.imgfmt, self.test_img,
34                          "-b", self.base_img, '-F', iotests.imgfmt)
35         iotests.qemu_io('-f', iotests.imgfmt, '-c', 'write -P0x5d 1M 128M',
36                         self.test_img)
37         self.vm = iotests.VM()
38         self.vm.add_object('throttle-group,id=tg0,x-bps-total=1024')
41                        'node-name=source,' \
42                        'throttle-group=tg0,' \
44                        f'file.file.filename={self.test_img}'
46         self.vm.add_drive(None, source_drive)
47         self.vm.launch()
49     def tearDown(self):  argument
50         self.vm.shutdown()
51         for img in (self.test_img, self.target_img, self.base_img,
52                     self.overlay_img):
55     def do_test_stop(self, cmd, **args):  argument
58         self.vm.cmd(cmd, **args)
60         self.vm.cmd("stop")
61         result = self.vm.qmp("query-block-jobs")
63         self.assert_qmp(result, 'return[0]/status', 'running')
64         self.assert_qmp(result, 'return[0]/ready', False)
66     def test_drive_mirror(self):  argument
67         self.do_test_stop("drive-mirror", device="drive0",
68                           target=self.target_img, format=iotests.imgfmt,
71     def test_drive_backup(self):  argument
72         # Limit max-chunk and max-workers so that block-copy will not
73         # launch so many workers working on so much data each that
75         self.do_test_stop("drive-backup", device="drive0",
76                           target=self.target_img, format=iotests.imgfmt,
78                           x_perf={'max-chunk': 65536,
79                                   'max-workers': 8})
81     def test_block_commit(self):  argument
85         iotests.qemu_img('create', '-f', iotests.imgfmt, self.overlay_img,
88         self.vm.cmd('blockdev-add', {
89             'node-name': 'overlay',
93                 'filename': self.overlay_img
97         self.vm.cmd('blockdev-snapshot',
100         self.do_test_stop('block-commit', device='drive0', top_node='source')