1#!/usr/bin/env python3 2# 3# Test case for the QMP 'change' command and all other associated 4# commands 5# 6# Copyright (C) 2015 Red Hat, Inc. 7# 8# This program is free software; you can redistribute it and/or modify 9# it under the terms of the GNU General Public License as published by 10# the Free Software Foundation; either version 2 of the License, or 11# (at your option) any later version. 12# 13# This program is distributed in the hope that it will be useful, 14# but WITHOUT ANY WARRANTY; without even the implied warranty of 15# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 16# GNU General Public License for more details. 17# 18# You should have received a copy of the GNU General Public License 19# along with this program. If not, see <http://www.gnu.org/licenses/>. 20# 21 22import os 23import stat 24import time 25import iotests 26from iotests import qemu_img 27 28old_img = os.path.join(iotests.test_dir, 'test0.img') 29new_img = os.path.join(iotests.test_dir, 'test1.img') 30 31def interface_to_device_name(interface): 32 if interface == 'ide': 33 return 'ide-cd' 34 elif interface == 'floppy': 35 return 'floppy' 36 elif interface == 'scsi': 37 return 'scsi-cd' 38 else: 39 return None 40 41class ChangeBaseClass(iotests.QMPTestCase): 42 has_opened = False 43 has_closed = False 44 45 device_name = 'qdev0' 46 use_drive = False 47 48 def process_events(self): 49 for event in self.vm.get_qmp_events(wait=False): 50 if (event['event'] == 'DEVICE_TRAY_MOVED' and 51 (event['data']['device'] == 'drive0' or 52 event['data']['id'] == self.device_name)): 53 if event['data']['tray-open'] == False: 54 self.has_closed = True 55 else: 56 self.has_opened = True 57 58 def wait_for_open(self): 59 if not self.has_real_tray: 60 return 61 62 with iotests.Timeout(3, 'Timeout while waiting for the tray to open'): 63 while not self.has_opened: 64 self.process_events() 65 66 def wait_for_close(self): 67 if not self.has_real_tray: 68 return 69 70 with iotests.Timeout(3, 'Timeout while waiting for the tray to close'): 71 while not self.has_closed: 72 self.process_events() 73 74class GeneralChangeTestsBaseClass(ChangeBaseClass): 75 76 def test_change(self): 77 # 'change' requires a drive name, so skip the test for blockdev 78 if not self.use_drive: 79 return 80 81 result = self.vm.qmp('change', device='drive0', target=new_img, 82 arg=iotests.imgfmt) 83 self.assert_qmp(result, 'return', {}) 84 85 self.wait_for_open() 86 self.wait_for_close() 87 88 result = self.vm.qmp('query-block') 89 if self.has_real_tray: 90 self.assert_qmp(result, 'return[0]/tray_open', False) 91 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 92 93 def test_blockdev_change_medium(self): 94 result = self.vm.qmp('blockdev-change-medium', 95 id=self.device_name, filename=new_img, 96 format=iotests.imgfmt) 97 98 self.assert_qmp(result, 'return', {}) 99 100 self.wait_for_open() 101 self.wait_for_close() 102 103 result = self.vm.qmp('query-block') 104 if self.has_real_tray: 105 self.assert_qmp(result, 'return[0]/tray_open', False) 106 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 107 108 def test_eject(self): 109 result = self.vm.qmp('eject', id=self.device_name, force=True) 110 self.assert_qmp(result, 'return', {}) 111 112 self.wait_for_open() 113 114 result = self.vm.qmp('query-block') 115 if self.has_real_tray: 116 self.assert_qmp(result, 'return[0]/tray_open', True) 117 self.assert_qmp_absent(result, 'return[0]/inserted') 118 119 def test_tray_eject_change(self): 120 result = self.vm.qmp('eject', id=self.device_name, force=True) 121 self.assert_qmp(result, 'return', {}) 122 123 self.wait_for_open() 124 125 result = self.vm.qmp('query-block') 126 if self.has_real_tray: 127 self.assert_qmp(result, 'return[0]/tray_open', True) 128 self.assert_qmp_absent(result, 'return[0]/inserted') 129 130 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 131 filename=new_img, format=iotests.imgfmt) 132 self.assert_qmp(result, 'return', {}) 133 134 self.wait_for_close() 135 136 result = self.vm.qmp('query-block') 137 if self.has_real_tray: 138 self.assert_qmp(result, 'return[0]/tray_open', False) 139 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 140 141 def test_tray_open_close(self): 142 result = self.vm.qmp('blockdev-open-tray', 143 id=self.device_name, force=True) 144 self.assert_qmp(result, 'return', {}) 145 146 self.wait_for_open() 147 148 result = self.vm.qmp('query-block') 149 if self.has_real_tray: 150 self.assert_qmp(result, 'return[0]/tray_open', True) 151 if self.was_empty == True: 152 self.assert_qmp_absent(result, 'return[0]/inserted') 153 else: 154 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 155 156 result = self.vm.qmp('blockdev-close-tray', id=self.device_name) 157 self.assert_qmp(result, 'return', {}) 158 159 if self.has_real_tray or not self.was_empty: 160 self.wait_for_close() 161 162 result = self.vm.qmp('query-block') 163 if self.has_real_tray: 164 self.assert_qmp(result, 'return[0]/tray_open', False) 165 if self.was_empty == True: 166 self.assert_qmp_absent(result, 'return[0]/inserted') 167 else: 168 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 169 170 def test_tray_eject_close(self): 171 result = self.vm.qmp('eject', id=self.device_name, force=True) 172 self.assert_qmp(result, 'return', {}) 173 174 self.wait_for_open() 175 176 result = self.vm.qmp('query-block') 177 if self.has_real_tray: 178 self.assert_qmp(result, 'return[0]/tray_open', True) 179 self.assert_qmp_absent(result, 'return[0]/inserted') 180 181 result = self.vm.qmp('blockdev-close-tray', id=self.device_name) 182 self.assert_qmp(result, 'return', {}) 183 184 self.wait_for_close() 185 186 result = self.vm.qmp('query-block') 187 if self.has_real_tray: 188 self.assert_qmp(result, 'return[0]/tray_open', False) 189 self.assert_qmp_absent(result, 'return[0]/inserted') 190 191 def test_tray_open_change(self): 192 result = self.vm.qmp('blockdev-open-tray', id=self.device_name, 193 force=True) 194 self.assert_qmp(result, 'return', {}) 195 196 self.wait_for_open() 197 198 result = self.vm.qmp('query-block') 199 if self.has_real_tray: 200 self.assert_qmp(result, 'return[0]/tray_open', True) 201 if self.was_empty == True: 202 self.assert_qmp_absent(result, 'return[0]/inserted') 203 else: 204 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 205 206 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 207 filename=new_img, 208 format=iotests.imgfmt) 209 self.assert_qmp(result, 'return', {}) 210 211 self.wait_for_close() 212 213 result = self.vm.qmp('query-block') 214 if self.has_real_tray: 215 self.assert_qmp(result, 'return[0]/tray_open', False) 216 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 217 218 def test_cycle(self, read_only_node=False): 219 result = self.vm.qmp('blockdev-add', 220 node_name='new', 221 driver=iotests.imgfmt, 222 read_only=read_only_node, 223 file={'filename': new_img, 224 'driver': 'file'}) 225 self.assert_qmp(result, 'return', {}) 226 227 result = self.vm.qmp('blockdev-open-tray', 228 id=self.device_name, force=True) 229 self.assert_qmp(result, 'return', {}) 230 231 self.wait_for_open() 232 233 result = self.vm.qmp('query-block') 234 if self.has_real_tray: 235 self.assert_qmp(result, 'return[0]/tray_open', True) 236 if self.was_empty == True: 237 self.assert_qmp_absent(result, 'return[0]/inserted') 238 else: 239 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 240 241 result = self.vm.qmp('blockdev-remove-medium', 242 id=self.device_name) 243 self.assert_qmp(result, 'return', {}) 244 245 result = self.vm.qmp('query-block') 246 if self.has_real_tray: 247 self.assert_qmp(result, 'return[0]/tray_open', True) 248 self.assert_qmp_absent(result, 'return[0]/inserted') 249 250 result = self.vm.qmp('blockdev-insert-medium', 251 id=self.device_name, node_name='new') 252 self.assert_qmp(result, 'return', {}) 253 254 result = self.vm.qmp('query-block') 255 if self.has_real_tray: 256 self.assert_qmp(result, 'return[0]/tray_open', True) 257 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 258 259 result = self.vm.qmp('blockdev-close-tray', id=self.device_name) 260 self.assert_qmp(result, 'return', {}) 261 262 self.wait_for_close() 263 264 result = self.vm.qmp('query-block') 265 if self.has_real_tray: 266 self.assert_qmp(result, 'return[0]/tray_open', False) 267 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 268 269 def test_cycle_read_only_media(self): 270 self.test_cycle(True) 271 272 def test_close_on_closed(self): 273 result = self.vm.qmp('blockdev-close-tray', id=self.device_name) 274 # Should be a no-op 275 self.assert_qmp(result, 'return', {}) 276 self.assertEqual(self.vm.get_qmp_events(wait=False), []) 277 278 def test_remove_on_closed(self): 279 if not self.has_real_tray: 280 return 281 282 result = self.vm.qmp('blockdev-remove-medium', id=self.device_name) 283 self.assert_qmp(result, 'error/class', 'GenericError') 284 285 def test_insert_on_closed(self): 286 if not self.has_real_tray: 287 return 288 289 result = self.vm.qmp('blockdev-add', 290 node_name='new', 291 driver=iotests.imgfmt, 292 file={'filename': new_img, 293 'driver': 'file'}) 294 self.assert_qmp(result, 'return', {}) 295 296 result = self.vm.qmp('blockdev-insert-medium', id=self.device_name, 297 node_name='new') 298 self.assert_qmp(result, 'error/class', 'GenericError') 299 300class TestInitiallyFilled(GeneralChangeTestsBaseClass): 301 was_empty = False 302 303 def setUp(self): 304 qemu_img('create', '-f', iotests.imgfmt, old_img, '1440k') 305 qemu_img('create', '-f', iotests.imgfmt, new_img, '1440k') 306 self.vm = iotests.VM() 307 if self.use_drive: 308 self.vm.add_drive(old_img, 'media=%s' % self.media, 'none') 309 else: 310 self.vm.add_blockdev([ 'node-name=drive0', 311 'driver=%s' % iotests.imgfmt, 312 'file.driver=file', 313 'file.filename=%s' % old_img ]) 314 if self.interface == 'scsi': 315 self.vm.add_device('virtio-scsi-pci') 316 self.vm.add_device('%s,drive=drive0,id=%s' % 317 (interface_to_device_name(self.interface), 318 self.device_name)) 319 self.vm.launch() 320 321 def tearDown(self): 322 self.vm.shutdown() 323 os.remove(old_img) 324 os.remove(new_img) 325 326 def test_insert_on_filled(self): 327 result = self.vm.qmp('blockdev-add', 328 node_name='new', 329 driver=iotests.imgfmt, 330 file={'filename': new_img, 331 'driver': 'file'}) 332 self.assert_qmp(result, 'return', {}) 333 334 result = self.vm.qmp('blockdev-open-tray', id=self.device_name) 335 self.assert_qmp(result, 'return', {}) 336 337 self.wait_for_open() 338 339 result = self.vm.qmp('blockdev-insert-medium', id=self.device_name, 340 node_name='new') 341 self.assert_qmp(result, 'error/class', 'GenericError') 342 343class TestInitiallyEmpty(GeneralChangeTestsBaseClass): 344 was_empty = True 345 346 def setUp(self): 347 qemu_img('create', '-f', iotests.imgfmt, new_img, '1440k') 348 self.vm = iotests.VM() 349 if self.use_drive: 350 self.vm.add_drive(None, 'media=%s' % self.media, 'none') 351 if self.interface == 'scsi': 352 self.vm.add_device('virtio-scsi-pci') 353 self.vm.add_device('%s,%sid=%s' % 354 (interface_to_device_name(self.interface), 355 'drive=drive0,' if self.use_drive else '', 356 self.device_name)) 357 self.vm.launch() 358 359 def tearDown(self): 360 self.vm.shutdown() 361 os.remove(new_img) 362 363 def test_remove_on_empty(self): 364 result = self.vm.qmp('blockdev-open-tray', id=self.device_name) 365 self.assert_qmp(result, 'return', {}) 366 367 self.wait_for_open() 368 369 result = self.vm.qmp('blockdev-remove-medium', id=self.device_name) 370 # Should be a no-op 371 self.assert_qmp(result, 'return', {}) 372 373# Do this in a function to avoid leaking variables like case into the global 374# name space (otherwise tests would be run for the abstract base classes) 375def create_basic_test_classes(): 376 for (media, interface, has_real_tray) in [ ('cdrom', 'ide', True), 377 ('cdrom', 'scsi', True), 378 ('disk', 'floppy', False) ]: 379 380 for case in [ TestInitiallyFilled, TestInitiallyEmpty ]: 381 for use_drive in [ True, False ]: 382 attr = { 'media': media, 383 'interface': interface, 384 'has_real_tray': has_real_tray, 385 'use_drive': use_drive } 386 387 name = '%s_%s_%s_%s' % (case.__name__, media, interface, 388 'drive' if use_drive else 'blockdev') 389 globals()[name] = type(name, (case, ), attr) 390 391create_basic_test_classes() 392 393class TestChangeReadOnly(ChangeBaseClass): 394 device_name = 'qdev0' 395 396 def setUp(self): 397 qemu_img('create', '-f', iotests.imgfmt, old_img, '1440k') 398 qemu_img('create', '-f', iotests.imgfmt, new_img, '1440k') 399 self.vm = iotests.VM() 400 401 def tearDown(self): 402 self.vm.shutdown() 403 os.chmod(old_img, 0o666) 404 os.chmod(new_img, 0o666) 405 os.remove(old_img) 406 os.remove(new_img) 407 408 def test_ro_ro_retain(self): 409 os.chmod(old_img, 0o444) 410 os.chmod(new_img, 0o444) 411 self.vm.add_drive(old_img, 'media=disk,read-only=on', 'none') 412 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 413 self.vm.launch() 414 415 result = self.vm.qmp('query-block') 416 self.assert_qmp(result, 'return[0]/inserted/ro', True) 417 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 418 419 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 420 filename=new_img, 421 format=iotests.imgfmt, 422 read_only_mode='retain') 423 self.assert_qmp(result, 'return', {}) 424 425 result = self.vm.qmp('query-block') 426 self.assert_qmp(result, 'return[0]/inserted/ro', True) 427 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 428 429 def test_ro_rw_retain(self): 430 os.chmod(old_img, 0o444) 431 self.vm.add_drive(old_img, 'media=disk,read-only=on', 'none') 432 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 433 self.vm.launch() 434 435 result = self.vm.qmp('query-block') 436 self.assert_qmp(result, 'return[0]/inserted/ro', True) 437 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 438 439 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 440 filename=new_img, 441 format=iotests.imgfmt, 442 read_only_mode='retain') 443 self.assert_qmp(result, 'return', {}) 444 445 result = self.vm.qmp('query-block') 446 self.assert_qmp(result, 'return[0]/inserted/ro', True) 447 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 448 449 @iotests.skip_if_user_is_root 450 def test_rw_ro_retain(self): 451 os.chmod(new_img, 0o444) 452 self.vm.add_drive(old_img, 'media=disk', 'none') 453 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 454 self.vm.launch() 455 456 result = self.vm.qmp('query-block') 457 self.assert_qmp(result, 'return[0]/inserted/ro', False) 458 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 459 460 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 461 filename=new_img, 462 format=iotests.imgfmt, 463 read_only_mode='retain') 464 self.assert_qmp(result, 'error/class', 'GenericError') 465 466 self.assertEqual(self.vm.get_qmp_events(wait=False), []) 467 468 result = self.vm.qmp('query-block') 469 self.assert_qmp(result, 'return[0]/inserted/ro', False) 470 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 471 472 def test_ro_rw(self): 473 os.chmod(old_img, 0o444) 474 self.vm.add_drive(old_img, 'media=disk,read-only=on', 'none') 475 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 476 self.vm.launch() 477 478 result = self.vm.qmp('query-block') 479 self.assert_qmp(result, 'return[0]/inserted/ro', True) 480 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 481 482 result = self.vm.qmp('blockdev-change-medium', 483 id=self.device_name, 484 filename=new_img, 485 format=iotests.imgfmt, 486 read_only_mode='read-write') 487 self.assert_qmp(result, 'return', {}) 488 489 result = self.vm.qmp('query-block') 490 self.assert_qmp(result, 'return[0]/inserted/ro', False) 491 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 492 493 def test_rw_ro(self): 494 os.chmod(new_img, 0o444) 495 self.vm.add_drive(old_img, 'media=disk', 'none') 496 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 497 self.vm.launch() 498 499 result = self.vm.qmp('query-block') 500 self.assert_qmp(result, 'return[0]/inserted/ro', False) 501 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 502 503 result = self.vm.qmp('blockdev-change-medium', 504 id=self.device_name, 505 filename=new_img, 506 format=iotests.imgfmt, 507 read_only_mode='read-only') 508 self.assert_qmp(result, 'return', {}) 509 510 result = self.vm.qmp('query-block') 511 self.assert_qmp(result, 'return[0]/inserted/ro', True) 512 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 513 514 def test_make_rw_ro(self): 515 self.vm.add_drive(old_img, 'media=disk', 'none') 516 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 517 self.vm.launch() 518 519 result = self.vm.qmp('query-block') 520 self.assert_qmp(result, 'return[0]/inserted/ro', False) 521 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 522 523 result = self.vm.qmp('blockdev-change-medium', 524 id=self.device_name, 525 filename=new_img, 526 format=iotests.imgfmt, 527 read_only_mode='read-only') 528 self.assert_qmp(result, 'return', {}) 529 530 result = self.vm.qmp('query-block') 531 self.assert_qmp(result, 'return[0]/inserted/ro', True) 532 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 533 534 @iotests.skip_if_user_is_root 535 def test_make_ro_rw(self): 536 os.chmod(new_img, 0o444) 537 self.vm.add_drive(old_img, 'media=disk', 'none') 538 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 539 self.vm.launch() 540 541 result = self.vm.qmp('query-block') 542 self.assert_qmp(result, 'return[0]/inserted/ro', False) 543 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 544 545 result = self.vm.qmp('blockdev-change-medium', 546 id=self.device_name, 547 filename=new_img, 548 format=iotests.imgfmt, 549 read_only_mode='read-write') 550 self.assert_qmp(result, 'error/class', 'GenericError') 551 552 result = self.vm.qmp('query-block') 553 self.assert_qmp(result, 'return[0]/inserted/ro', False) 554 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 555 556 def test_make_rw_ro_by_retain(self): 557 os.chmod(old_img, 0o444) 558 self.vm.add_drive(old_img, 'media=disk,read-only=on', 'none') 559 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 560 self.vm.launch() 561 562 result = self.vm.qmp('query-block') 563 self.assert_qmp(result, 'return[0]/inserted/ro', True) 564 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 565 566 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 567 filename=new_img, 568 format=iotests.imgfmt, 569 read_only_mode='retain') 570 self.assert_qmp(result, 'return', {}) 571 572 result = self.vm.qmp('query-block') 573 self.assert_qmp(result, 'return[0]/inserted/ro', True) 574 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 575 576 @iotests.skip_if_user_is_root 577 def test_make_ro_rw_by_retain(self): 578 os.chmod(new_img, 0o444) 579 self.vm.add_drive(old_img, 'media=disk', 'none') 580 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 581 self.vm.launch() 582 583 result = self.vm.qmp('query-block') 584 self.assert_qmp(result, 'return[0]/inserted/ro', False) 585 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 586 587 result = self.vm.qmp('blockdev-change-medium', id=self.device_name, 588 filename=new_img, 589 format=iotests.imgfmt, 590 read_only_mode='retain') 591 self.assert_qmp(result, 'error/class', 'GenericError') 592 593 result = self.vm.qmp('query-block') 594 self.assert_qmp(result, 'return[0]/inserted/ro', False) 595 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 596 597 def test_rw_ro_cycle(self): 598 os.chmod(new_img, 0o444) 599 self.vm.add_drive(old_img, 'media=disk', 'none') 600 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 601 self.vm.launch() 602 603 result = self.vm.qmp('query-block') 604 self.assert_qmp(result, 'return[0]/inserted/ro', False) 605 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 606 607 result = self.vm.qmp('blockdev-add', 608 node_name='new', 609 driver=iotests.imgfmt, 610 read_only=True, 611 file={'filename': new_img, 612 'driver': 'file'}) 613 self.assert_qmp(result, 'return', {}) 614 615 result = self.vm.qmp('query-block') 616 self.assert_qmp(result, 'return[0]/inserted/ro', False) 617 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 618 619 result = self.vm.qmp('blockdev-remove-medium', id=self.device_name) 620 self.assert_qmp(result, 'return', {}) 621 622 result = self.vm.qmp('query-block') 623 self.assert_qmp_absent(result, 'return[0]/inserted') 624 625 result = self.vm.qmp('blockdev-insert-medium', id=self.device_name, 626 node_name='new') 627 self.assert_qmp(result, 'return', {}) 628 629 result = self.vm.qmp('query-block') 630 self.assert_qmp(result, 'return[0]/inserted/ro', True) 631 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 632 633 result = self.vm.qmp('query-block') 634 self.assert_qmp(result, 'return[0]/inserted/ro', True) 635 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 636 637GeneralChangeTestsBaseClass = None 638TestInitiallyFilled = None 639TestInitiallyEmpty = None 640 641 642class TestBlockJobsAfterCycle(ChangeBaseClass): 643 device_name = 'qdev0' 644 645 def setUp(self): 646 qemu_img('create', '-f', iotests.imgfmt, old_img, '1440K') 647 648 self.vm = iotests.VM() 649 self.vm.add_drive_raw("id=drive0,driver=null-co,if=none") 650 self.vm.add_device('floppy,drive=drive0,id=%s' % self.device_name) 651 self.vm.launch() 652 653 result = self.vm.qmp('query-block') 654 self.assert_qmp(result, 'return[0]/inserted/image/format', 'null-co') 655 656 # For device-less BBs, calling blockdev-open-tray or blockdev-close-tray 657 # is not necessary 658 result = self.vm.qmp('blockdev-remove-medium', id=self.device_name) 659 self.assert_qmp(result, 'return', {}) 660 661 result = self.vm.qmp('query-block') 662 self.assert_qmp_absent(result, 'return[0]/inserted') 663 664 result = self.vm.qmp('blockdev-add', 665 node_name='node0', 666 driver=iotests.imgfmt, 667 file={'filename': old_img, 668 'driver': 'file'}) 669 self.assert_qmp(result, 'return', {}) 670 671 result = self.vm.qmp('blockdev-insert-medium', id=self.device_name, 672 node_name='node0') 673 self.assert_qmp(result, 'return', {}) 674 675 result = self.vm.qmp('query-block') 676 self.assert_qmp(result, 'return[0]/inserted/image/filename', old_img) 677 678 def tearDown(self): 679 self.vm.shutdown() 680 os.remove(old_img) 681 try: 682 os.remove(new_img) 683 except OSError: 684 pass 685 686 # We need backing file support 687 @iotests.skip_for_formats(('vpc', 'parallels', 'qcow', 'vdi', 'vmdk', 'raw', 688 'vhdx')) 689 def test_snapshot_and_commit(self): 690 result = self.vm.qmp('blockdev-snapshot-sync', device='drive0', 691 snapshot_file=new_img, 692 format=iotests.imgfmt) 693 self.assert_qmp(result, 'return', {}) 694 695 result = self.vm.qmp('query-block') 696 self.assert_qmp(result, 'return[0]/inserted/image/filename', new_img) 697 self.assert_qmp(result, 698 'return[0]/inserted/image/backing-image/filename', 699 old_img) 700 701 result = self.vm.qmp('block-commit', device='drive0') 702 self.assert_qmp(result, 'return', {}) 703 704 self.vm.event_wait(name='BLOCK_JOB_READY') 705 706 result = self.vm.qmp('query-block-jobs') 707 self.assert_qmp(result, 'return[0]/device', 'drive0') 708 709 result = self.vm.qmp('block-job-complete', device='drive0') 710 self.assert_qmp(result, 'return', {}) 711 712 self.vm.event_wait(name='BLOCK_JOB_COMPLETED') 713 714 715if __name__ == '__main__': 716 if iotests.qemu_default_machine != 'pc': 717 # We need floppy and IDE CD-ROM 718 iotests.notrun('not suitable for this machine type: %s' % 719 iotests.qemu_default_machine) 720 # Need to support image creation 721 iotests.main(supported_fmts=['vpc', 'parallels', 'qcow', 'vdi', 'qcow2', 722 'vmdk', 'raw', 'vhdx', 'qed'], 723 supported_protocols=['file']) 724