blob: a85a429aef5a6215d89f70d626d1d66816f251db [file] [log] [blame]
Markus Armbruster666daa62010-06-02 18:48:27 +02001/*
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"
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +000016#include "qemu-objects.h"
Markus Armbruster666daa62010-06-02 18:48:27 +020017#include "sysemu.h"
Ryan Harper9063f812010-11-12 11:07:13 -060018#include "block_int.h"
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -020019#include "qmp-commands.h"
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +000020#include "trace.h"
Anthony Liguoric9344f22012-02-03 11:22:35 -060021#include "arch_init.h"
Markus Armbruster666daa62010-06-02 18:48:27 +020022
Markus Armbrusterc9b62a72010-06-02 18:55:22 +020023static QTAILQ_HEAD(drivelist, DriveInfo) drives = QTAILQ_HEAD_INITIALIZER(drives);
Markus Armbruster666daa62010-06-02 18:48:27 +020024
Markus Armbruster19609662011-01-28 11:21:39 +010025static const char *const if_name[IF_COUNT] = {
26 [IF_NONE] = "none",
27 [IF_IDE] = "ide",
28 [IF_SCSI] = "scsi",
29 [IF_FLOPPY] = "floppy",
30 [IF_PFLASH] = "pflash",
31 [IF_MTD] = "mtd",
32 [IF_SD] = "sd",
33 [IF_VIRTIO] = "virtio",
34 [IF_XEN] = "xen",
35};
36
37static const int if_max_devs[IF_COUNT] = {
Markus Armbruster27d6bf42011-01-28 11:21:40 +010038 /*
39 * Do not change these numbers! They govern how drive option
40 * index maps to unit and bus. That mapping is ABI.
41 *
42 * All controllers used to imlement if=T drives need to support
43 * if_max_devs[T] units, for any T with if_max_devs[T] != 0.
44 * Otherwise, some index values map to "impossible" bus, unit
45 * values.
46 *
47 * For instance, if you change [IF_SCSI] to 255, -drive
48 * if=scsi,index=12 no longer means bus=1,unit=5, but
49 * bus=0,unit=12. With an lsi53c895a controller (7 units max),
50 * the drive can't be set up. Regression.
51 */
52 [IF_IDE] = 2,
53 [IF_SCSI] = 7,
Markus Armbruster19609662011-01-28 11:21:39 +010054};
55
Markus Armbruster14bafc52010-06-25 08:09:10 +020056/*
57 * We automatically delete the drive when a device using it gets
58 * unplugged. Questionable feature, but we can't just drop it.
59 * Device models call blockdev_mark_auto_del() to schedule the
60 * automatic deletion, and generic qdev code calls blockdev_auto_del()
61 * when deletion is actually safe.
62 */
63void blockdev_mark_auto_del(BlockDriverState *bs)
64{
65 DriveInfo *dinfo = drive_get_by_blockdev(bs);
66
Paolo Bonzini12bde0e2012-03-30 13:17:10 +020067 if (bs->job) {
68 block_job_cancel(bs->job);
69 }
Ryan Harper0fc0f1f2010-12-08 10:05:00 -060070 if (dinfo) {
71 dinfo->auto_del = 1;
72 }
Markus Armbruster14bafc52010-06-25 08:09:10 +020073}
74
75void blockdev_auto_del(BlockDriverState *bs)
76{
77 DriveInfo *dinfo = drive_get_by_blockdev(bs);
78
Ryan Harper0fc0f1f2010-12-08 10:05:00 -060079 if (dinfo && dinfo->auto_del) {
Marcelo Tosatti84fb3922011-01-26 12:12:32 -020080 drive_put_ref(dinfo);
Markus Armbruster14bafc52010-06-25 08:09:10 +020081 }
82}
83
Markus Armbruster505a7fb2011-01-28 11:21:43 +010084static int drive_index_to_bus_id(BlockInterfaceType type, int index)
85{
86 int max_devs = if_max_devs[type];
87 return max_devs ? index / max_devs : 0;
88}
89
90static int drive_index_to_unit_id(BlockInterfaceType type, int index)
91{
92 int max_devs = if_max_devs[type];
93 return max_devs ? index % max_devs : index;
94}
95
Markus Armbruster2292dda2011-01-28 11:21:41 +010096QemuOpts *drive_def(const char *optstr)
97{
98 return qemu_opts_parse(qemu_find_opts("drive"), optstr, 0);
99}
100
101QemuOpts *drive_add(BlockInterfaceType type, int index, const char *file,
Markus Armbruster5645b0f2011-01-31 11:50:09 +0100102 const char *optstr)
Markus Armbruster666daa62010-06-02 18:48:27 +0200103{
Markus Armbruster666daa62010-06-02 18:48:27 +0200104 QemuOpts *opts;
Markus Armbruster2292dda2011-01-28 11:21:41 +0100105 char buf[32];
Markus Armbruster666daa62010-06-02 18:48:27 +0200106
Markus Armbruster2292dda2011-01-28 11:21:41 +0100107 opts = drive_def(optstr);
Markus Armbruster666daa62010-06-02 18:48:27 +0200108 if (!opts) {
109 return NULL;
110 }
Markus Armbruster2292dda2011-01-28 11:21:41 +0100111 if (type != IF_DEFAULT) {
112 qemu_opt_set(opts, "if", if_name[type]);
113 }
114 if (index >= 0) {
115 snprintf(buf, sizeof(buf), "%d", index);
116 qemu_opt_set(opts, "index", buf);
117 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200118 if (file)
119 qemu_opt_set(opts, "file", file);
120 return opts;
121}
122
123DriveInfo *drive_get(BlockInterfaceType type, int bus, int unit)
124{
125 DriveInfo *dinfo;
126
127 /* seek interface, bus and unit */
128
129 QTAILQ_FOREACH(dinfo, &drives, next) {
130 if (dinfo->type == type &&
131 dinfo->bus == bus &&
132 dinfo->unit == unit)
133 return dinfo;
134 }
135
136 return NULL;
137}
138
Markus Armbrusterf1bd51a2011-01-28 11:21:44 +0100139DriveInfo *drive_get_by_index(BlockInterfaceType type, int index)
140{
141 return drive_get(type,
142 drive_index_to_bus_id(type, index),
143 drive_index_to_unit_id(type, index));
144}
145
Markus Armbruster666daa62010-06-02 18:48:27 +0200146int drive_get_max_bus(BlockInterfaceType type)
147{
148 int max_bus;
149 DriveInfo *dinfo;
150
151 max_bus = -1;
152 QTAILQ_FOREACH(dinfo, &drives, next) {
153 if(dinfo->type == type &&
154 dinfo->bus > max_bus)
155 max_bus = dinfo->bus;
156 }
157 return max_bus;
158}
159
Markus Armbruster13839972011-01-28 11:21:37 +0100160/* Get a block device. This should only be used for single-drive devices
161 (e.g. SD/Floppy/MTD). Multi-disk devices (scsi/ide) should use the
162 appropriate bus. */
163DriveInfo *drive_get_next(BlockInterfaceType type)
164{
165 static int next_block_unit[IF_COUNT];
166
167 return drive_get(type, 0, next_block_unit[type]++);
168}
169
Markus Armbrustere4700e52010-06-24 17:25:32 +0200170DriveInfo *drive_get_by_blockdev(BlockDriverState *bs)
Markus Armbruster666daa62010-06-02 18:48:27 +0200171{
172 DriveInfo *dinfo;
173
174 QTAILQ_FOREACH(dinfo, &drives, next) {
Markus Armbrustere4700e52010-06-24 17:25:32 +0200175 if (dinfo->bdrv == bs) {
176 return dinfo;
177 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200178 }
Markus Armbrustere4700e52010-06-24 17:25:32 +0200179 return NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200180}
181
Markus Armbruster666daa62010-06-02 18:48:27 +0200182static void bdrv_format_print(void *opaque, const char *name)
183{
Markus Armbruster807105a2011-01-17 19:31:27 +0100184 error_printf(" %s", name);
Markus Armbruster666daa62010-06-02 18:48:27 +0200185}
186
Marcelo Tosatti84fb3922011-01-26 12:12:32 -0200187static void drive_uninit(DriveInfo *dinfo)
Markus Armbruster666daa62010-06-02 18:48:27 +0200188{
189 qemu_opts_del(dinfo->opts);
190 bdrv_delete(dinfo->bdrv);
Anthony Liguori7267c092011-08-20 22:09:37 -0500191 g_free(dinfo->id);
Markus Armbruster666daa62010-06-02 18:48:27 +0200192 QTAILQ_REMOVE(&drives, dinfo, next);
Anthony Liguori7267c092011-08-20 22:09:37 -0500193 g_free(dinfo);
Markus Armbruster666daa62010-06-02 18:48:27 +0200194}
195
Marcelo Tosatti84fb3922011-01-26 12:12:32 -0200196void drive_put_ref(DriveInfo *dinfo)
197{
198 assert(dinfo->refcount);
199 if (--dinfo->refcount == 0) {
200 drive_uninit(dinfo);
201 }
202}
203
204void drive_get_ref(DriveInfo *dinfo)
205{
206 dinfo->refcount++;
207}
208
Stefan Hajnocziaa398a52012-01-18 14:40:50 +0000209typedef struct {
210 QEMUBH *bh;
211 DriveInfo *dinfo;
212} DrivePutRefBH;
213
214static void drive_put_ref_bh(void *opaque)
215{
216 DrivePutRefBH *s = opaque;
217
218 drive_put_ref(s->dinfo);
219 qemu_bh_delete(s->bh);
220 g_free(s);
221}
222
223/*
224 * Release a drive reference in a BH
225 *
226 * It is not possible to use drive_put_ref() from a callback function when the
227 * callers still need the drive. In such cases we schedule a BH to release the
228 * reference.
229 */
230static void drive_put_ref_bh_schedule(DriveInfo *dinfo)
231{
232 DrivePutRefBH *s;
233
234 s = g_new(DrivePutRefBH, 1);
235 s->bh = qemu_bh_new(drive_put_ref_bh, s);
236 s->dinfo = dinfo;
237 qemu_bh_schedule(s->bh);
238}
239
Markus Armbruster666daa62010-06-02 18:48:27 +0200240static int parse_block_error_action(const char *buf, int is_read)
241{
242 if (!strcmp(buf, "ignore")) {
243 return BLOCK_ERR_IGNORE;
244 } else if (!is_read && !strcmp(buf, "enospc")) {
245 return BLOCK_ERR_STOP_ENOSPC;
246 } else if (!strcmp(buf, "stop")) {
247 return BLOCK_ERR_STOP_ANY;
248 } else if (!strcmp(buf, "report")) {
249 return BLOCK_ERR_REPORT;
250 } else {
Markus Armbruster807105a2011-01-17 19:31:27 +0100251 error_report("'%s' invalid %s error action",
252 buf, is_read ? "read" : "write");
Markus Armbruster666daa62010-06-02 18:48:27 +0200253 return -1;
254 }
255}
256
Zhi Yong Wu0563e192011-11-03 16:57:25 +0800257static bool do_check_io_limits(BlockIOLimit *io_limits)
258{
259 bool bps_flag;
260 bool iops_flag;
261
262 assert(io_limits);
263
264 bps_flag = (io_limits->bps[BLOCK_IO_LIMIT_TOTAL] != 0)
265 && ((io_limits->bps[BLOCK_IO_LIMIT_READ] != 0)
266 || (io_limits->bps[BLOCK_IO_LIMIT_WRITE] != 0));
267 iops_flag = (io_limits->iops[BLOCK_IO_LIMIT_TOTAL] != 0)
268 && ((io_limits->iops[BLOCK_IO_LIMIT_READ] != 0)
269 || (io_limits->iops[BLOCK_IO_LIMIT_WRITE] != 0));
270 if (bps_flag || iops_flag) {
271 return false;
272 }
273
274 return true;
275}
276
Markus Armbruster319ae522011-01-28 11:21:46 +0100277DriveInfo *drive_init(QemuOpts *opts, int default_to_scsi)
Markus Armbruster666daa62010-06-02 18:48:27 +0200278{
279 const char *buf;
280 const char *file = NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200281 const char *serial;
282 const char *mediastr = "";
283 BlockInterfaceType type;
284 enum { MEDIA_DISK, MEDIA_CDROM } media;
285 int bus_id, unit_id;
286 int cyls, heads, secs, translation;
287 BlockDriver *drv = NULL;
288 int max_devs;
289 int index;
290 int ro = 0;
291 int bdrv_flags = 0;
292 int on_read_error, on_write_error;
293 const char *devaddr;
294 DriveInfo *dinfo;
Zhi Yong Wu0563e192011-11-03 16:57:25 +0800295 BlockIOLimit io_limits;
Markus Armbruster666daa62010-06-02 18:48:27 +0200296 int snapshot = 0;
Stefan Hajnoczifb0490f2011-11-17 13:40:32 +0000297 bool copy_on_read;
Markus Armbruster666daa62010-06-02 18:48:27 +0200298 int ret;
299
Markus Armbruster666daa62010-06-02 18:48:27 +0200300 translation = BIOS_ATA_TRANSLATION_AUTO;
Markus Armbruster666daa62010-06-02 18:48:27 +0200301 media = MEDIA_DISK;
302
303 /* extract parameters */
304 bus_id = qemu_opt_get_number(opts, "bus", 0);
305 unit_id = qemu_opt_get_number(opts, "unit", -1);
306 index = qemu_opt_get_number(opts, "index", -1);
307
308 cyls = qemu_opt_get_number(opts, "cyls", 0);
309 heads = qemu_opt_get_number(opts, "heads", 0);
310 secs = qemu_opt_get_number(opts, "secs", 0);
311
312 snapshot = qemu_opt_get_bool(opts, "snapshot", 0);
313 ro = qemu_opt_get_bool(opts, "readonly", 0);
Stefan Hajnoczifb0490f2011-11-17 13:40:32 +0000314 copy_on_read = qemu_opt_get_bool(opts, "copy-on-read", false);
Markus Armbruster666daa62010-06-02 18:48:27 +0200315
316 file = qemu_opt_get(opts, "file");
317 serial = qemu_opt_get(opts, "serial");
318
319 if ((buf = qemu_opt_get(opts, "if")) != NULL) {
Markus Armbruster19609662011-01-28 11:21:39 +0100320 for (type = 0; type < IF_COUNT && strcmp(buf, if_name[type]); type++)
321 ;
322 if (type == IF_COUNT) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100323 error_report("unsupported bus type '%s'", buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200324 return NULL;
325 }
Luiz Capitulino2d3999f2011-07-01 10:46:12 -0300326 } else {
327 type = default_to_scsi ? IF_SCSI : IF_IDE;
Markus Armbruster666daa62010-06-02 18:48:27 +0200328 }
Luiz Capitulino2d3999f2011-07-01 10:46:12 -0300329
Markus Armbruster19609662011-01-28 11:21:39 +0100330 max_devs = if_max_devs[type];
Markus Armbruster666daa62010-06-02 18:48:27 +0200331
332 if (cyls || heads || secs) {
333 if (cyls < 1 || (type == IF_IDE && cyls > 16383)) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100334 error_report("invalid physical cyls number");
Markus Armbruster666daa62010-06-02 18:48:27 +0200335 return NULL;
336 }
337 if (heads < 1 || (type == IF_IDE && heads > 16)) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100338 error_report("invalid physical heads number");
Markus Armbruster666daa62010-06-02 18:48:27 +0200339 return NULL;
340 }
341 if (secs < 1 || (type == IF_IDE && secs > 63)) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100342 error_report("invalid physical secs number");
Markus Armbruster666daa62010-06-02 18:48:27 +0200343 return NULL;
344 }
345 }
346
347 if ((buf = qemu_opt_get(opts, "trans")) != NULL) {
348 if (!cyls) {
Markus Armbrustere4080f92011-06-22 14:03:57 +0200349 error_report("'%s' trans must be used with cyls, heads and secs",
Markus Armbruster807105a2011-01-17 19:31:27 +0100350 buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200351 return NULL;
352 }
353 if (!strcmp(buf, "none"))
354 translation = BIOS_ATA_TRANSLATION_NONE;
355 else if (!strcmp(buf, "lba"))
356 translation = BIOS_ATA_TRANSLATION_LBA;
357 else if (!strcmp(buf, "auto"))
358 translation = BIOS_ATA_TRANSLATION_AUTO;
359 else {
Markus Armbruster807105a2011-01-17 19:31:27 +0100360 error_report("'%s' invalid translation type", buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200361 return NULL;
362 }
363 }
364
365 if ((buf = qemu_opt_get(opts, "media")) != NULL) {
366 if (!strcmp(buf, "disk")) {
367 media = MEDIA_DISK;
368 } else if (!strcmp(buf, "cdrom")) {
369 if (cyls || secs || heads) {
Luiz Capitulinoe7ff8f02011-07-01 10:46:13 -0300370 error_report("CHS can't be set with media=%s", buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200371 return NULL;
372 }
373 media = MEDIA_CDROM;
374 } else {
Markus Armbruster807105a2011-01-17 19:31:27 +0100375 error_report("'%s' invalid media", buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200376 return NULL;
377 }
378 }
379
380 if ((buf = qemu_opt_get(opts, "cache")) != NULL) {
Stefan Hajnoczic3993cd2011-08-04 12:26:51 +0100381 if (bdrv_parse_cache_flags(buf, &bdrv_flags) != 0) {
382 error_report("invalid cache option");
383 return NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200384 }
385 }
386
387#ifdef CONFIG_LINUX_AIO
388 if ((buf = qemu_opt_get(opts, "aio")) != NULL) {
389 if (!strcmp(buf, "native")) {
390 bdrv_flags |= BDRV_O_NATIVE_AIO;
391 } else if (!strcmp(buf, "threads")) {
392 /* this is the default */
393 } else {
Markus Armbruster807105a2011-01-17 19:31:27 +0100394 error_report("invalid aio option");
Markus Armbruster666daa62010-06-02 18:48:27 +0200395 return NULL;
396 }
397 }
398#endif
399
400 if ((buf = qemu_opt_get(opts, "format")) != NULL) {
401 if (strcmp(buf, "?") == 0) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100402 error_printf("Supported formats:");
403 bdrv_iterate_format(bdrv_format_print, NULL);
404 error_printf("\n");
405 return NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200406 }
407 drv = bdrv_find_whitelisted_format(buf);
408 if (!drv) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100409 error_report("'%s' invalid format", buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200410 return NULL;
411 }
412 }
413
Zhi Yong Wu0563e192011-11-03 16:57:25 +0800414 /* disk I/O throttling */
415 io_limits.bps[BLOCK_IO_LIMIT_TOTAL] =
416 qemu_opt_get_number(opts, "bps", 0);
417 io_limits.bps[BLOCK_IO_LIMIT_READ] =
418 qemu_opt_get_number(opts, "bps_rd", 0);
419 io_limits.bps[BLOCK_IO_LIMIT_WRITE] =
420 qemu_opt_get_number(opts, "bps_wr", 0);
421 io_limits.iops[BLOCK_IO_LIMIT_TOTAL] =
422 qemu_opt_get_number(opts, "iops", 0);
423 io_limits.iops[BLOCK_IO_LIMIT_READ] =
424 qemu_opt_get_number(opts, "iops_rd", 0);
425 io_limits.iops[BLOCK_IO_LIMIT_WRITE] =
426 qemu_opt_get_number(opts, "iops_wr", 0);
427
428 if (!do_check_io_limits(&io_limits)) {
429 error_report("bps(iops) and bps_rd/bps_wr(iops_rd/iops_wr) "
430 "cannot be used at the same time");
431 return NULL;
432 }
433
Markus Armbruster666daa62010-06-02 18:48:27 +0200434 on_write_error = BLOCK_ERR_STOP_ENOSPC;
435 if ((buf = qemu_opt_get(opts, "werror")) != NULL) {
436 if (type != IF_IDE && type != IF_SCSI && type != IF_VIRTIO && type != IF_NONE) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100437 error_report("werror is not supported by this bus type");
Markus Armbruster666daa62010-06-02 18:48:27 +0200438 return NULL;
439 }
440
441 on_write_error = parse_block_error_action(buf, 0);
442 if (on_write_error < 0) {
443 return NULL;
444 }
445 }
446
447 on_read_error = BLOCK_ERR_REPORT;
448 if ((buf = qemu_opt_get(opts, "rerror")) != NULL) {
Kevin Wolf5dba48a2010-10-25 14:52:21 +0200449 if (type != IF_IDE && type != IF_VIRTIO && type != IF_SCSI && type != IF_NONE) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100450 error_report("rerror is not supported by this bus type");
Markus Armbruster666daa62010-06-02 18:48:27 +0200451 return NULL;
452 }
453
454 on_read_error = parse_block_error_action(buf, 1);
455 if (on_read_error < 0) {
456 return NULL;
457 }
458 }
459
460 if ((devaddr = qemu_opt_get(opts, "addr")) != NULL) {
461 if (type != IF_VIRTIO) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100462 error_report("addr is not supported by this bus type");
Markus Armbruster666daa62010-06-02 18:48:27 +0200463 return NULL;
464 }
465 }
466
467 /* compute bus and unit according index */
468
469 if (index != -1) {
470 if (bus_id != 0 || unit_id != -1) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100471 error_report("index cannot be used with bus and unit");
Markus Armbruster666daa62010-06-02 18:48:27 +0200472 return NULL;
473 }
Markus Armbruster505a7fb2011-01-28 11:21:43 +0100474 bus_id = drive_index_to_bus_id(type, index);
475 unit_id = drive_index_to_unit_id(type, index);
Markus Armbruster666daa62010-06-02 18:48:27 +0200476 }
477
478 /* if user doesn't specify a unit_id,
479 * try to find the first free
480 */
481
482 if (unit_id == -1) {
483 unit_id = 0;
484 while (drive_get(type, bus_id, unit_id) != NULL) {
485 unit_id++;
486 if (max_devs && unit_id >= max_devs) {
487 unit_id -= max_devs;
488 bus_id++;
489 }
490 }
491 }
492
493 /* check unit id */
494
495 if (max_devs && unit_id >= max_devs) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100496 error_report("unit %d too big (max is %d)",
497 unit_id, max_devs - 1);
Markus Armbruster666daa62010-06-02 18:48:27 +0200498 return NULL;
499 }
500
501 /*
Markus Armbruster4e5d9b52011-01-28 11:21:45 +0100502 * catch multiple definitions
Markus Armbruster666daa62010-06-02 18:48:27 +0200503 */
504
505 if (drive_get(type, bus_id, unit_id) != NULL) {
Markus Armbruster4e5d9b52011-01-28 11:21:45 +0100506 error_report("drive with bus=%d, unit=%d (index=%d) exists",
507 bus_id, unit_id, index);
Markus Armbruster666daa62010-06-02 18:48:27 +0200508 return NULL;
509 }
510
511 /* init */
512
Anthony Liguori7267c092011-08-20 22:09:37 -0500513 dinfo = g_malloc0(sizeof(*dinfo));
Markus Armbruster666daa62010-06-02 18:48:27 +0200514 if ((buf = qemu_opts_id(opts)) != NULL) {
Anthony Liguori7267c092011-08-20 22:09:37 -0500515 dinfo->id = g_strdup(buf);
Markus Armbruster666daa62010-06-02 18:48:27 +0200516 } else {
517 /* no id supplied -> create one */
Anthony Liguori7267c092011-08-20 22:09:37 -0500518 dinfo->id = g_malloc0(32);
Markus Armbruster666daa62010-06-02 18:48:27 +0200519 if (type == IF_IDE || type == IF_SCSI)
520 mediastr = (media == MEDIA_CDROM) ? "-cd" : "-hd";
521 if (max_devs)
522 snprintf(dinfo->id, 32, "%s%i%s%i",
Markus Armbruster79d21d52012-06-05 14:52:53 +0200523 if_name[type], bus_id, mediastr, unit_id);
Markus Armbruster666daa62010-06-02 18:48:27 +0200524 else
525 snprintf(dinfo->id, 32, "%s%s%i",
Markus Armbruster79d21d52012-06-05 14:52:53 +0200526 if_name[type], mediastr, unit_id);
Markus Armbruster666daa62010-06-02 18:48:27 +0200527 }
528 dinfo->bdrv = bdrv_new(dinfo->id);
529 dinfo->devaddr = devaddr;
530 dinfo->type = type;
531 dinfo->bus = bus_id;
532 dinfo->unit = unit_id;
Markus Armbruster666daa62010-06-02 18:48:27 +0200533 dinfo->opts = opts;
Marcelo Tosatti84fb3922011-01-26 12:12:32 -0200534 dinfo->refcount = 1;
Floris Bosaa2c91b2012-03-12 21:05:10 +0100535 if (serial) {
536 pstrcpy(dinfo->serial, sizeof(dinfo->serial), serial);
537 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200538 QTAILQ_INSERT_TAIL(&drives, dinfo, next);
539
Markus Armbrusterabd7f682010-06-02 18:55:17 +0200540 bdrv_set_on_error(dinfo->bdrv, on_read_error, on_write_error);
541
Zhi Yong Wu0563e192011-11-03 16:57:25 +0800542 /* disk I/O throttling */
543 bdrv_set_io_limits(dinfo->bdrv, &io_limits);
544
Markus Armbruster666daa62010-06-02 18:48:27 +0200545 switch(type) {
546 case IF_IDE:
547 case IF_SCSI:
548 case IF_XEN:
549 case IF_NONE:
550 switch(media) {
551 case MEDIA_DISK:
552 if (cyls != 0) {
553 bdrv_set_geometry_hint(dinfo->bdrv, cyls, heads, secs);
554 bdrv_set_translation_hint(dinfo->bdrv, translation);
555 }
556 break;
557 case MEDIA_CDROM:
Markus Armbruster95b5edc2011-05-16 15:04:56 +0200558 dinfo->media_cd = 1;
Markus Armbruster666daa62010-06-02 18:48:27 +0200559 break;
560 }
561 break;
562 case IF_SD:
Markus Armbruster666daa62010-06-02 18:48:27 +0200563 case IF_FLOPPY:
Markus Armbruster666daa62010-06-02 18:48:27 +0200564 case IF_PFLASH:
565 case IF_MTD:
566 break;
567 case IF_VIRTIO:
568 /* add virtio block device */
Luiz Capitulino8be7e7e2012-03-20 15:51:57 -0300569 opts = qemu_opts_create(qemu_find_opts("device"), NULL, 0, NULL);
Anthony Liguorieeb9c1b2012-02-03 11:13:30 -0600570 if (arch_type == QEMU_ARCH_S390X) {
571 qemu_opt_set(opts, "driver", "virtio-blk-s390");
572 } else {
573 qemu_opt_set(opts, "driver", "virtio-blk-pci");
574 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200575 qemu_opt_set(opts, "drive", dinfo->id);
576 if (devaddr)
577 qemu_opt_set(opts, "addr", devaddr);
578 break;
Markus Armbruster2292dda2011-01-28 11:21:41 +0100579 default:
Markus Armbruster666daa62010-06-02 18:48:27 +0200580 abort();
581 }
Markus Armbrusterdd5b0d72010-05-11 15:36:46 +0200582 if (!file || !*file) {
Markus Armbruster319ae522011-01-28 11:21:46 +0100583 return dinfo;
Markus Armbruster666daa62010-06-02 18:48:27 +0200584 }
585 if (snapshot) {
586 /* always use cache=unsafe with snapshot */
587 bdrv_flags &= ~BDRV_O_CACHE_MASK;
588 bdrv_flags |= (BDRV_O_SNAPSHOT|BDRV_O_CACHE_WB|BDRV_O_NO_FLUSH);
589 }
590
Stefan Hajnoczifb0490f2011-11-17 13:40:32 +0000591 if (copy_on_read) {
592 bdrv_flags |= BDRV_O_COPY_ON_READ;
593 }
594
Benoît Caneted9d4202012-03-23 08:36:50 +0100595 if (runstate_check(RUN_STATE_INMIGRATE)) {
596 bdrv_flags |= BDRV_O_INCOMING;
597 }
598
Markus Armbruster666daa62010-06-02 18:48:27 +0200599 if (media == MEDIA_CDROM) {
600 /* CDROM is fine for any interface, don't check. */
601 ro = 1;
602 } else if (ro == 1) {
Jordan Justen1e9eb782012-02-21 23:18:48 -0800603 if (type != IF_SCSI && type != IF_VIRTIO && type != IF_FLOPPY &&
604 type != IF_NONE && type != IF_PFLASH) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100605 error_report("readonly not supported by this bus type");
Markus Armbrustera9ae2bf2011-02-08 15:12:39 +0100606 goto err;
Markus Armbruster666daa62010-06-02 18:48:27 +0200607 }
608 }
609
610 bdrv_flags |= ro ? 0 : BDRV_O_RDWR;
611
Stefan Hajnoczi04d4abe2012-06-27 18:03:13 +0100612 if (ro && copy_on_read) {
613 error_report("warning: disabling copy_on_read on readonly drive");
614 }
615
Markus Armbruster666daa62010-06-02 18:48:27 +0200616 ret = bdrv_open(dinfo->bdrv, file, bdrv_flags, drv);
617 if (ret < 0) {
Markus Armbruster807105a2011-01-17 19:31:27 +0100618 error_report("could not open disk image %s: %s",
619 file, strerror(-ret));
Markus Armbrustera9ae2bf2011-02-08 15:12:39 +0100620 goto err;
Markus Armbruster666daa62010-06-02 18:48:27 +0200621 }
622
623 if (bdrv_key_required(dinfo->bdrv))
624 autostart = 0;
Markus Armbruster666daa62010-06-02 18:48:27 +0200625 return dinfo;
Markus Armbrustera9ae2bf2011-02-08 15:12:39 +0100626
627err:
628 bdrv_delete(dinfo->bdrv);
Anthony Liguori7267c092011-08-20 22:09:37 -0500629 g_free(dinfo->id);
Markus Armbrustera9ae2bf2011-02-08 15:12:39 +0100630 QTAILQ_REMOVE(&drives, dinfo, next);
Anthony Liguori7267c092011-08-20 22:09:37 -0500631 g_free(dinfo);
Markus Armbrustera9ae2bf2011-02-08 15:12:39 +0100632 return NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200633}
634
635void do_commit(Monitor *mon, const QDict *qdict)
636{
Markus Armbruster666daa62010-06-02 18:48:27 +0200637 const char *device = qdict_get_str(qdict, "device");
Markus Armbruster6ab4b5a2010-06-02 18:55:18 +0200638 BlockDriverState *bs;
Stefan Hajnoczie8877492012-03-05 18:10:11 +0000639 int ret;
Markus Armbruster666daa62010-06-02 18:48:27 +0200640
Markus Armbruster6ab4b5a2010-06-02 18:55:18 +0200641 if (!strcmp(device, "all")) {
Stefan Hajnoczie8877492012-03-05 18:10:11 +0000642 ret = bdrv_commit_all();
643 if (ret == -EBUSY) {
644 qerror_report(QERR_DEVICE_IN_USE, device);
645 return;
646 }
Markus Armbruster6ab4b5a2010-06-02 18:55:18 +0200647 } else {
648 bs = bdrv_find(device);
Markus Armbrusterac59eb92010-06-02 18:55:19 +0200649 if (!bs) {
650 qerror_report(QERR_DEVICE_NOT_FOUND, device);
651 return;
Markus Armbruster6ab4b5a2010-06-02 18:55:18 +0200652 }
Stefan Hajnoczi2d3735d2012-01-18 14:40:41 +0000653 ret = bdrv_commit(bs);
654 if (ret == -EBUSY) {
655 qerror_report(QERR_DEVICE_IN_USE, device);
656 return;
657 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200658 }
659}
660
Paolo Bonzini6cc2a412012-03-06 18:55:59 +0100661static void blockdev_do_action(int kind, void *data, Error **errp)
662{
663 BlockdevAction action;
664 BlockdevActionList list;
665
666 action.kind = kind;
667 action.data = data;
668 list.value = &action;
669 list.next = NULL;
670 qmp_transaction(&list, errp);
671}
672
Luiz Capitulino6106e242011-11-25 16:15:19 -0200673void qmp_blockdev_snapshot_sync(const char *device, const char *snapshot_file,
674 bool has_format, const char *format,
Paolo Bonzini6cc2a412012-03-06 18:55:59 +0100675 bool has_mode, enum NewImageMode mode,
Luiz Capitulino6106e242011-11-25 16:15:19 -0200676 Error **errp)
Jes Sorensenf8882562010-12-16 13:52:16 +0100677{
Paolo Bonzini6cc2a412012-03-06 18:55:59 +0100678 BlockdevSnapshot snapshot = {
679 .device = (char *) device,
680 .snapshot_file = (char *) snapshot_file,
681 .has_format = has_format,
682 .format = (char *) format,
683 .has_mode = has_mode,
684 .mode = mode,
685 };
686 blockdev_do_action(BLOCKDEV_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC, &snapshot,
687 errp);
Jes Sorensenf8882562010-12-16 13:52:16 +0100688}
689
Jeff Cody8802d1f2012-02-28 15:54:06 -0500690
691/* New and old BlockDriverState structs for group snapshots */
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100692typedef struct BlkTransactionStates {
Jeff Cody8802d1f2012-02-28 15:54:06 -0500693 BlockDriverState *old_bs;
694 BlockDriverState *new_bs;
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100695 QSIMPLEQ_ENTRY(BlkTransactionStates) entry;
696} BlkTransactionStates;
Jeff Cody8802d1f2012-02-28 15:54:06 -0500697
698/*
699 * 'Atomic' group snapshots. The snapshots are taken as a set, and if any fail
700 * then we do not pivot any of the devices in the group, and abandon the
701 * snapshots
702 */
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100703void qmp_transaction(BlockdevActionList *dev_list, Error **errp)
Jeff Cody8802d1f2012-02-28 15:54:06 -0500704{
705 int ret = 0;
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100706 BlockdevActionList *dev_entry = dev_list;
707 BlkTransactionStates *states, *next;
Jeff Cody8802d1f2012-02-28 15:54:06 -0500708
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100709 QSIMPLEQ_HEAD(snap_bdrv_states, BlkTransactionStates) snap_bdrv_states;
Jeff Cody8802d1f2012-02-28 15:54:06 -0500710 QSIMPLEQ_INIT(&snap_bdrv_states);
711
712 /* drain all i/o before any snapshots */
713 bdrv_drain_all();
714
715 /* We don't do anything in this loop that commits us to the snapshot */
716 while (NULL != dev_entry) {
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100717 BlockdevAction *dev_info = NULL;
718 BlockDriver *proto_drv;
719 BlockDriver *drv;
720 int flags;
Paolo Bonzinibc8b0942012-03-06 18:55:58 +0100721 enum NewImageMode mode;
722 const char *new_image_file;
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100723 const char *device;
724 const char *format = "qcow2";
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100725
Jeff Cody8802d1f2012-02-28 15:54:06 -0500726 dev_info = dev_entry->value;
727 dev_entry = dev_entry->next;
728
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100729 states = g_malloc0(sizeof(BlkTransactionStates));
Jeff Cody8802d1f2012-02-28 15:54:06 -0500730 QSIMPLEQ_INSERT_TAIL(&snap_bdrv_states, states, entry);
731
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100732 switch (dev_info->kind) {
733 case BLOCKDEV_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC:
734 device = dev_info->blockdev_snapshot_sync->device;
Paolo Bonzinibc8b0942012-03-06 18:55:58 +0100735 if (!dev_info->blockdev_snapshot_sync->has_mode) {
736 dev_info->blockdev_snapshot_sync->mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
737 }
738 new_image_file = dev_info->blockdev_snapshot_sync->snapshot_file;
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100739 if (dev_info->blockdev_snapshot_sync->has_format) {
740 format = dev_info->blockdev_snapshot_sync->format;
741 }
Paolo Bonzinibc8b0942012-03-06 18:55:58 +0100742 mode = dev_info->blockdev_snapshot_sync->mode;
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100743 break;
744 default:
745 abort();
746 }
Jeff Cody8802d1f2012-02-28 15:54:06 -0500747
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100748 drv = bdrv_find_format(format);
749 if (!drv) {
750 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
751 goto delete_and_fail;
752 }
753
754 states->old_bs = bdrv_find(device);
Jeff Cody8802d1f2012-02-28 15:54:06 -0500755 if (!states->old_bs) {
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100756 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
Jeff Cody8802d1f2012-02-28 15:54:06 -0500757 goto delete_and_fail;
758 }
759
Paolo Bonzinie86fe182012-04-12 14:00:59 +0200760 if (!bdrv_is_inserted(states->old_bs)) {
761 error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
762 goto delete_and_fail;
763 }
764
Jeff Cody8802d1f2012-02-28 15:54:06 -0500765 if (bdrv_in_use(states->old_bs)) {
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100766 error_set(errp, QERR_DEVICE_IN_USE, device);
Jeff Cody8802d1f2012-02-28 15:54:06 -0500767 goto delete_and_fail;
768 }
769
Paolo Bonzinie86fe182012-04-12 14:00:59 +0200770 if (!bdrv_is_read_only(states->old_bs)) {
Jeff Cody8802d1f2012-02-28 15:54:06 -0500771 if (bdrv_flush(states->old_bs)) {
772 error_set(errp, QERR_IO_ERROR);
773 goto delete_and_fail;
774 }
775 }
776
Jeff Cody8802d1f2012-02-28 15:54:06 -0500777 flags = states->old_bs->open_flags;
778
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100779 proto_drv = bdrv_find_protocol(new_image_file);
Jeff Cody8802d1f2012-02-28 15:54:06 -0500780 if (!proto_drv) {
781 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
782 goto delete_and_fail;
783 }
784
785 /* create new image w/backing file */
Paolo Bonzinibc8b0942012-03-06 18:55:58 +0100786 if (mode != NEW_IMAGE_MODE_EXISTING) {
787 ret = bdrv_img_create(new_image_file, format,
788 states->old_bs->filename,
789 states->old_bs->drv->format_name,
790 NULL, -1, flags);
791 if (ret) {
792 error_set(errp, QERR_OPEN_FILE_FAILED, new_image_file);
793 goto delete_and_fail;
794 }
Jeff Cody8802d1f2012-02-28 15:54:06 -0500795 }
796
797 /* We will manually add the backing_hd field to the bs later */
798 states->new_bs = bdrv_new("");
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100799 ret = bdrv_open(states->new_bs, new_image_file,
Jeff Cody8802d1f2012-02-28 15:54:06 -0500800 flags | BDRV_O_NO_BACKING, drv);
801 if (ret != 0) {
Paolo Bonzini52e7c242012-03-06 18:55:57 +0100802 error_set(errp, QERR_OPEN_FILE_FAILED, new_image_file);
Jeff Cody8802d1f2012-02-28 15:54:06 -0500803 goto delete_and_fail;
804 }
805 }
806
807
808 /* Now we are going to do the actual pivot. Everything up to this point
809 * is reversible, but we are committed at this point */
810 QSIMPLEQ_FOREACH(states, &snap_bdrv_states, entry) {
811 /* This removes our old bs from the bdrv_states, and adds the new bs */
812 bdrv_append(states->new_bs, states->old_bs);
813 }
814
815 /* success */
816 goto exit;
817
818delete_and_fail:
819 /*
820 * failure, and it is all-or-none; abandon each new bs, and keep using
821 * the original bs for all images
822 */
823 QSIMPLEQ_FOREACH(states, &snap_bdrv_states, entry) {
824 if (states->new_bs) {
825 bdrv_delete(states->new_bs);
826 }
827 }
828exit:
Paolo Bonzini622d2412012-03-06 18:55:54 +0100829 QSIMPLEQ_FOREACH_SAFE(states, &snap_bdrv_states, entry, next) {
Jeff Cody8802d1f2012-02-28 15:54:06 -0500830 g_free(states);
831 }
832 return;
833}
834
835
Luiz Capitulino92d48552011-12-07 15:47:23 -0200836static void eject_device(BlockDriverState *bs, int force, Error **errp)
Markus Armbruster666daa62010-06-02 18:48:27 +0200837{
Stefan Hajnoczi2d3735d2012-01-18 14:40:41 +0000838 if (bdrv_in_use(bs)) {
839 error_set(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs));
840 return;
841 }
Markus Armbruster2c6942f2011-09-06 18:58:51 +0200842 if (!bdrv_dev_has_removable_media(bs)) {
Luiz Capitulino92d48552011-12-07 15:47:23 -0200843 error_set(errp, QERR_DEVICE_NOT_REMOVABLE, bdrv_get_device_name(bs));
844 return;
Markus Armbrusterea8f9422011-07-20 18:23:35 +0200845 }
Luiz Capitulino92d48552011-12-07 15:47:23 -0200846
Paolo Bonzini025ccaa2011-11-07 17:50:13 +0100847 if (bdrv_dev_is_medium_locked(bs) && !bdrv_dev_is_tray_open(bs)) {
848 bdrv_dev_eject_request(bs, force);
849 if (!force) {
Luiz Capitulino92d48552011-12-07 15:47:23 -0200850 error_set(errp, QERR_DEVICE_LOCKED, bdrv_get_device_name(bs));
851 return;
Paolo Bonzini025ccaa2011-11-07 17:50:13 +0100852 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200853 }
Luiz Capitulino92d48552011-12-07 15:47:23 -0200854
Eduardo Habkost3b5276b2010-06-01 19:12:19 -0300855 bdrv_close(bs);
Markus Armbruster666daa62010-06-02 18:48:27 +0200856}
857
Luiz Capitulinoc245b6a2011-12-07 16:02:36 -0200858void qmp_eject(const char *device, bool has_force, bool force, Error **errp)
Markus Armbruster666daa62010-06-02 18:48:27 +0200859{
860 BlockDriverState *bs;
Markus Armbruster666daa62010-06-02 18:48:27 +0200861
Luiz Capitulinoc245b6a2011-12-07 16:02:36 -0200862 bs = bdrv_find(device);
Markus Armbruster666daa62010-06-02 18:48:27 +0200863 if (!bs) {
Luiz Capitulinoc245b6a2011-12-07 16:02:36 -0200864 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
865 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200866 }
Luiz Capitulino92d48552011-12-07 15:47:23 -0200867
Luiz Capitulinoc245b6a2011-12-07 16:02:36 -0200868 eject_device(bs, force, errp);
Markus Armbruster666daa62010-06-02 18:48:27 +0200869}
870
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200871void qmp_block_passwd(const char *device, const char *password, Error **errp)
Markus Armbruster666daa62010-06-02 18:48:27 +0200872{
873 BlockDriverState *bs;
874 int err;
875
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200876 bs = bdrv_find(device);
Markus Armbruster666daa62010-06-02 18:48:27 +0200877 if (!bs) {
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200878 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
879 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200880 }
881
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200882 err = bdrv_set_key(bs, password);
Markus Armbruster666daa62010-06-02 18:48:27 +0200883 if (err == -EINVAL) {
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200884 error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs));
885 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200886 } else if (err < 0) {
Luiz Capitulinoa4dea8a2011-11-23 13:28:21 -0200887 error_set(errp, QERR_INVALID_PASSWORD);
888 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200889 }
Markus Armbruster666daa62010-06-02 18:48:27 +0200890}
891
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200892static void qmp_bdrv_open_encrypted(BlockDriverState *bs, const char *filename,
893 int bdrv_flags, BlockDriver *drv,
894 const char *password, Error **errp)
895{
896 if (bdrv_open(bs, filename, bdrv_flags, drv) < 0) {
897 error_set(errp, QERR_OPEN_FILE_FAILED, filename);
898 return;
899 }
900
901 if (bdrv_key_required(bs)) {
902 if (password) {
903 if (bdrv_set_key(bs, password) < 0) {
904 error_set(errp, QERR_INVALID_PASSWORD);
905 }
906 } else {
907 error_set(errp, QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs),
908 bdrv_get_encrypted_filename(bs));
909 }
910 } else if (password) {
911 error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs));
912 }
913}
914
915void qmp_change_blockdev(const char *device, const char *filename,
916 bool has_format, const char *format, Error **errp)
Markus Armbruster666daa62010-06-02 18:48:27 +0200917{
918 BlockDriverState *bs;
919 BlockDriver *drv = NULL;
920 int bdrv_flags;
Luiz Capitulino92d48552011-12-07 15:47:23 -0200921 Error *err = NULL;
Markus Armbruster666daa62010-06-02 18:48:27 +0200922
923 bs = bdrv_find(device);
924 if (!bs) {
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200925 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
926 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200927 }
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200928
929 if (format) {
930 drv = bdrv_find_whitelisted_format(format);
Markus Armbruster666daa62010-06-02 18:48:27 +0200931 if (!drv) {
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200932 error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
933 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200934 }
935 }
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200936
Luiz Capitulino92d48552011-12-07 15:47:23 -0200937 eject_device(bs, 0, &err);
938 if (error_is_set(&err)) {
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200939 error_propagate(errp, err);
940 return;
Markus Armbruster666daa62010-06-02 18:48:27 +0200941 }
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200942
Markus Armbruster528f7662010-06-25 15:26:48 +0200943 bdrv_flags = bdrv_is_read_only(bs) ? 0 : BDRV_O_RDWR;
Blue Swirl199630b2010-07-25 20:49:34 +0000944 bdrv_flags |= bdrv_is_snapshot(bs) ? BDRV_O_SNAPSHOT : 0;
Luiz Capitulino333a96e2011-12-08 11:13:50 -0200945
946 qmp_bdrv_open_encrypted(bs, filename, bdrv_flags, drv, NULL, errp);
Markus Armbruster666daa62010-06-02 18:48:27 +0200947}
Ryan Harper9063f812010-11-12 11:07:13 -0600948
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800949/* throttling disk I/O limits */
Luiz Capitulino80047da2011-12-14 16:49:14 -0200950void qmp_block_set_io_throttle(const char *device, int64_t bps, int64_t bps_rd,
951 int64_t bps_wr, int64_t iops, int64_t iops_rd,
952 int64_t iops_wr, Error **errp)
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800953{
954 BlockIOLimit io_limits;
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800955 BlockDriverState *bs;
956
Luiz Capitulino80047da2011-12-14 16:49:14 -0200957 bs = bdrv_find(device);
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800958 if (!bs) {
Luiz Capitulino80047da2011-12-14 16:49:14 -0200959 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
960 return;
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800961 }
962
Luiz Capitulino80047da2011-12-14 16:49:14 -0200963 io_limits.bps[BLOCK_IO_LIMIT_TOTAL] = bps;
964 io_limits.bps[BLOCK_IO_LIMIT_READ] = bps_rd;
965 io_limits.bps[BLOCK_IO_LIMIT_WRITE] = bps_wr;
966 io_limits.iops[BLOCK_IO_LIMIT_TOTAL]= iops;
967 io_limits.iops[BLOCK_IO_LIMIT_READ] = iops_rd;
968 io_limits.iops[BLOCK_IO_LIMIT_WRITE]= iops_wr;
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800969
970 if (!do_check_io_limits(&io_limits)) {
Luiz Capitulino80047da2011-12-14 16:49:14 -0200971 error_set(errp, QERR_INVALID_PARAMETER_COMBINATION);
972 return;
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800973 }
974
975 bs->io_limits = io_limits;
976 bs->slice_time = BLOCK_IO_SLICE_TIME;
977
978 if (!bs->io_limits_enabled && bdrv_io_limits_enabled(bs)) {
979 bdrv_io_limits_enable(bs);
980 } else if (bs->io_limits_enabled && !bdrv_io_limits_enabled(bs)) {
981 bdrv_io_limits_disable(bs);
982 } else {
983 if (bs->block_timer) {
984 qemu_mod_timer(bs->block_timer, qemu_get_clock_ns(vm_clock));
985 }
986 }
Zhi Yong Wu727f0052011-11-08 13:00:31 +0800987}
988
Ryan Harper9063f812010-11-12 11:07:13 -0600989int do_drive_del(Monitor *mon, const QDict *qdict, QObject **ret_data)
990{
991 const char *id = qdict_get_str(qdict, "id");
992 BlockDriverState *bs;
Ryan Harper9063f812010-11-12 11:07:13 -0600993
994 bs = bdrv_find(id);
995 if (!bs) {
996 qerror_report(QERR_DEVICE_NOT_FOUND, id);
997 return -1;
998 }
Marcelo Tosatti85916752011-01-26 12:12:35 -0200999 if (bdrv_in_use(bs)) {
1000 qerror_report(QERR_DEVICE_IN_USE, id);
1001 return -1;
1002 }
Ryan Harper9063f812010-11-12 11:07:13 -06001003
1004 /* quiesce block driver; prevent further io */
Stefan Hajnoczi922453b2011-11-30 12:23:43 +00001005 bdrv_drain_all();
Ryan Harper9063f812010-11-12 11:07:13 -06001006 bdrv_flush(bs);
1007 bdrv_close(bs);
1008
Markus Armbrusterfa879d62011-08-03 15:07:40 +02001009 /* if we have a device attached to this BlockDriverState
Ryan Harperd22b2f42011-03-29 20:51:47 -05001010 * then we need to make the drive anonymous until the device
1011 * can be removed. If this is a drive with no device backing
1012 * then we can just get rid of the block driver state right here.
1013 */
Markus Armbrusterfa879d62011-08-03 15:07:40 +02001014 if (bdrv_get_attached_dev(bs)) {
Ryan Harperd22b2f42011-03-29 20:51:47 -05001015 bdrv_make_anon(bs);
1016 } else {
1017 drive_uninit(drive_get_by_blockdev(bs));
Ryan Harper9063f812010-11-12 11:07:13 -06001018 }
1019
Ryan Harper9063f812010-11-12 11:07:13 -06001020 return 0;
1021}
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001022
Luiz Capitulino5e7caac2011-11-25 14:57:10 -02001023void qmp_block_resize(const char *device, int64_t size, Error **errp)
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001024{
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001025 BlockDriverState *bs;
1026
1027 bs = bdrv_find(device);
1028 if (!bs) {
Luiz Capitulino5e7caac2011-11-25 14:57:10 -02001029 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1030 return;
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001031 }
1032
1033 if (size < 0) {
Stefan Hajnoczi939a1cc2012-01-04 22:23:34 +00001034 error_set(errp, QERR_INVALID_PARAMETER_VALUE, "size", "a >0 size");
Luiz Capitulino5e7caac2011-11-25 14:57:10 -02001035 return;
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001036 }
1037
Stefan Hajnoczi939a1cc2012-01-04 22:23:34 +00001038 switch (bdrv_truncate(bs, size)) {
1039 case 0:
1040 break;
1041 case -ENOMEDIUM:
1042 error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
1043 break;
1044 case -ENOTSUP:
1045 error_set(errp, QERR_UNSUPPORTED);
1046 break;
1047 case -EACCES:
1048 error_set(errp, QERR_DEVICE_IS_READ_ONLY, device);
1049 break;
1050 case -EBUSY:
1051 error_set(errp, QERR_DEVICE_IN_USE, device);
1052 break;
1053 default:
Luiz Capitulino5e7caac2011-11-25 14:57:10 -02001054 error_set(errp, QERR_UNDEFINED_ERROR);
Stefan Hajnoczi939a1cc2012-01-04 22:23:34 +00001055 break;
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001056 }
Christoph Hellwig6d4a2b32011-01-24 13:32:33 +01001057}
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001058
1059static QObject *qobject_from_block_job(BlockJob *job)
1060{
1061 return qobject_from_jsonf("{ 'type': %s,"
1062 "'device': %s,"
1063 "'len': %" PRId64 ","
1064 "'offset': %" PRId64 ","
1065 "'speed': %" PRId64 " }",
1066 job->job_type->job_type,
1067 bdrv_get_device_name(job->bs),
1068 job->len,
1069 job->offset,
1070 job->speed);
1071}
1072
1073static void block_stream_cb(void *opaque, int ret)
1074{
1075 BlockDriverState *bs = opaque;
1076 QObject *obj;
1077
1078 trace_block_stream_cb(bs, bs->job, ret);
1079
1080 assert(bs->job);
1081 obj = qobject_from_block_job(bs->job);
1082 if (ret < 0) {
1083 QDict *dict = qobject_to_qdict(obj);
1084 qdict_put(dict, "error", qstring_from_str(strerror(-ret)));
1085 }
1086
Stefan Hajnoczi370521a2012-01-18 14:40:48 +00001087 if (block_job_is_cancelled(bs->job)) {
1088 monitor_protocol_event(QEVENT_BLOCK_JOB_CANCELLED, obj);
1089 } else {
1090 monitor_protocol_event(QEVENT_BLOCK_JOB_COMPLETED, obj);
1091 }
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001092 qobject_decref(obj);
Stefan Hajnocziaa398a52012-01-18 14:40:50 +00001093
1094 drive_put_ref_bh_schedule(drive_get_by_blockdev(bs));
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001095}
1096
1097void qmp_block_stream(const char *device, bool has_base,
Stefan Hajnoczic83c66c2012-04-25 16:51:03 +01001098 const char *base, bool has_speed,
1099 int64_t speed, Error **errp)
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001100{
1101 BlockDriverState *bs;
Marcelo Tosattic8c30802012-01-18 14:40:53 +00001102 BlockDriverState *base_bs = NULL;
Stefan Hajnoczifd7f8c62012-04-25 16:51:00 +01001103 Error *local_err = NULL;
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001104
1105 bs = bdrv_find(device);
1106 if (!bs) {
1107 error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1108 return;
1109 }
1110
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001111 if (base) {
Marcelo Tosattic8c30802012-01-18 14:40:53 +00001112 base_bs = bdrv_find_backing_image(bs, base);
1113 if (base_bs == NULL) {
1114 error_set(errp, QERR_BASE_NOT_FOUND, base);
1115 return;
1116 }
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001117 }
1118
Stefan Hajnoczic83c66c2012-04-25 16:51:03 +01001119 stream_start(bs, base_bs, base, has_speed ? speed : 0,
1120 block_stream_cb, bs, &local_err);
Stefan Hajnoczifd7f8c62012-04-25 16:51:00 +01001121 if (error_is_set(&local_err)) {
1122 error_propagate(errp, local_err);
1123 return;
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001124 }
1125
Stefan Hajnocziaa398a52012-01-18 14:40:50 +00001126 /* Grab a reference so hotplug does not delete the BlockDriverState from
1127 * underneath us.
1128 */
1129 drive_get_ref(drive_get_by_blockdev(bs));
1130
Stefan Hajnoczi12bd4512012-01-18 14:40:46 +00001131 trace_qmp_block_stream(bs, bs->job);
1132}
Stefan Hajnoczi2d47c6e2012-01-18 14:40:47 +00001133
1134static BlockJob *find_block_job(const char *device)
1135{
1136 BlockDriverState *bs;
1137
1138 bs = bdrv_find(device);
1139 if (!bs || !bs->job) {
1140 return NULL;
1141 }
1142 return bs->job;
1143}
1144
Stefan Hajnoczi882ec7c2012-04-25 16:51:02 +01001145void qmp_block_job_set_speed(const char *device, int64_t speed, Error **errp)
Stefan Hajnoczi2d47c6e2012-01-18 14:40:47 +00001146{
1147 BlockJob *job = find_block_job(device);
1148
1149 if (!job) {
1150 error_set(errp, QERR_DEVICE_NOT_ACTIVE, device);
1151 return;
1152 }
1153
Stefan Hajnoczi882ec7c2012-04-25 16:51:02 +01001154 block_job_set_speed(job, speed, errp);
Stefan Hajnoczi2d47c6e2012-01-18 14:40:47 +00001155}
Stefan Hajnoczi370521a2012-01-18 14:40:48 +00001156
1157void qmp_block_job_cancel(const char *device, Error **errp)
1158{
1159 BlockJob *job = find_block_job(device);
1160
1161 if (!job) {
1162 error_set(errp, QERR_DEVICE_NOT_ACTIVE, device);
1163 return;
1164 }
1165
1166 trace_qmp_block_job_cancel(job);
1167 block_job_cancel(job);
1168}
Stefan Hajnoczifb5458c2012-01-18 14:40:49 +00001169
1170static void do_qmp_query_block_jobs_one(void *opaque, BlockDriverState *bs)
1171{
1172 BlockJobInfoList **prev = opaque;
1173 BlockJob *job = bs->job;
1174
1175 if (job) {
1176 BlockJobInfoList *elem;
1177 BlockJobInfo *info = g_new(BlockJobInfo, 1);
1178 *info = (BlockJobInfo){
1179 .type = g_strdup(job->job_type->job_type),
1180 .device = g_strdup(bdrv_get_device_name(bs)),
1181 .len = job->len,
1182 .offset = job->offset,
1183 .speed = job->speed,
1184 };
1185
1186 elem = g_new0(BlockJobInfoList, 1);
1187 elem->value = info;
1188
1189 (*prev)->next = elem;
1190 *prev = elem;
1191 }
1192}
1193
1194BlockJobInfoList *qmp_query_block_jobs(Error **errp)
1195{
1196 /* Dummy is a fake list element for holding the head pointer */
1197 BlockJobInfoList dummy = {};
1198 BlockJobInfoList *prev = &dummy;
1199 bdrv_iterate(do_qmp_query_block_jobs_one, &prev);
1200 return dummy.next;
1201}