35     def tearDown(self):  argument
36         self.vm.shutdown()
40     def setUp(self):  argument
41         qemu_img_create('-f', iotests.imgfmt, source_img, size)
42         qemu_img_create('-f', iotests.imgfmt, temp_img, size)
43         qemu_io('-c', 'write 0 1M', source_img)
45         opts = ['-nodefaults', '-display', 'none', '-machine', 'none']
46         self.vm = QEMUMachine(iotests.qemu_prog, opts,
48         self.vm.launch()
50     def do_cbw_error(self, on_cbw_error):  argument
51         self.vm.cmd('blockdev-add', {
52             'node-name': 'cbw',
53             'driver': 'copy-before-write',
54             'on-cbw-error': on_cbw_error,
70                     'inject-error': [
82         self.vm.cmd('blockdev-add', {
83             'node-name': 'access',
84             'driver': 'snapshot-access',
88         result = self.vm.qmp('human-monitor-command',
89                              command_line='qemu-io cbw "write 0 1M"')
90         self.assert_qmp(result, 'return', '')
92         result = self.vm.qmp('human-monitor-command',
93                              command_line='qemu-io access "read 0 1M"')
94         self.assert_qmp(result, 'return', '')
96         self.vm.shutdown()
97         log = self.vm.get_log()
103     def test_break_snapshot_on_cbw_error(self):  argument
104         """break-snapshot behavior:
105         Guest write succeed, but further snapshot-read fails, as snapshot is
108         log = self.do_cbw_error('break-snapshot')
110         self.assertEqual(log, """\
116     def test_break_guest_write_on_cbw_error(self):  argument
117         """break-guest-write behavior:
118         Guest write fails, but snapshot-access continues working and further
119         snapshot-read succeeds.
121         log = self.do_cbw_error('break-guest-write')
123         self.assertEqual(log, """\
129     def do_cbw_timeout(self, on_cbw_error):  argument
130         self.vm.cmd('object-add', {
131             'qom-type': 'throttle-group',
133             'limits': {'bps-write': 300 * 1024}
136         self.vm.cmd('blockdev-add', {
137             'node-name': 'cbw',
138             'driver': 'copy-before-write',
139             'on-cbw-error': on_cbw_error,
140             'cbw-timeout': 1,
150                 'throttle-group': 'group0',
161         self.vm.cmd('blockdev-add', {
162             'node-name': 'access',
163             'driver': 'snapshot-access',
167         result = self.vm.qmp('human-monitor-command',
168                              command_line='qemu-io cbw "write 0 512K"')
169         self.assert_qmp(result, 'return', '')
172         result = self.vm.qmp('human-monitor-command',
173                              command_line='qemu-io cbw "write 512K 512K"')
174         self.assert_qmp(result, 'return', '')
176         result = self.vm.qmp('human-monitor-command',
177                              command_line='qemu-io access "read 0 1M"')
178         self.assert_qmp(result, 'return', '')
180         self.vm.shutdown()
181         log = self.vm.get_log()
187     def test_timeout_break_guest(self):  argument
188         log = self.do_cbw_timeout('break-guest-write')
194         self.assertEqual(log, """\
202     def test_timeout_break_snapshot(self):  argument
203         log = self.do_cbw_timeout('break-snapshot')
204         self.assertEqual(log, """\
216                  required_fmts=['copy-before-write'])