qemu

FORK: QEMU emulator
git clone https://git.neptards.moe/neptards/qemu.git
Log | Files | Refs | Submodules | LICENSE

255 (4169B)

      1 #!/usr/bin/env python3
      2 # group: rw quick
      3 #
      4 # Test commit job graph modifications while requests are active
      5 #
      6 # Copyright (C) 2019 Red Hat, Inc.
      7 #
      8 # Creator/Owner: Kevin Wolf <kwolf@redhat.com>
      9 #
     10 # This program is free software; you can redistribute it and/or modify
     11 # it under the terms of the GNU General Public License as published by
     12 # the Free Software Foundation; either version 2 of the License, or
     13 # (at your option) any later version.
     14 #
     15 # This program is distributed in the hope that it will be useful,
     16 # but WITHOUT ANY WARRANTY; without even the implied warranty of
     17 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     18 # GNU General Public License for more details.
     19 #
     20 # You should have received a copy of the GNU General Public License
     21 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
     22 #
     23 
     24 import iotests
     25 from iotests import imgfmt
     26 
     27 iotests.script_initialize(supported_fmts=['qcow2'])
     28 
     29 iotests.log('Finishing a commit job with background reads')
     30 iotests.log('============================================')
     31 iotests.log('')
     32 
     33 with iotests.FilePath('t.qcow2') as disk_path, \
     34      iotests.FilePath('t.qcow2.mid') as mid_path, \
     35      iotests.FilePath('t.qcow2.base') as base_path, \
     36      iotests.VM() as vm:
     37 
     38     iotests.log("=== Create backing chain and start VM ===")
     39     iotests.log("")
     40 
     41     size = 128 * 1024 * 1024
     42     size_str = str(size)
     43 
     44     iotests.create_image(base_path, size)
     45     iotests.qemu_img_create('-f', iotests.imgfmt, mid_path, size_str)
     46     iotests.qemu_img_create('-f', iotests.imgfmt, disk_path, size_str)
     47 
     48     # Create a backing chain like this:
     49     # base <- [throttled: bps-read=4096] <- mid <- overlay
     50 
     51     vm.add_object('throttle-group,x-bps-read=4096,id=throttle0')
     52     vm.add_blockdev('file,filename=%s,node-name=base' % (base_path))
     53     vm.add_blockdev('throttle,throttle-group=throttle0,file=base,node-name=throttled')
     54     vm.add_blockdev('file,filename=%s,node-name=mid-file' % (mid_path))
     55     vm.add_blockdev('qcow2,file=mid-file,node-name=mid,backing=throttled')
     56     vm.add_drive_raw('if=none,id=overlay,driver=qcow2,file=%s,backing=mid' % (disk_path))
     57 
     58     vm.launch()
     59 
     60     iotests.log("=== Start background read requests ===")
     61     iotests.log("")
     62 
     63     def start_requests():
     64         vm.hmp_qemu_io('overlay', 'aio_read 0 4k')
     65         vm.hmp_qemu_io('overlay', 'aio_read 0 4k')
     66 
     67     start_requests()
     68 
     69     iotests.log("=== Run a commit job ===")
     70     iotests.log("")
     71 
     72     result = vm.qmp_log('block-commit', job_id='job0', auto_finalize=False,
     73                         device='overlay', top_node='mid')
     74 
     75     vm.run_job('job0', auto_finalize=False, pre_finalize=start_requests,
     76                 auto_dismiss=True)
     77 
     78     vm.shutdown()
     79 
     80 iotests.log('')
     81 iotests.log('Closing the VM while a job is being cancelled')
     82 iotests.log('=============================================')
     83 iotests.log('')
     84 
     85 with iotests.FilePath('src.qcow2') as src_path, \
     86      iotests.FilePath('dst.qcow2') as dst_path, \
     87      iotests.VM() as vm:
     88 
     89     iotests.log('=== Create images and start VM ===')
     90     iotests.log('')
     91 
     92     size = 128 * 1024 * 1024
     93     size_str = str(size)
     94 
     95     iotests.qemu_img_create('-f', iotests.imgfmt, src_path, size_str)
     96     iotests.qemu_img_create('-f', iotests.imgfmt, dst_path, size_str)
     97 
     98     iotests.qemu_io_log('-f', iotests.imgfmt, '-c', 'write 0 1M', src_path),
     99 
    100     vm.add_object('throttle-group,x-bps-read=4096,id=throttle0')
    101 
    102     vm.add_blockdev('file,node-name=src-file,filename=%s' % (src_path))
    103     vm.add_blockdev('%s,node-name=src,file=src-file' % (iotests.imgfmt))
    104 
    105     vm.add_blockdev('file,node-name=dst-file,filename=%s' % (dst_path))
    106     vm.add_blockdev('%s,node-name=dst,file=dst-file' % (iotests.imgfmt))
    107 
    108     vm.add_blockdev('throttle,node-name=src-throttled,' +
    109                     'throttle-group=throttle0,file=src')
    110 
    111     vm.add_device('virtio-blk,drive=src-throttled')
    112 
    113     vm.launch()
    114 
    115     iotests.log('=== Start a mirror job ===')
    116     iotests.log('')
    117 
    118     vm.qmp_log('blockdev-mirror', job_id='job0', device='src-throttled',
    119                                   target='dst', sync='full')
    120 
    121     vm.qmp_log('block-job-cancel', device='job0')
    122     vm.qmp_log('quit')
    123 
    124     vm.shutdown()