tests/qemu-iotests/196

   1 #!/usr/bin/env python3
   2 # group: rw quick migration
   3 #
   4 # Test clearing unknown autoclear_features flag by qcow2 after
   5 # migration. This test mimics migration to older qemu.
   6 #
   7 # Copyright (c) 2017 Parallels International GmbH
   8 #
   9 # This program is free software; you can redistribute it and/or modify
  10 # it under the terms of the GNU General Public License as published by
  11 # the Free Software Foundation; either version 2 of the License, or
  12 # (at your option) any later version.
  13 #
  14 # This program is distributed in the hope that it will be useful,
  15 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  16 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17 # GNU General Public License for more details.
  18 #
  19 # You should have received a copy of the GNU General Public License
  20 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
  21 #
  22
  23 import os
  24 import iotests
  25 from iotests import qemu_img
  26
  27 disk = os.path.join(iotests.test_dir, 'disk')
  28 migfile = os.path.join(iotests.test_dir, 'migfile')
  29
  30 class TestInvalidateAutoclear(iotests.QMPTestCase):
  31
  32     def tearDown(self):
  33         self.vm_a.shutdown()
  34         self.vm_b.shutdown()
  35         os.remove(disk)
  36         os.remove(migfile)
  37
  38     def setUp(self):
  39         qemu_img('create', '-f', iotests.imgfmt, disk, '1M')
  40
  41         self.vm_a = iotests.VM(path_suffix='a').add_drive(disk)
  42         self.vm_a.launch()
  43
  44         self.vm_b = iotests.VM(path_suffix='b').add_drive(disk)
  45         self.vm_b.add_incoming("exec: cat '" + migfile + "'")
  46
  47     def test_migration(self):
  48         result = self.vm_a.qmp('migrate', uri='exec:cat>' + migfile)
  49         self.assert_qmp(result, 'return', {});
  50         self.assertNotEqual(self.vm_a.event_wait("STOP"), None)
  51
  52         with open(disk, 'r+b') as f:
  53             f.seek(88) # first byte of autoclear_features field
  54             f.write(b'\xff')
  55
  56         self.vm_b.launch()
  57         while True:
  58             result = self.vm_b.qmp('query-status')
  59             if result['return']['status'] == 'running':
  60                 break
  61
  62         with open(disk, 'rb') as f:
  63             f.seek(88)
  64             self.assertEqual(f.read(1), b'\x00')
  65
  66 if __name__ == '__main__':
  67     iotests.main(supported_fmts=['qcow2'],
  68                  supported_protocols=['file'])