1 /* 2 * QEMU host block devices 3 * 4 * Copyright (c) 2003-2008 Fabrice Bellard 5 * 6 * This work is licensed under the terms of the GNU GPL, version 2 or 7 * later. See the COPYING file in the top-level directory. 8 */ 9 10 #include "block.h" 11 #include "blockdev.h" 12 #include "monitor.h" 13 #include "qerror.h" 14 #include "qemu-option.h" 15 #include "qemu-config.h" 16 #include "qemu-objects.h" 17 #include "sysemu.h" 18 #include "block_int.h" 19 #include "qmp-commands.h" 20 #include "trace.h" 21 22 static QTAILQ_HEAD(drivelist, DriveInfo) drives = QTAILQ_HEAD_INITIALIZER(drives); 23 24 static const char *const if_name[IF_COUNT] = { 25 [IF_NONE] = "none", 26 [IF_IDE] = "ide", 27 [IF_SCSI] = "scsi", 28 [IF_FLOPPY] = "floppy", 29 [IF_PFLASH] = "pflash", 30 [IF_MTD] = "mtd", 31 [IF_SD] = "sd", 32 [IF_VIRTIO] = "virtio", 33 [IF_XEN] = "xen", 34 }; 35 36 static const int if_max_devs[IF_COUNT] = { 37 /* 38 * Do not change these numbers! They govern how drive option 39 * index maps to unit and bus. That mapping is ABI. 40 * 41 * All controllers used to imlement if=T drives need to support 42 * if_max_devs[T] units, for any T with if_max_devs[T] != 0. 43 * Otherwise, some index values map to "impossible" bus, unit 44 * values. 45 * 46 * For instance, if you change [IF_SCSI] to 255, -drive 47 * if=scsi,index=12 no longer means bus=1,unit=5, but 48 * bus=0,unit=12. With an lsi53c895a controller (7 units max), 49 * the drive can't be set up. Regression. 50 */ 51 [IF_IDE] = 2, 52 [IF_SCSI] = 7, 53 }; 54 55 /* 56 * We automatically delete the drive when a device using it gets 57 * unplugged. Questionable feature, but we can't just drop it. 58 * Device models call blockdev_mark_auto_del() to schedule the 59 * automatic deletion, and generic qdev code calls blockdev_auto_del() 60 * when deletion is actually safe. 61 */ 62 void blockdev_mark_auto_del(BlockDriverState *bs) 63 { 64 DriveInfo *dinfo = drive_get_by_blockdev(bs); 65 66 if (dinfo) { 67 dinfo->auto_del = 1; 68 } 69 } 70 71 void blockdev_auto_del(BlockDriverState *bs) 72 { 73 DriveInfo *dinfo = drive_get_by_blockdev(bs); 74 75 if (dinfo && dinfo->auto_del) { 76 drive_put_ref(dinfo); 77 } 78 } 79 80 static int drive_index_to_bus_id(BlockInterfaceType type, int index) 81 { 82 int max_devs = if_max_devs[type]; 83 return max_devs ? index / max_devs : 0; 84 } 85 86 static int drive_index_to_unit_id(BlockInterfaceType type, int index) 87 { 88 int max_devs = if_max_devs[type]; 89 return max_devs ? index % max_devs : index; 90 } 91 92 QemuOpts *drive_def(const char *optstr) 93 { 94 return qemu_opts_parse(qemu_find_opts("drive"), optstr, 0); 95 } 96 97 QemuOpts *drive_add(BlockInterfaceType type, int index, const char *file, 98 const char *optstr) 99 { 100 QemuOpts *opts; 101 char buf[32]; 102 103 opts = drive_def(optstr); 104 if (!opts) { 105 return NULL; 106 } 107 if (type != IF_DEFAULT) { 108 qemu_opt_set(opts, "if", if_name[type]); 109 } 110 if (index >= 0) { 111 snprintf(buf, sizeof(buf), "%d", index); 112 qemu_opt_set(opts, "index", buf); 113 } 114 if (file) 115 qemu_opt_set(opts, "file", file); 116 return opts; 117 } 118 119 DriveInfo *drive_get(BlockInterfaceType type, int bus, int unit) 120 { 121 DriveInfo *dinfo; 122 123 /* seek interface, bus and unit */ 124 125 QTAILQ_FOREACH(dinfo, &drives, next) { 126 if (dinfo->type == type && 127 dinfo->bus == bus && 128 dinfo->unit == unit) 129 return dinfo; 130 } 131 132 return NULL; 133 } 134 135 DriveInfo *drive_get_by_index(BlockInterfaceType type, int index) 136 { 137 return drive_get(type, 138 drive_index_to_bus_id(type, index), 139 drive_index_to_unit_id(type, index)); 140 } 141 142 int drive_get_max_bus(BlockInterfaceType type) 143 { 144 int max_bus; 145 DriveInfo *dinfo; 146 147 max_bus = -1; 148 QTAILQ_FOREACH(dinfo, &drives, next) { 149 if(dinfo->type == type && 150 dinfo->bus > max_bus) 151 max_bus = dinfo->bus; 152 } 153 return max_bus; 154 } 155 156 /* Get a block device. This should only be used for single-drive devices 157 (e.g. SD/Floppy/MTD). Multi-disk devices (scsi/ide) should use the 158 appropriate bus. */ 159 DriveInfo *drive_get_next(BlockInterfaceType type) 160 { 161 static int next_block_unit[IF_COUNT]; 162 163 return drive_get(type, 0, next_block_unit[type]++); 164 } 165 166 DriveInfo *drive_get_by_blockdev(BlockDriverState *bs) 167 { 168 DriveInfo *dinfo; 169 170 QTAILQ_FOREACH(dinfo, &drives, next) { 171 if (dinfo->bdrv == bs) { 172 return dinfo; 173 } 174 } 175 return NULL; 176 } 177 178 static void bdrv_format_print(void *opaque, const char *name) 179 { 180 error_printf(" %s", name); 181 } 182 183 static void drive_uninit(DriveInfo *dinfo) 184 { 185 qemu_opts_del(dinfo->opts); 186 bdrv_delete(dinfo->bdrv); 187 g_free(dinfo->id); 188 QTAILQ_REMOVE(&drives, dinfo, next); 189 g_free(dinfo); 190 } 191 192 void drive_put_ref(DriveInfo *dinfo) 193 { 194 assert(dinfo->refcount); 195 if (--dinfo->refcount == 0) { 196 drive_uninit(dinfo); 197 } 198 } 199 200 void drive_get_ref(DriveInfo *dinfo) 201 { 202 dinfo->refcount++; 203 } 204 205 typedef struct { 206 QEMUBH *bh; 207 DriveInfo *dinfo; 208 } DrivePutRefBH; 209 210 static void drive_put_ref_bh(void *opaque) 211 { 212 DrivePutRefBH *s = opaque; 213 214 drive_put_ref(s->dinfo); 215 qemu_bh_delete(s->bh); 216 g_free(s); 217 } 218 219 /* 220 * Release a drive reference in a BH 221 * 222 * It is not possible to use drive_put_ref() from a callback function when the 223 * callers still need the drive. In such cases we schedule a BH to release the 224 * reference. 225 */ 226 static void drive_put_ref_bh_schedule(DriveInfo *dinfo) 227 { 228 DrivePutRefBH *s; 229 230 s = g_new(DrivePutRefBH, 1); 231 s->bh = qemu_bh_new(drive_put_ref_bh, s); 232 s->dinfo = dinfo; 233 qemu_bh_schedule(s->bh); 234 } 235 236 static int parse_block_error_action(const char *buf, int is_read) 237 { 238 if (!strcmp(buf, "ignore")) { 239 return BLOCK_ERR_IGNORE; 240 } else if (!is_read && !strcmp(buf, "enospc")) { 241 return BLOCK_ERR_STOP_ENOSPC; 242 } else if (!strcmp(buf, "stop")) { 243 return BLOCK_ERR_STOP_ANY; 244 } else if (!strcmp(buf, "report")) { 245 return BLOCK_ERR_REPORT; 246 } else { 247 error_report("'%s' invalid %s error action", 248 buf, is_read ? "read" : "write"); 249 return -1; 250 } 251 } 252 253 static bool do_check_io_limits(BlockIOLimit *io_limits) 254 { 255 bool bps_flag; 256 bool iops_flag; 257 258 assert(io_limits); 259 260 bps_flag = (io_limits->bps[BLOCK_IO_LIMIT_TOTAL] != 0) 261 && ((io_limits->bps[BLOCK_IO_LIMIT_READ] != 0) 262 || (io_limits->bps[BLOCK_IO_LIMIT_WRITE] != 0)); 263 iops_flag = (io_limits->iops[BLOCK_IO_LIMIT_TOTAL] != 0) 264 && ((io_limits->iops[BLOCK_IO_LIMIT_READ] != 0) 265 || (io_limits->iops[BLOCK_IO_LIMIT_WRITE] != 0)); 266 if (bps_flag || iops_flag) { 267 return false; 268 } 269 270 return true; 271 } 272 273 DriveInfo *drive_init(QemuOpts *opts, int default_to_scsi) 274 { 275 const char *buf; 276 const char *file = NULL; 277 char devname[128]; 278 const char *serial; 279 const char *mediastr = ""; 280 BlockInterfaceType type; 281 enum { MEDIA_DISK, MEDIA_CDROM } media; 282 int bus_id, unit_id; 283 int cyls, heads, secs, translation; 284 BlockDriver *drv = NULL; 285 int max_devs; 286 int index; 287 int ro = 0; 288 int bdrv_flags = 0; 289 int on_read_error, on_write_error; 290 const char *devaddr; 291 DriveInfo *dinfo; 292 BlockIOLimit io_limits; 293 int snapshot = 0; 294 bool copy_on_read; 295 int ret; 296 297 translation = BIOS_ATA_TRANSLATION_AUTO; 298 media = MEDIA_DISK; 299 300 /* extract parameters */ 301 bus_id = qemu_opt_get_number(opts, "bus", 0); 302 unit_id = qemu_opt_get_number(opts, "unit", -1); 303 index = qemu_opt_get_number(opts, "index", -1); 304 305 cyls = qemu_opt_get_number(opts, "cyls", 0); 306 heads = qemu_opt_get_number(opts, "heads", 0); 307 secs = qemu_opt_get_number(opts, "secs", 0); 308 309 snapshot = qemu_opt_get_bool(opts, "snapshot", 0); 310 ro = qemu_opt_get_bool(opts, "readonly", 0); 311 copy_on_read = qemu_opt_get_bool(opts, "copy-on-read", false); 312 313 file = qemu_opt_get(opts, "file"); 314 serial = qemu_opt_get(opts, "serial"); 315 316 if ((buf = qemu_opt_get(opts, "if")) != NULL) { 317 pstrcpy(devname, sizeof(devname), buf); 318 for (type = 0; type < IF_COUNT && strcmp(buf, if_name[type]); type++) 319 ; 320 if (type == IF_COUNT) { 321 error_report("unsupported bus type '%s'", buf); 322 return NULL; 323 } 324 } else { 325 type = default_to_scsi ? IF_SCSI : IF_IDE; 326 pstrcpy(devname, sizeof(devname), if_name[type]); 327 } 328 329 max_devs = if_max_devs[type]; 330 331 if (cyls || heads || secs) { 332 if (cyls < 1 || (type == IF_IDE && cyls > 16383)) { 333 error_report("invalid physical cyls number"); 334 return NULL; 335 } 336 if (heads < 1 || (type == IF_IDE && heads > 16)) { 337 error_report("invalid physical heads number"); 338 return NULL; 339 } 340 if (secs < 1 || (type == IF_IDE && secs > 63)) { 341 error_report("invalid physical secs number"); 342 return NULL; 343 } 344 } 345 346 if ((buf = qemu_opt_get(opts, "trans")) != NULL) { 347 if (!cyls) { 348 error_report("'%s' trans must be used with cyls, heads and secs", 349 buf); 350 return NULL; 351 } 352 if (!strcmp(buf, "none")) 353 translation = BIOS_ATA_TRANSLATION_NONE; 354 else if (!strcmp(buf, "lba")) 355 translation = BIOS_ATA_TRANSLATION_LBA; 356 else if (!strcmp(buf, "auto")) 357 translation = BIOS_ATA_TRANSLATION_AUTO; 358 else { 359 error_report("'%s' invalid translation type", buf); 360 return NULL; 361 } 362 } 363 364 if ((buf = qemu_opt_get(opts, "media")) != NULL) { 365 if (!strcmp(buf, "disk")) { 366 media = MEDIA_DISK; 367 } else if (!strcmp(buf, "cdrom")) { 368 if (cyls || secs || heads) { 369 error_report("CHS can't be set with media=%s", buf); 370 return NULL; 371 } 372 media = MEDIA_CDROM; 373 } else { 374 error_report("'%s' invalid media", buf); 375 return NULL; 376 } 377 } 378 379 if ((buf = qemu_opt_get(opts, "cache")) != NULL) { 380 if (bdrv_parse_cache_flags(buf, &bdrv_flags) != 0) { 381 error_report("invalid cache option"); 382 return NULL; 383 } 384 } 385 386 #ifdef CONFIG_LINUX_AIO 387 if ((buf = qemu_opt_get(opts, "aio")) != NULL) { 388 if (!strcmp(buf, "native")) { 389 bdrv_flags |= BDRV_O_NATIVE_AIO; 390 } else if (!strcmp(buf, "threads")) { 391 /* this is the default */ 392 } else { 393 error_report("invalid aio option"); 394 return NULL; 395 } 396 } 397 #endif 398 399 if ((buf = qemu_opt_get(opts, "format")) != NULL) { 400 if (strcmp(buf, "?") == 0) { 401 error_printf("Supported formats:"); 402 bdrv_iterate_format(bdrv_format_print, NULL); 403 error_printf("\n"); 404 return NULL; 405 } 406 drv = bdrv_find_whitelisted_format(buf); 407 if (!drv) { 408 error_report("'%s' invalid format", buf); 409 return NULL; 410 } 411 } 412 413 /* disk I/O throttling */ 414 io_limits.bps[BLOCK_IO_LIMIT_TOTAL] = 415 qemu_opt_get_number(opts, "bps", 0); 416 io_limits.bps[BLOCK_IO_LIMIT_READ] = 417 qemu_opt_get_number(opts, "bps_rd", 0); 418 io_limits.bps[BLOCK_IO_LIMIT_WRITE] = 419 qemu_opt_get_number(opts, "bps_wr", 0); 420 io_limits.iops[BLOCK_IO_LIMIT_TOTAL] = 421 qemu_opt_get_number(opts, "iops", 0); 422 io_limits.iops[BLOCK_IO_LIMIT_READ] = 423 qemu_opt_get_number(opts, "iops_rd", 0); 424 io_limits.iops[BLOCK_IO_LIMIT_WRITE] = 425 qemu_opt_get_number(opts, "iops_wr", 0); 426 427 if (!do_check_io_limits(&io_limits)) { 428 error_report("bps(iops) and bps_rd/bps_wr(iops_rd/iops_wr) " 429 "cannot be used at the same time"); 430 return NULL; 431 } 432 433 on_write_error = BLOCK_ERR_STOP_ENOSPC; 434 if ((buf = qemu_opt_get(opts, "werror")) != NULL) { 435 if (type != IF_IDE && type != IF_SCSI && type != IF_VIRTIO && type != IF_NONE) { 436 error_report("werror is not supported by this bus type"); 437 return NULL; 438 } 439 440 on_write_error = parse_block_error_action(buf, 0); 441 if (on_write_error < 0) { 442 return NULL; 443 } 444 } 445 446 on_read_error = BLOCK_ERR_REPORT; 447 if ((buf = qemu_opt_get(opts, "rerror")) != NULL) { 448 if (type != IF_IDE && type != IF_VIRTIO && type != IF_SCSI && type != IF_NONE) { 449 error_report("rerror is not supported by this bus type"); 450 return NULL; 451 } 452 453 on_read_error = parse_block_error_action(buf, 1); 454 if (on_read_error < 0) { 455 return NULL; 456 } 457 } 458 459 if ((devaddr = qemu_opt_get(opts, "addr")) != NULL) { 460 if (type != IF_VIRTIO) { 461 error_report("addr is not supported by this bus type"); 462 return NULL; 463 } 464 } 465 466 /* compute bus and unit according index */ 467 468 if (index != -1) { 469 if (bus_id != 0 || unit_id != -1) { 470 error_report("index cannot be used with bus and unit"); 471 return NULL; 472 } 473 bus_id = drive_index_to_bus_id(type, index); 474 unit_id = drive_index_to_unit_id(type, index); 475 } 476 477 /* if user doesn't specify a unit_id, 478 * try to find the first free 479 */ 480 481 if (unit_id == -1) { 482 unit_id = 0; 483 while (drive_get(type, bus_id, unit_id) != NULL) { 484 unit_id++; 485 if (max_devs && unit_id >= max_devs) { 486 unit_id -= max_devs; 487 bus_id++; 488 } 489 } 490 } 491 492 /* check unit id */ 493 494 if (max_devs && unit_id >= max_devs) { 495 error_report("unit %d too big (max is %d)", 496 unit_id, max_devs - 1); 497 return NULL; 498 } 499 500 /* 501 * catch multiple definitions 502 */ 503 504 if (drive_get(type, bus_id, unit_id) != NULL) { 505 error_report("drive with bus=%d, unit=%d (index=%d) exists", 506 bus_id, unit_id, index); 507 return NULL; 508 } 509 510 /* init */ 511 512 dinfo = g_malloc0(sizeof(*dinfo)); 513 if ((buf = qemu_opts_id(opts)) != NULL) { 514 dinfo->id = g_strdup(buf); 515 } else { 516 /* no id supplied -> create one */ 517 dinfo->id = g_malloc0(32); 518 if (type == IF_IDE || type == IF_SCSI) 519 mediastr = (media == MEDIA_CDROM) ? "-cd" : "-hd"; 520 if (max_devs) 521 snprintf(dinfo->id, 32, "%s%i%s%i", 522 devname, bus_id, mediastr, unit_id); 523 else 524 snprintf(dinfo->id, 32, "%s%s%i", 525 devname, mediastr, unit_id); 526 } 527 dinfo->bdrv = bdrv_new(dinfo->id); 528 dinfo->devaddr = devaddr; 529 dinfo->type = type; 530 dinfo->bus = bus_id; 531 dinfo->unit = unit_id; 532 dinfo->opts = opts; 533 dinfo->refcount = 1; 534 if (serial) 535 strncpy(dinfo->serial, serial, sizeof(dinfo->serial) - 1); 536 QTAILQ_INSERT_TAIL(&drives, dinfo, next); 537 538 bdrv_set_on_error(dinfo->bdrv, on_read_error, on_write_error); 539 540 /* disk I/O throttling */ 541 bdrv_set_io_limits(dinfo->bdrv, &io_limits); 542 543 switch(type) { 544 case IF_IDE: 545 case IF_SCSI: 546 case IF_XEN: 547 case IF_NONE: 548 switch(media) { 549 case MEDIA_DISK: 550 if (cyls != 0) { 551 bdrv_set_geometry_hint(dinfo->bdrv, cyls, heads, secs); 552 bdrv_set_translation_hint(dinfo->bdrv, translation); 553 } 554 break; 555 case MEDIA_CDROM: 556 dinfo->media_cd = 1; 557 break; 558 } 559 break; 560 case IF_SD: 561 case IF_FLOPPY: 562 case IF_PFLASH: 563 case IF_MTD: 564 break; 565 case IF_VIRTIO: 566 /* add virtio block device */ 567 opts = qemu_opts_create(qemu_find_opts("device"), NULL, 0); 568 qemu_opt_set(opts, "driver", "virtio-blk"); 569 qemu_opt_set(opts, "drive", dinfo->id); 570 if (devaddr) 571 qemu_opt_set(opts, "addr", devaddr); 572 break; 573 default: 574 abort(); 575 } 576 if (!file || !*file) { 577 return dinfo; 578 } 579 if (snapshot) { 580 /* always use cache=unsafe with snapshot */ 581 bdrv_flags &= ~BDRV_O_CACHE_MASK; 582 bdrv_flags |= (BDRV_O_SNAPSHOT|BDRV_O_CACHE_WB|BDRV_O_NO_FLUSH); 583 } 584 585 if (copy_on_read) { 586 bdrv_flags |= BDRV_O_COPY_ON_READ; 587 } 588 589 if (media == MEDIA_CDROM) { 590 /* CDROM is fine for any interface, don't check. */ 591 ro = 1; 592 } else if (ro == 1) { 593 if (type != IF_SCSI && type != IF_VIRTIO && type != IF_FLOPPY && type != IF_NONE) { 594 error_report("readonly not supported by this bus type"); 595 goto err; 596 } 597 } 598 599 bdrv_flags |= ro ? 0 : BDRV_O_RDWR; 600 601 ret = bdrv_open(dinfo->bdrv, file, bdrv_flags, drv); 602 if (ret < 0) { 603 error_report("could not open disk image %s: %s", 604 file, strerror(-ret)); 605 goto err; 606 } 607 608 if (bdrv_key_required(dinfo->bdrv)) 609 autostart = 0; 610 return dinfo; 611 612 err: 613 bdrv_delete(dinfo->bdrv); 614 g_free(dinfo->id); 615 QTAILQ_REMOVE(&drives, dinfo, next); 616 g_free(dinfo); 617 return NULL; 618 } 619 620 void do_commit(Monitor *mon, const QDict *qdict) 621 { 622 const char *device = qdict_get_str(qdict, "device"); 623 BlockDriverState *bs; 624 625 if (!strcmp(device, "all")) { 626 bdrv_commit_all(); 627 } else { 628 int ret; 629 630 bs = bdrv_find(device); 631 if (!bs) { 632 qerror_report(QERR_DEVICE_NOT_FOUND, device); 633 return; 634 } 635 ret = bdrv_commit(bs); 636 if (ret == -EBUSY) { 637 qerror_report(QERR_DEVICE_IN_USE, device); 638 return; 639 } 640 } 641 } 642 643 void qmp_blockdev_snapshot_sync(const char *device, const char *snapshot_file, 644 bool has_format, const char *format, 645 Error **errp) 646 { 647 BlockDriverState *bs; 648 BlockDriver *drv, *old_drv, *proto_drv; 649 int ret = 0; 650 int flags; 651 char old_filename[1024]; 652 653 bs = bdrv_find(device); 654 if (!bs) { 655 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 656 return; 657 } 658 if (bdrv_in_use(bs)) { 659 error_set(errp, QERR_DEVICE_IN_USE, device); 660 return; 661 } 662 663 pstrcpy(old_filename, sizeof(old_filename), bs->filename); 664 665 old_drv = bs->drv; 666 flags = bs->open_flags; 667 668 if (!has_format) { 669 format = "qcow2"; 670 } 671 672 drv = bdrv_find_format(format); 673 if (!drv) { 674 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 675 return; 676 } 677 678 proto_drv = bdrv_find_protocol(snapshot_file); 679 if (!proto_drv) { 680 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 681 return; 682 } 683 684 ret = bdrv_img_create(snapshot_file, format, bs->filename, 685 bs->drv->format_name, NULL, -1, flags); 686 if (ret) { 687 error_set(errp, QERR_UNDEFINED_ERROR); 688 return; 689 } 690 691 bdrv_drain_all(); 692 bdrv_flush(bs); 693 694 bdrv_close(bs); 695 ret = bdrv_open(bs, snapshot_file, flags, drv); 696 /* 697 * If reopening the image file we just created fails, fall back 698 * and try to re-open the original image. If that fails too, we 699 * are in serious trouble. 700 */ 701 if (ret != 0) { 702 ret = bdrv_open(bs, old_filename, flags, old_drv); 703 if (ret != 0) { 704 error_set(errp, QERR_OPEN_FILE_FAILED, old_filename); 705 } else { 706 error_set(errp, QERR_OPEN_FILE_FAILED, snapshot_file); 707 } 708 } 709 } 710 711 static void eject_device(BlockDriverState *bs, int force, Error **errp) 712 { 713 if (bdrv_in_use(bs)) { 714 error_set(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 715 return; 716 } 717 if (!bdrv_dev_has_removable_media(bs)) { 718 error_set(errp, QERR_DEVICE_NOT_REMOVABLE, bdrv_get_device_name(bs)); 719 return; 720 } 721 722 if (bdrv_dev_is_medium_locked(bs) && !bdrv_dev_is_tray_open(bs)) { 723 bdrv_dev_eject_request(bs, force); 724 if (!force) { 725 error_set(errp, QERR_DEVICE_LOCKED, bdrv_get_device_name(bs)); 726 return; 727 } 728 } 729 730 bdrv_close(bs); 731 } 732 733 void qmp_eject(const char *device, bool has_force, bool force, Error **errp) 734 { 735 BlockDriverState *bs; 736 737 bs = bdrv_find(device); 738 if (!bs) { 739 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 740 return; 741 } 742 743 eject_device(bs, force, errp); 744 } 745 746 void qmp_block_passwd(const char *device, const char *password, Error **errp) 747 { 748 BlockDriverState *bs; 749 int err; 750 751 bs = bdrv_find(device); 752 if (!bs) { 753 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 754 return; 755 } 756 757 err = bdrv_set_key(bs, password); 758 if (err == -EINVAL) { 759 error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs)); 760 return; 761 } else if (err < 0) { 762 error_set(errp, QERR_INVALID_PASSWORD); 763 return; 764 } 765 } 766 767 static void qmp_bdrv_open_encrypted(BlockDriverState *bs, const char *filename, 768 int bdrv_flags, BlockDriver *drv, 769 const char *password, Error **errp) 770 { 771 if (bdrv_open(bs, filename, bdrv_flags, drv) < 0) { 772 error_set(errp, QERR_OPEN_FILE_FAILED, filename); 773 return; 774 } 775 776 if (bdrv_key_required(bs)) { 777 if (password) { 778 if (bdrv_set_key(bs, password) < 0) { 779 error_set(errp, QERR_INVALID_PASSWORD); 780 } 781 } else { 782 error_set(errp, QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs), 783 bdrv_get_encrypted_filename(bs)); 784 } 785 } else if (password) { 786 error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs)); 787 } 788 } 789 790 void qmp_change_blockdev(const char *device, const char *filename, 791 bool has_format, const char *format, Error **errp) 792 { 793 BlockDriverState *bs; 794 BlockDriver *drv = NULL; 795 int bdrv_flags; 796 Error *err = NULL; 797 798 bs = bdrv_find(device); 799 if (!bs) { 800 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 801 return; 802 } 803 804 if (format) { 805 drv = bdrv_find_whitelisted_format(format); 806 if (!drv) { 807 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 808 return; 809 } 810 } 811 812 eject_device(bs, 0, &err); 813 if (error_is_set(&err)) { 814 error_propagate(errp, err); 815 return; 816 } 817 818 bdrv_flags = bdrv_is_read_only(bs) ? 0 : BDRV_O_RDWR; 819 bdrv_flags |= bdrv_is_snapshot(bs) ? BDRV_O_SNAPSHOT : 0; 820 821 qmp_bdrv_open_encrypted(bs, filename, bdrv_flags, drv, NULL, errp); 822 } 823 824 /* throttling disk I/O limits */ 825 void qmp_block_set_io_throttle(const char *device, int64_t bps, int64_t bps_rd, 826 int64_t bps_wr, int64_t iops, int64_t iops_rd, 827 int64_t iops_wr, Error **errp) 828 { 829 BlockIOLimit io_limits; 830 BlockDriverState *bs; 831 832 bs = bdrv_find(device); 833 if (!bs) { 834 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 835 return; 836 } 837 838 io_limits.bps[BLOCK_IO_LIMIT_TOTAL] = bps; 839 io_limits.bps[BLOCK_IO_LIMIT_READ] = bps_rd; 840 io_limits.bps[BLOCK_IO_LIMIT_WRITE] = bps_wr; 841 io_limits.iops[BLOCK_IO_LIMIT_TOTAL]= iops; 842 io_limits.iops[BLOCK_IO_LIMIT_READ] = iops_rd; 843 io_limits.iops[BLOCK_IO_LIMIT_WRITE]= iops_wr; 844 845 if (!do_check_io_limits(&io_limits)) { 846 error_set(errp, QERR_INVALID_PARAMETER_COMBINATION); 847 return; 848 } 849 850 bs->io_limits = io_limits; 851 bs->slice_time = BLOCK_IO_SLICE_TIME; 852 853 if (!bs->io_limits_enabled && bdrv_io_limits_enabled(bs)) { 854 bdrv_io_limits_enable(bs); 855 } else if (bs->io_limits_enabled && !bdrv_io_limits_enabled(bs)) { 856 bdrv_io_limits_disable(bs); 857 } else { 858 if (bs->block_timer) { 859 qemu_mod_timer(bs->block_timer, qemu_get_clock_ns(vm_clock)); 860 } 861 } 862 } 863 864 int do_drive_del(Monitor *mon, const QDict *qdict, QObject **ret_data) 865 { 866 const char *id = qdict_get_str(qdict, "id"); 867 BlockDriverState *bs; 868 869 bs = bdrv_find(id); 870 if (!bs) { 871 qerror_report(QERR_DEVICE_NOT_FOUND, id); 872 return -1; 873 } 874 if (bdrv_in_use(bs)) { 875 qerror_report(QERR_DEVICE_IN_USE, id); 876 return -1; 877 } 878 879 /* quiesce block driver; prevent further io */ 880 bdrv_drain_all(); 881 bdrv_flush(bs); 882 bdrv_close(bs); 883 884 /* if we have a device attached to this BlockDriverState 885 * then we need to make the drive anonymous until the device 886 * can be removed. If this is a drive with no device backing 887 * then we can just get rid of the block driver state right here. 888 */ 889 if (bdrv_get_attached_dev(bs)) { 890 bdrv_make_anon(bs); 891 } else { 892 drive_uninit(drive_get_by_blockdev(bs)); 893 } 894 895 return 0; 896 } 897 898 void qmp_block_resize(const char *device, int64_t size, Error **errp) 899 { 900 BlockDriverState *bs; 901 902 bs = bdrv_find(device); 903 if (!bs) { 904 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 905 return; 906 } 907 908 if (size < 0) { 909 error_set(errp, QERR_INVALID_PARAMETER_VALUE, "size", "a >0 size"); 910 return; 911 } 912 913 switch (bdrv_truncate(bs, size)) { 914 case 0: 915 break; 916 case -ENOMEDIUM: 917 error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device); 918 break; 919 case -ENOTSUP: 920 error_set(errp, QERR_UNSUPPORTED); 921 break; 922 case -EACCES: 923 error_set(errp, QERR_DEVICE_IS_READ_ONLY, device); 924 break; 925 case -EBUSY: 926 error_set(errp, QERR_DEVICE_IN_USE, device); 927 break; 928 default: 929 error_set(errp, QERR_UNDEFINED_ERROR); 930 break; 931 } 932 } 933 934 static QObject *qobject_from_block_job(BlockJob *job) 935 { 936 return qobject_from_jsonf("{ 'type': %s," 937 "'device': %s," 938 "'len': %" PRId64 "," 939 "'offset': %" PRId64 "," 940 "'speed': %" PRId64 " }", 941 job->job_type->job_type, 942 bdrv_get_device_name(job->bs), 943 job->len, 944 job->offset, 945 job->speed); 946 } 947 948 static void block_stream_cb(void *opaque, int ret) 949 { 950 BlockDriverState *bs = opaque; 951 QObject *obj; 952 953 trace_block_stream_cb(bs, bs->job, ret); 954 955 assert(bs->job); 956 obj = qobject_from_block_job(bs->job); 957 if (ret < 0) { 958 QDict *dict = qobject_to_qdict(obj); 959 qdict_put(dict, "error", qstring_from_str(strerror(-ret))); 960 } 961 962 if (block_job_is_cancelled(bs->job)) { 963 monitor_protocol_event(QEVENT_BLOCK_JOB_CANCELLED, obj); 964 } else { 965 monitor_protocol_event(QEVENT_BLOCK_JOB_COMPLETED, obj); 966 } 967 qobject_decref(obj); 968 969 drive_put_ref_bh_schedule(drive_get_by_blockdev(bs)); 970 } 971 972 void qmp_block_stream(const char *device, bool has_base, 973 const char *base, Error **errp) 974 { 975 BlockDriverState *bs; 976 BlockDriverState *base_bs = NULL; 977 int ret; 978 979 bs = bdrv_find(device); 980 if (!bs) { 981 error_set(errp, QERR_DEVICE_NOT_FOUND, device); 982 return; 983 } 984 985 if (base) { 986 base_bs = bdrv_find_backing_image(bs, base); 987 if (base_bs == NULL) { 988 error_set(errp, QERR_BASE_NOT_FOUND, base); 989 return; 990 } 991 } 992 993 ret = stream_start(bs, base_bs, base, block_stream_cb, bs); 994 if (ret < 0) { 995 switch (ret) { 996 case -EBUSY: 997 error_set(errp, QERR_DEVICE_IN_USE, device); 998 return; 999 default: 1000 error_set(errp, QERR_NOT_SUPPORTED); 1001 return; 1002 } 1003 } 1004 1005 /* Grab a reference so hotplug does not delete the BlockDriverState from 1006 * underneath us. 1007 */ 1008 drive_get_ref(drive_get_by_blockdev(bs)); 1009 1010 trace_qmp_block_stream(bs, bs->job); 1011 } 1012 1013 static BlockJob *find_block_job(const char *device) 1014 { 1015 BlockDriverState *bs; 1016 1017 bs = bdrv_find(device); 1018 if (!bs || !bs->job) { 1019 return NULL; 1020 } 1021 return bs->job; 1022 } 1023 1024 void qmp_block_job_set_speed(const char *device, int64_t value, Error **errp) 1025 { 1026 BlockJob *job = find_block_job(device); 1027 1028 if (!job) { 1029 error_set(errp, QERR_DEVICE_NOT_ACTIVE, device); 1030 return; 1031 } 1032 1033 if (block_job_set_speed(job, value) < 0) { 1034 error_set(errp, QERR_NOT_SUPPORTED); 1035 } 1036 } 1037 1038 void qmp_block_job_cancel(const char *device, Error **errp) 1039 { 1040 BlockJob *job = find_block_job(device); 1041 1042 if (!job) { 1043 error_set(errp, QERR_DEVICE_NOT_ACTIVE, device); 1044 return; 1045 } 1046 1047 trace_qmp_block_job_cancel(job); 1048 block_job_cancel(job); 1049 } 1050 1051 static void do_qmp_query_block_jobs_one(void *opaque, BlockDriverState *bs) 1052 { 1053 BlockJobInfoList **prev = opaque; 1054 BlockJob *job = bs->job; 1055 1056 if (job) { 1057 BlockJobInfoList *elem; 1058 BlockJobInfo *info = g_new(BlockJobInfo, 1); 1059 *info = (BlockJobInfo){ 1060 .type = g_strdup(job->job_type->job_type), 1061 .device = g_strdup(bdrv_get_device_name(bs)), 1062 .len = job->len, 1063 .offset = job->offset, 1064 .speed = job->speed, 1065 }; 1066 1067 elem = g_new0(BlockJobInfoList, 1); 1068 elem->value = info; 1069 1070 (*prev)->next = elem; 1071 *prev = elem; 1072 } 1073 } 1074 1075 BlockJobInfoList *qmp_query_block_jobs(Error **errp) 1076 { 1077 /* Dummy is a fake list element for holding the head pointer */ 1078 BlockJobInfoList dummy = {}; 1079 BlockJobInfoList *prev = &dummy; 1080 bdrv_iterate(do_qmp_query_block_jobs_one, &prev); 1081 return dummy.next; 1082 } 1083