1666daa68SMarkus Armbruster /* 2666daa68SMarkus Armbruster * QEMU host block devices 3666daa68SMarkus Armbruster * 4666daa68SMarkus Armbruster * Copyright (c) 2003-2008 Fabrice Bellard 5666daa68SMarkus Armbruster * 6666daa68SMarkus Armbruster * This work is licensed under the terms of the GNU GPL, version 2 or 7666daa68SMarkus Armbruster * later. See the COPYING file in the top-level directory. 83618a094SMarkus Armbruster * 93618a094SMarkus Armbruster * This file incorporates work covered by the following copyright and 103618a094SMarkus Armbruster * permission notice: 113618a094SMarkus Armbruster * 123618a094SMarkus Armbruster * Copyright (c) 2003-2008 Fabrice Bellard 133618a094SMarkus Armbruster * 143618a094SMarkus Armbruster * Permission is hereby granted, free of charge, to any person obtaining a copy 153618a094SMarkus Armbruster * of this software and associated documentation files (the "Software"), to deal 163618a094SMarkus Armbruster * in the Software without restriction, including without limitation the rights 173618a094SMarkus Armbruster * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell 183618a094SMarkus Armbruster * copies of the Software, and to permit persons to whom the Software is 193618a094SMarkus Armbruster * furnished to do so, subject to the following conditions: 203618a094SMarkus Armbruster * 213618a094SMarkus Armbruster * The above copyright notice and this permission notice shall be included in 223618a094SMarkus Armbruster * all copies or substantial portions of the Software. 233618a094SMarkus Armbruster * 243618a094SMarkus Armbruster * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR 253618a094SMarkus Armbruster * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, 263618a094SMarkus Armbruster * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL 273618a094SMarkus Armbruster * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER 283618a094SMarkus Armbruster * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, 293618a094SMarkus Armbruster * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN 303618a094SMarkus Armbruster * THE SOFTWARE. 31666daa68SMarkus Armbruster */ 32666daa68SMarkus Armbruster 339c17d615SPaolo Bonzini #include "sysemu/blockdev.h" 340d09e41aSPaolo Bonzini #include "hw/block/block.h" 35737e150eSPaolo Bonzini #include "block/blockjob.h" 3683c9089eSPaolo Bonzini #include "monitor/monitor.h" 377b1b5d19SPaolo Bonzini #include "qapi/qmp/qerror.h" 381de7afc9SPaolo Bonzini #include "qemu/option.h" 391de7afc9SPaolo Bonzini #include "qemu/config-file.h" 407b1b5d19SPaolo Bonzini #include "qapi/qmp/types.h" 419c17d615SPaolo Bonzini #include "sysemu/sysemu.h" 42737e150eSPaolo Bonzini #include "block/block_int.h" 43a4dea8a9SLuiz Capitulino #include "qmp-commands.h" 4412bd451fSStefan Hajnoczi #include "trace.h" 459c17d615SPaolo Bonzini #include "sysemu/arch_init.h" 46666daa68SMarkus Armbruster 47c9b62a7eSMarkus Armbruster static QTAILQ_HEAD(drivelist, DriveInfo) drives = QTAILQ_HEAD_INITIALIZER(drives); 480006383eSKevin Wolf extern QemuOptsList qemu_common_drive_opts; 49666daa68SMarkus Armbruster 501960966dSMarkus Armbruster static const char *const if_name[IF_COUNT] = { 511960966dSMarkus Armbruster [IF_NONE] = "none", 521960966dSMarkus Armbruster [IF_IDE] = "ide", 531960966dSMarkus Armbruster [IF_SCSI] = "scsi", 541960966dSMarkus Armbruster [IF_FLOPPY] = "floppy", 551960966dSMarkus Armbruster [IF_PFLASH] = "pflash", 561960966dSMarkus Armbruster [IF_MTD] = "mtd", 571960966dSMarkus Armbruster [IF_SD] = "sd", 581960966dSMarkus Armbruster [IF_VIRTIO] = "virtio", 591960966dSMarkus Armbruster [IF_XEN] = "xen", 601960966dSMarkus Armbruster }; 611960966dSMarkus Armbruster 621960966dSMarkus Armbruster static const int if_max_devs[IF_COUNT] = { 6327d6bf40SMarkus Armbruster /* 6427d6bf40SMarkus Armbruster * Do not change these numbers! They govern how drive option 6527d6bf40SMarkus Armbruster * index maps to unit and bus. That mapping is ABI. 6627d6bf40SMarkus Armbruster * 6727d6bf40SMarkus Armbruster * All controllers used to imlement if=T drives need to support 6827d6bf40SMarkus Armbruster * if_max_devs[T] units, for any T with if_max_devs[T] != 0. 6927d6bf40SMarkus Armbruster * Otherwise, some index values map to "impossible" bus, unit 7027d6bf40SMarkus Armbruster * values. 7127d6bf40SMarkus Armbruster * 7227d6bf40SMarkus Armbruster * For instance, if you change [IF_SCSI] to 255, -drive 7327d6bf40SMarkus Armbruster * if=scsi,index=12 no longer means bus=1,unit=5, but 7427d6bf40SMarkus Armbruster * bus=0,unit=12. With an lsi53c895a controller (7 units max), 7527d6bf40SMarkus Armbruster * the drive can't be set up. Regression. 7627d6bf40SMarkus Armbruster */ 7727d6bf40SMarkus Armbruster [IF_IDE] = 2, 7827d6bf40SMarkus Armbruster [IF_SCSI] = 7, 791960966dSMarkus Armbruster }; 801960966dSMarkus Armbruster 8114bafc54SMarkus Armbruster /* 8214bafc54SMarkus Armbruster * We automatically delete the drive when a device using it gets 8314bafc54SMarkus Armbruster * unplugged. Questionable feature, but we can't just drop it. 8414bafc54SMarkus Armbruster * Device models call blockdev_mark_auto_del() to schedule the 8514bafc54SMarkus Armbruster * automatic deletion, and generic qdev code calls blockdev_auto_del() 8614bafc54SMarkus Armbruster * when deletion is actually safe. 8714bafc54SMarkus Armbruster */ 8814bafc54SMarkus Armbruster void blockdev_mark_auto_del(BlockDriverState *bs) 8914bafc54SMarkus Armbruster { 9014bafc54SMarkus Armbruster DriveInfo *dinfo = drive_get_by_blockdev(bs); 9114bafc54SMarkus Armbruster 9212bde0eeSPaolo Bonzini if (bs->job) { 9312bde0eeSPaolo Bonzini block_job_cancel(bs->job); 9412bde0eeSPaolo Bonzini } 950fc0f1faSRyan Harper if (dinfo) { 9614bafc54SMarkus Armbruster dinfo->auto_del = 1; 9714bafc54SMarkus Armbruster } 980fc0f1faSRyan Harper } 9914bafc54SMarkus Armbruster 10014bafc54SMarkus Armbruster void blockdev_auto_del(BlockDriverState *bs) 10114bafc54SMarkus Armbruster { 10214bafc54SMarkus Armbruster DriveInfo *dinfo = drive_get_by_blockdev(bs); 10314bafc54SMarkus Armbruster 1040fc0f1faSRyan Harper if (dinfo && dinfo->auto_del) { 10584fb3925SMarcelo Tosatti drive_put_ref(dinfo); 10614bafc54SMarkus Armbruster } 10714bafc54SMarkus Armbruster } 10814bafc54SMarkus Armbruster 109505a7fb1SMarkus Armbruster static int drive_index_to_bus_id(BlockInterfaceType type, int index) 110505a7fb1SMarkus Armbruster { 111505a7fb1SMarkus Armbruster int max_devs = if_max_devs[type]; 112505a7fb1SMarkus Armbruster return max_devs ? index / max_devs : 0; 113505a7fb1SMarkus Armbruster } 114505a7fb1SMarkus Armbruster 115505a7fb1SMarkus Armbruster static int drive_index_to_unit_id(BlockInterfaceType type, int index) 116505a7fb1SMarkus Armbruster { 117505a7fb1SMarkus Armbruster int max_devs = if_max_devs[type]; 118505a7fb1SMarkus Armbruster return max_devs ? index % max_devs : index; 119505a7fb1SMarkus Armbruster } 120505a7fb1SMarkus Armbruster 1212292ddaeSMarkus Armbruster QemuOpts *drive_def(const char *optstr) 1222292ddaeSMarkus Armbruster { 1232292ddaeSMarkus Armbruster return qemu_opts_parse(qemu_find_opts("drive"), optstr, 0); 1242292ddaeSMarkus Armbruster } 1252292ddaeSMarkus Armbruster 1262292ddaeSMarkus Armbruster QemuOpts *drive_add(BlockInterfaceType type, int index, const char *file, 1275645b0f4SMarkus Armbruster const char *optstr) 128666daa68SMarkus Armbruster { 129666daa68SMarkus Armbruster QemuOpts *opts; 1302292ddaeSMarkus Armbruster char buf[32]; 131666daa68SMarkus Armbruster 1322292ddaeSMarkus Armbruster opts = drive_def(optstr); 133666daa68SMarkus Armbruster if (!opts) { 134666daa68SMarkus Armbruster return NULL; 135666daa68SMarkus Armbruster } 1362292ddaeSMarkus Armbruster if (type != IF_DEFAULT) { 1372292ddaeSMarkus Armbruster qemu_opt_set(opts, "if", if_name[type]); 1382292ddaeSMarkus Armbruster } 1392292ddaeSMarkus Armbruster if (index >= 0) { 1402292ddaeSMarkus Armbruster snprintf(buf, sizeof(buf), "%d", index); 1412292ddaeSMarkus Armbruster qemu_opt_set(opts, "index", buf); 1422292ddaeSMarkus Armbruster } 143666daa68SMarkus Armbruster if (file) 144666daa68SMarkus Armbruster qemu_opt_set(opts, "file", file); 145666daa68SMarkus Armbruster return opts; 146666daa68SMarkus Armbruster } 147666daa68SMarkus Armbruster 148666daa68SMarkus Armbruster DriveInfo *drive_get(BlockInterfaceType type, int bus, int unit) 149666daa68SMarkus Armbruster { 150666daa68SMarkus Armbruster DriveInfo *dinfo; 151666daa68SMarkus Armbruster 152666daa68SMarkus Armbruster /* seek interface, bus and unit */ 153666daa68SMarkus Armbruster 154666daa68SMarkus Armbruster QTAILQ_FOREACH(dinfo, &drives, next) { 155666daa68SMarkus Armbruster if (dinfo->type == type && 156666daa68SMarkus Armbruster dinfo->bus == bus && 157666daa68SMarkus Armbruster dinfo->unit == unit) 158666daa68SMarkus Armbruster return dinfo; 159666daa68SMarkus Armbruster } 160666daa68SMarkus Armbruster 161666daa68SMarkus Armbruster return NULL; 162666daa68SMarkus Armbruster } 163666daa68SMarkus Armbruster 164f1bd51acSMarkus Armbruster DriveInfo *drive_get_by_index(BlockInterfaceType type, int index) 165f1bd51acSMarkus Armbruster { 166f1bd51acSMarkus Armbruster return drive_get(type, 167f1bd51acSMarkus Armbruster drive_index_to_bus_id(type, index), 168f1bd51acSMarkus Armbruster drive_index_to_unit_id(type, index)); 169f1bd51acSMarkus Armbruster } 170f1bd51acSMarkus Armbruster 171666daa68SMarkus Armbruster int drive_get_max_bus(BlockInterfaceType type) 172666daa68SMarkus Armbruster { 173666daa68SMarkus Armbruster int max_bus; 174666daa68SMarkus Armbruster DriveInfo *dinfo; 175666daa68SMarkus Armbruster 176666daa68SMarkus Armbruster max_bus = -1; 177666daa68SMarkus Armbruster QTAILQ_FOREACH(dinfo, &drives, next) { 178666daa68SMarkus Armbruster if(dinfo->type == type && 179666daa68SMarkus Armbruster dinfo->bus > max_bus) 180666daa68SMarkus Armbruster max_bus = dinfo->bus; 181666daa68SMarkus Armbruster } 182666daa68SMarkus Armbruster return max_bus; 183666daa68SMarkus Armbruster } 184666daa68SMarkus Armbruster 18513839974SMarkus Armbruster /* Get a block device. This should only be used for single-drive devices 18613839974SMarkus Armbruster (e.g. SD/Floppy/MTD). Multi-disk devices (scsi/ide) should use the 18713839974SMarkus Armbruster appropriate bus. */ 18813839974SMarkus Armbruster DriveInfo *drive_get_next(BlockInterfaceType type) 18913839974SMarkus Armbruster { 19013839974SMarkus Armbruster static int next_block_unit[IF_COUNT]; 19113839974SMarkus Armbruster 19213839974SMarkus Armbruster return drive_get(type, 0, next_block_unit[type]++); 19313839974SMarkus Armbruster } 19413839974SMarkus Armbruster 195e4700e59SMarkus Armbruster DriveInfo *drive_get_by_blockdev(BlockDriverState *bs) 196666daa68SMarkus Armbruster { 197666daa68SMarkus Armbruster DriveInfo *dinfo; 198666daa68SMarkus Armbruster 199666daa68SMarkus Armbruster QTAILQ_FOREACH(dinfo, &drives, next) { 200e4700e59SMarkus Armbruster if (dinfo->bdrv == bs) { 201e4700e59SMarkus Armbruster return dinfo; 202666daa68SMarkus Armbruster } 203e4700e59SMarkus Armbruster } 204e4700e59SMarkus Armbruster return NULL; 205666daa68SMarkus Armbruster } 206666daa68SMarkus Armbruster 207666daa68SMarkus Armbruster static void bdrv_format_print(void *opaque, const char *name) 208666daa68SMarkus Armbruster { 209807105a7SMarkus Armbruster error_printf(" %s", name); 210666daa68SMarkus Armbruster } 211666daa68SMarkus Armbruster 21284fb3925SMarcelo Tosatti static void drive_uninit(DriveInfo *dinfo) 213666daa68SMarkus Armbruster { 214666daa68SMarkus Armbruster qemu_opts_del(dinfo->opts); 215666daa68SMarkus Armbruster bdrv_delete(dinfo->bdrv); 2167267c094SAnthony Liguori g_free(dinfo->id); 217666daa68SMarkus Armbruster QTAILQ_REMOVE(&drives, dinfo, next); 218bb44619bSKevin Wolf g_free(dinfo->serial); 2197267c094SAnthony Liguori g_free(dinfo); 220666daa68SMarkus Armbruster } 221666daa68SMarkus Armbruster 22284fb3925SMarcelo Tosatti void drive_put_ref(DriveInfo *dinfo) 22384fb3925SMarcelo Tosatti { 22484fb3925SMarcelo Tosatti assert(dinfo->refcount); 22584fb3925SMarcelo Tosatti if (--dinfo->refcount == 0) { 22684fb3925SMarcelo Tosatti drive_uninit(dinfo); 22784fb3925SMarcelo Tosatti } 22884fb3925SMarcelo Tosatti } 22984fb3925SMarcelo Tosatti 23084fb3925SMarcelo Tosatti void drive_get_ref(DriveInfo *dinfo) 23184fb3925SMarcelo Tosatti { 23284fb3925SMarcelo Tosatti dinfo->refcount++; 23384fb3925SMarcelo Tosatti } 23484fb3925SMarcelo Tosatti 235aa398a5cSStefan Hajnoczi typedef struct { 236aa398a5cSStefan Hajnoczi QEMUBH *bh; 237aa398a5cSStefan Hajnoczi DriveInfo *dinfo; 238aa398a5cSStefan Hajnoczi } DrivePutRefBH; 239aa398a5cSStefan Hajnoczi 240aa398a5cSStefan Hajnoczi static void drive_put_ref_bh(void *opaque) 241aa398a5cSStefan Hajnoczi { 242aa398a5cSStefan Hajnoczi DrivePutRefBH *s = opaque; 243aa398a5cSStefan Hajnoczi 244aa398a5cSStefan Hajnoczi drive_put_ref(s->dinfo); 245aa398a5cSStefan Hajnoczi qemu_bh_delete(s->bh); 246aa398a5cSStefan Hajnoczi g_free(s); 247aa398a5cSStefan Hajnoczi } 248aa398a5cSStefan Hajnoczi 249aa398a5cSStefan Hajnoczi /* 250aa398a5cSStefan Hajnoczi * Release a drive reference in a BH 251aa398a5cSStefan Hajnoczi * 252aa398a5cSStefan Hajnoczi * It is not possible to use drive_put_ref() from a callback function when the 253aa398a5cSStefan Hajnoczi * callers still need the drive. In such cases we schedule a BH to release the 254aa398a5cSStefan Hajnoczi * reference. 255aa398a5cSStefan Hajnoczi */ 256aa398a5cSStefan Hajnoczi static void drive_put_ref_bh_schedule(DriveInfo *dinfo) 257aa398a5cSStefan Hajnoczi { 258aa398a5cSStefan Hajnoczi DrivePutRefBH *s; 259aa398a5cSStefan Hajnoczi 260aa398a5cSStefan Hajnoczi s = g_new(DrivePutRefBH, 1); 261aa398a5cSStefan Hajnoczi s->bh = qemu_bh_new(drive_put_ref_bh, s); 262aa398a5cSStefan Hajnoczi s->dinfo = dinfo; 263aa398a5cSStefan Hajnoczi qemu_bh_schedule(s->bh); 264aa398a5cSStefan Hajnoczi } 265aa398a5cSStefan Hajnoczi 2661ceee0d5SPaolo Bonzini static int parse_block_error_action(const char *buf, bool is_read) 267666daa68SMarkus Armbruster { 268666daa68SMarkus Armbruster if (!strcmp(buf, "ignore")) { 26992aa5c6dSPaolo Bonzini return BLOCKDEV_ON_ERROR_IGNORE; 270666daa68SMarkus Armbruster } else if (!is_read && !strcmp(buf, "enospc")) { 27192aa5c6dSPaolo Bonzini return BLOCKDEV_ON_ERROR_ENOSPC; 272666daa68SMarkus Armbruster } else if (!strcmp(buf, "stop")) { 27392aa5c6dSPaolo Bonzini return BLOCKDEV_ON_ERROR_STOP; 274666daa68SMarkus Armbruster } else if (!strcmp(buf, "report")) { 27592aa5c6dSPaolo Bonzini return BLOCKDEV_ON_ERROR_REPORT; 276666daa68SMarkus Armbruster } else { 277807105a7SMarkus Armbruster error_report("'%s' invalid %s error action", 278666daa68SMarkus Armbruster buf, is_read ? "read" : "write"); 279666daa68SMarkus Armbruster return -1; 280666daa68SMarkus Armbruster } 281666daa68SMarkus Armbruster } 282666daa68SMarkus Armbruster 283c546194fSStefan Hajnoczi static bool do_check_io_limits(BlockIOLimit *io_limits, Error **errp) 2840563e191SZhi Yong Wu { 2850563e191SZhi Yong Wu bool bps_flag; 2860563e191SZhi Yong Wu bool iops_flag; 2870563e191SZhi Yong Wu 2880563e191SZhi Yong Wu assert(io_limits); 2890563e191SZhi Yong Wu 2900563e191SZhi Yong Wu bps_flag = (io_limits->bps[BLOCK_IO_LIMIT_TOTAL] != 0) 2910563e191SZhi Yong Wu && ((io_limits->bps[BLOCK_IO_LIMIT_READ] != 0) 2920563e191SZhi Yong Wu || (io_limits->bps[BLOCK_IO_LIMIT_WRITE] != 0)); 2930563e191SZhi Yong Wu iops_flag = (io_limits->iops[BLOCK_IO_LIMIT_TOTAL] != 0) 2940563e191SZhi Yong Wu && ((io_limits->iops[BLOCK_IO_LIMIT_READ] != 0) 2950563e191SZhi Yong Wu || (io_limits->iops[BLOCK_IO_LIMIT_WRITE] != 0)); 2960563e191SZhi Yong Wu if (bps_flag || iops_flag) { 297c546194fSStefan Hajnoczi error_setg(errp, "bps(iops) and bps_rd/bps_wr(iops_rd/iops_wr) " 298c546194fSStefan Hajnoczi "cannot be used at the same time"); 2990563e191SZhi Yong Wu return false; 3000563e191SZhi Yong Wu } 3010563e191SZhi Yong Wu 3027d81c141SStefan Hajnoczi if (io_limits->bps[BLOCK_IO_LIMIT_TOTAL] < 0 || 3037d81c141SStefan Hajnoczi io_limits->bps[BLOCK_IO_LIMIT_WRITE] < 0 || 3047d81c141SStefan Hajnoczi io_limits->bps[BLOCK_IO_LIMIT_READ] < 0 || 3057d81c141SStefan Hajnoczi io_limits->iops[BLOCK_IO_LIMIT_TOTAL] < 0 || 3067d81c141SStefan Hajnoczi io_limits->iops[BLOCK_IO_LIMIT_WRITE] < 0 || 3077d81c141SStefan Hajnoczi io_limits->iops[BLOCK_IO_LIMIT_READ] < 0) { 3087d81c141SStefan Hajnoczi error_setg(errp, "bps and iops values must be 0 or greater"); 3097d81c141SStefan Hajnoczi return false; 3107d81c141SStefan Hajnoczi } 3117d81c141SStefan Hajnoczi 3120563e191SZhi Yong Wu return true; 3130563e191SZhi Yong Wu } 3140563e191SZhi Yong Wu 3150006383eSKevin Wolf DriveInfo *drive_init(QemuOpts *all_opts, BlockInterfaceType block_default_type) 316666daa68SMarkus Armbruster { 317666daa68SMarkus Armbruster const char *buf; 318666daa68SMarkus Armbruster const char *file = NULL; 319666daa68SMarkus Armbruster const char *serial; 320666daa68SMarkus Armbruster const char *mediastr = ""; 321666daa68SMarkus Armbruster BlockInterfaceType type; 322666daa68SMarkus Armbruster enum { MEDIA_DISK, MEDIA_CDROM } media; 323666daa68SMarkus Armbruster int bus_id, unit_id; 324666daa68SMarkus Armbruster int cyls, heads, secs, translation; 325666daa68SMarkus Armbruster BlockDriver *drv = NULL; 326666daa68SMarkus Armbruster int max_devs; 327666daa68SMarkus Armbruster int index; 328666daa68SMarkus Armbruster int ro = 0; 329666daa68SMarkus Armbruster int bdrv_flags = 0; 330666daa68SMarkus Armbruster int on_read_error, on_write_error; 331666daa68SMarkus Armbruster const char *devaddr; 332666daa68SMarkus Armbruster DriveInfo *dinfo; 3330563e191SZhi Yong Wu BlockIOLimit io_limits; 334666daa68SMarkus Armbruster int snapshot = 0; 335fb0490f6SStefan Hajnoczi bool copy_on_read; 336666daa68SMarkus Armbruster int ret; 337c546194fSStefan Hajnoczi Error *error = NULL; 3380006383eSKevin Wolf QemuOpts *opts; 3390006383eSKevin Wolf QDict *bs_opts; 3400006383eSKevin Wolf const char *id; 341666daa68SMarkus Armbruster 342666daa68SMarkus Armbruster translation = BIOS_ATA_TRANSLATION_AUTO; 343666daa68SMarkus Armbruster media = MEDIA_DISK; 344666daa68SMarkus Armbruster 3450006383eSKevin Wolf /* Check common options by copying from all_opts to opts, all other options 3460006383eSKevin Wolf * are stored in bs_opts. */ 3470006383eSKevin Wolf id = qemu_opts_id(all_opts); 3480006383eSKevin Wolf opts = qemu_opts_create(&qemu_common_drive_opts, id, 1, &error); 3490006383eSKevin Wolf if (error_is_set(&error)) { 3500006383eSKevin Wolf qerror_report_err(error); 3510006383eSKevin Wolf error_free(error); 3520006383eSKevin Wolf return NULL; 3530006383eSKevin Wolf } 3540006383eSKevin Wolf 3550006383eSKevin Wolf bs_opts = qdict_new(); 3560006383eSKevin Wolf qemu_opts_to_qdict(all_opts, bs_opts); 3570006383eSKevin Wolf qemu_opts_absorb_qdict(opts, bs_opts, &error); 3580006383eSKevin Wolf if (error_is_set(&error)) { 3590006383eSKevin Wolf qerror_report_err(error); 3600006383eSKevin Wolf error_free(error); 3610006383eSKevin Wolf return NULL; 3620006383eSKevin Wolf } 3630006383eSKevin Wolf 3640006383eSKevin Wolf if (id) { 3650006383eSKevin Wolf qdict_del(bs_opts, "id"); 3660006383eSKevin Wolf } 3670006383eSKevin Wolf 368666daa68SMarkus Armbruster /* extract parameters */ 369666daa68SMarkus Armbruster bus_id = qemu_opt_get_number(opts, "bus", 0); 370666daa68SMarkus Armbruster unit_id = qemu_opt_get_number(opts, "unit", -1); 371666daa68SMarkus Armbruster index = qemu_opt_get_number(opts, "index", -1); 372666daa68SMarkus Armbruster 373666daa68SMarkus Armbruster cyls = qemu_opt_get_number(opts, "cyls", 0); 374666daa68SMarkus Armbruster heads = qemu_opt_get_number(opts, "heads", 0); 375666daa68SMarkus Armbruster secs = qemu_opt_get_number(opts, "secs", 0); 376666daa68SMarkus Armbruster 377666daa68SMarkus Armbruster snapshot = qemu_opt_get_bool(opts, "snapshot", 0); 378666daa68SMarkus Armbruster ro = qemu_opt_get_bool(opts, "readonly", 0); 379fb0490f6SStefan Hajnoczi copy_on_read = qemu_opt_get_bool(opts, "copy-on-read", false); 380666daa68SMarkus Armbruster 381666daa68SMarkus Armbruster file = qemu_opt_get(opts, "file"); 382666daa68SMarkus Armbruster serial = qemu_opt_get(opts, "serial"); 383666daa68SMarkus Armbruster 384666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "if")) != NULL) { 3851960966dSMarkus Armbruster for (type = 0; type < IF_COUNT && strcmp(buf, if_name[type]); type++) 3861960966dSMarkus Armbruster ; 3871960966dSMarkus Armbruster if (type == IF_COUNT) { 388807105a7SMarkus Armbruster error_report("unsupported bus type '%s'", buf); 389666daa68SMarkus Armbruster return NULL; 390666daa68SMarkus Armbruster } 3912d3999feSLuiz Capitulino } else { 3922d0d2837SChristian Borntraeger type = block_default_type; 393666daa68SMarkus Armbruster } 3942d3999feSLuiz Capitulino 3951960966dSMarkus Armbruster max_devs = if_max_devs[type]; 396666daa68SMarkus Armbruster 397666daa68SMarkus Armbruster if (cyls || heads || secs) { 398aaea3f36SMarkus Armbruster if (cyls < 1) { 399807105a7SMarkus Armbruster error_report("invalid physical cyls number"); 400666daa68SMarkus Armbruster return NULL; 401666daa68SMarkus Armbruster } 402aaea3f36SMarkus Armbruster if (heads < 1) { 403807105a7SMarkus Armbruster error_report("invalid physical heads number"); 404666daa68SMarkus Armbruster return NULL; 405666daa68SMarkus Armbruster } 406aaea3f36SMarkus Armbruster if (secs < 1) { 407807105a7SMarkus Armbruster error_report("invalid physical secs number"); 408666daa68SMarkus Armbruster return NULL; 409666daa68SMarkus Armbruster } 410666daa68SMarkus Armbruster } 411666daa68SMarkus Armbruster 412666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "trans")) != NULL) { 413666daa68SMarkus Armbruster if (!cyls) { 414807105a7SMarkus Armbruster error_report("'%s' trans must be used with cyls, heads and secs", 415666daa68SMarkus Armbruster buf); 416666daa68SMarkus Armbruster return NULL; 417666daa68SMarkus Armbruster } 418666daa68SMarkus Armbruster if (!strcmp(buf, "none")) 419666daa68SMarkus Armbruster translation = BIOS_ATA_TRANSLATION_NONE; 420666daa68SMarkus Armbruster else if (!strcmp(buf, "lba")) 421666daa68SMarkus Armbruster translation = BIOS_ATA_TRANSLATION_LBA; 422666daa68SMarkus Armbruster else if (!strcmp(buf, "auto")) 423666daa68SMarkus Armbruster translation = BIOS_ATA_TRANSLATION_AUTO; 424666daa68SMarkus Armbruster else { 425807105a7SMarkus Armbruster error_report("'%s' invalid translation type", buf); 426666daa68SMarkus Armbruster return NULL; 427666daa68SMarkus Armbruster } 428666daa68SMarkus Armbruster } 429666daa68SMarkus Armbruster 430666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "media")) != NULL) { 431666daa68SMarkus Armbruster if (!strcmp(buf, "disk")) { 432666daa68SMarkus Armbruster media = MEDIA_DISK; 433666daa68SMarkus Armbruster } else if (!strcmp(buf, "cdrom")) { 434666daa68SMarkus Armbruster if (cyls || secs || heads) { 435e7ff8f0eSLuiz Capitulino error_report("CHS can't be set with media=%s", buf); 436666daa68SMarkus Armbruster return NULL; 437666daa68SMarkus Armbruster } 438666daa68SMarkus Armbruster media = MEDIA_CDROM; 439666daa68SMarkus Armbruster } else { 440807105a7SMarkus Armbruster error_report("'%s' invalid media", buf); 441666daa68SMarkus Armbruster return NULL; 442666daa68SMarkus Armbruster } 443666daa68SMarkus Armbruster } 444666daa68SMarkus Armbruster 445a9384affSPaolo Bonzini if ((buf = qemu_opt_get(opts, "discard")) != NULL) { 446a9384affSPaolo Bonzini if (bdrv_parse_discard_flags(buf, &bdrv_flags) != 0) { 447a9384affSPaolo Bonzini error_report("invalid discard option"); 448a9384affSPaolo Bonzini return NULL; 449a9384affSPaolo Bonzini } 450a9384affSPaolo Bonzini } 451a9384affSPaolo Bonzini 4521f212b9dSPaolo Bonzini bdrv_flags |= BDRV_O_CACHE_WB; 453666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "cache")) != NULL) { 454c3993cdcSStefan Hajnoczi if (bdrv_parse_cache_flags(buf, &bdrv_flags) != 0) { 455807105a7SMarkus Armbruster error_report("invalid cache option"); 456666daa68SMarkus Armbruster return NULL; 457666daa68SMarkus Armbruster } 458666daa68SMarkus Armbruster } 459666daa68SMarkus Armbruster 460666daa68SMarkus Armbruster #ifdef CONFIG_LINUX_AIO 461666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "aio")) != NULL) { 462666daa68SMarkus Armbruster if (!strcmp(buf, "native")) { 463666daa68SMarkus Armbruster bdrv_flags |= BDRV_O_NATIVE_AIO; 464666daa68SMarkus Armbruster } else if (!strcmp(buf, "threads")) { 465666daa68SMarkus Armbruster /* this is the default */ 466666daa68SMarkus Armbruster } else { 467807105a7SMarkus Armbruster error_report("invalid aio option"); 468666daa68SMarkus Armbruster return NULL; 469666daa68SMarkus Armbruster } 470666daa68SMarkus Armbruster } 471666daa68SMarkus Armbruster #endif 472666daa68SMarkus Armbruster 473666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "format")) != NULL) { 474c8057f95SPeter Maydell if (is_help_option(buf)) { 475807105a7SMarkus Armbruster error_printf("Supported formats:"); 476666daa68SMarkus Armbruster bdrv_iterate_format(bdrv_format_print, NULL); 477807105a7SMarkus Armbruster error_printf("\n"); 478666daa68SMarkus Armbruster return NULL; 479666daa68SMarkus Armbruster } 480666daa68SMarkus Armbruster drv = bdrv_find_whitelisted_format(buf); 481666daa68SMarkus Armbruster if (!drv) { 482807105a7SMarkus Armbruster error_report("'%s' invalid format", buf); 483666daa68SMarkus Armbruster return NULL; 484666daa68SMarkus Armbruster } 485666daa68SMarkus Armbruster } 486666daa68SMarkus Armbruster 4870563e191SZhi Yong Wu /* disk I/O throttling */ 4880563e191SZhi Yong Wu io_limits.bps[BLOCK_IO_LIMIT_TOTAL] = 4890563e191SZhi Yong Wu qemu_opt_get_number(opts, "bps", 0); 4900563e191SZhi Yong Wu io_limits.bps[BLOCK_IO_LIMIT_READ] = 4910563e191SZhi Yong Wu qemu_opt_get_number(opts, "bps_rd", 0); 4920563e191SZhi Yong Wu io_limits.bps[BLOCK_IO_LIMIT_WRITE] = 4930563e191SZhi Yong Wu qemu_opt_get_number(opts, "bps_wr", 0); 4940563e191SZhi Yong Wu io_limits.iops[BLOCK_IO_LIMIT_TOTAL] = 4950563e191SZhi Yong Wu qemu_opt_get_number(opts, "iops", 0); 4960563e191SZhi Yong Wu io_limits.iops[BLOCK_IO_LIMIT_READ] = 4970563e191SZhi Yong Wu qemu_opt_get_number(opts, "iops_rd", 0); 4980563e191SZhi Yong Wu io_limits.iops[BLOCK_IO_LIMIT_WRITE] = 4990563e191SZhi Yong Wu qemu_opt_get_number(opts, "iops_wr", 0); 5000563e191SZhi Yong Wu 501c546194fSStefan Hajnoczi if (!do_check_io_limits(&io_limits, &error)) { 502c546194fSStefan Hajnoczi error_report("%s", error_get_pretty(error)); 503c546194fSStefan Hajnoczi error_free(error); 5040563e191SZhi Yong Wu return NULL; 5050563e191SZhi Yong Wu } 5060563e191SZhi Yong Wu 5070d92d17aSJan Kiszka if (qemu_opt_get(opts, "boot") != NULL) { 5080d92d17aSJan Kiszka fprintf(stderr, "qemu-kvm: boot=on|off is deprecated and will be " 5090d92d17aSJan Kiszka "ignored. Future versions will reject this parameter. Please " 5100d92d17aSJan Kiszka "update your scripts.\n"); 5110d92d17aSJan Kiszka } 5120d92d17aSJan Kiszka 51392aa5c6dSPaolo Bonzini on_write_error = BLOCKDEV_ON_ERROR_ENOSPC; 514666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "werror")) != NULL) { 515666daa68SMarkus Armbruster if (type != IF_IDE && type != IF_SCSI && type != IF_VIRTIO && type != IF_NONE) { 516807105a7SMarkus Armbruster error_report("werror is not supported by this bus type"); 517666daa68SMarkus Armbruster return NULL; 518666daa68SMarkus Armbruster } 519666daa68SMarkus Armbruster 520666daa68SMarkus Armbruster on_write_error = parse_block_error_action(buf, 0); 521666daa68SMarkus Armbruster if (on_write_error < 0) { 522666daa68SMarkus Armbruster return NULL; 523666daa68SMarkus Armbruster } 524666daa68SMarkus Armbruster } 525666daa68SMarkus Armbruster 52692aa5c6dSPaolo Bonzini on_read_error = BLOCKDEV_ON_ERROR_REPORT; 527666daa68SMarkus Armbruster if ((buf = qemu_opt_get(opts, "rerror")) != NULL) { 5285dba48a8SKevin Wolf if (type != IF_IDE && type != IF_VIRTIO && type != IF_SCSI && type != IF_NONE) { 529807105a7SMarkus Armbruster error_report("rerror is not supported by this bus type"); 530666daa68SMarkus Armbruster return NULL; 531666daa68SMarkus Armbruster } 532666daa68SMarkus Armbruster 533666daa68SMarkus Armbruster on_read_error = parse_block_error_action(buf, 1); 534666daa68SMarkus Armbruster if (on_read_error < 0) { 535666daa68SMarkus Armbruster return NULL; 536666daa68SMarkus Armbruster } 537666daa68SMarkus Armbruster } 538666daa68SMarkus Armbruster 539666daa68SMarkus Armbruster if ((devaddr = qemu_opt_get(opts, "addr")) != NULL) { 540666daa68SMarkus Armbruster if (type != IF_VIRTIO) { 541807105a7SMarkus Armbruster error_report("addr is not supported by this bus type"); 542666daa68SMarkus Armbruster return NULL; 543666daa68SMarkus Armbruster } 544666daa68SMarkus Armbruster } 545666daa68SMarkus Armbruster 546666daa68SMarkus Armbruster /* compute bus and unit according index */ 547666daa68SMarkus Armbruster 548666daa68SMarkus Armbruster if (index != -1) { 549666daa68SMarkus Armbruster if (bus_id != 0 || unit_id != -1) { 550807105a7SMarkus Armbruster error_report("index cannot be used with bus and unit"); 551666daa68SMarkus Armbruster return NULL; 552666daa68SMarkus Armbruster } 553505a7fb1SMarkus Armbruster bus_id = drive_index_to_bus_id(type, index); 554505a7fb1SMarkus Armbruster unit_id = drive_index_to_unit_id(type, index); 555666daa68SMarkus Armbruster } 556666daa68SMarkus Armbruster 557666daa68SMarkus Armbruster /* if user doesn't specify a unit_id, 558666daa68SMarkus Armbruster * try to find the first free 559666daa68SMarkus Armbruster */ 560666daa68SMarkus Armbruster 561666daa68SMarkus Armbruster if (unit_id == -1) { 562666daa68SMarkus Armbruster unit_id = 0; 563666daa68SMarkus Armbruster while (drive_get(type, bus_id, unit_id) != NULL) { 564666daa68SMarkus Armbruster unit_id++; 565666daa68SMarkus Armbruster if (max_devs && unit_id >= max_devs) { 566666daa68SMarkus Armbruster unit_id -= max_devs; 567666daa68SMarkus Armbruster bus_id++; 568666daa68SMarkus Armbruster } 569666daa68SMarkus Armbruster } 570666daa68SMarkus Armbruster } 571666daa68SMarkus Armbruster 572666daa68SMarkus Armbruster /* check unit id */ 573666daa68SMarkus Armbruster 574666daa68SMarkus Armbruster if (max_devs && unit_id >= max_devs) { 575807105a7SMarkus Armbruster error_report("unit %d too big (max is %d)", 576666daa68SMarkus Armbruster unit_id, max_devs - 1); 577666daa68SMarkus Armbruster return NULL; 578666daa68SMarkus Armbruster } 579666daa68SMarkus Armbruster 580666daa68SMarkus Armbruster /* 5814e5d9b57SMarkus Armbruster * catch multiple definitions 582666daa68SMarkus Armbruster */ 583666daa68SMarkus Armbruster 584666daa68SMarkus Armbruster if (drive_get(type, bus_id, unit_id) != NULL) { 5854e5d9b57SMarkus Armbruster error_report("drive with bus=%d, unit=%d (index=%d) exists", 5864e5d9b57SMarkus Armbruster bus_id, unit_id, index); 587666daa68SMarkus Armbruster return NULL; 588666daa68SMarkus Armbruster } 589666daa68SMarkus Armbruster 590666daa68SMarkus Armbruster /* init */ 591666daa68SMarkus Armbruster 5927267c094SAnthony Liguori dinfo = g_malloc0(sizeof(*dinfo)); 593666daa68SMarkus Armbruster if ((buf = qemu_opts_id(opts)) != NULL) { 5947267c094SAnthony Liguori dinfo->id = g_strdup(buf); 595666daa68SMarkus Armbruster } else { 596666daa68SMarkus Armbruster /* no id supplied -> create one */ 5977267c094SAnthony Liguori dinfo->id = g_malloc0(32); 598666daa68SMarkus Armbruster if (type == IF_IDE || type == IF_SCSI) 599666daa68SMarkus Armbruster mediastr = (media == MEDIA_CDROM) ? "-cd" : "-hd"; 600666daa68SMarkus Armbruster if (max_devs) 601666daa68SMarkus Armbruster snprintf(dinfo->id, 32, "%s%i%s%i", 60279d21d5bSMarkus Armbruster if_name[type], bus_id, mediastr, unit_id); 603666daa68SMarkus Armbruster else 604666daa68SMarkus Armbruster snprintf(dinfo->id, 32, "%s%s%i", 60579d21d5bSMarkus Armbruster if_name[type], mediastr, unit_id); 606666daa68SMarkus Armbruster } 607666daa68SMarkus Armbruster dinfo->bdrv = bdrv_new(dinfo->id); 60880dd1aaeSKevin Shanahan dinfo->bdrv->open_flags = snapshot ? BDRV_O_SNAPSHOT : 0; 60980dd1aaeSKevin Shanahan dinfo->bdrv->read_only = ro; 610666daa68SMarkus Armbruster dinfo->devaddr = devaddr; 611666daa68SMarkus Armbruster dinfo->type = type; 612666daa68SMarkus Armbruster dinfo->bus = bus_id; 613666daa68SMarkus Armbruster dinfo->unit = unit_id; 614317bb412SMarkus Armbruster dinfo->cyls = cyls; 615317bb412SMarkus Armbruster dinfo->heads = heads; 616317bb412SMarkus Armbruster dinfo->secs = secs; 617317bb412SMarkus Armbruster dinfo->trans = translation; 6180006383eSKevin Wolf dinfo->opts = all_opts; 61984fb3925SMarcelo Tosatti dinfo->refcount = 1; 620bb44619bSKevin Wolf if (serial != NULL) { 621bb44619bSKevin Wolf dinfo->serial = g_strdup(serial); 622bb44619bSKevin Wolf } 623666daa68SMarkus Armbruster QTAILQ_INSERT_TAIL(&drives, dinfo, next); 624666daa68SMarkus Armbruster 625abd7f68dSMarkus Armbruster bdrv_set_on_error(dinfo->bdrv, on_read_error, on_write_error); 626abd7f68dSMarkus Armbruster 6270563e191SZhi Yong Wu /* disk I/O throttling */ 6280563e191SZhi Yong Wu bdrv_set_io_limits(dinfo->bdrv, &io_limits); 6290563e191SZhi Yong Wu 630666daa68SMarkus Armbruster switch(type) { 631666daa68SMarkus Armbruster case IF_IDE: 632666daa68SMarkus Armbruster case IF_SCSI: 633666daa68SMarkus Armbruster case IF_XEN: 634666daa68SMarkus Armbruster case IF_NONE: 6352b584959SMarkus Armbruster dinfo->media_cd = media == MEDIA_CDROM; 636666daa68SMarkus Armbruster break; 637666daa68SMarkus Armbruster case IF_SD: 638666daa68SMarkus Armbruster case IF_FLOPPY: 639666daa68SMarkus Armbruster case IF_PFLASH: 640666daa68SMarkus Armbruster case IF_MTD: 641666daa68SMarkus Armbruster break; 642666daa68SMarkus Armbruster case IF_VIRTIO: 6430006383eSKevin Wolf { 644666daa68SMarkus Armbruster /* add virtio block device */ 6450006383eSKevin Wolf QemuOpts *devopts; 6460006383eSKevin Wolf devopts = qemu_opts_create_nofail(qemu_find_opts("device")); 647eeb9c1b5SAnthony Liguori if (arch_type == QEMU_ARCH_S390X) { 6480006383eSKevin Wolf qemu_opt_set(devopts, "driver", "virtio-blk-s390"); 649eeb9c1b5SAnthony Liguori } else { 6500006383eSKevin Wolf qemu_opt_set(devopts, "driver", "virtio-blk-pci"); 651eeb9c1b5SAnthony Liguori } 6520006383eSKevin Wolf qemu_opt_set(devopts, "drive", dinfo->id); 653666daa68SMarkus Armbruster if (devaddr) 6540006383eSKevin Wolf qemu_opt_set(devopts, "addr", devaddr); 655666daa68SMarkus Armbruster break; 6560006383eSKevin Wolf } 6572292ddaeSMarkus Armbruster default: 658666daa68SMarkus Armbruster abort(); 659666daa68SMarkus Armbruster } 660dd5b0d71SMarkus Armbruster if (!file || !*file) { 661c2ad1b0cSKevin Wolf if (qdict_size(bs_opts)) { 662c2ad1b0cSKevin Wolf file = NULL; 663c2ad1b0cSKevin Wolf } else { 664319ae529SMarkus Armbruster return dinfo; 665666daa68SMarkus Armbruster } 666c2ad1b0cSKevin Wolf } 667666daa68SMarkus Armbruster if (snapshot) { 668666daa68SMarkus Armbruster /* always use cache=unsafe with snapshot */ 669666daa68SMarkus Armbruster bdrv_flags &= ~BDRV_O_CACHE_MASK; 670666daa68SMarkus Armbruster bdrv_flags |= (BDRV_O_SNAPSHOT|BDRV_O_CACHE_WB|BDRV_O_NO_FLUSH); 671666daa68SMarkus Armbruster } 672666daa68SMarkus Armbruster 673fb0490f6SStefan Hajnoczi if (copy_on_read) { 674fb0490f6SStefan Hajnoczi bdrv_flags |= BDRV_O_COPY_ON_READ; 675fb0490f6SStefan Hajnoczi } 676fb0490f6SStefan Hajnoczi 677ed9d4205SBenoît Canet if (runstate_check(RUN_STATE_INMIGRATE)) { 678ed9d4205SBenoît Canet bdrv_flags |= BDRV_O_INCOMING; 679ed9d4205SBenoît Canet } 680ed9d4205SBenoît Canet 681666daa68SMarkus Armbruster if (media == MEDIA_CDROM) { 682666daa68SMarkus Armbruster /* CDROM is fine for any interface, don't check. */ 683666daa68SMarkus Armbruster ro = 1; 684666daa68SMarkus Armbruster } else if (ro == 1) { 6851e9eb78aSJordan Justen if (type != IF_SCSI && type != IF_VIRTIO && type != IF_FLOPPY && 6861e9eb78aSJordan Justen type != IF_NONE && type != IF_PFLASH) { 687807105a7SMarkus Armbruster error_report("readonly not supported by this bus type"); 688a9ae2bffSMarkus Armbruster goto err; 689666daa68SMarkus Armbruster } 690666daa68SMarkus Armbruster } 691666daa68SMarkus Armbruster 692666daa68SMarkus Armbruster bdrv_flags |= ro ? 0 : BDRV_O_RDWR; 693666daa68SMarkus Armbruster 69404d4abe9SStefan Hajnoczi if (ro && copy_on_read) { 69504d4abe9SStefan Hajnoczi error_report("warning: disabling copy_on_read on readonly drive"); 69604d4abe9SStefan Hajnoczi } 69704d4abe9SStefan Hajnoczi 6980006383eSKevin Wolf ret = bdrv_open(dinfo->bdrv, file, bs_opts, bdrv_flags, drv); 6990006383eSKevin Wolf bs_opts = NULL; 7000006383eSKevin Wolf 701666daa68SMarkus Armbruster if (ret < 0) { 70202582abdSStefan Weil if (ret == -EMEDIUMTYPE) { 70302582abdSStefan Weil error_report("could not open disk image %s: not in %s format", 704c2ad1b0cSKevin Wolf file ?: dinfo->id, drv->format_name); 70502582abdSStefan Weil } else { 706807105a7SMarkus Armbruster error_report("could not open disk image %s: %s", 707c2ad1b0cSKevin Wolf file ?: dinfo->id, strerror(-ret)); 70802582abdSStefan Weil } 709a9ae2bffSMarkus Armbruster goto err; 710666daa68SMarkus Armbruster } 711666daa68SMarkus Armbruster 712666daa68SMarkus Armbruster if (bdrv_key_required(dinfo->bdrv)) 713666daa68SMarkus Armbruster autostart = 0; 7140006383eSKevin Wolf 7150006383eSKevin Wolf qemu_opts_del(opts); 7160006383eSKevin Wolf 717666daa68SMarkus Armbruster return dinfo; 718a9ae2bffSMarkus Armbruster 719a9ae2bffSMarkus Armbruster err: 7200006383eSKevin Wolf qemu_opts_del(opts); 7210006383eSKevin Wolf QDECREF(bs_opts); 722a9ae2bffSMarkus Armbruster bdrv_delete(dinfo->bdrv); 7237267c094SAnthony Liguori g_free(dinfo->id); 724a9ae2bffSMarkus Armbruster QTAILQ_REMOVE(&drives, dinfo, next); 7257267c094SAnthony Liguori g_free(dinfo); 726a9ae2bffSMarkus Armbruster return NULL; 727666daa68SMarkus Armbruster } 728666daa68SMarkus Armbruster 729666daa68SMarkus Armbruster void do_commit(Monitor *mon, const QDict *qdict) 730666daa68SMarkus Armbruster { 731666daa68SMarkus Armbruster const char *device = qdict_get_str(qdict, "device"); 7326ab4b5abSMarkus Armbruster BlockDriverState *bs; 7332d3735d3SStefan Hajnoczi int ret; 7342d3735d3SStefan Hajnoczi 735e8877497SStefan Hajnoczi if (!strcmp(device, "all")) { 736e8877497SStefan Hajnoczi ret = bdrv_commit_all(); 737e8877497SStefan Hajnoczi } else { 7386ab4b5abSMarkus Armbruster bs = bdrv_find(device); 739ac59eb95SMarkus Armbruster if (!bs) { 74058513bdeSJeff Cody monitor_printf(mon, "Device '%s' not found\n", device); 741ac59eb95SMarkus Armbruster return; 7426ab4b5abSMarkus Armbruster } 7432d3735d3SStefan Hajnoczi ret = bdrv_commit(bs); 7442d3735d3SStefan Hajnoczi } 74558513bdeSJeff Cody if (ret < 0) { 74658513bdeSJeff Cody monitor_printf(mon, "'commit' error for '%s': %s\n", device, 74758513bdeSJeff Cody strerror(-ret)); 748666daa68SMarkus Armbruster } 749666daa68SMarkus Armbruster } 750666daa68SMarkus Armbruster 7516cc2a415SPaolo Bonzini static void blockdev_do_action(int kind, void *data, Error **errp) 7526cc2a415SPaolo Bonzini { 7536cc2a415SPaolo Bonzini BlockdevAction action; 7546cc2a415SPaolo Bonzini BlockdevActionList list; 7556cc2a415SPaolo Bonzini 7566cc2a415SPaolo Bonzini action.kind = kind; 7576cc2a415SPaolo Bonzini action.data = data; 7586cc2a415SPaolo Bonzini list.value = &action; 7596cc2a415SPaolo Bonzini list.next = NULL; 7606cc2a415SPaolo Bonzini qmp_transaction(&list, errp); 7616cc2a415SPaolo Bonzini } 7626cc2a415SPaolo Bonzini 7636106e249SLuiz Capitulino void qmp_blockdev_snapshot_sync(const char *device, const char *snapshot_file, 7646106e249SLuiz Capitulino bool has_format, const char *format, 7656cc2a415SPaolo Bonzini bool has_mode, enum NewImageMode mode, 7666106e249SLuiz Capitulino Error **errp) 767f8882568SJes Sorensen { 7686cc2a415SPaolo Bonzini BlockdevSnapshot snapshot = { 7696cc2a415SPaolo Bonzini .device = (char *) device, 7706cc2a415SPaolo Bonzini .snapshot_file = (char *) snapshot_file, 7716cc2a415SPaolo Bonzini .has_format = has_format, 7726cc2a415SPaolo Bonzini .format = (char *) format, 7736cc2a415SPaolo Bonzini .has_mode = has_mode, 7746cc2a415SPaolo Bonzini .mode = mode, 7756cc2a415SPaolo Bonzini }; 7766cc2a415SPaolo Bonzini blockdev_do_action(BLOCKDEV_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC, &snapshot, 7776cc2a415SPaolo Bonzini errp); 778f8882568SJes Sorensen } 779f8882568SJes Sorensen 7808802d1fdSJeff Cody 7818802d1fdSJeff Cody /* New and old BlockDriverState structs for group snapshots */ 78252e7c241SPaolo Bonzini typedef struct BlkTransactionStates { 7838802d1fdSJeff Cody BlockDriverState *old_bs; 7848802d1fdSJeff Cody BlockDriverState *new_bs; 78552e7c241SPaolo Bonzini QSIMPLEQ_ENTRY(BlkTransactionStates) entry; 78652e7c241SPaolo Bonzini } BlkTransactionStates; 7878802d1fdSJeff Cody 7888802d1fdSJeff Cody /* 7898802d1fdSJeff Cody * 'Atomic' group snapshots. The snapshots are taken as a set, and if any fail 7908802d1fdSJeff Cody * then we do not pivot any of the devices in the group, and abandon the 7918802d1fdSJeff Cody * snapshots 7928802d1fdSJeff Cody */ 79352e7c241SPaolo Bonzini void qmp_transaction(BlockdevActionList *dev_list, Error **errp) 7948802d1fdSJeff Cody { 7958802d1fdSJeff Cody int ret = 0; 79652e7c241SPaolo Bonzini BlockdevActionList *dev_entry = dev_list; 79752e7c241SPaolo Bonzini BlkTransactionStates *states, *next; 79843e17041SLuiz Capitulino Error *local_err = NULL; 7998802d1fdSJeff Cody 80052e7c241SPaolo Bonzini QSIMPLEQ_HEAD(snap_bdrv_states, BlkTransactionStates) snap_bdrv_states; 8018802d1fdSJeff Cody QSIMPLEQ_INIT(&snap_bdrv_states); 8028802d1fdSJeff Cody 8038802d1fdSJeff Cody /* drain all i/o before any snapshots */ 8048802d1fdSJeff Cody bdrv_drain_all(); 8058802d1fdSJeff Cody 8068802d1fdSJeff Cody /* We don't do anything in this loop that commits us to the snapshot */ 8078802d1fdSJeff Cody while (NULL != dev_entry) { 80852e7c241SPaolo Bonzini BlockdevAction *dev_info = NULL; 80952e7c241SPaolo Bonzini BlockDriver *proto_drv; 81052e7c241SPaolo Bonzini BlockDriver *drv; 81152e7c241SPaolo Bonzini int flags; 812bc8b094fSPaolo Bonzini enum NewImageMode mode; 813bc8b094fSPaolo Bonzini const char *new_image_file; 81452e7c241SPaolo Bonzini const char *device; 81552e7c241SPaolo Bonzini const char *format = "qcow2"; 81652e7c241SPaolo Bonzini 8178802d1fdSJeff Cody dev_info = dev_entry->value; 8188802d1fdSJeff Cody dev_entry = dev_entry->next; 8198802d1fdSJeff Cody 82052e7c241SPaolo Bonzini states = g_malloc0(sizeof(BlkTransactionStates)); 8218802d1fdSJeff Cody QSIMPLEQ_INSERT_TAIL(&snap_bdrv_states, states, entry); 8228802d1fdSJeff Cody 82352e7c241SPaolo Bonzini switch (dev_info->kind) { 82452e7c241SPaolo Bonzini case BLOCKDEV_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC: 82552e7c241SPaolo Bonzini device = dev_info->blockdev_snapshot_sync->device; 826bc8b094fSPaolo Bonzini if (!dev_info->blockdev_snapshot_sync->has_mode) { 827bc8b094fSPaolo Bonzini dev_info->blockdev_snapshot_sync->mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS; 828bc8b094fSPaolo Bonzini } 829bc8b094fSPaolo Bonzini new_image_file = dev_info->blockdev_snapshot_sync->snapshot_file; 83052e7c241SPaolo Bonzini if (dev_info->blockdev_snapshot_sync->has_format) { 83152e7c241SPaolo Bonzini format = dev_info->blockdev_snapshot_sync->format; 83252e7c241SPaolo Bonzini } 833bc8b094fSPaolo Bonzini mode = dev_info->blockdev_snapshot_sync->mode; 83452e7c241SPaolo Bonzini break; 83552e7c241SPaolo Bonzini default: 83652e7c241SPaolo Bonzini abort(); 83752e7c241SPaolo Bonzini } 8388802d1fdSJeff Cody 83952e7c241SPaolo Bonzini drv = bdrv_find_format(format); 84052e7c241SPaolo Bonzini if (!drv) { 84152e7c241SPaolo Bonzini error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 84252e7c241SPaolo Bonzini goto delete_and_fail; 84352e7c241SPaolo Bonzini } 84452e7c241SPaolo Bonzini 84552e7c241SPaolo Bonzini states->old_bs = bdrv_find(device); 8468802d1fdSJeff Cody if (!states->old_bs) { 84752e7c241SPaolo Bonzini error_set(errp, QERR_DEVICE_NOT_FOUND, device); 8488802d1fdSJeff Cody goto delete_and_fail; 8498802d1fdSJeff Cody } 8508802d1fdSJeff Cody 851e86fe18aSPaolo Bonzini if (!bdrv_is_inserted(states->old_bs)) { 852e86fe18aSPaolo Bonzini error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device); 853e86fe18aSPaolo Bonzini goto delete_and_fail; 854e86fe18aSPaolo Bonzini } 855e86fe18aSPaolo Bonzini 8568802d1fdSJeff Cody if (bdrv_in_use(states->old_bs)) { 85752e7c241SPaolo Bonzini error_set(errp, QERR_DEVICE_IN_USE, device); 8588802d1fdSJeff Cody goto delete_and_fail; 8598802d1fdSJeff Cody } 8608802d1fdSJeff Cody 861e86fe18aSPaolo Bonzini if (!bdrv_is_read_only(states->old_bs)) { 8628802d1fdSJeff Cody if (bdrv_flush(states->old_bs)) { 8638802d1fdSJeff Cody error_set(errp, QERR_IO_ERROR); 8648802d1fdSJeff Cody goto delete_and_fail; 8658802d1fdSJeff Cody } 8668802d1fdSJeff Cody } 8678802d1fdSJeff Cody 8688802d1fdSJeff Cody flags = states->old_bs->open_flags; 8698802d1fdSJeff Cody 87052e7c241SPaolo Bonzini proto_drv = bdrv_find_protocol(new_image_file); 8718802d1fdSJeff Cody if (!proto_drv) { 8728802d1fdSJeff Cody error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 8738802d1fdSJeff Cody goto delete_and_fail; 8748802d1fdSJeff Cody } 8758802d1fdSJeff Cody 8768802d1fdSJeff Cody /* create new image w/backing file */ 877bc8b094fSPaolo Bonzini if (mode != NEW_IMAGE_MODE_EXISTING) { 87843e17041SLuiz Capitulino bdrv_img_create(new_image_file, format, 8798802d1fdSJeff Cody states->old_bs->filename, 880d0895d6eSPaolo Bonzini states->old_bs->drv->format_name, 881f382d43aSMiroslav Rezanina NULL, -1, flags, &local_err, false); 88243e17041SLuiz Capitulino if (error_is_set(&local_err)) { 88343e17041SLuiz Capitulino error_propagate(errp, local_err); 8848802d1fdSJeff Cody goto delete_and_fail; 8858802d1fdSJeff Cody } 886bc8b094fSPaolo Bonzini } 8878802d1fdSJeff Cody 8888802d1fdSJeff Cody /* We will manually add the backing_hd field to the bs later */ 8898802d1fdSJeff Cody states->new_bs = bdrv_new(""); 890de9c0cecSKevin Wolf /* TODO Inherit bs->options or only take explicit options with an 891de9c0cecSKevin Wolf * extended QMP command? */ 892de9c0cecSKevin Wolf ret = bdrv_open(states->new_bs, new_image_file, NULL, 8938802d1fdSJeff Cody flags | BDRV_O_NO_BACKING, drv); 8948802d1fdSJeff Cody if (ret != 0) { 89552e7c241SPaolo Bonzini error_set(errp, QERR_OPEN_FILE_FAILED, new_image_file); 8968802d1fdSJeff Cody goto delete_and_fail; 8978802d1fdSJeff Cody } 8988802d1fdSJeff Cody } 8998802d1fdSJeff Cody 9008802d1fdSJeff Cody 9018802d1fdSJeff Cody /* Now we are going to do the actual pivot. Everything up to this point 9028802d1fdSJeff Cody * is reversible, but we are committed at this point */ 9038802d1fdSJeff Cody QSIMPLEQ_FOREACH(states, &snap_bdrv_states, entry) { 9048802d1fdSJeff Cody /* This removes our old bs from the bdrv_states, and adds the new bs */ 9058802d1fdSJeff Cody bdrv_append(states->new_bs, states->old_bs); 906870f5681SJeff Cody /* We don't need (or want) to use the transactional 907870f5681SJeff Cody * bdrv_reopen_multiple() across all the entries at once, because we 908870f5681SJeff Cody * don't want to abort all of them if one of them fails the reopen */ 909870f5681SJeff Cody bdrv_reopen(states->new_bs, states->new_bs->open_flags & ~BDRV_O_RDWR, 910870f5681SJeff Cody NULL); 9118802d1fdSJeff Cody } 9128802d1fdSJeff Cody 9138802d1fdSJeff Cody /* success */ 9148802d1fdSJeff Cody goto exit; 9158802d1fdSJeff Cody 9168802d1fdSJeff Cody delete_and_fail: 9178802d1fdSJeff Cody /* 9188802d1fdSJeff Cody * failure, and it is all-or-none; abandon each new bs, and keep using 9198802d1fdSJeff Cody * the original bs for all images 9208802d1fdSJeff Cody */ 9218802d1fdSJeff Cody QSIMPLEQ_FOREACH(states, &snap_bdrv_states, entry) { 9228802d1fdSJeff Cody if (states->new_bs) { 9238802d1fdSJeff Cody bdrv_delete(states->new_bs); 9248802d1fdSJeff Cody } 9258802d1fdSJeff Cody } 9268802d1fdSJeff Cody exit: 927622d2419SPaolo Bonzini QSIMPLEQ_FOREACH_SAFE(states, &snap_bdrv_states, entry, next) { 9288802d1fdSJeff Cody g_free(states); 9298802d1fdSJeff Cody } 9308802d1fdSJeff Cody } 9318802d1fdSJeff Cody 9328802d1fdSJeff Cody 93392d48558SLuiz Capitulino static void eject_device(BlockDriverState *bs, int force, Error **errp) 934666daa68SMarkus Armbruster { 9352d3735d3SStefan Hajnoczi if (bdrv_in_use(bs)) { 9362d3735d3SStefan Hajnoczi error_set(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs)); 9372d3735d3SStefan Hajnoczi return; 9382d3735d3SStefan Hajnoczi } 9392c6942faSMarkus Armbruster if (!bdrv_dev_has_removable_media(bs)) { 94092d48558SLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_REMOVABLE, bdrv_get_device_name(bs)); 94192d48558SLuiz Capitulino return; 942666daa68SMarkus Armbruster } 94392d48558SLuiz Capitulino 944025ccaa7SPaolo Bonzini if (bdrv_dev_is_medium_locked(bs) && !bdrv_dev_is_tray_open(bs)) { 945025ccaa7SPaolo Bonzini bdrv_dev_eject_request(bs, force); 946025ccaa7SPaolo Bonzini if (!force) { 94792d48558SLuiz Capitulino error_set(errp, QERR_DEVICE_LOCKED, bdrv_get_device_name(bs)); 94892d48558SLuiz Capitulino return; 949666daa68SMarkus Armbruster } 950025ccaa7SPaolo Bonzini } 95192d48558SLuiz Capitulino 952666daa68SMarkus Armbruster bdrv_close(bs); 953666daa68SMarkus Armbruster } 954666daa68SMarkus Armbruster 955c245b6a3SLuiz Capitulino void qmp_eject(const char *device, bool has_force, bool force, Error **errp) 956666daa68SMarkus Armbruster { 957666daa68SMarkus Armbruster BlockDriverState *bs; 958666daa68SMarkus Armbruster 959c245b6a3SLuiz Capitulino bs = bdrv_find(device); 960666daa68SMarkus Armbruster if (!bs) { 961c245b6a3SLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_FOUND, device); 962c245b6a3SLuiz Capitulino return; 963666daa68SMarkus Armbruster } 96492d48558SLuiz Capitulino 965c245b6a3SLuiz Capitulino eject_device(bs, force, errp); 966666daa68SMarkus Armbruster } 967666daa68SMarkus Armbruster 968a4dea8a9SLuiz Capitulino void qmp_block_passwd(const char *device, const char *password, Error **errp) 969666daa68SMarkus Armbruster { 970666daa68SMarkus Armbruster BlockDriverState *bs; 971666daa68SMarkus Armbruster int err; 972666daa68SMarkus Armbruster 973a4dea8a9SLuiz Capitulino bs = bdrv_find(device); 974666daa68SMarkus Armbruster if (!bs) { 975a4dea8a9SLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_FOUND, device); 976a4dea8a9SLuiz Capitulino return; 977666daa68SMarkus Armbruster } 978666daa68SMarkus Armbruster 979a4dea8a9SLuiz Capitulino err = bdrv_set_key(bs, password); 980666daa68SMarkus Armbruster if (err == -EINVAL) { 981a4dea8a9SLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs)); 982a4dea8a9SLuiz Capitulino return; 983666daa68SMarkus Armbruster } else if (err < 0) { 984a4dea8a9SLuiz Capitulino error_set(errp, QERR_INVALID_PASSWORD); 985a4dea8a9SLuiz Capitulino return; 986666daa68SMarkus Armbruster } 987666daa68SMarkus Armbruster } 988666daa68SMarkus Armbruster 989333a96ecSLuiz Capitulino static void qmp_bdrv_open_encrypted(BlockDriverState *bs, const char *filename, 990333a96ecSLuiz Capitulino int bdrv_flags, BlockDriver *drv, 991333a96ecSLuiz Capitulino const char *password, Error **errp) 992333a96ecSLuiz Capitulino { 993de9c0cecSKevin Wolf if (bdrv_open(bs, filename, NULL, bdrv_flags, drv) < 0) { 994333a96ecSLuiz Capitulino error_set(errp, QERR_OPEN_FILE_FAILED, filename); 995333a96ecSLuiz Capitulino return; 996333a96ecSLuiz Capitulino } 997333a96ecSLuiz Capitulino 998333a96ecSLuiz Capitulino if (bdrv_key_required(bs)) { 999333a96ecSLuiz Capitulino if (password) { 1000333a96ecSLuiz Capitulino if (bdrv_set_key(bs, password) < 0) { 1001333a96ecSLuiz Capitulino error_set(errp, QERR_INVALID_PASSWORD); 1002333a96ecSLuiz Capitulino } 1003333a96ecSLuiz Capitulino } else { 1004333a96ecSLuiz Capitulino error_set(errp, QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs), 1005333a96ecSLuiz Capitulino bdrv_get_encrypted_filename(bs)); 1006333a96ecSLuiz Capitulino } 1007333a96ecSLuiz Capitulino } else if (password) { 1008333a96ecSLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs)); 1009333a96ecSLuiz Capitulino } 1010333a96ecSLuiz Capitulino } 1011333a96ecSLuiz Capitulino 1012333a96ecSLuiz Capitulino void qmp_change_blockdev(const char *device, const char *filename, 1013333a96ecSLuiz Capitulino bool has_format, const char *format, Error **errp) 1014666daa68SMarkus Armbruster { 1015666daa68SMarkus Armbruster BlockDriverState *bs; 1016666daa68SMarkus Armbruster BlockDriver *drv = NULL; 1017666daa68SMarkus Armbruster int bdrv_flags; 101892d48558SLuiz Capitulino Error *err = NULL; 1019666daa68SMarkus Armbruster 1020666daa68SMarkus Armbruster bs = bdrv_find(device); 1021666daa68SMarkus Armbruster if (!bs) { 1022333a96ecSLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_FOUND, device); 1023333a96ecSLuiz Capitulino return; 1024666daa68SMarkus Armbruster } 1025333a96ecSLuiz Capitulino 1026333a96ecSLuiz Capitulino if (format) { 1027333a96ecSLuiz Capitulino drv = bdrv_find_whitelisted_format(format); 1028666daa68SMarkus Armbruster if (!drv) { 1029333a96ecSLuiz Capitulino error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 1030333a96ecSLuiz Capitulino return; 1031666daa68SMarkus Armbruster } 1032666daa68SMarkus Armbruster } 1033333a96ecSLuiz Capitulino 103492d48558SLuiz Capitulino eject_device(bs, 0, &err); 103592d48558SLuiz Capitulino if (error_is_set(&err)) { 1036333a96ecSLuiz Capitulino error_propagate(errp, err); 1037333a96ecSLuiz Capitulino return; 1038666daa68SMarkus Armbruster } 1039333a96ecSLuiz Capitulino 1040528f7663SMarkus Armbruster bdrv_flags = bdrv_is_read_only(bs) ? 0 : BDRV_O_RDWR; 1041199630b6SBlue Swirl bdrv_flags |= bdrv_is_snapshot(bs) ? BDRV_O_SNAPSHOT : 0; 1042333a96ecSLuiz Capitulino 1043333a96ecSLuiz Capitulino qmp_bdrv_open_encrypted(bs, filename, bdrv_flags, drv, NULL, errp); 1044666daa68SMarkus Armbruster } 10459063f814SRyan Harper 1046727f005eSZhi Yong Wu /* throttling disk I/O limits */ 104780047da5SLuiz Capitulino void qmp_block_set_io_throttle(const char *device, int64_t bps, int64_t bps_rd, 104880047da5SLuiz Capitulino int64_t bps_wr, int64_t iops, int64_t iops_rd, 104980047da5SLuiz Capitulino int64_t iops_wr, Error **errp) 1050727f005eSZhi Yong Wu { 1051727f005eSZhi Yong Wu BlockIOLimit io_limits; 1052727f005eSZhi Yong Wu BlockDriverState *bs; 1053727f005eSZhi Yong Wu 105480047da5SLuiz Capitulino bs = bdrv_find(device); 1055727f005eSZhi Yong Wu if (!bs) { 105680047da5SLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_FOUND, device); 105780047da5SLuiz Capitulino return; 1058727f005eSZhi Yong Wu } 1059727f005eSZhi Yong Wu 106080047da5SLuiz Capitulino io_limits.bps[BLOCK_IO_LIMIT_TOTAL] = bps; 106180047da5SLuiz Capitulino io_limits.bps[BLOCK_IO_LIMIT_READ] = bps_rd; 106280047da5SLuiz Capitulino io_limits.bps[BLOCK_IO_LIMIT_WRITE] = bps_wr; 106380047da5SLuiz Capitulino io_limits.iops[BLOCK_IO_LIMIT_TOTAL]= iops; 106480047da5SLuiz Capitulino io_limits.iops[BLOCK_IO_LIMIT_READ] = iops_rd; 106580047da5SLuiz Capitulino io_limits.iops[BLOCK_IO_LIMIT_WRITE]= iops_wr; 1066727f005eSZhi Yong Wu 1067c546194fSStefan Hajnoczi if (!do_check_io_limits(&io_limits, errp)) { 106880047da5SLuiz Capitulino return; 1069727f005eSZhi Yong Wu } 1070727f005eSZhi Yong Wu 1071727f005eSZhi Yong Wu bs->io_limits = io_limits; 1072727f005eSZhi Yong Wu 1073727f005eSZhi Yong Wu if (!bs->io_limits_enabled && bdrv_io_limits_enabled(bs)) { 1074727f005eSZhi Yong Wu bdrv_io_limits_enable(bs); 1075727f005eSZhi Yong Wu } else if (bs->io_limits_enabled && !bdrv_io_limits_enabled(bs)) { 1076727f005eSZhi Yong Wu bdrv_io_limits_disable(bs); 1077727f005eSZhi Yong Wu } else { 1078727f005eSZhi Yong Wu if (bs->block_timer) { 1079727f005eSZhi Yong Wu qemu_mod_timer(bs->block_timer, qemu_get_clock_ns(vm_clock)); 1080727f005eSZhi Yong Wu } 1081727f005eSZhi Yong Wu } 1082727f005eSZhi Yong Wu } 1083727f005eSZhi Yong Wu 10849063f814SRyan Harper int do_drive_del(Monitor *mon, const QDict *qdict, QObject **ret_data) 10859063f814SRyan Harper { 10869063f814SRyan Harper const char *id = qdict_get_str(qdict, "id"); 10879063f814SRyan Harper BlockDriverState *bs; 10889063f814SRyan Harper 10899063f814SRyan Harper bs = bdrv_find(id); 10909063f814SRyan Harper if (!bs) { 10919063f814SRyan Harper qerror_report(QERR_DEVICE_NOT_FOUND, id); 10929063f814SRyan Harper return -1; 10939063f814SRyan Harper } 10948591675fSMarcelo Tosatti if (bdrv_in_use(bs)) { 10958591675fSMarcelo Tosatti qerror_report(QERR_DEVICE_IN_USE, id); 10968591675fSMarcelo Tosatti return -1; 10978591675fSMarcelo Tosatti } 10989063f814SRyan Harper 10999063f814SRyan Harper /* quiesce block driver; prevent further io */ 1100922453bcSStefan Hajnoczi bdrv_drain_all(); 11019063f814SRyan Harper bdrv_flush(bs); 11029063f814SRyan Harper bdrv_close(bs); 11039063f814SRyan Harper 1104fa879d62SMarkus Armbruster /* if we have a device attached to this BlockDriverState 1105d22b2f41SRyan Harper * then we need to make the drive anonymous until the device 1106d22b2f41SRyan Harper * can be removed. If this is a drive with no device backing 1107d22b2f41SRyan Harper * then we can just get rid of the block driver state right here. 1108d22b2f41SRyan Harper */ 1109fa879d62SMarkus Armbruster if (bdrv_get_attached_dev(bs)) { 1110d22b2f41SRyan Harper bdrv_make_anon(bs); 1111d22b2f41SRyan Harper } else { 11129063f814SRyan Harper drive_uninit(drive_get_by_blockdev(bs)); 1113d22b2f41SRyan Harper } 11149063f814SRyan Harper 11159063f814SRyan Harper return 0; 11169063f814SRyan Harper } 11176d4a2b3aSChristoph Hellwig 11185e7caacbSLuiz Capitulino void qmp_block_resize(const char *device, int64_t size, Error **errp) 11196d4a2b3aSChristoph Hellwig { 11206d4a2b3aSChristoph Hellwig BlockDriverState *bs; 1121*8732901eSKevin Wolf int ret; 11226d4a2b3aSChristoph Hellwig 11236d4a2b3aSChristoph Hellwig bs = bdrv_find(device); 11246d4a2b3aSChristoph Hellwig if (!bs) { 11255e7caacbSLuiz Capitulino error_set(errp, QERR_DEVICE_NOT_FOUND, device); 11265e7caacbSLuiz Capitulino return; 11276d4a2b3aSChristoph Hellwig } 11286d4a2b3aSChristoph Hellwig 11296d4a2b3aSChristoph Hellwig if (size < 0) { 1130939a1cc3SStefan Hajnoczi error_set(errp, QERR_INVALID_PARAMETER_VALUE, "size", "a >0 size"); 11315e7caacbSLuiz Capitulino return; 11326d4a2b3aSChristoph Hellwig } 11336d4a2b3aSChristoph Hellwig 113492b7a08dSPeter Lieven /* complete all in-flight operations before resizing the device */ 113592b7a08dSPeter Lieven bdrv_drain_all(); 113692b7a08dSPeter Lieven 1137*8732901eSKevin Wolf ret = bdrv_truncate(bs, size); 1138*8732901eSKevin Wolf switch (ret) { 1139939a1cc3SStefan Hajnoczi case 0: 1140939a1cc3SStefan Hajnoczi break; 1141939a1cc3SStefan Hajnoczi case -ENOMEDIUM: 1142939a1cc3SStefan Hajnoczi error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device); 1143939a1cc3SStefan Hajnoczi break; 1144939a1cc3SStefan Hajnoczi case -ENOTSUP: 1145939a1cc3SStefan Hajnoczi error_set(errp, QERR_UNSUPPORTED); 1146939a1cc3SStefan Hajnoczi break; 1147939a1cc3SStefan Hajnoczi case -EACCES: 1148939a1cc3SStefan Hajnoczi error_set(errp, QERR_DEVICE_IS_READ_ONLY, device); 1149939a1cc3SStefan Hajnoczi break; 1150939a1cc3SStefan Hajnoczi case -EBUSY: 1151939a1cc3SStefan Hajnoczi error_set(errp, QERR_DEVICE_IN_USE, device); 1152939a1cc3SStefan Hajnoczi break; 1153939a1cc3SStefan Hajnoczi default: 1154*8732901eSKevin Wolf error_setg_errno(errp, -ret, "Could not resize"); 1155939a1cc3SStefan Hajnoczi break; 11566d4a2b3aSChristoph Hellwig } 11576d4a2b3aSChristoph Hellwig } 115812bd451fSStefan Hajnoczi 11599abf2dbaSJeff Cody static void block_job_cb(void *opaque, int ret) 116012bd451fSStefan Hajnoczi { 116112bd451fSStefan Hajnoczi BlockDriverState *bs = opaque; 116212bd451fSStefan Hajnoczi QObject *obj; 116312bd451fSStefan Hajnoczi 11649abf2dbaSJeff Cody trace_block_job_cb(bs, bs->job, ret); 116512bd451fSStefan Hajnoczi 116612bd451fSStefan Hajnoczi assert(bs->job); 116712bd451fSStefan Hajnoczi obj = qobject_from_block_job(bs->job); 116812bd451fSStefan Hajnoczi if (ret < 0) { 116912bd451fSStefan Hajnoczi QDict *dict = qobject_to_qdict(obj); 117012bd451fSStefan Hajnoczi qdict_put(dict, "error", qstring_from_str(strerror(-ret))); 117112bd451fSStefan Hajnoczi } 117212bd451fSStefan Hajnoczi 1173370521a1SStefan Hajnoczi if (block_job_is_cancelled(bs->job)) { 1174370521a1SStefan Hajnoczi monitor_protocol_event(QEVENT_BLOCK_JOB_CANCELLED, obj); 1175370521a1SStefan Hajnoczi } else { 117612bd451fSStefan Hajnoczi monitor_protocol_event(QEVENT_BLOCK_JOB_COMPLETED, obj); 1177370521a1SStefan Hajnoczi } 117812bd451fSStefan Hajnoczi qobject_decref(obj); 1179aa398a5cSStefan Hajnoczi 1180aa398a5cSStefan Hajnoczi drive_put_ref_bh_schedule(drive_get_by_blockdev(bs)); 118112bd451fSStefan Hajnoczi } 118212bd451fSStefan Hajnoczi 118312bd451fSStefan Hajnoczi void qmp_block_stream(const char *device, bool has_base, 11841d809098SPaolo Bonzini const char *base, bool has_speed, int64_t speed, 11851d809098SPaolo Bonzini bool has_on_error, BlockdevOnError on_error, 11861d809098SPaolo Bonzini Error **errp) 118712bd451fSStefan Hajnoczi { 118812bd451fSStefan Hajnoczi BlockDriverState *bs; 1189c8c3080fSMarcelo Tosatti BlockDriverState *base_bs = NULL; 1190fd7f8c65SStefan Hajnoczi Error *local_err = NULL; 119112bd451fSStefan Hajnoczi 11921d809098SPaolo Bonzini if (!has_on_error) { 11931d809098SPaolo Bonzini on_error = BLOCKDEV_ON_ERROR_REPORT; 11941d809098SPaolo Bonzini } 11951d809098SPaolo Bonzini 119612bd451fSStefan Hajnoczi bs = bdrv_find(device); 119712bd451fSStefan Hajnoczi if (!bs) { 119812bd451fSStefan Hajnoczi error_set(errp, QERR_DEVICE_NOT_FOUND, device); 119912bd451fSStefan Hajnoczi return; 120012bd451fSStefan Hajnoczi } 120112bd451fSStefan Hajnoczi 120212bd451fSStefan Hajnoczi if (base) { 1203c8c3080fSMarcelo Tosatti base_bs = bdrv_find_backing_image(bs, base); 1204c8c3080fSMarcelo Tosatti if (base_bs == NULL) { 1205c8c3080fSMarcelo Tosatti error_set(errp, QERR_BASE_NOT_FOUND, base); 120612bd451fSStefan Hajnoczi return; 120712bd451fSStefan Hajnoczi } 1208c8c3080fSMarcelo Tosatti } 120912bd451fSStefan Hajnoczi 1210c83c66c3SStefan Hajnoczi stream_start(bs, base_bs, base, has_speed ? speed : 0, 12111d809098SPaolo Bonzini on_error, block_job_cb, bs, &local_err); 1212fd7f8c65SStefan Hajnoczi if (error_is_set(&local_err)) { 1213fd7f8c65SStefan Hajnoczi error_propagate(errp, local_err); 121412bd451fSStefan Hajnoczi return; 121512bd451fSStefan Hajnoczi } 121612bd451fSStefan Hajnoczi 1217aa398a5cSStefan Hajnoczi /* Grab a reference so hotplug does not delete the BlockDriverState from 1218aa398a5cSStefan Hajnoczi * underneath us. 1219aa398a5cSStefan Hajnoczi */ 1220aa398a5cSStefan Hajnoczi drive_get_ref(drive_get_by_blockdev(bs)); 1221aa398a5cSStefan Hajnoczi 122212bd451fSStefan Hajnoczi trace_qmp_block_stream(bs, bs->job); 122312bd451fSStefan Hajnoczi } 12242d47c6e9SStefan Hajnoczi 1225ed61fc10SJeff Cody void qmp_block_commit(const char *device, 1226ed61fc10SJeff Cody bool has_base, const char *base, const char *top, 1227ed61fc10SJeff Cody bool has_speed, int64_t speed, 1228ed61fc10SJeff Cody Error **errp) 1229ed61fc10SJeff Cody { 1230ed61fc10SJeff Cody BlockDriverState *bs; 1231ed61fc10SJeff Cody BlockDriverState *base_bs, *top_bs; 1232ed61fc10SJeff Cody Error *local_err = NULL; 1233ed61fc10SJeff Cody /* This will be part of the QMP command, if/when the 1234ed61fc10SJeff Cody * BlockdevOnError change for blkmirror makes it in 1235ed61fc10SJeff Cody */ 123692aa5c6dSPaolo Bonzini BlockdevOnError on_error = BLOCKDEV_ON_ERROR_REPORT; 1237ed61fc10SJeff Cody 1238ed61fc10SJeff Cody /* drain all i/o before commits */ 1239ed61fc10SJeff Cody bdrv_drain_all(); 1240ed61fc10SJeff Cody 1241ed61fc10SJeff Cody bs = bdrv_find(device); 1242ed61fc10SJeff Cody if (!bs) { 1243ed61fc10SJeff Cody error_set(errp, QERR_DEVICE_NOT_FOUND, device); 1244ed61fc10SJeff Cody return; 1245ed61fc10SJeff Cody } 1246ed61fc10SJeff Cody 1247ed61fc10SJeff Cody /* default top_bs is the active layer */ 1248ed61fc10SJeff Cody top_bs = bs; 1249ed61fc10SJeff Cody 1250ed61fc10SJeff Cody if (top) { 1251ed61fc10SJeff Cody if (strcmp(bs->filename, top) != 0) { 1252ed61fc10SJeff Cody top_bs = bdrv_find_backing_image(bs, top); 1253ed61fc10SJeff Cody } 1254ed61fc10SJeff Cody } 1255ed61fc10SJeff Cody 1256ed61fc10SJeff Cody if (top_bs == NULL) { 1257ed61fc10SJeff Cody error_setg(errp, "Top image file %s not found", top ? top : "NULL"); 1258ed61fc10SJeff Cody return; 1259ed61fc10SJeff Cody } 1260ed61fc10SJeff Cody 1261d5208c45SJeff Cody if (has_base && base) { 1262d5208c45SJeff Cody base_bs = bdrv_find_backing_image(top_bs, base); 1263d5208c45SJeff Cody } else { 1264d5208c45SJeff Cody base_bs = bdrv_find_base(top_bs); 1265d5208c45SJeff Cody } 1266d5208c45SJeff Cody 1267d5208c45SJeff Cody if (base_bs == NULL) { 1268d5208c45SJeff Cody error_set(errp, QERR_BASE_NOT_FOUND, base ? base : "NULL"); 1269d5208c45SJeff Cody return; 1270d5208c45SJeff Cody } 1271d5208c45SJeff Cody 1272ed61fc10SJeff Cody commit_start(bs, base_bs, top_bs, speed, on_error, block_job_cb, bs, 1273ed61fc10SJeff Cody &local_err); 1274ed61fc10SJeff Cody if (local_err != NULL) { 1275ed61fc10SJeff Cody error_propagate(errp, local_err); 1276ed61fc10SJeff Cody return; 1277ed61fc10SJeff Cody } 1278ed61fc10SJeff Cody /* Grab a reference so hotplug does not delete the BlockDriverState from 1279ed61fc10SJeff Cody * underneath us. 1280ed61fc10SJeff Cody */ 1281ed61fc10SJeff Cody drive_get_ref(drive_get_by_blockdev(bs)); 1282ed61fc10SJeff Cody } 1283ed61fc10SJeff Cody 128408e4ed6cSPaolo Bonzini #define DEFAULT_MIRROR_BUF_SIZE (10 << 20) 128508e4ed6cSPaolo Bonzini 1286d9b902dbSPaolo Bonzini void qmp_drive_mirror(const char *device, const char *target, 1287d9b902dbSPaolo Bonzini bool has_format, const char *format, 1288d9b902dbSPaolo Bonzini enum MirrorSyncMode sync, 1289d9b902dbSPaolo Bonzini bool has_mode, enum NewImageMode mode, 1290b952b558SPaolo Bonzini bool has_speed, int64_t speed, 1291eee13dfeSPaolo Bonzini bool has_granularity, uint32_t granularity, 129208e4ed6cSPaolo Bonzini bool has_buf_size, int64_t buf_size, 1293b952b558SPaolo Bonzini bool has_on_source_error, BlockdevOnError on_source_error, 1294b952b558SPaolo Bonzini bool has_on_target_error, BlockdevOnError on_target_error, 1295b952b558SPaolo Bonzini Error **errp) 1296d9b902dbSPaolo Bonzini { 1297d9b902dbSPaolo Bonzini BlockDriverState *bs; 1298d9b902dbSPaolo Bonzini BlockDriverState *source, *target_bs; 1299d9b902dbSPaolo Bonzini BlockDriver *proto_drv; 1300d9b902dbSPaolo Bonzini BlockDriver *drv = NULL; 1301d9b902dbSPaolo Bonzini Error *local_err = NULL; 1302d9b902dbSPaolo Bonzini int flags; 1303d9b902dbSPaolo Bonzini uint64_t size; 1304d9b902dbSPaolo Bonzini int ret; 1305d9b902dbSPaolo Bonzini 1306d9b902dbSPaolo Bonzini if (!has_speed) { 1307d9b902dbSPaolo Bonzini speed = 0; 1308d9b902dbSPaolo Bonzini } 1309b952b558SPaolo Bonzini if (!has_on_source_error) { 1310b952b558SPaolo Bonzini on_source_error = BLOCKDEV_ON_ERROR_REPORT; 1311b952b558SPaolo Bonzini } 1312b952b558SPaolo Bonzini if (!has_on_target_error) { 1313b952b558SPaolo Bonzini on_target_error = BLOCKDEV_ON_ERROR_REPORT; 1314b952b558SPaolo Bonzini } 1315d9b902dbSPaolo Bonzini if (!has_mode) { 1316d9b902dbSPaolo Bonzini mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS; 1317d9b902dbSPaolo Bonzini } 1318eee13dfeSPaolo Bonzini if (!has_granularity) { 1319eee13dfeSPaolo Bonzini granularity = 0; 1320eee13dfeSPaolo Bonzini } 132108e4ed6cSPaolo Bonzini if (!has_buf_size) { 132208e4ed6cSPaolo Bonzini buf_size = DEFAULT_MIRROR_BUF_SIZE; 132308e4ed6cSPaolo Bonzini } 132408e4ed6cSPaolo Bonzini 1325eee13dfeSPaolo Bonzini if (granularity != 0 && (granularity < 512 || granularity > 1048576 * 64)) { 1326eee13dfeSPaolo Bonzini error_set(errp, QERR_INVALID_PARAMETER, device); 1327eee13dfeSPaolo Bonzini return; 1328eee13dfeSPaolo Bonzini } 1329eee13dfeSPaolo Bonzini if (granularity & (granularity - 1)) { 1330eee13dfeSPaolo Bonzini error_set(errp, QERR_INVALID_PARAMETER, device); 1331eee13dfeSPaolo Bonzini return; 1332eee13dfeSPaolo Bonzini } 1333d9b902dbSPaolo Bonzini 1334d9b902dbSPaolo Bonzini bs = bdrv_find(device); 1335d9b902dbSPaolo Bonzini if (!bs) { 1336d9b902dbSPaolo Bonzini error_set(errp, QERR_DEVICE_NOT_FOUND, device); 1337d9b902dbSPaolo Bonzini return; 1338d9b902dbSPaolo Bonzini } 1339d9b902dbSPaolo Bonzini 1340d9b902dbSPaolo Bonzini if (!bdrv_is_inserted(bs)) { 1341d9b902dbSPaolo Bonzini error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device); 1342d9b902dbSPaolo Bonzini return; 1343d9b902dbSPaolo Bonzini } 1344d9b902dbSPaolo Bonzini 1345d9b902dbSPaolo Bonzini if (!has_format) { 1346d9b902dbSPaolo Bonzini format = mode == NEW_IMAGE_MODE_EXISTING ? NULL : bs->drv->format_name; 1347d9b902dbSPaolo Bonzini } 1348d9b902dbSPaolo Bonzini if (format) { 1349d9b902dbSPaolo Bonzini drv = bdrv_find_format(format); 1350d9b902dbSPaolo Bonzini if (!drv) { 1351d9b902dbSPaolo Bonzini error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 1352d9b902dbSPaolo Bonzini return; 1353d9b902dbSPaolo Bonzini } 1354d9b902dbSPaolo Bonzini } 1355d9b902dbSPaolo Bonzini 1356d9b902dbSPaolo Bonzini if (bdrv_in_use(bs)) { 1357d9b902dbSPaolo Bonzini error_set(errp, QERR_DEVICE_IN_USE, device); 1358d9b902dbSPaolo Bonzini return; 1359d9b902dbSPaolo Bonzini } 1360d9b902dbSPaolo Bonzini 1361d9b902dbSPaolo Bonzini flags = bs->open_flags | BDRV_O_RDWR; 1362d9b902dbSPaolo Bonzini source = bs->backing_hd; 1363d9b902dbSPaolo Bonzini if (!source && sync == MIRROR_SYNC_MODE_TOP) { 1364d9b902dbSPaolo Bonzini sync = MIRROR_SYNC_MODE_FULL; 1365d9b902dbSPaolo Bonzini } 1366d9b902dbSPaolo Bonzini 1367d9b902dbSPaolo Bonzini proto_drv = bdrv_find_protocol(target); 1368d9b902dbSPaolo Bonzini if (!proto_drv) { 1369d9b902dbSPaolo Bonzini error_set(errp, QERR_INVALID_BLOCK_FORMAT, format); 1370d9b902dbSPaolo Bonzini return; 1371d9b902dbSPaolo Bonzini } 1372d9b902dbSPaolo Bonzini 137386899072SVishvananda Ishaya bdrv_get_geometry(bs, &size); 137486899072SVishvananda Ishaya size *= 512; 1375d9b902dbSPaolo Bonzini if (sync == MIRROR_SYNC_MODE_FULL && mode != NEW_IMAGE_MODE_EXISTING) { 1376d9b902dbSPaolo Bonzini /* create new image w/o backing file */ 1377d9b902dbSPaolo Bonzini assert(format && drv); 1378cf8f2426SLuiz Capitulino bdrv_img_create(target, format, 1379f382d43aSMiroslav Rezanina NULL, NULL, NULL, size, flags, &local_err, false); 1380d9b902dbSPaolo Bonzini } else { 1381d9b902dbSPaolo Bonzini switch (mode) { 1382d9b902dbSPaolo Bonzini case NEW_IMAGE_MODE_EXISTING: 1383d9b902dbSPaolo Bonzini ret = 0; 1384d9b902dbSPaolo Bonzini break; 1385d9b902dbSPaolo Bonzini case NEW_IMAGE_MODE_ABSOLUTE_PATHS: 1386d9b902dbSPaolo Bonzini /* create new image with backing file */ 1387cf8f2426SLuiz Capitulino bdrv_img_create(target, format, 1388d9b902dbSPaolo Bonzini source->filename, 1389d9b902dbSPaolo Bonzini source->drv->format_name, 1390f382d43aSMiroslav Rezanina NULL, size, flags, &local_err, false); 1391d9b902dbSPaolo Bonzini break; 1392d9b902dbSPaolo Bonzini default: 1393d9b902dbSPaolo Bonzini abort(); 1394d9b902dbSPaolo Bonzini } 1395d9b902dbSPaolo Bonzini } 1396d9b902dbSPaolo Bonzini 1397cf8f2426SLuiz Capitulino if (error_is_set(&local_err)) { 1398cf8f2426SLuiz Capitulino error_propagate(errp, local_err); 1399d9b902dbSPaolo Bonzini return; 1400d9b902dbSPaolo Bonzini } 1401d9b902dbSPaolo Bonzini 1402b812f671SPaolo Bonzini /* Mirroring takes care of copy-on-write using the source's backing 1403b812f671SPaolo Bonzini * file. 1404b812f671SPaolo Bonzini */ 1405d9b902dbSPaolo Bonzini target_bs = bdrv_new(""); 1406de9c0cecSKevin Wolf ret = bdrv_open(target_bs, target, NULL, flags | BDRV_O_NO_BACKING, drv); 1407d9b902dbSPaolo Bonzini 1408d9b902dbSPaolo Bonzini if (ret < 0) { 1409d9b902dbSPaolo Bonzini bdrv_delete(target_bs); 1410d9b902dbSPaolo Bonzini error_set(errp, QERR_OPEN_FILE_FAILED, target); 1411d9b902dbSPaolo Bonzini return; 1412d9b902dbSPaolo Bonzini } 1413d9b902dbSPaolo Bonzini 141408e4ed6cSPaolo Bonzini mirror_start(bs, target_bs, speed, granularity, buf_size, sync, 1415eee13dfeSPaolo Bonzini on_source_error, on_target_error, 1416b952b558SPaolo Bonzini block_job_cb, bs, &local_err); 1417d9b902dbSPaolo Bonzini if (local_err != NULL) { 1418d9b902dbSPaolo Bonzini bdrv_delete(target_bs); 1419d9b902dbSPaolo Bonzini error_propagate(errp, local_err); 1420d9b902dbSPaolo Bonzini return; 1421d9b902dbSPaolo Bonzini } 1422d9b902dbSPaolo Bonzini 1423d9b902dbSPaolo Bonzini /* Grab a reference so hotplug does not delete the BlockDriverState from 1424d9b902dbSPaolo Bonzini * underneath us. 1425d9b902dbSPaolo Bonzini */ 1426d9b902dbSPaolo Bonzini drive_get_ref(drive_get_by_blockdev(bs)); 1427d9b902dbSPaolo Bonzini } 1428d9b902dbSPaolo Bonzini 14292d47c6e9SStefan Hajnoczi static BlockJob *find_block_job(const char *device) 14302d47c6e9SStefan Hajnoczi { 14312d47c6e9SStefan Hajnoczi BlockDriverState *bs; 14322d47c6e9SStefan Hajnoczi 14332d47c6e9SStefan Hajnoczi bs = bdrv_find(device); 14342d47c6e9SStefan Hajnoczi if (!bs || !bs->job) { 14352d47c6e9SStefan Hajnoczi return NULL; 14362d47c6e9SStefan Hajnoczi } 14372d47c6e9SStefan Hajnoczi return bs->job; 14382d47c6e9SStefan Hajnoczi } 14392d47c6e9SStefan Hajnoczi 1440882ec7ceSStefan Hajnoczi void qmp_block_job_set_speed(const char *device, int64_t speed, Error **errp) 14412d47c6e9SStefan Hajnoczi { 14422d47c6e9SStefan Hajnoczi BlockJob *job = find_block_job(device); 14432d47c6e9SStefan Hajnoczi 14442d47c6e9SStefan Hajnoczi if (!job) { 14457ef15070SPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device); 14462d47c6e9SStefan Hajnoczi return; 14472d47c6e9SStefan Hajnoczi } 14482d47c6e9SStefan Hajnoczi 1449882ec7ceSStefan Hajnoczi block_job_set_speed(job, speed, errp); 14502d47c6e9SStefan Hajnoczi } 1451370521a1SStefan Hajnoczi 14526e37fb81SPaolo Bonzini void qmp_block_job_cancel(const char *device, 14536e37fb81SPaolo Bonzini bool has_force, bool force, Error **errp) 14546e37fb81SPaolo Bonzini { 14556e37fb81SPaolo Bonzini BlockJob *job = find_block_job(device); 14566e37fb81SPaolo Bonzini 14576e37fb81SPaolo Bonzini if (!has_force) { 14586e37fb81SPaolo Bonzini force = false; 14596e37fb81SPaolo Bonzini } 14606e37fb81SPaolo Bonzini 14616e37fb81SPaolo Bonzini if (!job) { 14626e37fb81SPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device); 14636e37fb81SPaolo Bonzini return; 14646e37fb81SPaolo Bonzini } 14656e37fb81SPaolo Bonzini if (job->paused && !force) { 14666e37fb81SPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_PAUSED, device); 14676e37fb81SPaolo Bonzini return; 14686e37fb81SPaolo Bonzini } 14696e37fb81SPaolo Bonzini 14706e37fb81SPaolo Bonzini trace_qmp_block_job_cancel(job); 14716e37fb81SPaolo Bonzini block_job_cancel(job); 14726e37fb81SPaolo Bonzini } 14736e37fb81SPaolo Bonzini 14746e37fb81SPaolo Bonzini void qmp_block_job_pause(const char *device, Error **errp) 1475370521a1SStefan Hajnoczi { 1476370521a1SStefan Hajnoczi BlockJob *job = find_block_job(device); 1477370521a1SStefan Hajnoczi 1478370521a1SStefan Hajnoczi if (!job) { 14797ef15070SPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device); 1480370521a1SStefan Hajnoczi return; 1481370521a1SStefan Hajnoczi } 14826e37fb81SPaolo Bonzini 14836e37fb81SPaolo Bonzini trace_qmp_block_job_pause(job); 14846e37fb81SPaolo Bonzini block_job_pause(job); 14856e37fb81SPaolo Bonzini } 14866e37fb81SPaolo Bonzini 14876e37fb81SPaolo Bonzini void qmp_block_job_resume(const char *device, Error **errp) 14886e37fb81SPaolo Bonzini { 14896e37fb81SPaolo Bonzini BlockJob *job = find_block_job(device); 14906e37fb81SPaolo Bonzini 14916e37fb81SPaolo Bonzini if (!job) { 14926e37fb81SPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device); 14938acc72a4SPaolo Bonzini return; 14948acc72a4SPaolo Bonzini } 1495370521a1SStefan Hajnoczi 14966e37fb81SPaolo Bonzini trace_qmp_block_job_resume(job); 14976e37fb81SPaolo Bonzini block_job_resume(job); 1498370521a1SStefan Hajnoczi } 1499fb5458cdSStefan Hajnoczi 1500aeae883bSPaolo Bonzini void qmp_block_job_complete(const char *device, Error **errp) 1501aeae883bSPaolo Bonzini { 1502aeae883bSPaolo Bonzini BlockJob *job = find_block_job(device); 1503aeae883bSPaolo Bonzini 1504aeae883bSPaolo Bonzini if (!job) { 1505aeae883bSPaolo Bonzini error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device); 1506aeae883bSPaolo Bonzini return; 1507aeae883bSPaolo Bonzini } 1508aeae883bSPaolo Bonzini 1509aeae883bSPaolo Bonzini trace_qmp_block_job_complete(job); 1510aeae883bSPaolo Bonzini block_job_complete(job, errp); 1511aeae883bSPaolo Bonzini } 1512aeae883bSPaolo Bonzini 1513fb5458cdSStefan Hajnoczi static void do_qmp_query_block_jobs_one(void *opaque, BlockDriverState *bs) 1514fb5458cdSStefan Hajnoczi { 1515fb5458cdSStefan Hajnoczi BlockJobInfoList **prev = opaque; 1516fb5458cdSStefan Hajnoczi BlockJob *job = bs->job; 1517fb5458cdSStefan Hajnoczi 1518fb5458cdSStefan Hajnoczi if (job) { 151930e628b7SPaolo Bonzini BlockJobInfoList *elem = g_new0(BlockJobInfoList, 1); 152030e628b7SPaolo Bonzini elem->value = block_job_query(bs->job); 1521fb5458cdSStefan Hajnoczi (*prev)->next = elem; 1522fb5458cdSStefan Hajnoczi *prev = elem; 1523fb5458cdSStefan Hajnoczi } 1524fb5458cdSStefan Hajnoczi } 1525fb5458cdSStefan Hajnoczi 1526fb5458cdSStefan Hajnoczi BlockJobInfoList *qmp_query_block_jobs(Error **errp) 1527fb5458cdSStefan Hajnoczi { 1528fb5458cdSStefan Hajnoczi /* Dummy is a fake list element for holding the head pointer */ 1529fb5458cdSStefan Hajnoczi BlockJobInfoList dummy = {}; 1530fb5458cdSStefan Hajnoczi BlockJobInfoList *prev = &dummy; 1531fb5458cdSStefan Hajnoczi bdrv_iterate(do_qmp_query_block_jobs_one, &prev); 1532fb5458cdSStefan Hajnoczi return dummy.next; 1533fb5458cdSStefan Hajnoczi } 15344d454574SPaolo Bonzini 15350006383eSKevin Wolf QemuOptsList qemu_common_drive_opts = { 15364d454574SPaolo Bonzini .name = "drive", 15370006383eSKevin Wolf .head = QTAILQ_HEAD_INITIALIZER(qemu_common_drive_opts.head), 15384d454574SPaolo Bonzini .desc = { 15394d454574SPaolo Bonzini { 15404d454574SPaolo Bonzini .name = "bus", 15414d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15424d454574SPaolo Bonzini .help = "bus number", 15434d454574SPaolo Bonzini },{ 15444d454574SPaolo Bonzini .name = "unit", 15454d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15464d454574SPaolo Bonzini .help = "unit number (i.e. lun for scsi)", 15474d454574SPaolo Bonzini },{ 15484d454574SPaolo Bonzini .name = "if", 15494d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15504d454574SPaolo Bonzini .help = "interface (ide, scsi, sd, mtd, floppy, pflash, virtio)", 15514d454574SPaolo Bonzini },{ 15524d454574SPaolo Bonzini .name = "index", 15534d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15544d454574SPaolo Bonzini .help = "index number", 15554d454574SPaolo Bonzini },{ 15564d454574SPaolo Bonzini .name = "cyls", 15574d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15584d454574SPaolo Bonzini .help = "number of cylinders (ide disk geometry)", 15594d454574SPaolo Bonzini },{ 15604d454574SPaolo Bonzini .name = "heads", 15614d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15624d454574SPaolo Bonzini .help = "number of heads (ide disk geometry)", 15634d454574SPaolo Bonzini },{ 15644d454574SPaolo Bonzini .name = "secs", 15654d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 15664d454574SPaolo Bonzini .help = "number of sectors (ide disk geometry)", 15674d454574SPaolo Bonzini },{ 15684d454574SPaolo Bonzini .name = "trans", 15694d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15704d454574SPaolo Bonzini .help = "chs translation (auto, lba. none)", 15714d454574SPaolo Bonzini },{ 15724d454574SPaolo Bonzini .name = "media", 15734d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15744d454574SPaolo Bonzini .help = "media type (disk, cdrom)", 15754d454574SPaolo Bonzini },{ 15764d454574SPaolo Bonzini .name = "snapshot", 15774d454574SPaolo Bonzini .type = QEMU_OPT_BOOL, 15784d454574SPaolo Bonzini .help = "enable/disable snapshot mode", 15794d454574SPaolo Bonzini },{ 15804d454574SPaolo Bonzini .name = "file", 15814d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15824d454574SPaolo Bonzini .help = "disk image", 15834d454574SPaolo Bonzini },{ 1584a9384affSPaolo Bonzini .name = "discard", 1585a9384affSPaolo Bonzini .type = QEMU_OPT_STRING, 1586a9384affSPaolo Bonzini .help = "discard operation (ignore/off, unmap/on)", 1587a9384affSPaolo Bonzini },{ 15884d454574SPaolo Bonzini .name = "cache", 15894d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15904d454574SPaolo Bonzini .help = "host cache usage (none, writeback, writethrough, " 15914d454574SPaolo Bonzini "directsync, unsafe)", 15924d454574SPaolo Bonzini },{ 15934d454574SPaolo Bonzini .name = "aio", 15944d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15954d454574SPaolo Bonzini .help = "host AIO implementation (threads, native)", 15964d454574SPaolo Bonzini },{ 15974d454574SPaolo Bonzini .name = "format", 15984d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 15994d454574SPaolo Bonzini .help = "disk format (raw, qcow2, ...)", 16004d454574SPaolo Bonzini },{ 16014d454574SPaolo Bonzini .name = "serial", 16024d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 16034d454574SPaolo Bonzini .help = "disk serial number", 16044d454574SPaolo Bonzini },{ 16054d454574SPaolo Bonzini .name = "rerror", 16064d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 16074d454574SPaolo Bonzini .help = "read error action", 16084d454574SPaolo Bonzini },{ 16094d454574SPaolo Bonzini .name = "werror", 16104d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 16114d454574SPaolo Bonzini .help = "write error action", 16124d454574SPaolo Bonzini },{ 16134d454574SPaolo Bonzini .name = "addr", 16144d454574SPaolo Bonzini .type = QEMU_OPT_STRING, 16154d454574SPaolo Bonzini .help = "pci address (virtio only)", 16164d454574SPaolo Bonzini },{ 16174d454574SPaolo Bonzini .name = "readonly", 16184d454574SPaolo Bonzini .type = QEMU_OPT_BOOL, 16194d454574SPaolo Bonzini .help = "open drive file as read-only", 16204d454574SPaolo Bonzini },{ 16214d454574SPaolo Bonzini .name = "iops", 16224d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16234d454574SPaolo Bonzini .help = "limit total I/O operations per second", 16244d454574SPaolo Bonzini },{ 16254d454574SPaolo Bonzini .name = "iops_rd", 16264d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16274d454574SPaolo Bonzini .help = "limit read operations per second", 16284d454574SPaolo Bonzini },{ 16294d454574SPaolo Bonzini .name = "iops_wr", 16304d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16314d454574SPaolo Bonzini .help = "limit write operations per second", 16324d454574SPaolo Bonzini },{ 16334d454574SPaolo Bonzini .name = "bps", 16344d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16354d454574SPaolo Bonzini .help = "limit total bytes per second", 16364d454574SPaolo Bonzini },{ 16374d454574SPaolo Bonzini .name = "bps_rd", 16384d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16394d454574SPaolo Bonzini .help = "limit read bytes per second", 16404d454574SPaolo Bonzini },{ 16414d454574SPaolo Bonzini .name = "bps_wr", 16424d454574SPaolo Bonzini .type = QEMU_OPT_NUMBER, 16434d454574SPaolo Bonzini .help = "limit write bytes per second", 16444d454574SPaolo Bonzini },{ 16454d454574SPaolo Bonzini .name = "copy-on-read", 16464d454574SPaolo Bonzini .type = QEMU_OPT_BOOL, 16474d454574SPaolo Bonzini .help = "copy read data from backing file into image file", 16484d454574SPaolo Bonzini },{ 16494d454574SPaolo Bonzini .name = "boot", 16504d454574SPaolo Bonzini .type = QEMU_OPT_BOOL, 16514d454574SPaolo Bonzini .help = "(deprecated, ignored)", 16524d454574SPaolo Bonzini }, 16534d454574SPaolo Bonzini { /* end of list */ } 16544d454574SPaolo Bonzini }, 16554d454574SPaolo Bonzini }; 16560006383eSKevin Wolf 16570006383eSKevin Wolf QemuOptsList qemu_drive_opts = { 16580006383eSKevin Wolf .name = "drive", 16590006383eSKevin Wolf .head = QTAILQ_HEAD_INITIALIZER(qemu_drive_opts.head), 16600006383eSKevin Wolf .desc = { 16618ec7d390SKevin Wolf { 16628ec7d390SKevin Wolf .name = "bus", 16638ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16648ec7d390SKevin Wolf .help = "bus number", 16658ec7d390SKevin Wolf },{ 16668ec7d390SKevin Wolf .name = "unit", 16678ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16688ec7d390SKevin Wolf .help = "unit number (i.e. lun for scsi)", 16698ec7d390SKevin Wolf },{ 16708ec7d390SKevin Wolf .name = "if", 16718ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 16728ec7d390SKevin Wolf .help = "interface (ide, scsi, sd, mtd, floppy, pflash, virtio)", 16738ec7d390SKevin Wolf },{ 16748ec7d390SKevin Wolf .name = "index", 16758ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16768ec7d390SKevin Wolf .help = "index number", 16778ec7d390SKevin Wolf },{ 16788ec7d390SKevin Wolf .name = "cyls", 16798ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16808ec7d390SKevin Wolf .help = "number of cylinders (ide disk geometry)", 16818ec7d390SKevin Wolf },{ 16828ec7d390SKevin Wolf .name = "heads", 16838ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16848ec7d390SKevin Wolf .help = "number of heads (ide disk geometry)", 16858ec7d390SKevin Wolf },{ 16868ec7d390SKevin Wolf .name = "secs", 16878ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 16888ec7d390SKevin Wolf .help = "number of sectors (ide disk geometry)", 16898ec7d390SKevin Wolf },{ 16908ec7d390SKevin Wolf .name = "trans", 16918ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 16928ec7d390SKevin Wolf .help = "chs translation (auto, lba. none)", 16938ec7d390SKevin Wolf },{ 16948ec7d390SKevin Wolf .name = "media", 16958ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 16968ec7d390SKevin Wolf .help = "media type (disk, cdrom)", 16978ec7d390SKevin Wolf },{ 16988ec7d390SKevin Wolf .name = "snapshot", 16998ec7d390SKevin Wolf .type = QEMU_OPT_BOOL, 17008ec7d390SKevin Wolf .help = "enable/disable snapshot mode", 17018ec7d390SKevin Wolf },{ 17028ec7d390SKevin Wolf .name = "file", 17038ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17048ec7d390SKevin Wolf .help = "disk image", 17058ec7d390SKevin Wolf },{ 17068ec7d390SKevin Wolf .name = "discard", 17078ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17088ec7d390SKevin Wolf .help = "discard operation (ignore/off, unmap/on)", 17098ec7d390SKevin Wolf },{ 17108ec7d390SKevin Wolf .name = "cache", 17118ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17128ec7d390SKevin Wolf .help = "host cache usage (none, writeback, writethrough, " 17138ec7d390SKevin Wolf "directsync, unsafe)", 17148ec7d390SKevin Wolf },{ 17158ec7d390SKevin Wolf .name = "aio", 17168ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17178ec7d390SKevin Wolf .help = "host AIO implementation (threads, native)", 17188ec7d390SKevin Wolf },{ 17198ec7d390SKevin Wolf .name = "format", 17208ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17218ec7d390SKevin Wolf .help = "disk format (raw, qcow2, ...)", 17228ec7d390SKevin Wolf },{ 17238ec7d390SKevin Wolf .name = "serial", 17248ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17258ec7d390SKevin Wolf .help = "disk serial number", 17268ec7d390SKevin Wolf },{ 17278ec7d390SKevin Wolf .name = "rerror", 17288ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17298ec7d390SKevin Wolf .help = "read error action", 17308ec7d390SKevin Wolf },{ 17318ec7d390SKevin Wolf .name = "werror", 17328ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17338ec7d390SKevin Wolf .help = "write error action", 17348ec7d390SKevin Wolf },{ 17358ec7d390SKevin Wolf .name = "addr", 17368ec7d390SKevin Wolf .type = QEMU_OPT_STRING, 17378ec7d390SKevin Wolf .help = "pci address (virtio only)", 17388ec7d390SKevin Wolf },{ 17398ec7d390SKevin Wolf .name = "readonly", 17408ec7d390SKevin Wolf .type = QEMU_OPT_BOOL, 17418ec7d390SKevin Wolf .help = "open drive file as read-only", 17428ec7d390SKevin Wolf },{ 17438ec7d390SKevin Wolf .name = "iops", 17448ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17458ec7d390SKevin Wolf .help = "limit total I/O operations per second", 17468ec7d390SKevin Wolf },{ 17478ec7d390SKevin Wolf .name = "iops_rd", 17488ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17498ec7d390SKevin Wolf .help = "limit read operations per second", 17508ec7d390SKevin Wolf },{ 17518ec7d390SKevin Wolf .name = "iops_wr", 17528ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17538ec7d390SKevin Wolf .help = "limit write operations per second", 17548ec7d390SKevin Wolf },{ 17558ec7d390SKevin Wolf .name = "bps", 17568ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17578ec7d390SKevin Wolf .help = "limit total bytes per second", 17588ec7d390SKevin Wolf },{ 17598ec7d390SKevin Wolf .name = "bps_rd", 17608ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17618ec7d390SKevin Wolf .help = "limit read bytes per second", 17628ec7d390SKevin Wolf },{ 17638ec7d390SKevin Wolf .name = "bps_wr", 17648ec7d390SKevin Wolf .type = QEMU_OPT_NUMBER, 17658ec7d390SKevin Wolf .help = "limit write bytes per second", 17668ec7d390SKevin Wolf },{ 17678ec7d390SKevin Wolf .name = "copy-on-read", 17688ec7d390SKevin Wolf .type = QEMU_OPT_BOOL, 17698ec7d390SKevin Wolf .help = "copy read data from backing file into image file", 17708ec7d390SKevin Wolf },{ 17718ec7d390SKevin Wolf .name = "boot", 17728ec7d390SKevin Wolf .type = QEMU_OPT_BOOL, 17738ec7d390SKevin Wolf .help = "(deprecated, ignored)", 17748ec7d390SKevin Wolf }, 17750006383eSKevin Wolf { /* end of list */ } 17760006383eSKevin Wolf }, 17770006383eSKevin Wolf }; 1778