tests/qemu-iotests/218

   1 #!/usr/bin/env python3
   2 # group: rw quick
   3 #
   4 # This test covers what happens when a mirror block job is cancelled
   5 # in various phases of its existence.
   6 #
   7 # Note that this test only checks the emitted events (i.e.
   8 # BLOCK_JOB_COMPLETED vs. BLOCK_JOB_CANCELLED), it does not compare
   9 # whether the target is in sync with the source when the
  10 # BLOCK_JOB_COMPLETED event occurs.  This is covered by other tests
  11 # (such as 041).
  12 #
  13 # Copyright (C) 2018 Red Hat, Inc.
  14 #
  15 # This program is free software; you can redistribute it and/or modify
  16 # it under the terms of the GNU General Public License as published by
  17 # the Free Software Foundation; either version 2 of the License, or
  18 # (at your option) any later version.
  19 #
  20 # This program is distributed in the hope that it will be useful,
  21 # but WITHOUT ANY WARRANTY; without even the implied warranty of
  22 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  23 # GNU General Public License for more details.
  24 #
  25 # You should have received a copy of the GNU General Public License
  26 # along with this program.  If not, see <http://www.gnu.org/licenses/>.
  27 #
  28 # Creator/Owner: Max Reitz <mreitz@redhat.com>
  29
  30 import iotests
  31 from iotests import log, qemu_img, qemu_io_silent
  32
  33 iotests.script_initialize(supported_fmts=['qcow2', 'raw'])
  34
  35
  36 # Launches the VM, adds two null-co nodes (source and target), and
  37 # starts a blockdev-mirror job on them.
  38 #
  39 # Either both or none of speed and buf_size must be given.
  40
  41 def start_mirror(vm, speed=None, buf_size=None):
  42     vm.launch()
  43
  44     ret = vm.qmp('blockdev-add',
  45                      node_name='source',
  46                      driver='null-co',
  47                      size=1048576)
  48     assert ret['return'] == {}
  49
  50     ret = vm.qmp('blockdev-add',
  51                      node_name='target',
  52                      driver='null-co',
  53                      size=1048576)
  54     assert ret['return'] == {}
  55
  56     if speed is not None:
  57         ret = vm.qmp('blockdev-mirror',
  58                          job_id='mirror',
  59                          device='source',
  60                          target='target',
  61                          sync='full',
  62                          speed=speed,
  63                          buf_size=buf_size)
  64     else:
  65         ret = vm.qmp('blockdev-mirror',
  66                          job_id='mirror',
  67                          device='source',
  68                          target='target',
  69                          sync='full')
  70
  71     assert ret['return'] == {}
  72
  73
  74 log('')
  75 log('=== Cancel mirror job before convergence ===')
  76 log('')
  77
  78 log('--- force=false ---')
  79 log('')
  80
  81 with iotests.VM() as vm:
  82     # Low speed so it does not converge
  83     start_mirror(vm, 65536, 65536)
  84
  85     log('Cancelling job')
  86     log(vm.qmp('block-job-cancel', device='mirror', force=False))
  87
  88     log(vm.event_wait('BLOCK_JOB_CANCELLED'),
  89         filters=[iotests.filter_qmp_event])
  90
  91 log('')
  92 log('--- force=true ---')
  93 log('')
  94
  95 with iotests.VM() as vm:
  96     # Low speed so it does not converge
  97     start_mirror(vm, 65536, 65536)
  98
  99     log('Cancelling job')
 100     log(vm.qmp('block-job-cancel', device='mirror', force=True))
 101
 102     log(vm.event_wait('BLOCK_JOB_CANCELLED'),
 103         filters=[iotests.filter_qmp_event])
 104
 105
 106 log('')
 107 log('=== Cancel mirror job after convergence ===')
 108 log('')
 109
 110 log('--- force=false ---')
 111 log('')
 112
 113 with iotests.VM() as vm:
 114     start_mirror(vm)
 115
 116     log(vm.event_wait('BLOCK_JOB_READY'),
 117         filters=[iotests.filter_qmp_event])
 118
 119     log('Cancelling job')
 120     log(vm.qmp('block-job-cancel', device='mirror', force=False))
 121
 122     log(vm.event_wait('BLOCK_JOB_COMPLETED'),
 123         filters=[iotests.filter_qmp_event])
 124
 125 log('')
 126 log('--- force=true ---')
 127 log('')
 128
 129 with iotests.VM() as vm:
 130     start_mirror(vm)
 131
 132     log(vm.event_wait('BLOCK_JOB_READY'),
 133         filters=[iotests.filter_qmp_event])
 134
 135     log('Cancelling job')
 136     log(vm.qmp('block-job-cancel', device='mirror', force=True))
 137
 138     log(vm.event_wait('BLOCK_JOB_CANCELLED'),
 139         filters=[iotests.filter_qmp_event])
 140
 141 log('')
 142 log('=== Cancel mirror job from throttled node by quitting ===')
 143 log('')
 144
 145 with iotests.VM() as vm, \
 146      iotests.FilePath('src.img') as src_img_path:
 147
 148     assert qemu_img('create', '-f', iotests.imgfmt, src_img_path, '64M') == 0
 149     assert qemu_io_silent('-f', iotests.imgfmt, src_img_path,
 150                           '-c', 'write -P 42 0M 64M') == 0
 151
 152     vm.launch()
 153
 154     ret = vm.qmp('object-add', qom_type='throttle-group', id='tg',
 155                  limits={'bps-read': 4096})
 156     assert ret['return'] == {}
 157
 158     ret = vm.qmp('blockdev-add',
 159                  node_name='source',
 160                  driver=iotests.imgfmt,
 161                  file={
 162                      'driver': 'file',
 163                      'filename': src_img_path
 164                  })
 165     assert ret['return'] == {}
 166
 167     ret = vm.qmp('blockdev-add',
 168                  node_name='throttled-source',
 169                  driver='throttle',
 170                  throttle_group='tg',
 171                  file='source')
 172     assert ret['return'] == {}
 173
 174     ret = vm.qmp('blockdev-add',
 175                  node_name='target',
 176                  driver='null-co',
 177                  size=(64 * 1048576))
 178     assert ret['return'] == {}
 179
 180     ret = vm.qmp('blockdev-mirror',
 181                  job_id='mirror',
 182                  device='throttled-source',
 183                  target='target',
 184                  sync='full')
 185     assert ret['return'] == {}
 186
 187     log(vm.qmp('quit'))
 188
 189     with iotests.Timeout(5, 'Timeout waiting for VM to quit'):
 190         vm.shutdown(has_quit=True)