Statistics
| Branch: | Revision:

root / blockdev.c @ 82beb536

History | View | Annotate | Download (69.9 kB)

1 666daa68 Markus Armbruster
/*
2 666daa68 Markus Armbruster
 * QEMU host block devices
3 666daa68 Markus Armbruster
 *
4 666daa68 Markus Armbruster
 * Copyright (c) 2003-2008 Fabrice Bellard
5 666daa68 Markus Armbruster
 *
6 666daa68 Markus Armbruster
 * This work is licensed under the terms of the GNU GPL, version 2 or
7 666daa68 Markus Armbruster
 * later.  See the COPYING file in the top-level directory.
8 3618a094 Markus Armbruster
 *
9 3618a094 Markus Armbruster
 * This file incorporates work covered by the following copyright and
10 3618a094 Markus Armbruster
 * permission notice:
11 3618a094 Markus Armbruster
 *
12 3618a094 Markus Armbruster
 * Copyright (c) 2003-2008 Fabrice Bellard
13 3618a094 Markus Armbruster
 *
14 3618a094 Markus Armbruster
 * Permission is hereby granted, free of charge, to any person obtaining a copy
15 3618a094 Markus Armbruster
 * of this software and associated documentation files (the "Software"), to deal
16 3618a094 Markus Armbruster
 * in the Software without restriction, including without limitation the rights
17 3618a094 Markus Armbruster
 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
18 3618a094 Markus Armbruster
 * copies of the Software, and to permit persons to whom the Software is
19 3618a094 Markus Armbruster
 * furnished to do so, subject to the following conditions:
20 3618a094 Markus Armbruster
 *
21 3618a094 Markus Armbruster
 * The above copyright notice and this permission notice shall be included in
22 3618a094 Markus Armbruster
 * all copies or substantial portions of the Software.
23 3618a094 Markus Armbruster
 *
24 3618a094 Markus Armbruster
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
25 3618a094 Markus Armbruster
 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
26 3618a094 Markus Armbruster
 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
27 3618a094 Markus Armbruster
 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
28 3618a094 Markus Armbruster
 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
29 3618a094 Markus Armbruster
 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
30 3618a094 Markus Armbruster
 * THE SOFTWARE.
31 666daa68 Markus Armbruster
 */
32 666daa68 Markus Armbruster
33 9c17d615 Paolo Bonzini
#include "sysemu/blockdev.h"
34 0d09e41a Paolo Bonzini
#include "hw/block/block.h"
35 737e150e Paolo Bonzini
#include "block/blockjob.h"
36 83c9089e Paolo Bonzini
#include "monitor/monitor.h"
37 7b1b5d19 Paolo Bonzini
#include "qapi/qmp/qerror.h"
38 1de7afc9 Paolo Bonzini
#include "qemu/option.h"
39 1de7afc9 Paolo Bonzini
#include "qemu/config-file.h"
40 7b1b5d19 Paolo Bonzini
#include "qapi/qmp/types.h"
41 d26c9a15 Kevin Wolf
#include "qapi-visit.h"
42 d26c9a15 Kevin Wolf
#include "qapi/qmp-output-visitor.h"
43 9c17d615 Paolo Bonzini
#include "sysemu/sysemu.h"
44 737e150e Paolo Bonzini
#include "block/block_int.h"
45 a4dea8a9 Luiz Capitulino
#include "qmp-commands.h"
46 12bd451f Stefan Hajnoczi
#include "trace.h"
47 9c17d615 Paolo Bonzini
#include "sysemu/arch_init.h"
48 666daa68 Markus Armbruster
49 c9b62a7e Markus Armbruster
static QTAILQ_HEAD(drivelist, DriveInfo) drives = QTAILQ_HEAD_INITIALIZER(drives);
50 666daa68 Markus Armbruster
51 1960966d Markus Armbruster
static const char *const if_name[IF_COUNT] = {
52 1960966d Markus Armbruster
    [IF_NONE] = "none",
53 1960966d Markus Armbruster
    [IF_IDE] = "ide",
54 1960966d Markus Armbruster
    [IF_SCSI] = "scsi",
55 1960966d Markus Armbruster
    [IF_FLOPPY] = "floppy",
56 1960966d Markus Armbruster
    [IF_PFLASH] = "pflash",
57 1960966d Markus Armbruster
    [IF_MTD] = "mtd",
58 1960966d Markus Armbruster
    [IF_SD] = "sd",
59 1960966d Markus Armbruster
    [IF_VIRTIO] = "virtio",
60 1960966d Markus Armbruster
    [IF_XEN] = "xen",
61 1960966d Markus Armbruster
};
62 1960966d Markus Armbruster
63 1960966d Markus Armbruster
static const int if_max_devs[IF_COUNT] = {
64 27d6bf40 Markus Armbruster
    /*
65 27d6bf40 Markus Armbruster
     * Do not change these numbers!  They govern how drive option
66 27d6bf40 Markus Armbruster
     * index maps to unit and bus.  That mapping is ABI.
67 27d6bf40 Markus Armbruster
     *
68 27d6bf40 Markus Armbruster
     * All controllers used to imlement if=T drives need to support
69 27d6bf40 Markus Armbruster
     * if_max_devs[T] units, for any T with if_max_devs[T] != 0.
70 27d6bf40 Markus Armbruster
     * Otherwise, some index values map to "impossible" bus, unit
71 27d6bf40 Markus Armbruster
     * values.
72 27d6bf40 Markus Armbruster
     *
73 27d6bf40 Markus Armbruster
     * For instance, if you change [IF_SCSI] to 255, -drive
74 27d6bf40 Markus Armbruster
     * if=scsi,index=12 no longer means bus=1,unit=5, but
75 27d6bf40 Markus Armbruster
     * bus=0,unit=12.  With an lsi53c895a controller (7 units max),
76 27d6bf40 Markus Armbruster
     * the drive can't be set up.  Regression.
77 27d6bf40 Markus Armbruster
     */
78 27d6bf40 Markus Armbruster
    [IF_IDE] = 2,
79 27d6bf40 Markus Armbruster
    [IF_SCSI] = 7,
80 1960966d Markus Armbruster
};
81 1960966d Markus Armbruster
82 14bafc54 Markus Armbruster
/*
83 14bafc54 Markus Armbruster
 * We automatically delete the drive when a device using it gets
84 14bafc54 Markus Armbruster
 * unplugged.  Questionable feature, but we can't just drop it.
85 14bafc54 Markus Armbruster
 * Device models call blockdev_mark_auto_del() to schedule the
86 14bafc54 Markus Armbruster
 * automatic deletion, and generic qdev code calls blockdev_auto_del()
87 14bafc54 Markus Armbruster
 * when deletion is actually safe.
88 14bafc54 Markus Armbruster
 */
89 14bafc54 Markus Armbruster
void blockdev_mark_auto_del(BlockDriverState *bs)
90 14bafc54 Markus Armbruster
{
91 14bafc54 Markus Armbruster
    DriveInfo *dinfo = drive_get_by_blockdev(bs);
92 14bafc54 Markus Armbruster
93 2d246f01 Kevin Wolf
    if (dinfo && !dinfo->enable_auto_del) {
94 2d246f01 Kevin Wolf
        return;
95 2d246f01 Kevin Wolf
    }
96 2d246f01 Kevin Wolf
97 12bde0ee Paolo Bonzini
    if (bs->job) {
98 12bde0ee Paolo Bonzini
        block_job_cancel(bs->job);
99 12bde0ee Paolo Bonzini
    }
100 0fc0f1fa Ryan Harper
    if (dinfo) {
101 0fc0f1fa Ryan Harper
        dinfo->auto_del = 1;
102 0fc0f1fa Ryan Harper
    }
103 14bafc54 Markus Armbruster
}
104 14bafc54 Markus Armbruster
105 14bafc54 Markus Armbruster
void blockdev_auto_del(BlockDriverState *bs)
106 14bafc54 Markus Armbruster
{
107 14bafc54 Markus Armbruster
    DriveInfo *dinfo = drive_get_by_blockdev(bs);
108 14bafc54 Markus Armbruster
109 0fc0f1fa Ryan Harper
    if (dinfo && dinfo->auto_del) {
110 84fb3925 Marcelo Tosatti
        drive_put_ref(dinfo);
111 14bafc54 Markus Armbruster
    }
112 14bafc54 Markus Armbruster
}
113 14bafc54 Markus Armbruster
114 505a7fb1 Markus Armbruster
static int drive_index_to_bus_id(BlockInterfaceType type, int index)
115 505a7fb1 Markus Armbruster
{
116 505a7fb1 Markus Armbruster
    int max_devs = if_max_devs[type];
117 505a7fb1 Markus Armbruster
    return max_devs ? index / max_devs : 0;
118 505a7fb1 Markus Armbruster
}
119 505a7fb1 Markus Armbruster
120 505a7fb1 Markus Armbruster
static int drive_index_to_unit_id(BlockInterfaceType type, int index)
121 505a7fb1 Markus Armbruster
{
122 505a7fb1 Markus Armbruster
    int max_devs = if_max_devs[type];
123 505a7fb1 Markus Armbruster
    return max_devs ? index % max_devs : index;
124 505a7fb1 Markus Armbruster
}
125 505a7fb1 Markus Armbruster
126 2292ddae Markus Armbruster
QemuOpts *drive_def(const char *optstr)
127 2292ddae Markus Armbruster
{
128 2292ddae Markus Armbruster
    return qemu_opts_parse(qemu_find_opts("drive"), optstr, 0);
129 2292ddae Markus Armbruster
}
130 2292ddae Markus Armbruster
131 2292ddae Markus Armbruster
QemuOpts *drive_add(BlockInterfaceType type, int index, const char *file,
132 5645b0f4 Markus Armbruster
                    const char *optstr)
133 666daa68 Markus Armbruster
{
134 666daa68 Markus Armbruster
    QemuOpts *opts;
135 2292ddae Markus Armbruster
    char buf[32];
136 666daa68 Markus Armbruster
137 2292ddae Markus Armbruster
    opts = drive_def(optstr);
138 666daa68 Markus Armbruster
    if (!opts) {
139 666daa68 Markus Armbruster
        return NULL;
140 666daa68 Markus Armbruster
    }
141 2292ddae Markus Armbruster
    if (type != IF_DEFAULT) {
142 2292ddae Markus Armbruster
        qemu_opt_set(opts, "if", if_name[type]);
143 2292ddae Markus Armbruster
    }
144 2292ddae Markus Armbruster
    if (index >= 0) {
145 2292ddae Markus Armbruster
        snprintf(buf, sizeof(buf), "%d", index);
146 2292ddae Markus Armbruster
        qemu_opt_set(opts, "index", buf);
147 2292ddae Markus Armbruster
    }
148 666daa68 Markus Armbruster
    if (file)
149 666daa68 Markus Armbruster
        qemu_opt_set(opts, "file", file);
150 666daa68 Markus Armbruster
    return opts;
151 666daa68 Markus Armbruster
}
152 666daa68 Markus Armbruster
153 666daa68 Markus Armbruster
DriveInfo *drive_get(BlockInterfaceType type, int bus, int unit)
154 666daa68 Markus Armbruster
{
155 666daa68 Markus Armbruster
    DriveInfo *dinfo;
156 666daa68 Markus Armbruster
157 666daa68 Markus Armbruster
    /* seek interface, bus and unit */
158 666daa68 Markus Armbruster
159 666daa68 Markus Armbruster
    QTAILQ_FOREACH(dinfo, &drives, next) {
160 666daa68 Markus Armbruster
        if (dinfo->type == type &&
161 666daa68 Markus Armbruster
            dinfo->bus == bus &&
162 666daa68 Markus Armbruster
            dinfo->unit == unit)
163 666daa68 Markus Armbruster
            return dinfo;
164 666daa68 Markus Armbruster
    }
165 666daa68 Markus Armbruster
166 666daa68 Markus Armbruster
    return NULL;
167 666daa68 Markus Armbruster
}
168 666daa68 Markus Armbruster
169 f1bd51ac Markus Armbruster
DriveInfo *drive_get_by_index(BlockInterfaceType type, int index)
170 f1bd51ac Markus Armbruster
{
171 f1bd51ac Markus Armbruster
    return drive_get(type,
172 f1bd51ac Markus Armbruster
                     drive_index_to_bus_id(type, index),
173 f1bd51ac Markus Armbruster
                     drive_index_to_unit_id(type, index));
174 f1bd51ac Markus Armbruster
}
175 f1bd51ac Markus Armbruster
176 666daa68 Markus Armbruster
int drive_get_max_bus(BlockInterfaceType type)
177 666daa68 Markus Armbruster
{
178 666daa68 Markus Armbruster
    int max_bus;
179 666daa68 Markus Armbruster
    DriveInfo *dinfo;
180 666daa68 Markus Armbruster
181 666daa68 Markus Armbruster
    max_bus = -1;
182 666daa68 Markus Armbruster
    QTAILQ_FOREACH(dinfo, &drives, next) {
183 666daa68 Markus Armbruster
        if(dinfo->type == type &&
184 666daa68 Markus Armbruster
           dinfo->bus > max_bus)
185 666daa68 Markus Armbruster
            max_bus = dinfo->bus;
186 666daa68 Markus Armbruster
    }
187 666daa68 Markus Armbruster
    return max_bus;
188 666daa68 Markus Armbruster
}
189 666daa68 Markus Armbruster
190 13839974 Markus Armbruster
/* Get a block device.  This should only be used for single-drive devices
191 13839974 Markus Armbruster
   (e.g. SD/Floppy/MTD).  Multi-disk devices (scsi/ide) should use the
192 13839974 Markus Armbruster
   appropriate bus.  */
193 13839974 Markus Armbruster
DriveInfo *drive_get_next(BlockInterfaceType type)
194 13839974 Markus Armbruster
{
195 13839974 Markus Armbruster
    static int next_block_unit[IF_COUNT];
196 13839974 Markus Armbruster
197 13839974 Markus Armbruster
    return drive_get(type, 0, next_block_unit[type]++);
198 13839974 Markus Armbruster
}
199 13839974 Markus Armbruster
200 e4700e59 Markus Armbruster
DriveInfo *drive_get_by_blockdev(BlockDriverState *bs)
201 666daa68 Markus Armbruster
{
202 666daa68 Markus Armbruster
    DriveInfo *dinfo;
203 666daa68 Markus Armbruster
204 666daa68 Markus Armbruster
    QTAILQ_FOREACH(dinfo, &drives, next) {
205 e4700e59 Markus Armbruster
        if (dinfo->bdrv == bs) {
206 e4700e59 Markus Armbruster
            return dinfo;
207 e4700e59 Markus Armbruster
        }
208 666daa68 Markus Armbruster
    }
209 e4700e59 Markus Armbruster
    return NULL;
210 666daa68 Markus Armbruster
}
211 666daa68 Markus Armbruster
212 666daa68 Markus Armbruster
static void bdrv_format_print(void *opaque, const char *name)
213 666daa68 Markus Armbruster
{
214 807105a7 Markus Armbruster
    error_printf(" %s", name);
215 666daa68 Markus Armbruster
}
216 666daa68 Markus Armbruster
217 84fb3925 Marcelo Tosatti
static void drive_uninit(DriveInfo *dinfo)
218 666daa68 Markus Armbruster
{
219 f298d071 Kevin Wolf
    if (dinfo->opts) {
220 f298d071 Kevin Wolf
        qemu_opts_del(dinfo->opts);
221 f298d071 Kevin Wolf
    }
222 f298d071 Kevin Wolf
223 4f6fd349 Fam Zheng
    bdrv_unref(dinfo->bdrv);
224 7267c094 Anthony Liguori
    g_free(dinfo->id);
225 666daa68 Markus Armbruster
    QTAILQ_REMOVE(&drives, dinfo, next);
226 bb44619b Kevin Wolf
    g_free(dinfo->serial);
227 7267c094 Anthony Liguori
    g_free(dinfo);
228 666daa68 Markus Armbruster
}
229 666daa68 Markus Armbruster
230 84fb3925 Marcelo Tosatti
void drive_put_ref(DriveInfo *dinfo)
231 84fb3925 Marcelo Tosatti
{
232 84fb3925 Marcelo Tosatti
    assert(dinfo->refcount);
233 84fb3925 Marcelo Tosatti
    if (--dinfo->refcount == 0) {
234 84fb3925 Marcelo Tosatti
        drive_uninit(dinfo);
235 84fb3925 Marcelo Tosatti
    }
236 84fb3925 Marcelo Tosatti
}
237 84fb3925 Marcelo Tosatti
238 84fb3925 Marcelo Tosatti
void drive_get_ref(DriveInfo *dinfo)
239 84fb3925 Marcelo Tosatti
{
240 84fb3925 Marcelo Tosatti
    dinfo->refcount++;
241 84fb3925 Marcelo Tosatti
}
242 84fb3925 Marcelo Tosatti
243 aa398a5c Stefan Hajnoczi
typedef struct {
244 aa398a5c Stefan Hajnoczi
    QEMUBH *bh;
245 fa510ebf Fam Zheng
    BlockDriverState *bs;
246 fa510ebf Fam Zheng
} BDRVPutRefBH;
247 aa398a5c Stefan Hajnoczi
248 fa510ebf Fam Zheng
static void bdrv_put_ref_bh(void *opaque)
249 aa398a5c Stefan Hajnoczi
{
250 fa510ebf Fam Zheng
    BDRVPutRefBH *s = opaque;
251 aa398a5c Stefan Hajnoczi
252 fa510ebf Fam Zheng
    bdrv_unref(s->bs);
253 aa398a5c Stefan Hajnoczi
    qemu_bh_delete(s->bh);
254 aa398a5c Stefan Hajnoczi
    g_free(s);
255 aa398a5c Stefan Hajnoczi
}
256 aa398a5c Stefan Hajnoczi
257 aa398a5c Stefan Hajnoczi
/*
258 fa510ebf Fam Zheng
 * Release a BDS reference in a BH
259 aa398a5c Stefan Hajnoczi
 *
260 fa510ebf Fam Zheng
 * It is not safe to use bdrv_unref() from a callback function when the callers
261 fa510ebf Fam Zheng
 * still need the BlockDriverState.  In such cases we schedule a BH to release
262 fa510ebf Fam Zheng
 * the reference.
263 aa398a5c Stefan Hajnoczi
 */
264 fa510ebf Fam Zheng
static void bdrv_put_ref_bh_schedule(BlockDriverState *bs)
265 aa398a5c Stefan Hajnoczi
{
266 fa510ebf Fam Zheng
    BDRVPutRefBH *s;
267 aa398a5c Stefan Hajnoczi
268 fa510ebf Fam Zheng
    s = g_new(BDRVPutRefBH, 1);
269 fa510ebf Fam Zheng
    s->bh = qemu_bh_new(bdrv_put_ref_bh, s);
270 fa510ebf Fam Zheng
    s->bs = bs;
271 aa398a5c Stefan Hajnoczi
    qemu_bh_schedule(s->bh);
272 aa398a5c Stefan Hajnoczi
}
273 aa398a5c Stefan Hajnoczi
274 b681072d Kevin Wolf
static int parse_block_error_action(const char *buf, bool is_read, Error **errp)
275 666daa68 Markus Armbruster
{
276 666daa68 Markus Armbruster
    if (!strcmp(buf, "ignore")) {
277 92aa5c6d Paolo Bonzini
        return BLOCKDEV_ON_ERROR_IGNORE;
278 666daa68 Markus Armbruster
    } else if (!is_read && !strcmp(buf, "enospc")) {
279 92aa5c6d Paolo Bonzini
        return BLOCKDEV_ON_ERROR_ENOSPC;
280 666daa68 Markus Armbruster
    } else if (!strcmp(buf, "stop")) {
281 92aa5c6d Paolo Bonzini
        return BLOCKDEV_ON_ERROR_STOP;
282 666daa68 Markus Armbruster
    } else if (!strcmp(buf, "report")) {
283 92aa5c6d Paolo Bonzini
        return BLOCKDEV_ON_ERROR_REPORT;
284 666daa68 Markus Armbruster
    } else {
285 b681072d Kevin Wolf
        error_setg(errp, "'%s' invalid %s error action",
286 b681072d Kevin Wolf
                   buf, is_read ? "read" : "write");
287 666daa68 Markus Armbruster
        return -1;
288 666daa68 Markus Armbruster
    }
289 666daa68 Markus Armbruster
}
290 666daa68 Markus Armbruster
291 cc0681c4 Benoît Canet
static bool check_throttle_config(ThrottleConfig *cfg, Error **errp)
292 0563e191 Zhi Yong Wu
{
293 cc0681c4 Benoît Canet
    if (throttle_conflicting(cfg)) {
294 cc0681c4 Benoît Canet
        error_setg(errp, "bps/iops/max total values and read/write values"
295 cc0681c4 Benoît Canet
                         " cannot be used at the same time");
296 0563e191 Zhi Yong Wu
        return false;
297 0563e191 Zhi Yong Wu
    }
298 0563e191 Zhi Yong Wu
299 cc0681c4 Benoît Canet
    if (!throttle_is_valid(cfg)) {
300 cc0681c4 Benoît Canet
        error_setg(errp, "bps/iops/maxs values must be 0 or greater");
301 7d81c141 Stefan Hajnoczi
        return false;
302 7d81c141 Stefan Hajnoczi
    }
303 7d81c141 Stefan Hajnoczi
304 0563e191 Zhi Yong Wu
    return true;
305 0563e191 Zhi Yong Wu
}
306 0563e191 Zhi Yong Wu
307 33cb7dc8 Kevin Wolf
typedef enum { MEDIA_DISK, MEDIA_CDROM } DriveMediaType;
308 33cb7dc8 Kevin Wolf
309 f298d071 Kevin Wolf
/* Takes the ownership of bs_opts */
310 d095b465 Max Reitz
static DriveInfo *blockdev_init(const char *file, QDict *bs_opts,
311 b681072d Kevin Wolf
                                BlockInterfaceType type,
312 b681072d Kevin Wolf
                                Error **errp)
313 666daa68 Markus Armbruster
{
314 666daa68 Markus Armbruster
    const char *buf;
315 666daa68 Markus Armbruster
    const char *serial;
316 666daa68 Markus Armbruster
    int ro = 0;
317 666daa68 Markus Armbruster
    int bdrv_flags = 0;
318 666daa68 Markus Armbruster
    int on_read_error, on_write_error;
319 666daa68 Markus Armbruster
    DriveInfo *dinfo;
320 cc0681c4 Benoît Canet
    ThrottleConfig cfg;
321 666daa68 Markus Armbruster
    int snapshot = 0;
322 fb0490f6 Stefan Hajnoczi
    bool copy_on_read;
323 666daa68 Markus Armbruster
    int ret;
324 c546194f Stefan Hajnoczi
    Error *error = NULL;
325 0006383e Kevin Wolf
    QemuOpts *opts;
326 0006383e Kevin Wolf
    const char *id;
327 74fe54f2 Kevin Wolf
    bool has_driver_specific_opts;
328 6db5f5d6 Mike Qiu
    BlockDriver *drv = NULL;
329 666daa68 Markus Armbruster
330 f298d071 Kevin Wolf
    /* Check common options by copying from bs_opts to opts, all other options
331 f298d071 Kevin Wolf
     * stay in bs_opts for processing by bdrv_open(). */
332 f298d071 Kevin Wolf
    id = qdict_get_try_str(bs_opts, "id");
333 0006383e Kevin Wolf
    opts = qemu_opts_create(&qemu_common_drive_opts, id, 1, &error);
334 0006383e Kevin Wolf
    if (error_is_set(&error)) {
335 b681072d Kevin Wolf
        error_propagate(errp, error);
336 0006383e Kevin Wolf
        return NULL;
337 0006383e Kevin Wolf
    }
338 0006383e Kevin Wolf
339 0006383e Kevin Wolf
    qemu_opts_absorb_qdict(opts, bs_opts, &error);
340 0006383e Kevin Wolf
    if (error_is_set(&error)) {
341 b681072d Kevin Wolf
        error_propagate(errp, error);
342 ec9c10d2 Stefan Hajnoczi
        goto early_err;
343 0006383e Kevin Wolf
    }
344 0006383e Kevin Wolf
345 0006383e Kevin Wolf
    if (id) {
346 0006383e Kevin Wolf
        qdict_del(bs_opts, "id");
347 0006383e Kevin Wolf
    }
348 0006383e Kevin Wolf
349 74fe54f2 Kevin Wolf
    has_driver_specific_opts = !!qdict_size(bs_opts);
350 74fe54f2 Kevin Wolf
351 666daa68 Markus Armbruster
    /* extract parameters */
352 666daa68 Markus Armbruster
    snapshot = qemu_opt_get_bool(opts, "snapshot", 0);
353 0f227a94 Kevin Wolf
    ro = qemu_opt_get_bool(opts, "read-only", 0);
354 fb0490f6 Stefan Hajnoczi
    copy_on_read = qemu_opt_get_bool(opts, "copy-on-read", false);
355 666daa68 Markus Armbruster
356 666daa68 Markus Armbruster
    serial = qemu_opt_get(opts, "serial");
357 666daa68 Markus Armbruster
358 a9384aff Paolo Bonzini
    if ((buf = qemu_opt_get(opts, "discard")) != NULL) {
359 a9384aff Paolo Bonzini
        if (bdrv_parse_discard_flags(buf, &bdrv_flags) != 0) {
360 b681072d Kevin Wolf
            error_setg(errp, "invalid discard option");
361 ec9c10d2 Stefan Hajnoczi
            goto early_err;
362 a9384aff Paolo Bonzini
        }
363 a9384aff Paolo Bonzini
    }
364 a9384aff Paolo Bonzini
365 29c4e2b5 Kevin Wolf
    if (qemu_opt_get_bool(opts, "cache.writeback", true)) {
366 29c4e2b5 Kevin Wolf
        bdrv_flags |= BDRV_O_CACHE_WB;
367 29c4e2b5 Kevin Wolf
    }
368 29c4e2b5 Kevin Wolf
    if (qemu_opt_get_bool(opts, "cache.direct", false)) {
369 29c4e2b5 Kevin Wolf
        bdrv_flags |= BDRV_O_NOCACHE;
370 29c4e2b5 Kevin Wolf
    }
371 1df6fa4b Paolo Bonzini
    if (qemu_opt_get_bool(opts, "cache.no-flush", false)) {
372 29c4e2b5 Kevin Wolf
        bdrv_flags |= BDRV_O_NO_FLUSH;
373 666daa68 Markus Armbruster
    }
374 666daa68 Markus Armbruster
375 666daa68 Markus Armbruster
#ifdef CONFIG_LINUX_AIO
376 666daa68 Markus Armbruster
    if ((buf = qemu_opt_get(opts, "aio")) != NULL) {
377 666daa68 Markus Armbruster
        if (!strcmp(buf, "native")) {
378 666daa68 Markus Armbruster
            bdrv_flags |= BDRV_O_NATIVE_AIO;
379 666daa68 Markus Armbruster
        } else if (!strcmp(buf, "threads")) {
380 666daa68 Markus Armbruster
            /* this is the default */
381 666daa68 Markus Armbruster
        } else {
382 b681072d Kevin Wolf
           error_setg(errp, "invalid aio option");
383 ec9c10d2 Stefan Hajnoczi
           goto early_err;
384 666daa68 Markus Armbruster
        }
385 666daa68 Markus Armbruster
    }
386 666daa68 Markus Armbruster
#endif
387 666daa68 Markus Armbruster
388 666daa68 Markus Armbruster
    if ((buf = qemu_opt_get(opts, "format")) != NULL) {
389 c8057f95 Peter Maydell
        if (is_help_option(buf)) {
390 c8057f95 Peter Maydell
            error_printf("Supported formats:");
391 c8057f95 Peter Maydell
            bdrv_iterate_format(bdrv_format_print, NULL);
392 c8057f95 Peter Maydell
            error_printf("\n");
393 ec9c10d2 Stefan Hajnoczi
            goto early_err;
394 666daa68 Markus Armbruster
        }
395 74fe54f2 Kevin Wolf
396 8f94a6e4 Kevin Wolf
        drv = bdrv_find_format(buf);
397 6db5f5d6 Mike Qiu
        if (!drv) {
398 b681072d Kevin Wolf
            error_setg(errp, "'%s' invalid format", buf);
399 ec9c10d2 Stefan Hajnoczi
            goto early_err;
400 6db5f5d6 Mike Qiu
        }
401 666daa68 Markus Armbruster
    }
402 666daa68 Markus Armbruster
403 0563e191 Zhi Yong Wu
    /* disk I/O throttling */
404 cc0681c4 Benoît Canet
    memset(&cfg, 0, sizeof(cfg));
405 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_TOTAL].avg =
406 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.bps-total", 0);
407 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_READ].avg  =
408 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.bps-read", 0);
409 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_WRITE].avg =
410 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.bps-write", 0);
411 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_TOTAL].avg =
412 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.iops-total", 0);
413 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_READ].avg =
414 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.iops-read", 0);
415 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_WRITE].avg =
416 57975222 Kevin Wolf
        qemu_opt_get_number(opts, "throttling.iops-write", 0);
417 0563e191 Zhi Yong Wu
418 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_BPS_TOTAL].max =
419 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.bps-total-max", 0);
420 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_BPS_READ].max  =
421 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.bps-read-max", 0);
422 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_BPS_WRITE].max =
423 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.bps-write-max", 0);
424 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_OPS_TOTAL].max =
425 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.iops-total-max", 0);
426 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_OPS_READ].max =
427 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.iops-read-max", 0);
428 3e9fab69 Benoît Canet
    cfg.buckets[THROTTLE_OPS_WRITE].max =
429 3e9fab69 Benoît Canet
        qemu_opt_get_number(opts, "throttling.iops-write-max", 0);
430 cc0681c4 Benoît Canet
431 2024c1df Benoît Canet
    cfg.op_size = qemu_opt_get_number(opts, "throttling.iops-size", 0);
432 cc0681c4 Benoît Canet
433 cc0681c4 Benoît Canet
    if (!check_throttle_config(&cfg, &error)) {
434 b681072d Kevin Wolf
        error_propagate(errp, error);
435 ec9c10d2 Stefan Hajnoczi
        goto early_err;
436 0563e191 Zhi Yong Wu
    }
437 0563e191 Zhi Yong Wu
438 92aa5c6d Paolo Bonzini
    on_write_error = BLOCKDEV_ON_ERROR_ENOSPC;
439 666daa68 Markus Armbruster
    if ((buf = qemu_opt_get(opts, "werror")) != NULL) {
440 666daa68 Markus Armbruster
        if (type != IF_IDE && type != IF_SCSI && type != IF_VIRTIO && type != IF_NONE) {
441 b681072d Kevin Wolf
            error_setg(errp, "werror is not supported by this bus type");
442 ec9c10d2 Stefan Hajnoczi
            goto early_err;
443 666daa68 Markus Armbruster
        }
444 666daa68 Markus Armbruster
445 b681072d Kevin Wolf
        on_write_error = parse_block_error_action(buf, 0, &error);
446 b681072d Kevin Wolf
        if (error_is_set(&error)) {
447 b681072d Kevin Wolf
            error_propagate(errp, error);
448 ec9c10d2 Stefan Hajnoczi
            goto early_err;
449 666daa68 Markus Armbruster
        }
450 666daa68 Markus Armbruster
    }
451 666daa68 Markus Armbruster
452 92aa5c6d Paolo Bonzini
    on_read_error = BLOCKDEV_ON_ERROR_REPORT;
453 666daa68 Markus Armbruster
    if ((buf = qemu_opt_get(opts, "rerror")) != NULL) {
454 5dba48a8 Kevin Wolf
        if (type != IF_IDE && type != IF_VIRTIO && type != IF_SCSI && type != IF_NONE) {
455 807105a7 Markus Armbruster
            error_report("rerror is not supported by this bus type");
456 ec9c10d2 Stefan Hajnoczi
            goto early_err;
457 666daa68 Markus Armbruster
        }
458 666daa68 Markus Armbruster
459 b681072d Kevin Wolf
        on_read_error = parse_block_error_action(buf, 1, &error);
460 b681072d Kevin Wolf
        if (error_is_set(&error)) {
461 b681072d Kevin Wolf
            error_propagate(errp, error);
462 ec9c10d2 Stefan Hajnoczi
            goto early_err;
463 666daa68 Markus Armbruster
        }
464 666daa68 Markus Armbruster
    }
465 666daa68 Markus Armbruster
466 326642bc Kevin Wolf
    /* init */
467 326642bc Kevin Wolf
    dinfo = g_malloc0(sizeof(*dinfo));
468 326642bc Kevin Wolf
    dinfo->id = g_strdup(qemu_opts_id(opts));
469 666daa68 Markus Armbruster
    dinfo->bdrv = bdrv_new(dinfo->id);
470 80dd1aae Kevin Shanahan
    dinfo->bdrv->open_flags = snapshot ? BDRV_O_SNAPSHOT : 0;
471 80dd1aae Kevin Shanahan
    dinfo->bdrv->read_only = ro;
472 666daa68 Markus Armbruster
    dinfo->type = type;
473 84fb3925 Marcelo Tosatti
    dinfo->refcount = 1;
474 bb44619b Kevin Wolf
    if (serial != NULL) {
475 bb44619b Kevin Wolf
        dinfo->serial = g_strdup(serial);
476 bb44619b Kevin Wolf
    }
477 666daa68 Markus Armbruster
    QTAILQ_INSERT_TAIL(&drives, dinfo, next);
478 666daa68 Markus Armbruster
479 abd7f68d Markus Armbruster
    bdrv_set_on_error(dinfo->bdrv, on_read_error, on_write_error);
480 abd7f68d Markus Armbruster
481 0563e191 Zhi Yong Wu
    /* disk I/O throttling */
482 cc0681c4 Benoît Canet
    if (throttle_enabled(&cfg)) {
483 cc0681c4 Benoît Canet
        bdrv_io_limits_enable(dinfo->bdrv);
484 cc0681c4 Benoît Canet
        bdrv_set_io_limits(dinfo->bdrv, &cfg);
485 cc0681c4 Benoît Canet
    }
486 0563e191 Zhi Yong Wu
487 dd5b0d71 Markus Armbruster
    if (!file || !*file) {
488 74fe54f2 Kevin Wolf
        if (has_driver_specific_opts) {
489 c2ad1b0c Kevin Wolf
            file = NULL;
490 c2ad1b0c Kevin Wolf
        } else {
491 ec9c10d2 Stefan Hajnoczi
            QDECREF(bs_opts);
492 ec9c10d2 Stefan Hajnoczi
            qemu_opts_del(opts);
493 c2ad1b0c Kevin Wolf
            return dinfo;
494 c2ad1b0c Kevin Wolf
        }
495 666daa68 Markus Armbruster
    }
496 666daa68 Markus Armbruster
    if (snapshot) {
497 666daa68 Markus Armbruster
        /* always use cache=unsafe with snapshot */
498 666daa68 Markus Armbruster
        bdrv_flags &= ~BDRV_O_CACHE_MASK;
499 666daa68 Markus Armbruster
        bdrv_flags |= (BDRV_O_SNAPSHOT|BDRV_O_CACHE_WB|BDRV_O_NO_FLUSH);
500 666daa68 Markus Armbruster
    }
501 666daa68 Markus Armbruster
502 fb0490f6 Stefan Hajnoczi
    if (copy_on_read) {
503 fb0490f6 Stefan Hajnoczi
        bdrv_flags |= BDRV_O_COPY_ON_READ;
504 fb0490f6 Stefan Hajnoczi
    }
505 fb0490f6 Stefan Hajnoczi
506 ed9d4205 Benoît Canet
    if (runstate_check(RUN_STATE_INMIGRATE)) {
507 ed9d4205 Benoît Canet
        bdrv_flags |= BDRV_O_INCOMING;
508 ed9d4205 Benoît Canet
    }
509 ed9d4205 Benoît Canet
510 666daa68 Markus Armbruster
    bdrv_flags |= ro ? 0 : BDRV_O_RDWR;
511 666daa68 Markus Armbruster
512 74fe54f2 Kevin Wolf
    QINCREF(bs_opts);
513 34b5d2c6 Max Reitz
    ret = bdrv_open(dinfo->bdrv, file, bs_opts, bdrv_flags, drv, &error);
514 0006383e Kevin Wolf
515 666daa68 Markus Armbruster
    if (ret < 0) {
516 b681072d Kevin Wolf
        error_setg(errp, "could not open disk image %s: %s",
517 b681072d Kevin Wolf
                   file ?: dinfo->id, error_get_pretty(error));
518 b681072d Kevin Wolf
        error_free(error);
519 a9ae2bff Markus Armbruster
        goto err;
520 666daa68 Markus Armbruster
    }
521 666daa68 Markus Armbruster
522 666daa68 Markus Armbruster
    if (bdrv_key_required(dinfo->bdrv))
523 666daa68 Markus Armbruster
        autostart = 0;
524 0006383e Kevin Wolf
525 74fe54f2 Kevin Wolf
    QDECREF(bs_opts);
526 0006383e Kevin Wolf
    qemu_opts_del(opts);
527 0006383e Kevin Wolf
528 666daa68 Markus Armbruster
    return dinfo;
529 a9ae2bff Markus Armbruster
530 a9ae2bff Markus Armbruster
err:
531 4f6fd349 Fam Zheng
    bdrv_unref(dinfo->bdrv);
532 7267c094 Anthony Liguori
    g_free(dinfo->id);
533 a9ae2bff Markus Armbruster
    QTAILQ_REMOVE(&drives, dinfo, next);
534 7267c094 Anthony Liguori
    g_free(dinfo);
535 ec9c10d2 Stefan Hajnoczi
early_err:
536 ec9c10d2 Stefan Hajnoczi
    QDECREF(bs_opts);
537 ec9c10d2 Stefan Hajnoczi
    qemu_opts_del(opts);
538 a9ae2bff Markus Armbruster
    return NULL;
539 666daa68 Markus Armbruster
}
540 666daa68 Markus Armbruster
541 57975222 Kevin Wolf
static void qemu_opt_rename(QemuOpts *opts, const char *from, const char *to)
542 57975222 Kevin Wolf
{
543 57975222 Kevin Wolf
    const char *value;
544 57975222 Kevin Wolf
545 57975222 Kevin Wolf
    value = qemu_opt_get(opts, from);
546 57975222 Kevin Wolf
    if (value) {
547 57975222 Kevin Wolf
        qemu_opt_set(opts, to, value);
548 57975222 Kevin Wolf
        qemu_opt_unset(opts, from);
549 57975222 Kevin Wolf
    }
550 57975222 Kevin Wolf
}
551 57975222 Kevin Wolf
552 33cb7dc8 Kevin Wolf
QemuOptsList qemu_legacy_drive_opts = {
553 33cb7dc8 Kevin Wolf
    .name = "drive",
554 33cb7dc8 Kevin Wolf
    .head = QTAILQ_HEAD_INITIALIZER(qemu_legacy_drive_opts.head),
555 33cb7dc8 Kevin Wolf
    .desc = {
556 33cb7dc8 Kevin Wolf
        {
557 87a899c5 Kevin Wolf
            .name = "bus",
558 87a899c5 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
559 87a899c5 Kevin Wolf
            .help = "bus number",
560 87a899c5 Kevin Wolf
        },{
561 87a899c5 Kevin Wolf
            .name = "unit",
562 87a899c5 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
563 87a899c5 Kevin Wolf
            .help = "unit number (i.e. lun for scsi)",
564 87a899c5 Kevin Wolf
        },{
565 87a899c5 Kevin Wolf
            .name = "index",
566 87a899c5 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
567 87a899c5 Kevin Wolf
            .help = "index number",
568 87a899c5 Kevin Wolf
        },{
569 33cb7dc8 Kevin Wolf
            .name = "media",
570 33cb7dc8 Kevin Wolf
            .type = QEMU_OPT_STRING,
571 33cb7dc8 Kevin Wolf
            .help = "media type (disk, cdrom)",
572 593d464b Kevin Wolf
        },{
573 593d464b Kevin Wolf
            .name = "if",
574 593d464b Kevin Wolf
            .type = QEMU_OPT_STRING,
575 593d464b Kevin Wolf
            .help = "interface (ide, scsi, sd, mtd, floppy, pflash, virtio)",
576 b41a7338 Kevin Wolf
        },{
577 b41a7338 Kevin Wolf
            .name = "cyls",
578 b41a7338 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
579 b41a7338 Kevin Wolf
            .help = "number of cylinders (ide disk geometry)",
580 b41a7338 Kevin Wolf
        },{
581 b41a7338 Kevin Wolf
            .name = "heads",
582 b41a7338 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
583 b41a7338 Kevin Wolf
            .help = "number of heads (ide disk geometry)",
584 b41a7338 Kevin Wolf
        },{
585 b41a7338 Kevin Wolf
            .name = "secs",
586 b41a7338 Kevin Wolf
            .type = QEMU_OPT_NUMBER,
587 b41a7338 Kevin Wolf
            .help = "number of sectors (ide disk geometry)",
588 b41a7338 Kevin Wolf
        },{
589 b41a7338 Kevin Wolf
            .name = "trans",
590 b41a7338 Kevin Wolf
            .type = QEMU_OPT_STRING,
591 b41a7338 Kevin Wolf
            .help = "chs translation (auto, lba, none)",
592 26929298 Kevin Wolf
        },{
593 26929298 Kevin Wolf
            .name = "boot",
594 26929298 Kevin Wolf
            .type = QEMU_OPT_BOOL,
595 26929298 Kevin Wolf
            .help = "(deprecated, ignored)",
596 394c7d4d Kevin Wolf
        },{
597 394c7d4d Kevin Wolf
            .name = "addr",
598 394c7d4d Kevin Wolf
            .type = QEMU_OPT_STRING,
599 394c7d4d Kevin Wolf
            .help = "pci address (virtio only)",
600 d095b465 Max Reitz
        },{
601 d095b465 Max Reitz
            .name = "file",
602 d095b465 Max Reitz
            .type = QEMU_OPT_STRING,
603 d095b465 Max Reitz
            .help = "file name",
604 33cb7dc8 Kevin Wolf
        },
605 0ebd24e0 Kevin Wolf
606 0ebd24e0 Kevin Wolf
        /* Options that are passed on, but have special semantics with -drive */
607 0ebd24e0 Kevin Wolf
        {
608 0ebd24e0 Kevin Wolf
            .name = "read-only",
609 0ebd24e0 Kevin Wolf
            .type = QEMU_OPT_BOOL,
610 0ebd24e0 Kevin Wolf
            .help = "open drive file as read-only",
611 0ebd24e0 Kevin Wolf
        },{
612 0ebd24e0 Kevin Wolf
            .name = "copy-on-read",
613 0ebd24e0 Kevin Wolf
            .type = QEMU_OPT_BOOL,
614 0ebd24e0 Kevin Wolf
            .help = "copy read data from backing file into image file",
615 0ebd24e0 Kevin Wolf
        },
616 0ebd24e0 Kevin Wolf
617 33cb7dc8 Kevin Wolf
        { /* end of list */ }
618 33cb7dc8 Kevin Wolf
    },
619 33cb7dc8 Kevin Wolf
};
620 33cb7dc8 Kevin Wolf
621 57975222 Kevin Wolf
DriveInfo *drive_init(QemuOpts *all_opts, BlockInterfaceType block_default_type)
622 57975222 Kevin Wolf
{
623 29c4e2b5 Kevin Wolf
    const char *value;
624 33cb7dc8 Kevin Wolf
    DriveInfo *dinfo = NULL;
625 f298d071 Kevin Wolf
    QDict *bs_opts;
626 33cb7dc8 Kevin Wolf
    QemuOpts *legacy_opts;
627 33cb7dc8 Kevin Wolf
    DriveMediaType media = MEDIA_DISK;
628 593d464b Kevin Wolf
    BlockInterfaceType type;
629 b41a7338 Kevin Wolf
    int cyls, heads, secs, translation;
630 87a899c5 Kevin Wolf
    int max_devs, bus_id, unit_id, index;
631 394c7d4d Kevin Wolf
    const char *devaddr;
632 a7fdbcf0 Fam Zheng
    bool read_only = false;
633 a7fdbcf0 Fam Zheng
    bool copy_on_read;
634 d095b465 Max Reitz
    const char *filename;
635 33cb7dc8 Kevin Wolf
    Error *local_err = NULL;
636 29c4e2b5 Kevin Wolf
637 57975222 Kevin Wolf
    /* Change legacy command line options into QMP ones */
638 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "iops", "throttling.iops-total");
639 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "iops_rd", "throttling.iops-read");
640 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "iops_wr", "throttling.iops-write");
641 57975222 Kevin Wolf
642 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "bps", "throttling.bps-total");
643 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "bps_rd", "throttling.bps-read");
644 57975222 Kevin Wolf
    qemu_opt_rename(all_opts, "bps_wr", "throttling.bps-write");
645 57975222 Kevin Wolf
646 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "iops_max", "throttling.iops-total-max");
647 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "iops_rd_max", "throttling.iops-read-max");
648 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "iops_wr_max", "throttling.iops-write-max");
649 3e9fab69 Benoît Canet
650 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "bps_max", "throttling.bps-total-max");
651 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "bps_rd_max", "throttling.bps-read-max");
652 3e9fab69 Benoît Canet
    qemu_opt_rename(all_opts, "bps_wr_max", "throttling.bps-write-max");
653 3e9fab69 Benoît Canet
654 2024c1df Benoît Canet
    qemu_opt_rename(all_opts,
655 2024c1df Benoît Canet
                    "iops_size", "throttling.iops-size");
656 2024c1df Benoît Canet
657 0f227a94 Kevin Wolf
    qemu_opt_rename(all_opts, "readonly", "read-only");
658 0f227a94 Kevin Wolf
659 29c4e2b5 Kevin Wolf
    value = qemu_opt_get(all_opts, "cache");
660 29c4e2b5 Kevin Wolf
    if (value) {
661 29c4e2b5 Kevin Wolf
        int flags = 0;
662 29c4e2b5 Kevin Wolf
663 29c4e2b5 Kevin Wolf
        if (bdrv_parse_cache_flags(value, &flags) != 0) {
664 29c4e2b5 Kevin Wolf
            error_report("invalid cache option");
665 29c4e2b5 Kevin Wolf
            return NULL;
666 29c4e2b5 Kevin Wolf
        }
667 29c4e2b5 Kevin Wolf
668 29c4e2b5 Kevin Wolf
        /* Specific options take precedence */
669 29c4e2b5 Kevin Wolf
        if (!qemu_opt_get(all_opts, "cache.writeback")) {
670 29c4e2b5 Kevin Wolf
            qemu_opt_set_bool(all_opts, "cache.writeback",
671 29c4e2b5 Kevin Wolf
                              !!(flags & BDRV_O_CACHE_WB));
672 29c4e2b5 Kevin Wolf
        }
673 29c4e2b5 Kevin Wolf
        if (!qemu_opt_get(all_opts, "cache.direct")) {
674 29c4e2b5 Kevin Wolf
            qemu_opt_set_bool(all_opts, "cache.direct",
675 29c4e2b5 Kevin Wolf
                              !!(flags & BDRV_O_NOCACHE));
676 29c4e2b5 Kevin Wolf
        }
677 29c4e2b5 Kevin Wolf
        if (!qemu_opt_get(all_opts, "cache.no-flush")) {
678 29c4e2b5 Kevin Wolf
            qemu_opt_set_bool(all_opts, "cache.no-flush",
679 29c4e2b5 Kevin Wolf
                              !!(flags & BDRV_O_NO_FLUSH));
680 29c4e2b5 Kevin Wolf
        }
681 29c4e2b5 Kevin Wolf
        qemu_opt_unset(all_opts, "cache");
682 29c4e2b5 Kevin Wolf
    }
683 29c4e2b5 Kevin Wolf
684 f298d071 Kevin Wolf
    /* Get a QDict for processing the options */
685 f298d071 Kevin Wolf
    bs_opts = qdict_new();
686 f298d071 Kevin Wolf
    qemu_opts_to_qdict(all_opts, bs_opts);
687 f298d071 Kevin Wolf
688 87ea75d5 Peter Crosthwaite
    legacy_opts = qemu_opts_create(&qemu_legacy_drive_opts, NULL, 0,
689 87ea75d5 Peter Crosthwaite
                                   &error_abort);
690 33cb7dc8 Kevin Wolf
    qemu_opts_absorb_qdict(legacy_opts, bs_opts, &local_err);
691 33cb7dc8 Kevin Wolf
    if (error_is_set(&local_err)) {
692 33cb7dc8 Kevin Wolf
        qerror_report_err(local_err);
693 33cb7dc8 Kevin Wolf
        error_free(local_err);
694 33cb7dc8 Kevin Wolf
        goto fail;
695 33cb7dc8 Kevin Wolf
    }
696 33cb7dc8 Kevin Wolf
697 26929298 Kevin Wolf
    /* Deprecated option boot=[on|off] */
698 26929298 Kevin Wolf
    if (qemu_opt_get(legacy_opts, "boot") != NULL) {
699 26929298 Kevin Wolf
        fprintf(stderr, "qemu-kvm: boot=on|off is deprecated and will be "
700 26929298 Kevin Wolf
                "ignored. Future versions will reject this parameter. Please "
701 26929298 Kevin Wolf
                "update your scripts.\n");
702 26929298 Kevin Wolf
    }
703 26929298 Kevin Wolf
704 33cb7dc8 Kevin Wolf
    /* Media type */
705 33cb7dc8 Kevin Wolf
    value = qemu_opt_get(legacy_opts, "media");
706 33cb7dc8 Kevin Wolf
    if (value) {
707 33cb7dc8 Kevin Wolf
        if (!strcmp(value, "disk")) {
708 33cb7dc8 Kevin Wolf
            media = MEDIA_DISK;
709 33cb7dc8 Kevin Wolf
        } else if (!strcmp(value, "cdrom")) {
710 33cb7dc8 Kevin Wolf
            media = MEDIA_CDROM;
711 a7fdbcf0 Fam Zheng
            read_only = true;
712 33cb7dc8 Kevin Wolf
        } else {
713 33cb7dc8 Kevin Wolf
            error_report("'%s' invalid media", value);
714 33cb7dc8 Kevin Wolf
            goto fail;
715 33cb7dc8 Kevin Wolf
        }
716 33cb7dc8 Kevin Wolf
    }
717 33cb7dc8 Kevin Wolf
718 0ebd24e0 Kevin Wolf
    /* copy-on-read is disabled with a warning for read-only devices */
719 a7fdbcf0 Fam Zheng
    read_only |= qemu_opt_get_bool(legacy_opts, "read-only", false);
720 0ebd24e0 Kevin Wolf
    copy_on_read = qemu_opt_get_bool(legacy_opts, "copy-on-read", false);
721 0ebd24e0 Kevin Wolf
722 0ebd24e0 Kevin Wolf
    if (read_only && copy_on_read) {
723 0ebd24e0 Kevin Wolf
        error_report("warning: disabling copy-on-read on read-only drive");
724 0ebd24e0 Kevin Wolf
        copy_on_read = false;
725 0ebd24e0 Kevin Wolf
    }
726 0ebd24e0 Kevin Wolf
727 0ebd24e0 Kevin Wolf
    qdict_put(bs_opts, "read-only",
728 0ebd24e0 Kevin Wolf
              qstring_from_str(read_only ? "on" : "off"));
729 0ebd24e0 Kevin Wolf
    qdict_put(bs_opts, "copy-on-read",
730 0ebd24e0 Kevin Wolf
              qstring_from_str(copy_on_read ? "on" :"off"));
731 0ebd24e0 Kevin Wolf
732 593d464b Kevin Wolf
    /* Controller type */
733 593d464b Kevin Wolf
    value = qemu_opt_get(legacy_opts, "if");
734 593d464b Kevin Wolf
    if (value) {
735 593d464b Kevin Wolf
        for (type = 0;
736 593d464b Kevin Wolf
             type < IF_COUNT && strcmp(value, if_name[type]);
737 593d464b Kevin Wolf
             type++) {
738 593d464b Kevin Wolf
        }
739 593d464b Kevin Wolf
        if (type == IF_COUNT) {
740 593d464b Kevin Wolf
            error_report("unsupported bus type '%s'", value);
741 593d464b Kevin Wolf
            goto fail;
742 593d464b Kevin Wolf
        }
743 593d464b Kevin Wolf
    } else {
744 593d464b Kevin Wolf
        type = block_default_type;
745 593d464b Kevin Wolf
    }
746 593d464b Kevin Wolf
747 b41a7338 Kevin Wolf
    /* Geometry */
748 b41a7338 Kevin Wolf
    cyls  = qemu_opt_get_number(legacy_opts, "cyls", 0);
749 b41a7338 Kevin Wolf
    heads = qemu_opt_get_number(legacy_opts, "heads", 0);
750 b41a7338 Kevin Wolf
    secs  = qemu_opt_get_number(legacy_opts, "secs", 0);
751 b41a7338 Kevin Wolf
752 b41a7338 Kevin Wolf
    if (cyls || heads || secs) {
753 b41a7338 Kevin Wolf
        if (cyls < 1) {
754 b41a7338 Kevin Wolf
            error_report("invalid physical cyls number");
755 b41a7338 Kevin Wolf
            goto fail;
756 b41a7338 Kevin Wolf
        }
757 b41a7338 Kevin Wolf
        if (heads < 1) {
758 b41a7338 Kevin Wolf
            error_report("invalid physical heads number");
759 b41a7338 Kevin Wolf
            goto fail;
760 b41a7338 Kevin Wolf
        }
761 b41a7338 Kevin Wolf
        if (secs < 1) {
762 b41a7338 Kevin Wolf
            error_report("invalid physical secs number");
763 b41a7338 Kevin Wolf
            goto fail;
764 b41a7338 Kevin Wolf
        }
765 b41a7338 Kevin Wolf
    }
766 b41a7338 Kevin Wolf
767 b41a7338 Kevin Wolf
    translation = BIOS_ATA_TRANSLATION_AUTO;
768 b41a7338 Kevin Wolf
    value = qemu_opt_get(legacy_opts, "trans");
769 b41a7338 Kevin Wolf
    if (value != NULL) {
770 b41a7338 Kevin Wolf
        if (!cyls) {
771 b41a7338 Kevin Wolf
            error_report("'%s' trans must be used with cyls, heads and secs",
772 b41a7338 Kevin Wolf
                         value);
773 b41a7338 Kevin Wolf
            goto fail;
774 b41a7338 Kevin Wolf
        }
775 b41a7338 Kevin Wolf
        if (!strcmp(value, "none")) {
776 b41a7338 Kevin Wolf
            translation = BIOS_ATA_TRANSLATION_NONE;
777 b41a7338 Kevin Wolf
        } else if (!strcmp(value, "lba")) {
778 b41a7338 Kevin Wolf
            translation = BIOS_ATA_TRANSLATION_LBA;
779 b41a7338 Kevin Wolf
        } else if (!strcmp(value, "auto")) {
780 b41a7338 Kevin Wolf
            translation = BIOS_ATA_TRANSLATION_AUTO;
781 b41a7338 Kevin Wolf
        } else {
782 b41a7338 Kevin Wolf
            error_report("'%s' invalid translation type", value);
783 b41a7338 Kevin Wolf
            goto fail;
784 b41a7338 Kevin Wolf
        }
785 b41a7338 Kevin Wolf
    }
786 b41a7338 Kevin Wolf
787 b41a7338 Kevin Wolf
    if (media == MEDIA_CDROM) {
788 b41a7338 Kevin Wolf
        if (cyls || secs || heads) {
789 b41a7338 Kevin Wolf
            error_report("CHS can't be set with media=cdrom");
790 b41a7338 Kevin Wolf
            goto fail;
791 b41a7338 Kevin Wolf
        }
792 b41a7338 Kevin Wolf
    }
793 b41a7338 Kevin Wolf
794 87a899c5 Kevin Wolf
    /* Device address specified by bus/unit or index.
795 87a899c5 Kevin Wolf
     * If none was specified, try to find the first free one. */
796 87a899c5 Kevin Wolf
    bus_id  = qemu_opt_get_number(legacy_opts, "bus", 0);
797 87a899c5 Kevin Wolf
    unit_id = qemu_opt_get_number(legacy_opts, "unit", -1);
798 87a899c5 Kevin Wolf
    index   = qemu_opt_get_number(legacy_opts, "index", -1);
799 87a899c5 Kevin Wolf
800 87a899c5 Kevin Wolf
    max_devs = if_max_devs[type];
801 87a899c5 Kevin Wolf
802 87a899c5 Kevin Wolf
    if (index != -1) {
803 87a899c5 Kevin Wolf
        if (bus_id != 0 || unit_id != -1) {
804 87a899c5 Kevin Wolf
            error_report("index cannot be used with bus and unit");
805 87a899c5 Kevin Wolf
            goto fail;
806 87a899c5 Kevin Wolf
        }
807 87a899c5 Kevin Wolf
        bus_id = drive_index_to_bus_id(type, index);
808 87a899c5 Kevin Wolf
        unit_id = drive_index_to_unit_id(type, index);
809 87a899c5 Kevin Wolf
    }
810 87a899c5 Kevin Wolf
811 87a899c5 Kevin Wolf
    if (unit_id == -1) {
812 87a899c5 Kevin Wolf
       unit_id = 0;
813 87a899c5 Kevin Wolf
       while (drive_get(type, bus_id, unit_id) != NULL) {
814 87a899c5 Kevin Wolf
           unit_id++;
815 87a899c5 Kevin Wolf
           if (max_devs && unit_id >= max_devs) {
816 87a899c5 Kevin Wolf
               unit_id -= max_devs;
817 87a899c5 Kevin Wolf
               bus_id++;
818 87a899c5 Kevin Wolf
           }
819 87a899c5 Kevin Wolf
       }
820 87a899c5 Kevin Wolf
    }
821 87a899c5 Kevin Wolf
822 87a899c5 Kevin Wolf
    if (max_devs && unit_id >= max_devs) {
823 87a899c5 Kevin Wolf
        error_report("unit %d too big (max is %d)", unit_id, max_devs - 1);
824 87a899c5 Kevin Wolf
        goto fail;
825 87a899c5 Kevin Wolf
    }
826 87a899c5 Kevin Wolf
827 87a899c5 Kevin Wolf
    if (drive_get(type, bus_id, unit_id) != NULL) {
828 87a899c5 Kevin Wolf
        error_report("drive with bus=%d, unit=%d (index=%d) exists",
829 87a899c5 Kevin Wolf
                     bus_id, unit_id, index);
830 87a899c5 Kevin Wolf
        goto fail;
831 87a899c5 Kevin Wolf
    }
832 87a899c5 Kevin Wolf
833 87a899c5 Kevin Wolf
    /* no id supplied -> create one */
834 87a899c5 Kevin Wolf
    if (qemu_opts_id(all_opts) == NULL) {
835 87a899c5 Kevin Wolf
        char *new_id;
836 87a899c5 Kevin Wolf
        const char *mediastr = "";
837 87a899c5 Kevin Wolf
        if (type == IF_IDE || type == IF_SCSI) {
838 87a899c5 Kevin Wolf
            mediastr = (media == MEDIA_CDROM) ? "-cd" : "-hd";
839 87a899c5 Kevin Wolf
        }
840 87a899c5 Kevin Wolf
        if (max_devs) {
841 87a899c5 Kevin Wolf
            new_id = g_strdup_printf("%s%i%s%i", if_name[type], bus_id,
842 87a899c5 Kevin Wolf
                                     mediastr, unit_id);
843 87a899c5 Kevin Wolf
        } else {
844 87a899c5 Kevin Wolf
            new_id = g_strdup_printf("%s%s%i", if_name[type],
845 87a899c5 Kevin Wolf
                                     mediastr, unit_id);
846 87a899c5 Kevin Wolf
        }
847 87a899c5 Kevin Wolf
        qdict_put(bs_opts, "id", qstring_from_str(new_id));
848 87a899c5 Kevin Wolf
        g_free(new_id);
849 87a899c5 Kevin Wolf
    }
850 87a899c5 Kevin Wolf
851 394c7d4d Kevin Wolf
    /* Add virtio block device */
852 394c7d4d Kevin Wolf
    devaddr = qemu_opt_get(legacy_opts, "addr");
853 394c7d4d Kevin Wolf
    if (devaddr && type != IF_VIRTIO) {
854 394c7d4d Kevin Wolf
        error_report("addr is not supported by this bus type");
855 394c7d4d Kevin Wolf
        goto fail;
856 394c7d4d Kevin Wolf
    }
857 394c7d4d Kevin Wolf
858 394c7d4d Kevin Wolf
    if (type == IF_VIRTIO) {
859 394c7d4d Kevin Wolf
        QemuOpts *devopts;
860 87ea75d5 Peter Crosthwaite
        devopts = qemu_opts_create(qemu_find_opts("device"), NULL, 0,
861 87ea75d5 Peter Crosthwaite
                                   &error_abort);
862 394c7d4d Kevin Wolf
        if (arch_type == QEMU_ARCH_S390X) {
863 394c7d4d Kevin Wolf
            qemu_opt_set(devopts, "driver", "virtio-blk-s390");
864 394c7d4d Kevin Wolf
        } else {
865 394c7d4d Kevin Wolf
            qemu_opt_set(devopts, "driver", "virtio-blk-pci");
866 394c7d4d Kevin Wolf
        }
867 394c7d4d Kevin Wolf
        qemu_opt_set(devopts, "drive", qdict_get_str(bs_opts, "id"));
868 394c7d4d Kevin Wolf
        if (devaddr) {
869 394c7d4d Kevin Wolf
            qemu_opt_set(devopts, "addr", devaddr);
870 394c7d4d Kevin Wolf
        }
871 394c7d4d Kevin Wolf
    }
872 394c7d4d Kevin Wolf
873 d095b465 Max Reitz
    filename = qemu_opt_get(legacy_opts, "file");
874 d095b465 Max Reitz
875 2d246f01 Kevin Wolf
    /* Actual block device init: Functionality shared with blockdev-add */
876 d095b465 Max Reitz
    dinfo = blockdev_init(filename, bs_opts, type, &local_err);
877 2d246f01 Kevin Wolf
    if (dinfo == NULL) {
878 b681072d Kevin Wolf
        if (error_is_set(&local_err)) {
879 b681072d Kevin Wolf
            qerror_report_err(local_err);
880 b681072d Kevin Wolf
            error_free(local_err);
881 b681072d Kevin Wolf
        }
882 2d246f01 Kevin Wolf
        goto fail;
883 b681072d Kevin Wolf
    } else {
884 b681072d Kevin Wolf
        assert(!error_is_set(&local_err));
885 2d246f01 Kevin Wolf
    }
886 2d246f01 Kevin Wolf
887 2d246f01 Kevin Wolf
    /* Set legacy DriveInfo fields */
888 2d246f01 Kevin Wolf
    dinfo->enable_auto_del = true;
889 f298d071 Kevin Wolf
    dinfo->opts = all_opts;
890 2d246f01 Kevin Wolf
891 b41a7338 Kevin Wolf
    dinfo->cyls = cyls;
892 b41a7338 Kevin Wolf
    dinfo->heads = heads;
893 b41a7338 Kevin Wolf
    dinfo->secs = secs;
894 b41a7338 Kevin Wolf
    dinfo->trans = translation;
895 b41a7338 Kevin Wolf
896 87a899c5 Kevin Wolf
    dinfo->bus = bus_id;
897 87a899c5 Kevin Wolf
    dinfo->unit = unit_id;
898 394c7d4d Kevin Wolf
    dinfo->devaddr = devaddr;
899 87a899c5 Kevin Wolf
900 e34ef046 Kevin Wolf
    switch(type) {
901 e34ef046 Kevin Wolf
    case IF_IDE:
902 e34ef046 Kevin Wolf
    case IF_SCSI:
903 e34ef046 Kevin Wolf
    case IF_XEN:
904 e34ef046 Kevin Wolf
    case IF_NONE:
905 e34ef046 Kevin Wolf
        dinfo->media_cd = media == MEDIA_CDROM;
906 e34ef046 Kevin Wolf
        break;
907 e34ef046 Kevin Wolf
    default:
908 e34ef046 Kevin Wolf
        break;
909 e34ef046 Kevin Wolf
    }
910 e34ef046 Kevin Wolf
911 2d246f01 Kevin Wolf
fail:
912 33cb7dc8 Kevin Wolf
    qemu_opts_del(legacy_opts);
913 2d246f01 Kevin Wolf
    return dinfo;
914 57975222 Kevin Wolf
}
915 57975222 Kevin Wolf
916 666daa68 Markus Armbruster
void do_commit(Monitor *mon, const QDict *qdict)
917 666daa68 Markus Armbruster
{
918 666daa68 Markus Armbruster
    const char *device = qdict_get_str(qdict, "device");
919 6ab4b5ab Markus Armbruster
    BlockDriverState *bs;
920 e8877497 Stefan Hajnoczi
    int ret;
921 666daa68 Markus Armbruster
922 6ab4b5ab Markus Armbruster
    if (!strcmp(device, "all")) {
923 e8877497 Stefan Hajnoczi
        ret = bdrv_commit_all();
924 6ab4b5ab Markus Armbruster
    } else {
925 6ab4b5ab Markus Armbruster
        bs = bdrv_find(device);
926 ac59eb95 Markus Armbruster
        if (!bs) {
927 58513bde Jeff Cody
            monitor_printf(mon, "Device '%s' not found\n", device);
928 ac59eb95 Markus Armbruster
            return;
929 6ab4b5ab Markus Armbruster
        }
930 2d3735d3 Stefan Hajnoczi
        ret = bdrv_commit(bs);
931 58513bde Jeff Cody
    }
932 58513bde Jeff Cody
    if (ret < 0) {
933 58513bde Jeff Cody
        monitor_printf(mon, "'commit' error for '%s': %s\n", device,
934 58513bde Jeff Cody
                       strerror(-ret));
935 666daa68 Markus Armbruster
    }
936 666daa68 Markus Armbruster
}
937 666daa68 Markus Armbruster
938 6cc2a415 Paolo Bonzini
static void blockdev_do_action(int kind, void *data, Error **errp)
939 6cc2a415 Paolo Bonzini
{
940 c8a83e85 Kevin Wolf
    TransactionAction action;
941 c8a83e85 Kevin Wolf
    TransactionActionList list;
942 6cc2a415 Paolo Bonzini
943 6cc2a415 Paolo Bonzini
    action.kind = kind;
944 6cc2a415 Paolo Bonzini
    action.data = data;
945 6cc2a415 Paolo Bonzini
    list.value = &action;
946 6cc2a415 Paolo Bonzini
    list.next = NULL;
947 6cc2a415 Paolo Bonzini
    qmp_transaction(&list, errp);
948 6cc2a415 Paolo Bonzini
}
949 6cc2a415 Paolo Bonzini
950 0901f67e Benoît Canet
void qmp_blockdev_snapshot_sync(bool has_device, const char *device,
951 0901f67e Benoît Canet
                                bool has_node_name, const char *node_name,
952 0901f67e Benoît Canet
                                const char *snapshot_file,
953 0901f67e Benoît Canet
                                bool has_snapshot_node_name,
954 0901f67e Benoît Canet
                                const char *snapshot_node_name,
955 6106e249 Luiz Capitulino
                                bool has_format, const char *format,
956 0901f67e Benoît Canet
                                bool has_mode, NewImageMode mode, Error **errp)
957 f8882568 Jes Sorensen
{
958 6cc2a415 Paolo Bonzini
    BlockdevSnapshot snapshot = {
959 0901f67e Benoît Canet
        .has_device = has_device,
960 6cc2a415 Paolo Bonzini
        .device = (char *) device,
961 0901f67e Benoît Canet
        .has_node_name = has_node_name,
962 0901f67e Benoît Canet
        .node_name = (char *) node_name,
963 6cc2a415 Paolo Bonzini
        .snapshot_file = (char *) snapshot_file,
964 0901f67e Benoît Canet
        .has_snapshot_node_name = has_snapshot_node_name,
965 0901f67e Benoît Canet
        .snapshot_node_name = (char *) snapshot_node_name,
966 6cc2a415 Paolo Bonzini
        .has_format = has_format,
967 6cc2a415 Paolo Bonzini
        .format = (char *) format,
968 6cc2a415 Paolo Bonzini
        .has_mode = has_mode,
969 6cc2a415 Paolo Bonzini
        .mode = mode,
970 6cc2a415 Paolo Bonzini
    };
971 c8a83e85 Kevin Wolf
    blockdev_do_action(TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC,
972 c8a83e85 Kevin Wolf
                       &snapshot, errp);
973 f8882568 Jes Sorensen
}
974 f8882568 Jes Sorensen
975 f323bc9e Wenchao Xia
void qmp_blockdev_snapshot_internal_sync(const char *device,
976 f323bc9e Wenchao Xia
                                         const char *name,
977 f323bc9e Wenchao Xia
                                         Error **errp)
978 f323bc9e Wenchao Xia
{
979 f323bc9e Wenchao Xia
    BlockdevSnapshotInternal snapshot = {
980 f323bc9e Wenchao Xia
        .device = (char *) device,
981 f323bc9e Wenchao Xia
        .name = (char *) name
982 f323bc9e Wenchao Xia
    };
983 f323bc9e Wenchao Xia
984 f323bc9e Wenchao Xia
    blockdev_do_action(TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_INTERNAL_SYNC,
985 f323bc9e Wenchao Xia
                       &snapshot, errp);
986 f323bc9e Wenchao Xia
}
987 f323bc9e Wenchao Xia
988 44e3e053 Wenchao Xia
SnapshotInfo *qmp_blockdev_snapshot_delete_internal_sync(const char *device,
989 44e3e053 Wenchao Xia
                                                         bool has_id,
990 44e3e053 Wenchao Xia
                                                         const char *id,
991 44e3e053 Wenchao Xia
                                                         bool has_name,
992 44e3e053 Wenchao Xia
                                                         const char *name,
993 44e3e053 Wenchao Xia
                                                         Error **errp)
994 44e3e053 Wenchao Xia
{
995 44e3e053 Wenchao Xia
    BlockDriverState *bs = bdrv_find(device);
996 44e3e053 Wenchao Xia
    QEMUSnapshotInfo sn;
997 44e3e053 Wenchao Xia
    Error *local_err = NULL;
998 44e3e053 Wenchao Xia
    SnapshotInfo *info = NULL;
999 44e3e053 Wenchao Xia
    int ret;
1000 44e3e053 Wenchao Xia
1001 44e3e053 Wenchao Xia
    if (!bs) {
1002 44e3e053 Wenchao Xia
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1003 44e3e053 Wenchao Xia
        return NULL;
1004 44e3e053 Wenchao Xia
    }
1005 44e3e053 Wenchao Xia
1006 44e3e053 Wenchao Xia
    if (!has_id) {
1007 44e3e053 Wenchao Xia
        id = NULL;
1008 44e3e053 Wenchao Xia
    }
1009 44e3e053 Wenchao Xia
1010 44e3e053 Wenchao Xia
    if (!has_name) {
1011 44e3e053 Wenchao Xia
        name = NULL;
1012 44e3e053 Wenchao Xia
    }
1013 44e3e053 Wenchao Xia
1014 44e3e053 Wenchao Xia
    if (!id && !name) {
1015 44e3e053 Wenchao Xia
        error_setg(errp, "Name or id must be provided");
1016 44e3e053 Wenchao Xia
        return NULL;
1017 44e3e053 Wenchao Xia
    }
1018 44e3e053 Wenchao Xia
1019 44e3e053 Wenchao Xia
    ret = bdrv_snapshot_find_by_id_and_name(bs, id, name, &sn, &local_err);
1020 44e3e053 Wenchao Xia
    if (error_is_set(&local_err)) {
1021 44e3e053 Wenchao Xia
        error_propagate(errp, local_err);
1022 44e3e053 Wenchao Xia
        return NULL;
1023 44e3e053 Wenchao Xia
    }
1024 44e3e053 Wenchao Xia
    if (!ret) {
1025 44e3e053 Wenchao Xia
        error_setg(errp,
1026 44e3e053 Wenchao Xia
                   "Snapshot with id '%s' and name '%s' does not exist on "
1027 44e3e053 Wenchao Xia
                   "device '%s'",
1028 44e3e053 Wenchao Xia
                   STR_OR_NULL(id), STR_OR_NULL(name), device);
1029 44e3e053 Wenchao Xia
        return NULL;
1030 44e3e053 Wenchao Xia
    }
1031 44e3e053 Wenchao Xia
1032 44e3e053 Wenchao Xia
    bdrv_snapshot_delete(bs, id, name, &local_err);
1033 44e3e053 Wenchao Xia
    if (error_is_set(&local_err)) {
1034 44e3e053 Wenchao Xia
        error_propagate(errp, local_err);
1035 44e3e053 Wenchao Xia
        return NULL;
1036 44e3e053 Wenchao Xia
    }
1037 44e3e053 Wenchao Xia
1038 44e3e053 Wenchao Xia
    info = g_malloc0(sizeof(SnapshotInfo));
1039 44e3e053 Wenchao Xia
    info->id = g_strdup(sn.id_str);
1040 44e3e053 Wenchao Xia
    info->name = g_strdup(sn.name);
1041 44e3e053 Wenchao Xia
    info->date_nsec = sn.date_nsec;
1042 44e3e053 Wenchao Xia
    info->date_sec = sn.date_sec;
1043 44e3e053 Wenchao Xia
    info->vm_state_size = sn.vm_state_size;
1044 44e3e053 Wenchao Xia
    info->vm_clock_nsec = sn.vm_clock_nsec % 1000000000;
1045 44e3e053 Wenchao Xia
    info->vm_clock_sec = sn.vm_clock_nsec / 1000000000;
1046 44e3e053 Wenchao Xia
1047 44e3e053 Wenchao Xia
    return info;
1048 44e3e053 Wenchao Xia
}
1049 8802d1fd Jeff Cody
1050 8802d1fd Jeff Cody
/* New and old BlockDriverState structs for group snapshots */
1051 ba0c86a3 Wenchao Xia
1052 ba5d6ab6 Stefan Hajnoczi
typedef struct BlkTransactionState BlkTransactionState;
1053 ba0c86a3 Wenchao Xia
1054 ba0c86a3 Wenchao Xia
/* Only prepare() may fail. In a single transaction, only one of commit() or
1055 ba0c86a3 Wenchao Xia
   abort() will be called, clean() will always be called if it present. */
1056 ba0c86a3 Wenchao Xia
typedef struct BdrvActionOps {
1057 ba0c86a3 Wenchao Xia
    /* Size of state struct, in bytes. */
1058 ba0c86a3 Wenchao Xia
    size_t instance_size;
1059 ba0c86a3 Wenchao Xia
    /* Prepare the work, must NOT be NULL. */
1060 ba5d6ab6 Stefan Hajnoczi
    void (*prepare)(BlkTransactionState *common, Error **errp);
1061 f9ea81e8 Stefan Hajnoczi
    /* Commit the changes, can be NULL. */
1062 ba5d6ab6 Stefan Hajnoczi
    void (*commit)(BlkTransactionState *common);
1063 ba0c86a3 Wenchao Xia
    /* Abort the changes on fail, can be NULL. */
1064 ba5d6ab6 Stefan Hajnoczi
    void (*abort)(BlkTransactionState *common);
1065 ba0c86a3 Wenchao Xia
    /* Clean up resource in the end, can be NULL. */
1066 ba5d6ab6 Stefan Hajnoczi
    void (*clean)(BlkTransactionState *common);
1067 ba0c86a3 Wenchao Xia
} BdrvActionOps;
1068 ba0c86a3 Wenchao Xia
1069 ba0c86a3 Wenchao Xia
/*
1070 ba0c86a3 Wenchao Xia
 * This structure must be arranged as first member in child type, assuming
1071 ba0c86a3 Wenchao Xia
 * that compiler will also arrange it to the same address with parent instance.
1072 ba0c86a3 Wenchao Xia
 * Later it will be used in free().
1073 ba0c86a3 Wenchao Xia
 */
1074 ba5d6ab6 Stefan Hajnoczi
struct BlkTransactionState {
1075 c8a83e85 Kevin Wolf
    TransactionAction *action;
1076 ba0c86a3 Wenchao Xia
    const BdrvActionOps *ops;
1077 ba5d6ab6 Stefan Hajnoczi
    QSIMPLEQ_ENTRY(BlkTransactionState) entry;
1078 ba0c86a3 Wenchao Xia
};
1079 ba0c86a3 Wenchao Xia
1080 bbe86010 Wenchao Xia
/* internal snapshot private data */
1081 bbe86010 Wenchao Xia
typedef struct InternalSnapshotState {
1082 bbe86010 Wenchao Xia
    BlkTransactionState common;
1083 bbe86010 Wenchao Xia
    BlockDriverState *bs;
1084 bbe86010 Wenchao Xia
    QEMUSnapshotInfo sn;
1085 bbe86010 Wenchao Xia
} InternalSnapshotState;
1086 bbe86010 Wenchao Xia
1087 bbe86010 Wenchao Xia
static void internal_snapshot_prepare(BlkTransactionState *common,
1088 bbe86010 Wenchao Xia
                                      Error **errp)
1089 bbe86010 Wenchao Xia
{
1090 bbe86010 Wenchao Xia
    const char *device;
1091 bbe86010 Wenchao Xia
    const char *name;
1092 bbe86010 Wenchao Xia
    BlockDriverState *bs;
1093 bbe86010 Wenchao Xia
    QEMUSnapshotInfo old_sn, *sn;
1094 bbe86010 Wenchao Xia
    bool ret;
1095 bbe86010 Wenchao Xia
    qemu_timeval tv;
1096 bbe86010 Wenchao Xia
    BlockdevSnapshotInternal *internal;
1097 bbe86010 Wenchao Xia
    InternalSnapshotState *state;
1098 bbe86010 Wenchao Xia
    int ret1;
1099 bbe86010 Wenchao Xia
1100 bbe86010 Wenchao Xia
    g_assert(common->action->kind ==
1101 bbe86010 Wenchao Xia
             TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_INTERNAL_SYNC);
1102 bbe86010 Wenchao Xia
    internal = common->action->blockdev_snapshot_internal_sync;
1103 bbe86010 Wenchao Xia
    state = DO_UPCAST(InternalSnapshotState, common, common);
1104 bbe86010 Wenchao Xia
1105 bbe86010 Wenchao Xia
    /* 1. parse input */
1106 bbe86010 Wenchao Xia
    device = internal->device;
1107 bbe86010 Wenchao Xia
    name = internal->name;
1108 bbe86010 Wenchao Xia
1109 bbe86010 Wenchao Xia
    /* 2. check for validation */
1110 bbe86010 Wenchao Xia
    bs = bdrv_find(device);
1111 bbe86010 Wenchao Xia
    if (!bs) {
1112 bbe86010 Wenchao Xia
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1113 bbe86010 Wenchao Xia
        return;
1114 bbe86010 Wenchao Xia
    }
1115 bbe86010 Wenchao Xia
1116 bbe86010 Wenchao Xia
    if (!bdrv_is_inserted(bs)) {
1117 bbe86010 Wenchao Xia
        error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
1118 bbe86010 Wenchao Xia
        return;
1119 bbe86010 Wenchao Xia
    }
1120 bbe86010 Wenchao Xia
1121 bbe86010 Wenchao Xia
    if (bdrv_is_read_only(bs)) {
1122 bbe86010 Wenchao Xia
        error_set(errp, QERR_DEVICE_IS_READ_ONLY, device);
1123 bbe86010 Wenchao Xia
        return;
1124 bbe86010 Wenchao Xia
    }
1125 bbe86010 Wenchao Xia
1126 bbe86010 Wenchao Xia
    if (!bdrv_can_snapshot(bs)) {
1127 bbe86010 Wenchao Xia
        error_set(errp, QERR_BLOCK_FORMAT_FEATURE_NOT_SUPPORTED,
1128 bbe86010 Wenchao Xia
                  bs->drv->format_name, device, "internal snapshot");
1129 bbe86010 Wenchao Xia
        return;
1130 bbe86010 Wenchao Xia
    }
1131 bbe86010 Wenchao Xia
1132 bbe86010 Wenchao Xia
    if (!strlen(name)) {
1133 bbe86010 Wenchao Xia
        error_setg(errp, "Name is empty");
1134 bbe86010 Wenchao Xia
        return;
1135 bbe86010 Wenchao Xia
    }
1136 bbe86010 Wenchao Xia
1137 bbe86010 Wenchao Xia
    /* check whether a snapshot with name exist */
1138 bbe86010 Wenchao Xia
    ret = bdrv_snapshot_find_by_id_and_name(bs, NULL, name, &old_sn, errp);
1139 bbe86010 Wenchao Xia
    if (error_is_set(errp)) {
1140 bbe86010 Wenchao Xia
        return;
1141 bbe86010 Wenchao Xia
    } else if (ret) {
1142 bbe86010 Wenchao Xia
        error_setg(errp,
1143 bbe86010 Wenchao Xia
                   "Snapshot with name '%s' already exists on device '%s'",
1144 bbe86010 Wenchao Xia
                   name, device);
1145 bbe86010 Wenchao Xia
        return;
1146 bbe86010 Wenchao Xia
    }
1147 bbe86010 Wenchao Xia
1148 bbe86010 Wenchao Xia
    /* 3. take the snapshot */
1149 bbe86010 Wenchao Xia
    sn = &state->sn;
1150 bbe86010 Wenchao Xia
    pstrcpy(sn->name, sizeof(sn->name), name);
1151 bbe86010 Wenchao Xia
    qemu_gettimeofday(&tv);
1152 bbe86010 Wenchao Xia
    sn->date_sec = tv.tv_sec;
1153 bbe86010 Wenchao Xia
    sn->date_nsec = tv.tv_usec * 1000;
1154 bbe86010 Wenchao Xia
    sn->vm_clock_nsec = qemu_clock_get_ns(QEMU_CLOCK_VIRTUAL);
1155 bbe86010 Wenchao Xia
1156 bbe86010 Wenchao Xia
    ret1 = bdrv_snapshot_create(bs, sn);
1157 bbe86010 Wenchao Xia
    if (ret1 < 0) {
1158 bbe86010 Wenchao Xia
        error_setg_errno(errp, -ret1,
1159 bbe86010 Wenchao Xia
                         "Failed to create snapshot '%s' on device '%s'",
1160 bbe86010 Wenchao Xia
                         name, device);
1161 bbe86010 Wenchao Xia
        return;
1162 bbe86010 Wenchao Xia
    }
1163 bbe86010 Wenchao Xia
1164 bbe86010 Wenchao Xia
    /* 4. succeed, mark a snapshot is created */
1165 bbe86010 Wenchao Xia
    state->bs = bs;
1166 bbe86010 Wenchao Xia
}
1167 bbe86010 Wenchao Xia
1168 bbe86010 Wenchao Xia
static void internal_snapshot_abort(BlkTransactionState *common)
1169 bbe86010 Wenchao Xia
{
1170 bbe86010 Wenchao Xia
    InternalSnapshotState *state =
1171 bbe86010 Wenchao Xia
                             DO_UPCAST(InternalSnapshotState, common, common);
1172 bbe86010 Wenchao Xia
    BlockDriverState *bs = state->bs;
1173 bbe86010 Wenchao Xia
    QEMUSnapshotInfo *sn = &state->sn;
1174 bbe86010 Wenchao Xia
    Error *local_error = NULL;
1175 bbe86010 Wenchao Xia
1176 bbe86010 Wenchao Xia
    if (!bs) {
1177 bbe86010 Wenchao Xia
        return;
1178 bbe86010 Wenchao Xia
    }
1179 bbe86010 Wenchao Xia
1180 bbe86010 Wenchao Xia
    if (bdrv_snapshot_delete(bs, sn->id_str, sn->name, &local_error) < 0) {
1181 bbe86010 Wenchao Xia
        error_report("Failed to delete snapshot with id '%s' and name '%s' on "
1182 bbe86010 Wenchao Xia
                     "device '%s' in abort: %s",
1183 bbe86010 Wenchao Xia
                     sn->id_str,
1184 bbe86010 Wenchao Xia
                     sn->name,
1185 bbe86010 Wenchao Xia
                     bdrv_get_device_name(bs),
1186 bbe86010 Wenchao Xia
                     error_get_pretty(local_error));
1187 bbe86010 Wenchao Xia
        error_free(local_error);
1188 bbe86010 Wenchao Xia
    }
1189 bbe86010 Wenchao Xia
}
1190 bbe86010 Wenchao Xia
1191 ba0c86a3 Wenchao Xia
/* external snapshot private data */
1192 ba5d6ab6 Stefan Hajnoczi
typedef struct ExternalSnapshotState {
1193 ba5d6ab6 Stefan Hajnoczi
    BlkTransactionState common;
1194 8802d1fd Jeff Cody
    BlockDriverState *old_bs;
1195 8802d1fd Jeff Cody
    BlockDriverState *new_bs;
1196 ba5d6ab6 Stefan Hajnoczi
} ExternalSnapshotState;
1197 8802d1fd Jeff Cody
1198 ba5d6ab6 Stefan Hajnoczi
static void external_snapshot_prepare(BlkTransactionState *common,
1199 9b9877ee Wenchao Xia
                                      Error **errp)
1200 9b9877ee Wenchao Xia
{
1201 9b9877ee Wenchao Xia
    BlockDriver *drv;
1202 9b9877ee Wenchao Xia
    int flags, ret;
1203 0901f67e Benoît Canet
    QDict *options = NULL;
1204 9b9877ee Wenchao Xia
    Error *local_err = NULL;
1205 0901f67e Benoît Canet
    bool has_device = false;
1206 e2a31e87 Wenchao Xia
    const char *device;
1207 0901f67e Benoît Canet
    bool has_node_name = false;
1208 0901f67e Benoît Canet
    const char *node_name;
1209 0901f67e Benoît Canet
    bool has_snapshot_node_name = false;
1210 0901f67e Benoît Canet
    const char *snapshot_node_name;
1211 e2a31e87 Wenchao Xia
    const char *new_image_file;
1212 e2a31e87 Wenchao Xia
    const char *format = "qcow2";
1213 e2a31e87 Wenchao Xia
    enum NewImageMode mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1214 ba5d6ab6 Stefan Hajnoczi
    ExternalSnapshotState *state =
1215 ba5d6ab6 Stefan Hajnoczi
                             DO_UPCAST(ExternalSnapshotState, common, common);
1216 c8a83e85 Kevin Wolf
    TransactionAction *action = common->action;
1217 9b9877ee Wenchao Xia
1218 e2a31e87 Wenchao Xia
    /* get parameters */
1219 c8a83e85 Kevin Wolf
    g_assert(action->kind == TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC);
1220 e2a31e87 Wenchao Xia
1221 0901f67e Benoît Canet
    has_device = action->blockdev_snapshot_sync->has_device;
1222 e2a31e87 Wenchao Xia
    device = action->blockdev_snapshot_sync->device;
1223 0901f67e Benoît Canet
    has_node_name = action->blockdev_snapshot_sync->has_node_name;
1224 0901f67e Benoît Canet
    node_name = action->blockdev_snapshot_sync->node_name;
1225 0901f67e Benoît Canet
    has_snapshot_node_name =
1226 0901f67e Benoît Canet
        action->blockdev_snapshot_sync->has_snapshot_node_name;
1227 0901f67e Benoît Canet
    snapshot_node_name = action->blockdev_snapshot_sync->snapshot_node_name;
1228 0901f67e Benoît Canet
1229 e2a31e87 Wenchao Xia
    new_image_file = action->blockdev_snapshot_sync->snapshot_file;
1230 e2a31e87 Wenchao Xia
    if (action->blockdev_snapshot_sync->has_format) {
1231 e2a31e87 Wenchao Xia
        format = action->blockdev_snapshot_sync->format;
1232 e2a31e87 Wenchao Xia
    }
1233 e2a31e87 Wenchao Xia
    if (action->blockdev_snapshot_sync->has_mode) {
1234 e2a31e87 Wenchao Xia
        mode = action->blockdev_snapshot_sync->mode;
1235 e2a31e87 Wenchao Xia
    }
1236 e2a31e87 Wenchao Xia
1237 e2a31e87 Wenchao Xia
    /* start processing */
1238 9b9877ee Wenchao Xia
    drv = bdrv_find_format(format);
1239 9b9877ee Wenchao Xia
    if (!drv) {
1240 9b9877ee Wenchao Xia
        error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
1241 9b9877ee Wenchao Xia
        return;
1242 9b9877ee Wenchao Xia
    }
1243 9b9877ee Wenchao Xia
1244 0901f67e Benoît Canet
    state->old_bs = bdrv_lookup_bs(has_device ? device : NULL,
1245 0901f67e Benoît Canet
                                   has_node_name ? node_name : NULL,
1246 0901f67e Benoît Canet
                                   &local_err);
1247 0901f67e Benoît Canet
    if (error_is_set(&local_err)) {
1248 0901f67e Benoît Canet
        error_propagate(errp, local_err);
1249 0901f67e Benoît Canet
        return;
1250 0901f67e Benoît Canet
    }
1251 0901f67e Benoît Canet
1252 0901f67e Benoît Canet
    if (has_node_name && !has_snapshot_node_name) {
1253 0901f67e Benoît Canet
        error_setg(errp, "New snapshot node name missing");
1254 0901f67e Benoît Canet
        return;
1255 0901f67e Benoît Canet
    }
1256 0901f67e Benoît Canet
1257 0901f67e Benoît Canet
    if (has_snapshot_node_name && bdrv_find_node(snapshot_node_name)) {
1258 0901f67e Benoît Canet
        error_setg(errp, "New snapshot node name already existing");
1259 9b9877ee Wenchao Xia
        return;
1260 9b9877ee Wenchao Xia
    }
1261 9b9877ee Wenchao Xia
1262 ba5d6ab6 Stefan Hajnoczi
    if (!bdrv_is_inserted(state->old_bs)) {
1263 9b9877ee Wenchao Xia
        error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
1264 9b9877ee Wenchao Xia
        return;
1265 9b9877ee Wenchao Xia
    }
1266 9b9877ee Wenchao Xia
1267 ba5d6ab6 Stefan Hajnoczi
    if (bdrv_in_use(state->old_bs)) {
1268 9b9877ee Wenchao Xia
        error_set(errp, QERR_DEVICE_IN_USE, device);
1269 9b9877ee Wenchao Xia
        return;
1270 9b9877ee Wenchao Xia
    }
1271 9b9877ee Wenchao Xia
1272 ba5d6ab6 Stefan Hajnoczi
    if (!bdrv_is_read_only(state->old_bs)) {
1273 ba5d6ab6 Stefan Hajnoczi
        if (bdrv_flush(state->old_bs)) {
1274 9b9877ee Wenchao Xia
            error_set(errp, QERR_IO_ERROR);
1275 9b9877ee Wenchao Xia
            return;
1276 9b9877ee Wenchao Xia
        }
1277 9b9877ee Wenchao Xia
    }
1278 9b9877ee Wenchao Xia
1279 212a5a8f Benoît Canet
    if (!bdrv_is_first_non_filter(state->old_bs)) {
1280 f6186f49 Benoît Canet
        error_set(errp, QERR_FEATURE_DISABLED, "snapshot");
1281 f6186f49 Benoît Canet
        return;
1282 f6186f49 Benoît Canet
    }
1283 f6186f49 Benoît Canet
1284 ba5d6ab6 Stefan Hajnoczi
    flags = state->old_bs->open_flags;
1285 9b9877ee Wenchao Xia
1286 9b9877ee Wenchao Xia
    /* create new image w/backing file */
1287 9b9877ee Wenchao Xia
    if (mode != NEW_IMAGE_MODE_EXISTING) {
1288 9b9877ee Wenchao Xia
        bdrv_img_create(new_image_file, format,
1289 ba5d6ab6 Stefan Hajnoczi
                        state->old_bs->filename,
1290 ba5d6ab6 Stefan Hajnoczi
                        state->old_bs->drv->format_name,
1291 9b9877ee Wenchao Xia
                        NULL, -1, flags, &local_err, false);
1292 9b9877ee Wenchao Xia
        if (error_is_set(&local_err)) {
1293 9b9877ee Wenchao Xia
            error_propagate(errp, local_err);
1294 9b9877ee Wenchao Xia
            return;
1295 9b9877ee Wenchao Xia
        }
1296 9b9877ee Wenchao Xia
    }
1297 9b9877ee Wenchao Xia
1298 0901f67e Benoît Canet
    if (has_snapshot_node_name) {
1299 0901f67e Benoît Canet
        options = qdict_new();
1300 0901f67e Benoît Canet
        qdict_put(options, "node-name",
1301 0901f67e Benoît Canet
                  qstring_from_str(snapshot_node_name));
1302 0901f67e Benoît Canet
    }
1303 0901f67e Benoît Canet
1304 9b9877ee Wenchao Xia
    /* We will manually add the backing_hd field to the bs later */
1305 ba5d6ab6 Stefan Hajnoczi
    state->new_bs = bdrv_new("");
1306 9b9877ee Wenchao Xia
    /* TODO Inherit bs->options or only take explicit options with an
1307 9b9877ee Wenchao Xia
     * extended QMP command? */
1308 0901f67e Benoît Canet
    ret = bdrv_open(state->new_bs, new_image_file, options,
1309 34b5d2c6 Max Reitz
                    flags | BDRV_O_NO_BACKING, drv, &local_err);
1310 9b9877ee Wenchao Xia
    if (ret != 0) {
1311 34b5d2c6 Max Reitz
        error_propagate(errp, local_err);
1312 9b9877ee Wenchao Xia
    }
1313 0901f67e Benoît Canet
1314 0901f67e Benoît Canet
    QDECREF(options);
1315 9b9877ee Wenchao Xia
}
1316 9b9877ee Wenchao Xia
1317 ba5d6ab6 Stefan Hajnoczi
static void external_snapshot_commit(BlkTransactionState *common)
1318 3b0047e8 Wenchao Xia
{
1319 ba5d6ab6 Stefan Hajnoczi
    ExternalSnapshotState *state =
1320 ba5d6ab6 Stefan Hajnoczi
                             DO_UPCAST(ExternalSnapshotState, common, common);
1321 ba0c86a3 Wenchao Xia
1322 ba5d6ab6 Stefan Hajnoczi
    /* This removes our old bs and adds the new bs */
1323 ba5d6ab6 Stefan Hajnoczi
    bdrv_append(state->new_bs, state->old_bs);
1324 3b0047e8 Wenchao Xia
    /* We don't need (or want) to use the transactional
1325 3b0047e8 Wenchao Xia
     * bdrv_reopen_multiple() across all the entries at once, because we
1326 3b0047e8 Wenchao Xia
     * don't want to abort all of them if one of them fails the reopen */
1327 ba5d6ab6 Stefan Hajnoczi
    bdrv_reopen(state->new_bs, state->new_bs->open_flags & ~BDRV_O_RDWR,
1328 3b0047e8 Wenchao Xia
                NULL);
1329 3b0047e8 Wenchao Xia
}
1330 3b0047e8 Wenchao Xia
1331 ba5d6ab6 Stefan Hajnoczi
static void external_snapshot_abort(BlkTransactionState *common)
1332 96b86bf7 Wenchao Xia
{
1333 ba5d6ab6 Stefan Hajnoczi
    ExternalSnapshotState *state =
1334 ba5d6ab6 Stefan Hajnoczi
                             DO_UPCAST(ExternalSnapshotState, common, common);
1335 ba5d6ab6 Stefan Hajnoczi
    if (state->new_bs) {
1336 4f6fd349 Fam Zheng
        bdrv_unref(state->new_bs);
1337 96b86bf7 Wenchao Xia
    }
1338 96b86bf7 Wenchao Xia
}
1339 96b86bf7 Wenchao Xia
1340 3037f364 Stefan Hajnoczi
typedef struct DriveBackupState {
1341 3037f364 Stefan Hajnoczi
    BlkTransactionState common;
1342 3037f364 Stefan Hajnoczi
    BlockDriverState *bs;
1343 3037f364 Stefan Hajnoczi
    BlockJob *job;
1344 3037f364 Stefan Hajnoczi
} DriveBackupState;
1345 3037f364 Stefan Hajnoczi
1346 3037f364 Stefan Hajnoczi
static void drive_backup_prepare(BlkTransactionState *common, Error **errp)
1347 3037f364 Stefan Hajnoczi
{
1348 3037f364 Stefan Hajnoczi
    DriveBackupState *state = DO_UPCAST(DriveBackupState, common, common);
1349 3037f364 Stefan Hajnoczi
    DriveBackup *backup;
1350 3037f364 Stefan Hajnoczi
    Error *local_err = NULL;
1351 3037f364 Stefan Hajnoczi
1352 3037f364 Stefan Hajnoczi
    assert(common->action->kind == TRANSACTION_ACTION_KIND_DRIVE_BACKUP);
1353 3037f364 Stefan Hajnoczi
    backup = common->action->drive_backup;
1354 3037f364 Stefan Hajnoczi
1355 3037f364 Stefan Hajnoczi
    qmp_drive_backup(backup->device, backup->target,
1356 3037f364 Stefan Hajnoczi
                     backup->has_format, backup->format,
1357 b53169ea Stefan Hajnoczi
                     backup->sync,
1358 3037f364 Stefan Hajnoczi
                     backup->has_mode, backup->mode,
1359 3037f364 Stefan Hajnoczi
                     backup->has_speed, backup->speed,
1360 3037f364 Stefan Hajnoczi
                     backup->has_on_source_error, backup->on_source_error,
1361 3037f364 Stefan Hajnoczi
                     backup->has_on_target_error, backup->on_target_error,
1362 3037f364 Stefan Hajnoczi
                     &local_err);
1363 3037f364 Stefan Hajnoczi
    if (error_is_set(&local_err)) {
1364 3037f364 Stefan Hajnoczi
        error_propagate(errp, local_err);
1365 3037f364 Stefan Hajnoczi
        state->bs = NULL;
1366 3037f364 Stefan Hajnoczi
        state->job = NULL;
1367 3037f364 Stefan Hajnoczi
        return;
1368 3037f364 Stefan Hajnoczi
    }
1369 3037f364 Stefan Hajnoczi
1370 3037f364 Stefan Hajnoczi
    state->bs = bdrv_find(backup->device);
1371 3037f364 Stefan Hajnoczi
    state->job = state->bs->job;
1372 3037f364 Stefan Hajnoczi
}
1373 3037f364 Stefan Hajnoczi
1374 3037f364 Stefan Hajnoczi
static void drive_backup_abort(BlkTransactionState *common)
1375 3037f364 Stefan Hajnoczi
{
1376 3037f364 Stefan Hajnoczi
    DriveBackupState *state = DO_UPCAST(DriveBackupState, common, common);
1377 3037f364 Stefan Hajnoczi
    BlockDriverState *bs = state->bs;
1378 3037f364 Stefan Hajnoczi
1379 3037f364 Stefan Hajnoczi
    /* Only cancel if it's the job we started */
1380 3037f364 Stefan Hajnoczi
    if (bs && bs->job && bs->job == state->job) {
1381 3037f364 Stefan Hajnoczi
        block_job_cancel_sync(bs->job);
1382 3037f364 Stefan Hajnoczi
    }
1383 3037f364 Stefan Hajnoczi
}
1384 3037f364 Stefan Hajnoczi
1385 78b18b78 Stefan Hajnoczi
static void abort_prepare(BlkTransactionState *common, Error **errp)
1386 78b18b78 Stefan Hajnoczi
{
1387 78b18b78 Stefan Hajnoczi
    error_setg(errp, "Transaction aborted using Abort action");
1388 78b18b78 Stefan Hajnoczi
}
1389 78b18b78 Stefan Hajnoczi
1390 78b18b78 Stefan Hajnoczi
static void abort_commit(BlkTransactionState *common)
1391 78b18b78 Stefan Hajnoczi
{
1392 dfc6f865 Stefan Weil
    g_assert_not_reached(); /* this action never succeeds */
1393 78b18b78 Stefan Hajnoczi
}
1394 78b18b78 Stefan Hajnoczi
1395 ba0c86a3 Wenchao Xia
static const BdrvActionOps actions[] = {
1396 c8a83e85 Kevin Wolf
    [TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_SYNC] = {
1397 ba5d6ab6 Stefan Hajnoczi
        .instance_size = sizeof(ExternalSnapshotState),
1398 ba0c86a3 Wenchao Xia
        .prepare  = external_snapshot_prepare,
1399 ba0c86a3 Wenchao Xia
        .commit   = external_snapshot_commit,
1400 ba0c86a3 Wenchao Xia
        .abort = external_snapshot_abort,
1401 ba0c86a3 Wenchao Xia
    },
1402 3037f364 Stefan Hajnoczi
    [TRANSACTION_ACTION_KIND_DRIVE_BACKUP] = {
1403 3037f364 Stefan Hajnoczi
        .instance_size = sizeof(DriveBackupState),
1404 3037f364 Stefan Hajnoczi
        .prepare = drive_backup_prepare,
1405 3037f364 Stefan Hajnoczi
        .abort = drive_backup_abort,
1406 3037f364 Stefan Hajnoczi
    },
1407 78b18b78 Stefan Hajnoczi
    [TRANSACTION_ACTION_KIND_ABORT] = {
1408 78b18b78 Stefan Hajnoczi
        .instance_size = sizeof(BlkTransactionState),
1409 78b18b78 Stefan Hajnoczi
        .prepare = abort_prepare,
1410 78b18b78 Stefan Hajnoczi
        .commit = abort_commit,
1411 78b18b78 Stefan Hajnoczi
    },
1412 bbe86010 Wenchao Xia
    [TRANSACTION_ACTION_KIND_BLOCKDEV_SNAPSHOT_INTERNAL_SYNC] = {
1413 bbe86010 Wenchao Xia
        .instance_size = sizeof(InternalSnapshotState),
1414 bbe86010 Wenchao Xia
        .prepare  = internal_snapshot_prepare,
1415 bbe86010 Wenchao Xia
        .abort = internal_snapshot_abort,
1416 bbe86010 Wenchao Xia
    },
1417 ba0c86a3 Wenchao Xia
};
1418 ba0c86a3 Wenchao Xia
1419 8802d1fd Jeff Cody
/*
1420 8802d1fd Jeff Cody
 * 'Atomic' group snapshots.  The snapshots are taken as a set, and if any fail
1421 8802d1fd Jeff Cody
 *  then we do not pivot any of the devices in the group, and abandon the
1422 8802d1fd Jeff Cody
 *  snapshots
1423 8802d1fd Jeff Cody
 */
1424 c8a83e85 Kevin Wolf
void qmp_transaction(TransactionActionList *dev_list, Error **errp)
1425 8802d1fd Jeff Cody
{
1426 c8a83e85 Kevin Wolf
    TransactionActionList *dev_entry = dev_list;
1427 ba5d6ab6 Stefan Hajnoczi
    BlkTransactionState *state, *next;
1428 43e17041 Luiz Capitulino
    Error *local_err = NULL;
1429 8802d1fd Jeff Cody
1430 ba5d6ab6 Stefan Hajnoczi
    QSIMPLEQ_HEAD(snap_bdrv_states, BlkTransactionState) snap_bdrv_states;
1431 8802d1fd Jeff Cody
    QSIMPLEQ_INIT(&snap_bdrv_states);
1432 8802d1fd Jeff Cody
1433 8802d1fd Jeff Cody
    /* drain all i/o before any snapshots */
1434 8802d1fd Jeff Cody
    bdrv_drain_all();
1435 8802d1fd Jeff Cody
1436 8802d1fd Jeff Cody
    /* We don't do anything in this loop that commits us to the snapshot */
1437 8802d1fd Jeff Cody
    while (NULL != dev_entry) {
1438 c8a83e85 Kevin Wolf
        TransactionAction *dev_info = NULL;
1439 ba0c86a3 Wenchao Xia
        const BdrvActionOps *ops;
1440 52e7c241 Paolo Bonzini
1441 8802d1fd Jeff Cody
        dev_info = dev_entry->value;
1442 8802d1fd Jeff Cody
        dev_entry = dev_entry->next;
1443 8802d1fd Jeff Cody
1444 ba0c86a3 Wenchao Xia
        assert(dev_info->kind < ARRAY_SIZE(actions));
1445 ba0c86a3 Wenchao Xia
1446 ba0c86a3 Wenchao Xia
        ops = &actions[dev_info->kind];
1447 aa3fe714 Max Reitz
        assert(ops->instance_size > 0);
1448 aa3fe714 Max Reitz
1449 ba5d6ab6 Stefan Hajnoczi
        state = g_malloc0(ops->instance_size);
1450 ba5d6ab6 Stefan Hajnoczi
        state->ops = ops;
1451 ba5d6ab6 Stefan Hajnoczi
        state->action = dev_info;
1452 ba5d6ab6 Stefan Hajnoczi
        QSIMPLEQ_INSERT_TAIL(&snap_bdrv_states, state, entry);
1453 8802d1fd Jeff Cody
1454 ba5d6ab6 Stefan Hajnoczi
        state->ops->prepare(state, &local_err);
1455 ba0c86a3 Wenchao Xia
        if (error_is_set(&local_err)) {
1456 ba0c86a3 Wenchao Xia
            error_propagate(errp, local_err);
1457 ba0c86a3 Wenchao Xia
            goto delete_and_fail;
1458 8802d1fd Jeff Cody
        }
1459 8802d1fd Jeff Cody
    }
1460 8802d1fd Jeff Cody
1461 ba5d6ab6 Stefan Hajnoczi
    QSIMPLEQ_FOREACH(state, &snap_bdrv_states, entry) {
1462 f9ea81e8 Stefan Hajnoczi
        if (state->ops->commit) {
1463 f9ea81e8 Stefan Hajnoczi
            state->ops->commit(state);
1464 f9ea81e8 Stefan Hajnoczi
        }
1465 8802d1fd Jeff Cody
    }
1466 8802d1fd Jeff Cody
1467 8802d1fd Jeff Cody
    /* success */
1468 8802d1fd Jeff Cody
    goto exit;
1469 8802d1fd Jeff Cody
1470 8802d1fd Jeff Cody
delete_and_fail:
1471 8802d1fd Jeff Cody
    /*
1472 8802d1fd Jeff Cody
    * failure, and it is all-or-none; abandon each new bs, and keep using
1473 8802d1fd Jeff Cody
    * the original bs for all images
1474 8802d1fd Jeff Cody
    */
1475 ba5d6ab6 Stefan Hajnoczi
    QSIMPLEQ_FOREACH(state, &snap_bdrv_states, entry) {
1476 ba5d6ab6 Stefan Hajnoczi
        if (state->ops->abort) {
1477 ba5d6ab6 Stefan Hajnoczi
            state->ops->abort(state);
1478 ba0c86a3 Wenchao Xia
        }
1479 8802d1fd Jeff Cody
    }
1480 8802d1fd Jeff Cody
exit:
1481 ba5d6ab6 Stefan Hajnoczi
    QSIMPLEQ_FOREACH_SAFE(state, &snap_bdrv_states, entry, next) {
1482 ba5d6ab6 Stefan Hajnoczi
        if (state->ops->clean) {
1483 ba5d6ab6 Stefan Hajnoczi
            state->ops->clean(state);
1484 ba0c86a3 Wenchao Xia
        }
1485 ba5d6ab6 Stefan Hajnoczi
        g_free(state);
1486 8802d1fd Jeff Cody
    }
1487 8802d1fd Jeff Cody
}
1488 8802d1fd Jeff Cody
1489 8802d1fd Jeff Cody
1490 92d48558 Luiz Capitulino
static void eject_device(BlockDriverState *bs, int force, Error **errp)
1491 666daa68 Markus Armbruster
{
1492 2d3735d3 Stefan Hajnoczi
    if (bdrv_in_use(bs)) {
1493 2d3735d3 Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_IN_USE, bdrv_get_device_name(bs));
1494 2d3735d3 Stefan Hajnoczi
        return;
1495 2d3735d3 Stefan Hajnoczi
    }
1496 2c6942fa Markus Armbruster
    if (!bdrv_dev_has_removable_media(bs)) {
1497 92d48558 Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_REMOVABLE, bdrv_get_device_name(bs));
1498 92d48558 Luiz Capitulino
        return;
1499 ea8f942f Markus Armbruster
    }
1500 92d48558 Luiz Capitulino
1501 025ccaa7 Paolo Bonzini
    if (bdrv_dev_is_medium_locked(bs) && !bdrv_dev_is_tray_open(bs)) {
1502 025ccaa7 Paolo Bonzini
        bdrv_dev_eject_request(bs, force);
1503 025ccaa7 Paolo Bonzini
        if (!force) {
1504 92d48558 Luiz Capitulino
            error_set(errp, QERR_DEVICE_LOCKED, bdrv_get_device_name(bs));
1505 92d48558 Luiz Capitulino
            return;
1506 025ccaa7 Paolo Bonzini
        }
1507 666daa68 Markus Armbruster
    }
1508 92d48558 Luiz Capitulino
1509 3b5276b5 Eduardo Habkost
    bdrv_close(bs);
1510 666daa68 Markus Armbruster
}
1511 666daa68 Markus Armbruster
1512 c245b6a3 Luiz Capitulino
void qmp_eject(const char *device, bool has_force, bool force, Error **errp)
1513 666daa68 Markus Armbruster
{
1514 666daa68 Markus Armbruster
    BlockDriverState *bs;
1515 666daa68 Markus Armbruster
1516 c245b6a3 Luiz Capitulino
    bs = bdrv_find(device);
1517 666daa68 Markus Armbruster
    if (!bs) {
1518 c245b6a3 Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1519 c245b6a3 Luiz Capitulino
        return;
1520 92d48558 Luiz Capitulino
    }
1521 92d48558 Luiz Capitulino
1522 c245b6a3 Luiz Capitulino
    eject_device(bs, force, errp);
1523 666daa68 Markus Armbruster
}
1524 666daa68 Markus Armbruster
1525 12d3ba82 Benoît Canet
void qmp_block_passwd(bool has_device, const char *device,
1526 12d3ba82 Benoît Canet
                      bool has_node_name, const char *node_name,
1527 12d3ba82 Benoît Canet
                      const char *password, Error **errp)
1528 666daa68 Markus Armbruster
{
1529 12d3ba82 Benoît Canet
    Error *local_err = NULL;
1530 666daa68 Markus Armbruster
    BlockDriverState *bs;
1531 666daa68 Markus Armbruster
    int err;
1532 666daa68 Markus Armbruster
1533 12d3ba82 Benoît Canet
    bs = bdrv_lookup_bs(has_device ? device : NULL,
1534 12d3ba82 Benoît Canet
                        has_node_name ? node_name : NULL,
1535 12d3ba82 Benoît Canet
                        &local_err);
1536 12d3ba82 Benoît Canet
    if (error_is_set(&local_err)) {
1537 12d3ba82 Benoît Canet
        error_propagate(errp, local_err);
1538 a4dea8a9 Luiz Capitulino
        return;
1539 666daa68 Markus Armbruster
    }
1540 666daa68 Markus Armbruster
1541 a4dea8a9 Luiz Capitulino
    err = bdrv_set_key(bs, password);
1542 666daa68 Markus Armbruster
    if (err == -EINVAL) {
1543 a4dea8a9 Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs));
1544 a4dea8a9 Luiz Capitulino
        return;
1545 666daa68 Markus Armbruster
    } else if (err < 0) {
1546 a4dea8a9 Luiz Capitulino
        error_set(errp, QERR_INVALID_PASSWORD);
1547 a4dea8a9 Luiz Capitulino
        return;
1548 666daa68 Markus Armbruster
    }
1549 666daa68 Markus Armbruster
}
1550 666daa68 Markus Armbruster
1551 333a96ec Luiz Capitulino
static void qmp_bdrv_open_encrypted(BlockDriverState *bs, const char *filename,
1552 333a96ec Luiz Capitulino
                                    int bdrv_flags, BlockDriver *drv,
1553 333a96ec Luiz Capitulino
                                    const char *password, Error **errp)
1554 333a96ec Luiz Capitulino
{
1555 34b5d2c6 Max Reitz
    Error *local_err = NULL;
1556 0eef407c Luiz Capitulino
    int ret;
1557 0eef407c Luiz Capitulino
1558 34b5d2c6 Max Reitz
    ret = bdrv_open(bs, filename, NULL, bdrv_flags, drv, &local_err);
1559 0eef407c Luiz Capitulino
    if (ret < 0) {
1560 34b5d2c6 Max Reitz
        error_propagate(errp, local_err);
1561 333a96ec Luiz Capitulino
        return;
1562 333a96ec Luiz Capitulino
    }
1563 333a96ec Luiz Capitulino
1564 333a96ec Luiz Capitulino
    if (bdrv_key_required(bs)) {
1565 333a96ec Luiz Capitulino
        if (password) {
1566 333a96ec Luiz Capitulino
            if (bdrv_set_key(bs, password) < 0) {
1567 333a96ec Luiz Capitulino
                error_set(errp, QERR_INVALID_PASSWORD);
1568 333a96ec Luiz Capitulino
            }
1569 333a96ec Luiz Capitulino
        } else {
1570 333a96ec Luiz Capitulino
            error_set(errp, QERR_DEVICE_ENCRYPTED, bdrv_get_device_name(bs),
1571 333a96ec Luiz Capitulino
                      bdrv_get_encrypted_filename(bs));
1572 333a96ec Luiz Capitulino
        }
1573 333a96ec Luiz Capitulino
    } else if (password) {
1574 333a96ec Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_ENCRYPTED, bdrv_get_device_name(bs));
1575 333a96ec Luiz Capitulino
    }
1576 333a96ec Luiz Capitulino
}
1577 333a96ec Luiz Capitulino
1578 333a96ec Luiz Capitulino
void qmp_change_blockdev(const char *device, const char *filename,
1579 314f7ea7 Marc-André Lureau
                         const char *format, Error **errp)
1580 666daa68 Markus Armbruster
{
1581 666daa68 Markus Armbruster
    BlockDriverState *bs;
1582 666daa68 Markus Armbruster
    BlockDriver *drv = NULL;
1583 666daa68 Markus Armbruster
    int bdrv_flags;
1584 92d48558 Luiz Capitulino
    Error *err = NULL;
1585 666daa68 Markus Armbruster
1586 666daa68 Markus Armbruster
    bs = bdrv_find(device);
1587 666daa68 Markus Armbruster
    if (!bs) {
1588 333a96ec Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1589 333a96ec Luiz Capitulino
        return;
1590 666daa68 Markus Armbruster
    }
1591 333a96ec Luiz Capitulino
1592 333a96ec Luiz Capitulino
    if (format) {
1593 b64ec4e4 Fam Zheng
        drv = bdrv_find_whitelisted_format(format, bs->read_only);
1594 666daa68 Markus Armbruster
        if (!drv) {
1595 333a96ec Luiz Capitulino
            error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
1596 333a96ec Luiz Capitulino
            return;
1597 666daa68 Markus Armbruster
        }
1598 666daa68 Markus Armbruster
    }
1599 333a96ec Luiz Capitulino
1600 92d48558 Luiz Capitulino
    eject_device(bs, 0, &err);
1601 92d48558 Luiz Capitulino
    if (error_is_set(&err)) {
1602 333a96ec Luiz Capitulino
        error_propagate(errp, err);
1603 333a96ec Luiz Capitulino
        return;
1604 666daa68 Markus Armbruster
    }
1605 333a96ec Luiz Capitulino
1606 528f7663 Markus Armbruster
    bdrv_flags = bdrv_is_read_only(bs) ? 0 : BDRV_O_RDWR;
1607 199630b6 Blue Swirl
    bdrv_flags |= bdrv_is_snapshot(bs) ? BDRV_O_SNAPSHOT : 0;
1608 333a96ec Luiz Capitulino
1609 333a96ec Luiz Capitulino
    qmp_bdrv_open_encrypted(bs, filename, bdrv_flags, drv, NULL, errp);
1610 666daa68 Markus Armbruster
}
1611 9063f814 Ryan Harper
1612 727f005e Zhi Yong Wu
/* throttling disk I/O limits */
1613 80047da5 Luiz Capitulino
void qmp_block_set_io_throttle(const char *device, int64_t bps, int64_t bps_rd,
1614 3e9fab69 Benoît Canet
                               int64_t bps_wr,
1615 3e9fab69 Benoît Canet
                               int64_t iops,
1616 3e9fab69 Benoît Canet
                               int64_t iops_rd,
1617 3e9fab69 Benoît Canet
                               int64_t iops_wr,
1618 3e9fab69 Benoît Canet
                               bool has_bps_max,
1619 3e9fab69 Benoît Canet
                               int64_t bps_max,
1620 3e9fab69 Benoît Canet
                               bool has_bps_rd_max,
1621 3e9fab69 Benoît Canet
                               int64_t bps_rd_max,
1622 3e9fab69 Benoît Canet
                               bool has_bps_wr_max,
1623 3e9fab69 Benoît Canet
                               int64_t bps_wr_max,
1624 3e9fab69 Benoît Canet
                               bool has_iops_max,
1625 3e9fab69 Benoît Canet
                               int64_t iops_max,
1626 3e9fab69 Benoît Canet
                               bool has_iops_rd_max,
1627 3e9fab69 Benoît Canet
                               int64_t iops_rd_max,
1628 3e9fab69 Benoît Canet
                               bool has_iops_wr_max,
1629 2024c1df Benoît Canet
                               int64_t iops_wr_max,
1630 2024c1df Benoît Canet
                               bool has_iops_size,
1631 2024c1df Benoît Canet
                               int64_t iops_size, Error **errp)
1632 727f005e Zhi Yong Wu
{
1633 cc0681c4 Benoît Canet
    ThrottleConfig cfg;
1634 727f005e Zhi Yong Wu
    BlockDriverState *bs;
1635 727f005e Zhi Yong Wu
1636 80047da5 Luiz Capitulino
    bs = bdrv_find(device);
1637 727f005e Zhi Yong Wu
    if (!bs) {
1638 80047da5 Luiz Capitulino
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1639 80047da5 Luiz Capitulino
        return;
1640 727f005e Zhi Yong Wu
    }
1641 727f005e Zhi Yong Wu
1642 cc0681c4 Benoît Canet
    memset(&cfg, 0, sizeof(cfg));
1643 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_TOTAL].avg = bps;
1644 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_READ].avg  = bps_rd;
1645 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_BPS_WRITE].avg = bps_wr;
1646 cc0681c4 Benoît Canet
1647 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_TOTAL].avg = iops;
1648 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_READ].avg  = iops_rd;
1649 cc0681c4 Benoît Canet
    cfg.buckets[THROTTLE_OPS_WRITE].avg = iops_wr;
1650 cc0681c4 Benoît Canet
1651 3e9fab69 Benoît Canet
    if (has_bps_max) {
1652 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_BPS_TOTAL].max = bps_max;
1653 3e9fab69 Benoît Canet
    }
1654 3e9fab69 Benoît Canet
    if (has_bps_rd_max) {
1655 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_BPS_READ].max = bps_rd_max;
1656 3e9fab69 Benoît Canet
    }
1657 3e9fab69 Benoît Canet
    if (has_bps_wr_max) {
1658 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_BPS_WRITE].max = bps_wr_max;
1659 3e9fab69 Benoît Canet
    }
1660 3e9fab69 Benoît Canet
    if (has_iops_max) {
1661 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_OPS_TOTAL].max = iops_max;
1662 3e9fab69 Benoît Canet
    }
1663 3e9fab69 Benoît Canet
    if (has_iops_rd_max) {
1664 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_OPS_READ].max = iops_rd_max;
1665 3e9fab69 Benoît Canet
    }
1666 3e9fab69 Benoît Canet
    if (has_iops_wr_max) {
1667 3e9fab69 Benoît Canet
        cfg.buckets[THROTTLE_OPS_WRITE].max = iops_wr_max;
1668 3e9fab69 Benoît Canet
    }
1669 727f005e Zhi Yong Wu
1670 2024c1df Benoît Canet
    if (has_iops_size) {
1671 2024c1df Benoît Canet
        cfg.op_size = iops_size;
1672 2024c1df Benoît Canet
    }
1673 cc0681c4 Benoît Canet
1674 cc0681c4 Benoît Canet
    if (!check_throttle_config(&cfg, errp)) {
1675 80047da5 Luiz Capitulino
        return;
1676 727f005e Zhi Yong Wu
    }
1677 727f005e Zhi Yong Wu
1678 cc0681c4 Benoît Canet
    if (!bs->io_limits_enabled && throttle_enabled(&cfg)) {
1679 727f005e Zhi Yong Wu
        bdrv_io_limits_enable(bs);
1680 cc0681c4 Benoît Canet
    } else if (bs->io_limits_enabled && !throttle_enabled(&cfg)) {
1681 727f005e Zhi Yong Wu
        bdrv_io_limits_disable(bs);
1682 cc0681c4 Benoît Canet
    }
1683 cc0681c4 Benoît Canet
1684 cc0681c4 Benoît Canet
    if (bs->io_limits_enabled) {
1685 cc0681c4 Benoît Canet
        bdrv_set_io_limits(bs, &cfg);
1686 727f005e Zhi Yong Wu
    }
1687 727f005e Zhi Yong Wu
}
1688 727f005e Zhi Yong Wu
1689 9063f814 Ryan Harper
int do_drive_del(Monitor *mon, const QDict *qdict, QObject **ret_data)
1690 9063f814 Ryan Harper
{
1691 9063f814 Ryan Harper
    const char *id = qdict_get_str(qdict, "id");
1692 9063f814 Ryan Harper
    BlockDriverState *bs;
1693 9063f814 Ryan Harper
1694 9063f814 Ryan Harper
    bs = bdrv_find(id);
1695 9063f814 Ryan Harper
    if (!bs) {
1696 9063f814 Ryan Harper
        qerror_report(QERR_DEVICE_NOT_FOUND, id);
1697 9063f814 Ryan Harper
        return -1;
1698 9063f814 Ryan Harper
    }
1699 8591675f Marcelo Tosatti
    if (bdrv_in_use(bs)) {
1700 8591675f Marcelo Tosatti
        qerror_report(QERR_DEVICE_IN_USE, id);
1701 8591675f Marcelo Tosatti
        return -1;
1702 8591675f Marcelo Tosatti
    }
1703 9063f814 Ryan Harper
1704 9063f814 Ryan Harper
    /* quiesce block driver; prevent further io */
1705 922453bc Stefan Hajnoczi
    bdrv_drain_all();
1706 9063f814 Ryan Harper
    bdrv_flush(bs);
1707 9063f814 Ryan Harper
    bdrv_close(bs);
1708 9063f814 Ryan Harper
1709 fa879d62 Markus Armbruster
    /* if we have a device attached to this BlockDriverState
1710 d22b2f41 Ryan Harper
     * then we need to make the drive anonymous until the device
1711 d22b2f41 Ryan Harper
     * can be removed.  If this is a drive with no device backing
1712 d22b2f41 Ryan Harper
     * then we can just get rid of the block driver state right here.
1713 d22b2f41 Ryan Harper
     */
1714 fa879d62 Markus Armbruster
    if (bdrv_get_attached_dev(bs)) {
1715 d22b2f41 Ryan Harper
        bdrv_make_anon(bs);
1716 293c51a6 Stefan Hajnoczi
1717 293c51a6 Stefan Hajnoczi
        /* Further I/O must not pause the guest */
1718 293c51a6 Stefan Hajnoczi
        bdrv_set_on_error(bs, BLOCKDEV_ON_ERROR_REPORT,
1719 293c51a6 Stefan Hajnoczi
                          BLOCKDEV_ON_ERROR_REPORT);
1720 d22b2f41 Ryan Harper
    } else {
1721 d22b2f41 Ryan Harper
        drive_uninit(drive_get_by_blockdev(bs));
1722 9063f814 Ryan Harper
    }
1723 9063f814 Ryan Harper
1724 9063f814 Ryan Harper
    return 0;
1725 9063f814 Ryan Harper
}
1726 6d4a2b3a Christoph Hellwig
1727 3b1dbd11 Benoît Canet
void qmp_block_resize(bool has_device, const char *device,
1728 3b1dbd11 Benoît Canet
                      bool has_node_name, const char *node_name,
1729 3b1dbd11 Benoît Canet
                      int64_t size, Error **errp)
1730 6d4a2b3a Christoph Hellwig
{
1731 3b1dbd11 Benoît Canet
    Error *local_err = NULL;
1732 6d4a2b3a Christoph Hellwig
    BlockDriverState *bs;
1733 8732901e Kevin Wolf
    int ret;
1734 6d4a2b3a Christoph Hellwig
1735 3b1dbd11 Benoît Canet
    bs = bdrv_lookup_bs(has_device ? device : NULL,
1736 3b1dbd11 Benoît Canet
                        has_node_name ? node_name : NULL,
1737 3b1dbd11 Benoît Canet
                        &local_err);
1738 3b1dbd11 Benoît Canet
    if (error_is_set(&local_err)) {
1739 3b1dbd11 Benoît Canet
        error_propagate(errp, local_err);
1740 3b1dbd11 Benoît Canet
        return;
1741 3b1dbd11 Benoît Canet
    }
1742 3b1dbd11 Benoît Canet
1743 3b1dbd11 Benoît Canet
    if (!bdrv_is_first_non_filter(bs)) {
1744 3b1dbd11 Benoît Canet
        error_set(errp, QERR_FEATURE_DISABLED, "resize");
1745 5e7caacb Luiz Capitulino
        return;
1746 6d4a2b3a Christoph Hellwig
    }
1747 6d4a2b3a Christoph Hellwig
1748 6d4a2b3a Christoph Hellwig
    if (size < 0) {
1749 939a1cc3 Stefan Hajnoczi
        error_set(errp, QERR_INVALID_PARAMETER_VALUE, "size", "a >0 size");
1750 5e7caacb Luiz Capitulino
        return;
1751 6d4a2b3a Christoph Hellwig
    }
1752 6d4a2b3a Christoph Hellwig
1753 92b7a08d Peter Lieven
    /* complete all in-flight operations before resizing the device */
1754 92b7a08d Peter Lieven
    bdrv_drain_all();
1755 92b7a08d Peter Lieven
1756 8732901e Kevin Wolf
    ret = bdrv_truncate(bs, size);
1757 8732901e Kevin Wolf
    switch (ret) {
1758 939a1cc3 Stefan Hajnoczi
    case 0:
1759 939a1cc3 Stefan Hajnoczi
        break;
1760 939a1cc3 Stefan Hajnoczi
    case -ENOMEDIUM:
1761 939a1cc3 Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
1762 939a1cc3 Stefan Hajnoczi
        break;
1763 939a1cc3 Stefan Hajnoczi
    case -ENOTSUP:
1764 939a1cc3 Stefan Hajnoczi
        error_set(errp, QERR_UNSUPPORTED);
1765 939a1cc3 Stefan Hajnoczi
        break;
1766 939a1cc3 Stefan Hajnoczi
    case -EACCES:
1767 939a1cc3 Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_IS_READ_ONLY, device);
1768 939a1cc3 Stefan Hajnoczi
        break;
1769 939a1cc3 Stefan Hajnoczi
    case -EBUSY:
1770 939a1cc3 Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_IN_USE, device);
1771 939a1cc3 Stefan Hajnoczi
        break;
1772 939a1cc3 Stefan Hajnoczi
    default:
1773 8732901e Kevin Wolf
        error_setg_errno(errp, -ret, "Could not resize");
1774 939a1cc3 Stefan Hajnoczi
        break;
1775 6d4a2b3a Christoph Hellwig
    }
1776 6d4a2b3a Christoph Hellwig
}
1777 12bd451f Stefan Hajnoczi
1778 9abf2dba Jeff Cody
static void block_job_cb(void *opaque, int ret)
1779 12bd451f Stefan Hajnoczi
{
1780 12bd451f Stefan Hajnoczi
    BlockDriverState *bs = opaque;
1781 12bd451f Stefan Hajnoczi
    QObject *obj;
1782 12bd451f Stefan Hajnoczi
1783 9abf2dba Jeff Cody
    trace_block_job_cb(bs, bs->job, ret);
1784 12bd451f Stefan Hajnoczi
1785 12bd451f Stefan Hajnoczi
    assert(bs->job);
1786 12bd451f Stefan Hajnoczi
    obj = qobject_from_block_job(bs->job);
1787 12bd451f Stefan Hajnoczi
    if (ret < 0) {
1788 12bd451f Stefan Hajnoczi
        QDict *dict = qobject_to_qdict(obj);
1789 12bd451f Stefan Hajnoczi
        qdict_put(dict, "error", qstring_from_str(strerror(-ret)));
1790 12bd451f Stefan Hajnoczi
    }
1791 12bd451f Stefan Hajnoczi
1792 370521a1 Stefan Hajnoczi
    if (block_job_is_cancelled(bs->job)) {
1793 370521a1 Stefan Hajnoczi
        monitor_protocol_event(QEVENT_BLOCK_JOB_CANCELLED, obj);
1794 370521a1 Stefan Hajnoczi
    } else {
1795 370521a1 Stefan Hajnoczi
        monitor_protocol_event(QEVENT_BLOCK_JOB_COMPLETED, obj);
1796 370521a1 Stefan Hajnoczi
    }
1797 12bd451f Stefan Hajnoczi
    qobject_decref(obj);
1798 aa398a5c Stefan Hajnoczi
1799 fa510ebf Fam Zheng
    bdrv_put_ref_bh_schedule(bs);
1800 12bd451f Stefan Hajnoczi
}
1801 12bd451f Stefan Hajnoczi
1802 12bd451f Stefan Hajnoczi
void qmp_block_stream(const char *device, bool has_base,
1803 1d809098 Paolo Bonzini
                      const char *base, bool has_speed, int64_t speed,
1804 1d809098 Paolo Bonzini
                      bool has_on_error, BlockdevOnError on_error,
1805 1d809098 Paolo Bonzini
                      Error **errp)
1806 12bd451f Stefan Hajnoczi
{
1807 12bd451f Stefan Hajnoczi
    BlockDriverState *bs;
1808 c8c3080f Marcelo Tosatti
    BlockDriverState *base_bs = NULL;
1809 fd7f8c65 Stefan Hajnoczi
    Error *local_err = NULL;
1810 12bd451f Stefan Hajnoczi
1811 1d809098 Paolo Bonzini
    if (!has_on_error) {
1812 1d809098 Paolo Bonzini
        on_error = BLOCKDEV_ON_ERROR_REPORT;
1813 1d809098 Paolo Bonzini
    }
1814 1d809098 Paolo Bonzini
1815 12bd451f Stefan Hajnoczi
    bs = bdrv_find(device);
1816 12bd451f Stefan Hajnoczi
    if (!bs) {
1817 12bd451f Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1818 12bd451f Stefan Hajnoczi
        return;
1819 12bd451f Stefan Hajnoczi
    }
1820 12bd451f Stefan Hajnoczi
1821 12bd451f Stefan Hajnoczi
    if (base) {
1822 c8c3080f Marcelo Tosatti
        base_bs = bdrv_find_backing_image(bs, base);
1823 c8c3080f Marcelo Tosatti
        if (base_bs == NULL) {
1824 c8c3080f Marcelo Tosatti
            error_set(errp, QERR_BASE_NOT_FOUND, base);
1825 c8c3080f Marcelo Tosatti
            return;
1826 c8c3080f Marcelo Tosatti
        }
1827 12bd451f Stefan Hajnoczi
    }
1828 12bd451f Stefan Hajnoczi
1829 c83c66c3 Stefan Hajnoczi
    stream_start(bs, base_bs, base, has_speed ? speed : 0,
1830 1d809098 Paolo Bonzini
                 on_error, block_job_cb, bs, &local_err);
1831 fd7f8c65 Stefan Hajnoczi
    if (error_is_set(&local_err)) {
1832 fd7f8c65 Stefan Hajnoczi
        error_propagate(errp, local_err);
1833 fd7f8c65 Stefan Hajnoczi
        return;
1834 12bd451f Stefan Hajnoczi
    }
1835 12bd451f Stefan Hajnoczi
1836 12bd451f Stefan Hajnoczi
    trace_qmp_block_stream(bs, bs->job);
1837 12bd451f Stefan Hajnoczi
}
1838 2d47c6e9 Stefan Hajnoczi
1839 ed61fc10 Jeff Cody
void qmp_block_commit(const char *device,
1840 ed61fc10 Jeff Cody
                      bool has_base, const char *base, const char *top,
1841 ed61fc10 Jeff Cody
                      bool has_speed, int64_t speed,
1842 ed61fc10 Jeff Cody
                      Error **errp)
1843 ed61fc10 Jeff Cody
{
1844 ed61fc10 Jeff Cody
    BlockDriverState *bs;
1845 ed61fc10 Jeff Cody
    BlockDriverState *base_bs, *top_bs;
1846 ed61fc10 Jeff Cody
    Error *local_err = NULL;
1847 ed61fc10 Jeff Cody
    /* This will be part of the QMP command, if/when the
1848 ed61fc10 Jeff Cody
     * BlockdevOnError change for blkmirror makes it in
1849 ed61fc10 Jeff Cody
     */
1850 92aa5c6d Paolo Bonzini
    BlockdevOnError on_error = BLOCKDEV_ON_ERROR_REPORT;
1851 ed61fc10 Jeff Cody
1852 ed61fc10 Jeff Cody
    /* drain all i/o before commits */
1853 ed61fc10 Jeff Cody
    bdrv_drain_all();
1854 ed61fc10 Jeff Cody
1855 ed61fc10 Jeff Cody
    bs = bdrv_find(device);
1856 ed61fc10 Jeff Cody
    if (!bs) {
1857 ed61fc10 Jeff Cody
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1858 ed61fc10 Jeff Cody
        return;
1859 ed61fc10 Jeff Cody
    }
1860 ed61fc10 Jeff Cody
1861 ed61fc10 Jeff Cody
    /* default top_bs is the active layer */
1862 ed61fc10 Jeff Cody
    top_bs = bs;
1863 ed61fc10 Jeff Cody
1864 ed61fc10 Jeff Cody
    if (top) {
1865 ed61fc10 Jeff Cody
        if (strcmp(bs->filename, top) != 0) {
1866 ed61fc10 Jeff Cody
            top_bs = bdrv_find_backing_image(bs, top);
1867 ed61fc10 Jeff Cody
        }
1868 ed61fc10 Jeff Cody
    }
1869 ed61fc10 Jeff Cody
1870 ed61fc10 Jeff Cody
    if (top_bs == NULL) {
1871 ed61fc10 Jeff Cody
        error_setg(errp, "Top image file %s not found", top ? top : "NULL");
1872 ed61fc10 Jeff Cody
        return;
1873 ed61fc10 Jeff Cody
    }
1874 ed61fc10 Jeff Cody
1875 d5208c45 Jeff Cody
    if (has_base && base) {
1876 d5208c45 Jeff Cody
        base_bs = bdrv_find_backing_image(top_bs, base);
1877 d5208c45 Jeff Cody
    } else {
1878 d5208c45 Jeff Cody
        base_bs = bdrv_find_base(top_bs);
1879 d5208c45 Jeff Cody
    }
1880 d5208c45 Jeff Cody
1881 d5208c45 Jeff Cody
    if (base_bs == NULL) {
1882 d5208c45 Jeff Cody
        error_set(errp, QERR_BASE_NOT_FOUND, base ? base : "NULL");
1883 d5208c45 Jeff Cody
        return;
1884 d5208c45 Jeff Cody
    }
1885 d5208c45 Jeff Cody
1886 20a63d2c Fam Zheng
    if (top_bs == bs) {
1887 20a63d2c Fam Zheng
        commit_active_start(bs, base_bs, speed, on_error, block_job_cb,
1888 20a63d2c Fam Zheng
                            bs, &local_err);
1889 20a63d2c Fam Zheng
    } else {
1890 20a63d2c Fam Zheng
        commit_start(bs, base_bs, top_bs, speed, on_error, block_job_cb, bs,
1891 20a63d2c Fam Zheng
                    &local_err);
1892 20a63d2c Fam Zheng
    }
1893 ed61fc10 Jeff Cody
    if (local_err != NULL) {
1894 ed61fc10 Jeff Cody
        error_propagate(errp, local_err);
1895 ed61fc10 Jeff Cody
        return;
1896 ed61fc10 Jeff Cody
    }
1897 ed61fc10 Jeff Cody
}
1898 ed61fc10 Jeff Cody
1899 99a9addf Stefan Hajnoczi
void qmp_drive_backup(const char *device, const char *target,
1900 99a9addf Stefan Hajnoczi
                      bool has_format, const char *format,
1901 b53169ea Stefan Hajnoczi
                      enum MirrorSyncMode sync,
1902 99a9addf Stefan Hajnoczi
                      bool has_mode, enum NewImageMode mode,
1903 99a9addf Stefan Hajnoczi
                      bool has_speed, int64_t speed,
1904 99a9addf Stefan Hajnoczi
                      bool has_on_source_error, BlockdevOnError on_source_error,
1905 99a9addf Stefan Hajnoczi
                      bool has_on_target_error, BlockdevOnError on_target_error,
1906 99a9addf Stefan Hajnoczi
                      Error **errp)
1907 99a9addf Stefan Hajnoczi
{
1908 99a9addf Stefan Hajnoczi
    BlockDriverState *bs;
1909 99a9addf Stefan Hajnoczi
    BlockDriverState *target_bs;
1910 fc5d3f84 Ian Main
    BlockDriverState *source = NULL;
1911 99a9addf Stefan Hajnoczi
    BlockDriver *drv = NULL;
1912 99a9addf Stefan Hajnoczi
    Error *local_err = NULL;
1913 99a9addf Stefan Hajnoczi
    int flags;
1914 99a9addf Stefan Hajnoczi
    int64_t size;
1915 99a9addf Stefan Hajnoczi
    int ret;
1916 99a9addf Stefan Hajnoczi
1917 99a9addf Stefan Hajnoczi
    if (!has_speed) {
1918 99a9addf Stefan Hajnoczi
        speed = 0;
1919 99a9addf Stefan Hajnoczi
    }
1920 99a9addf Stefan Hajnoczi
    if (!has_on_source_error) {
1921 99a9addf Stefan Hajnoczi
        on_source_error = BLOCKDEV_ON_ERROR_REPORT;
1922 99a9addf Stefan Hajnoczi
    }
1923 99a9addf Stefan Hajnoczi
    if (!has_on_target_error) {
1924 99a9addf Stefan Hajnoczi
        on_target_error = BLOCKDEV_ON_ERROR_REPORT;
1925 99a9addf Stefan Hajnoczi
    }
1926 99a9addf Stefan Hajnoczi
    if (!has_mode) {
1927 99a9addf Stefan Hajnoczi
        mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
1928 99a9addf Stefan Hajnoczi
    }
1929 99a9addf Stefan Hajnoczi
1930 99a9addf Stefan Hajnoczi
    bs = bdrv_find(device);
1931 99a9addf Stefan Hajnoczi
    if (!bs) {
1932 99a9addf Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
1933 99a9addf Stefan Hajnoczi
        return;
1934 99a9addf Stefan Hajnoczi
    }
1935 99a9addf Stefan Hajnoczi
1936 99a9addf Stefan Hajnoczi
    if (!bdrv_is_inserted(bs)) {
1937 99a9addf Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
1938 99a9addf Stefan Hajnoczi
        return;
1939 99a9addf Stefan Hajnoczi
    }
1940 99a9addf Stefan Hajnoczi
1941 99a9addf Stefan Hajnoczi
    if (!has_format) {
1942 99a9addf Stefan Hajnoczi
        format = mode == NEW_IMAGE_MODE_EXISTING ? NULL : bs->drv->format_name;
1943 99a9addf Stefan Hajnoczi
    }
1944 99a9addf Stefan Hajnoczi
    if (format) {
1945 99a9addf Stefan Hajnoczi
        drv = bdrv_find_format(format);
1946 99a9addf Stefan Hajnoczi
        if (!drv) {
1947 99a9addf Stefan Hajnoczi
            error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
1948 99a9addf Stefan Hajnoczi
            return;
1949 99a9addf Stefan Hajnoczi
        }
1950 99a9addf Stefan Hajnoczi
    }
1951 99a9addf Stefan Hajnoczi
1952 99a9addf Stefan Hajnoczi
    if (bdrv_in_use(bs)) {
1953 99a9addf Stefan Hajnoczi
        error_set(errp, QERR_DEVICE_IN_USE, device);
1954 99a9addf Stefan Hajnoczi
        return;
1955 99a9addf Stefan Hajnoczi
    }
1956 99a9addf Stefan Hajnoczi
1957 99a9addf Stefan Hajnoczi
    flags = bs->open_flags | BDRV_O_RDWR;
1958 99a9addf Stefan Hajnoczi
1959 fc5d3f84 Ian Main
    /* See if we have a backing HD we can use to create our new image
1960 fc5d3f84 Ian Main
     * on top of. */
1961 fc5d3f84 Ian Main
    if (sync == MIRROR_SYNC_MODE_TOP) {
1962 fc5d3f84 Ian Main
        source = bs->backing_hd;
1963 fc5d3f84 Ian Main
        if (!source) {
1964 fc5d3f84 Ian Main
            sync = MIRROR_SYNC_MODE_FULL;
1965 fc5d3f84 Ian Main
        }
1966 fc5d3f84 Ian Main
    }
1967 fc5d3f84 Ian Main
    if (sync == MIRROR_SYNC_MODE_NONE) {
1968 fc5d3f84 Ian Main
        source = bs;
1969 fc5d3f84 Ian Main
    }
1970 fc5d3f84 Ian Main
1971 99a9addf Stefan Hajnoczi
    size = bdrv_getlength(bs);
1972 99a9addf Stefan Hajnoczi
    if (size < 0) {
1973 99a9addf Stefan Hajnoczi
        error_setg_errno(errp, -size, "bdrv_getlength failed");
1974 99a9addf Stefan Hajnoczi
        return;
1975 99a9addf Stefan Hajnoczi
    }
1976 99a9addf Stefan Hajnoczi
1977 99a9addf Stefan Hajnoczi
    if (mode != NEW_IMAGE_MODE_EXISTING) {
1978 99a9addf Stefan Hajnoczi
        assert(format && drv);
1979 fc5d3f84 Ian Main
        if (source) {
1980 fc5d3f84 Ian Main
            bdrv_img_create(target, format, source->filename,
1981 fc5d3f84 Ian Main
                            source->drv->format_name, NULL,
1982 fc5d3f84 Ian Main
                            size, flags, &local_err, false);
1983 fc5d3f84 Ian Main
        } else {
1984 fc5d3f84 Ian Main
            bdrv_img_create(target, format, NULL, NULL, NULL,
1985 fc5d3f84 Ian Main
                            size, flags, &local_err, false);
1986 fc5d3f84 Ian Main
        }
1987 99a9addf Stefan Hajnoczi
    }
1988 99a9addf Stefan Hajnoczi
1989 99a9addf Stefan Hajnoczi
    if (error_is_set(&local_err)) {
1990 99a9addf Stefan Hajnoczi
        error_propagate(errp, local_err);
1991 99a9addf Stefan Hajnoczi
        return;
1992 99a9addf Stefan Hajnoczi
    }
1993 99a9addf Stefan Hajnoczi
1994 99a9addf Stefan Hajnoczi
    target_bs = bdrv_new("");
1995 34b5d2c6 Max Reitz
    ret = bdrv_open(target_bs, target, NULL, flags, drv, &local_err);
1996 99a9addf Stefan Hajnoczi
    if (ret < 0) {
1997 4f6fd349 Fam Zheng
        bdrv_unref(target_bs);
1998 34b5d2c6 Max Reitz
        error_propagate(errp, local_err);
1999 99a9addf Stefan Hajnoczi
        return;
2000 99a9addf Stefan Hajnoczi
    }
2001 99a9addf Stefan Hajnoczi
2002 fc5d3f84 Ian Main
    backup_start(bs, target_bs, speed, sync, on_source_error, on_target_error,
2003 99a9addf Stefan Hajnoczi
                 block_job_cb, bs, &local_err);
2004 99a9addf Stefan Hajnoczi
    if (local_err != NULL) {
2005 4f6fd349 Fam Zheng
        bdrv_unref(target_bs);
2006 99a9addf Stefan Hajnoczi
        error_propagate(errp, local_err);
2007 99a9addf Stefan Hajnoczi
        return;
2008 99a9addf Stefan Hajnoczi
    }
2009 99a9addf Stefan Hajnoczi
}
2010 99a9addf Stefan Hajnoczi
2011 c13163fb Benoît Canet
BlockDeviceInfoList *qmp_query_named_block_nodes(Error **errp)
2012 c13163fb Benoît Canet
{
2013 c13163fb Benoît Canet
    return bdrv_named_nodes_list();
2014 c13163fb Benoît Canet
}
2015 c13163fb Benoît Canet
2016 08e4ed6c Paolo Bonzini
#define DEFAULT_MIRROR_BUF_SIZE   (10 << 20)
2017 08e4ed6c Paolo Bonzini
2018 d9b902db Paolo Bonzini
void qmp_drive_mirror(const char *device, const char *target,
2019 d9b902db Paolo Bonzini
                      bool has_format, const char *format,
2020 d9b902db Paolo Bonzini
                      enum MirrorSyncMode sync,
2021 d9b902db Paolo Bonzini
                      bool has_mode, enum NewImageMode mode,
2022 b952b558 Paolo Bonzini
                      bool has_speed, int64_t speed,
2023 eee13dfe Paolo Bonzini
                      bool has_granularity, uint32_t granularity,
2024 08e4ed6c Paolo Bonzini
                      bool has_buf_size, int64_t buf_size,
2025 b952b558 Paolo Bonzini
                      bool has_on_source_error, BlockdevOnError on_source_error,
2026 b952b558 Paolo Bonzini
                      bool has_on_target_error, BlockdevOnError on_target_error,
2027 b952b558 Paolo Bonzini
                      Error **errp)
2028 d9b902db Paolo Bonzini
{
2029 d9b902db Paolo Bonzini
    BlockDriverState *bs;
2030 d9b902db Paolo Bonzini
    BlockDriverState *source, *target_bs;
2031 d9b902db Paolo Bonzini
    BlockDriver *drv = NULL;
2032 d9b902db Paolo Bonzini
    Error *local_err = NULL;
2033 d9b902db Paolo Bonzini
    int flags;
2034 ac3c5d83 Stefan Hajnoczi
    int64_t size;
2035 d9b902db Paolo Bonzini
    int ret;
2036 d9b902db Paolo Bonzini
2037 d9b902db Paolo Bonzini
    if (!has_speed) {
2038 d9b902db Paolo Bonzini
        speed = 0;
2039 d9b902db Paolo Bonzini
    }
2040 b952b558 Paolo Bonzini
    if (!has_on_source_error) {
2041 b952b558 Paolo Bonzini
        on_source_error = BLOCKDEV_ON_ERROR_REPORT;
2042 b952b558 Paolo Bonzini
    }
2043 b952b558 Paolo Bonzini
    if (!has_on_target_error) {
2044 b952b558 Paolo Bonzini
        on_target_error = BLOCKDEV_ON_ERROR_REPORT;
2045 b952b558 Paolo Bonzini
    }
2046 d9b902db Paolo Bonzini
    if (!has_mode) {
2047 d9b902db Paolo Bonzini
        mode = NEW_IMAGE_MODE_ABSOLUTE_PATHS;
2048 d9b902db Paolo Bonzini
    }
2049 eee13dfe Paolo Bonzini
    if (!has_granularity) {
2050 eee13dfe Paolo Bonzini
        granularity = 0;
2051 eee13dfe Paolo Bonzini
    }
2052 08e4ed6c Paolo Bonzini
    if (!has_buf_size) {
2053 08e4ed6c Paolo Bonzini
        buf_size = DEFAULT_MIRROR_BUF_SIZE;
2054 08e4ed6c Paolo Bonzini
    }
2055 08e4ed6c Paolo Bonzini
2056 eee13dfe Paolo Bonzini
    if (granularity != 0 && (granularity < 512 || granularity > 1048576 * 64)) {
2057 eee13dfe Paolo Bonzini
        error_set(errp, QERR_INVALID_PARAMETER, device);
2058 eee13dfe Paolo Bonzini
        return;
2059 eee13dfe Paolo Bonzini
    }
2060 eee13dfe Paolo Bonzini
    if (granularity & (granularity - 1)) {
2061 eee13dfe Paolo Bonzini
        error_set(errp, QERR_INVALID_PARAMETER, device);
2062 eee13dfe Paolo Bonzini
        return;
2063 eee13dfe Paolo Bonzini
    }
2064 d9b902db Paolo Bonzini
2065 d9b902db Paolo Bonzini
    bs = bdrv_find(device);
2066 d9b902db Paolo Bonzini
    if (!bs) {
2067 d9b902db Paolo Bonzini
        error_set(errp, QERR_DEVICE_NOT_FOUND, device);
2068 d9b902db Paolo Bonzini
        return;
2069 d9b902db Paolo Bonzini
    }
2070 d9b902db Paolo Bonzini
2071 d9b902db Paolo Bonzini
    if (!bdrv_is_inserted(bs)) {
2072 d9b902db Paolo Bonzini
        error_set(errp, QERR_DEVICE_HAS_NO_MEDIUM, device);
2073 d9b902db Paolo Bonzini
        return;
2074 d9b902db Paolo Bonzini
    }
2075 d9b902db Paolo Bonzini
2076 d9b902db Paolo Bonzini
    if (!has_format) {
2077 d9b902db Paolo Bonzini
        format = mode == NEW_IMAGE_MODE_EXISTING ? NULL : bs->drv->format_name;
2078 d9b902db Paolo Bonzini
    }
2079 d9b902db Paolo Bonzini
    if (format) {
2080 d9b902db Paolo Bonzini
        drv = bdrv_find_format(format);
2081 d9b902db Paolo Bonzini
        if (!drv) {
2082 d9b902db Paolo Bonzini
            error_set(errp, QERR_INVALID_BLOCK_FORMAT, format);
2083 d9b902db Paolo Bonzini
            return;
2084 d9b902db Paolo Bonzini
        }
2085 d9b902db Paolo Bonzini
    }
2086 d9b902db Paolo Bonzini
2087 d9b902db Paolo Bonzini
    if (bdrv_in_use(bs)) {
2088 d9b902db Paolo Bonzini
        error_set(errp, QERR_DEVICE_IN_USE, device);
2089 d9b902db Paolo Bonzini
        return;
2090 d9b902db Paolo Bonzini
    }
2091 d9b902db Paolo Bonzini
2092 d9b902db Paolo Bonzini
    flags = bs->open_flags | BDRV_O_RDWR;
2093 d9b902db Paolo Bonzini
    source = bs->backing_hd;
2094 d9b902db Paolo Bonzini
    if (!source && sync == MIRROR_SYNC_MODE_TOP) {
2095 d9b902db Paolo Bonzini
        sync = MIRROR_SYNC_MODE_FULL;
2096 d9b902db Paolo Bonzini
    }
2097 117e0c82 Max Reitz
    if (sync == MIRROR_SYNC_MODE_NONE) {
2098 117e0c82 Max Reitz
        source = bs;
2099 117e0c82 Max Reitz
    }
2100 d9b902db Paolo Bonzini
2101 ac3c5d83 Stefan Hajnoczi
    size = bdrv_getlength(bs);
2102 ac3c5d83 Stefan Hajnoczi
    if (size < 0) {
2103 ac3c5d83 Stefan Hajnoczi
        error_setg_errno(errp, -size, "bdrv_getlength failed");
2104 ac3c5d83 Stefan Hajnoczi
        return;
2105 ac3c5d83 Stefan Hajnoczi
    }
2106 ac3c5d83 Stefan Hajnoczi
2107 14526864 Max Reitz
    if ((sync == MIRROR_SYNC_MODE_FULL || !source)
2108 14526864 Max Reitz
        && mode != NEW_IMAGE_MODE_EXISTING)
2109 14526864 Max Reitz
    {
2110 d9b902db Paolo Bonzini
        /* create new image w/o backing file */
2111 d9b902db Paolo Bonzini
        assert(format && drv);
2112 cf8f2426 Luiz Capitulino
        bdrv_img_create(target, format,
2113 f382d43a Miroslav Rezanina
                        NULL, NULL, NULL, size, flags, &local_err, false);
2114 d9b902db Paolo Bonzini
    } else {
2115 d9b902db Paolo Bonzini
        switch (mode) {
2116 d9b902db Paolo Bonzini
        case NEW_IMAGE_MODE_EXISTING:
2117 d9b902db Paolo Bonzini
            break;
2118 d9b902db Paolo Bonzini
        case NEW_IMAGE_MODE_ABSOLUTE_PATHS:
2119 d9b902db Paolo Bonzini
            /* create new image with backing file */
2120 cf8f2426 Luiz Capitulino
            bdrv_img_create(target, format,
2121 cf8f2426 Luiz Capitulino
                            source->filename,
2122 cf8f2426 Luiz Capitulino
                            source->drv->format_name,
2123 f382d43a Miroslav Rezanina
                            NULL, size, flags, &local_err, false);
2124 d9b902db Paolo Bonzini
            break;
2125 d9b902db Paolo Bonzini
        default:
2126 d9b902db Paolo Bonzini
            abort();
2127 d9b902db Paolo Bonzini
        }
2128 d9b902db Paolo Bonzini
    }
2129 d9b902db Paolo Bonzini
2130 cf8f2426 Luiz Capitulino
    if (error_is_set(&local_err)) {
2131 cf8f2426 Luiz Capitulino
        error_propagate(errp, local_err);
2132 d9b902db Paolo Bonzini
        return;
2133 d9b902db Paolo Bonzini
    }
2134 d9b902db Paolo Bonzini
2135 b812f671 Paolo Bonzini
    /* Mirroring takes care of copy-on-write using the source's backing
2136 b812f671 Paolo Bonzini
     * file.
2137 b812f671 Paolo Bonzini
     */
2138 d9b902db Paolo Bonzini
    target_bs = bdrv_new("");
2139 34b5d2c6 Max Reitz
    ret = bdrv_open(target_bs, target, NULL, flags | BDRV_O_NO_BACKING, drv,
2140 34b5d2c6 Max Reitz
                    &local_err);
2141 d9b902db Paolo Bonzini
    if (ret < 0) {
2142 4f6fd349 Fam Zheng
        bdrv_unref(target_bs);
2143 34b5d2c6 Max Reitz
        error_propagate(errp, local_err);
2144 d9b902db Paolo Bonzini
        return;
2145 d9b902db Paolo Bonzini
    }
2146 d9b902db Paolo Bonzini
2147 08e4ed6c Paolo Bonzini
    mirror_start(bs, target_bs, speed, granularity, buf_size, sync,
2148 eee13dfe Paolo Bonzini
                 on_source_error, on_target_error,
2149 b952b558 Paolo Bonzini
                 block_job_cb, bs, &local_err);
2150 d9b902db Paolo Bonzini
    if (local_err != NULL) {
2151 4f6fd349 Fam Zheng
        bdrv_unref(target_bs);
2152 d9b902db Paolo Bonzini
        error_propagate(errp, local_err);
2153 d9b902db Paolo Bonzini
        return;
2154 d9b902db Paolo Bonzini
    }
2155 d9b902db Paolo Bonzini
}
2156 d9b902db Paolo Bonzini
2157 2d47c6e9 Stefan Hajnoczi
static BlockJob *find_block_job(const char *device)
2158 2d47c6e9 Stefan Hajnoczi
{
2159 2d47c6e9 Stefan Hajnoczi
    BlockDriverState *bs;
2160 2d47c6e9 Stefan Hajnoczi
2161 2d47c6e9 Stefan Hajnoczi
    bs = bdrv_find(device);
2162 2d47c6e9 Stefan Hajnoczi
    if (!bs || !bs->job) {
2163 2d47c6e9 Stefan Hajnoczi
        return NULL;
2164 2d47c6e9 Stefan Hajnoczi
    }
2165 2d47c6e9 Stefan Hajnoczi
    return bs->job;
2166 2d47c6e9 Stefan Hajnoczi
}
2167 2d47c6e9 Stefan Hajnoczi
2168 882ec7ce Stefan Hajnoczi
void qmp_block_job_set_speed(const char *device, int64_t speed, Error **errp)
2169 2d47c6e9 Stefan Hajnoczi
{
2170 2d47c6e9 Stefan Hajnoczi
    BlockJob *job = find_block_job(device);
2171 2d47c6e9 Stefan Hajnoczi
2172 2d47c6e9 Stefan Hajnoczi
    if (!job) {
2173 7ef15070 Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device);
2174 2d47c6e9 Stefan Hajnoczi
        return;
2175 2d47c6e9 Stefan Hajnoczi
    }
2176 2d47c6e9 Stefan Hajnoczi
2177 882ec7ce Stefan Hajnoczi
    block_job_set_speed(job, speed, errp);
2178 2d47c6e9 Stefan Hajnoczi
}
2179 370521a1 Stefan Hajnoczi
2180 6e37fb81 Paolo Bonzini
void qmp_block_job_cancel(const char *device,
2181 6e37fb81 Paolo Bonzini
                          bool has_force, bool force, Error **errp)
2182 370521a1 Stefan Hajnoczi
{
2183 370521a1 Stefan Hajnoczi
    BlockJob *job = find_block_job(device);
2184 370521a1 Stefan Hajnoczi
2185 6e37fb81 Paolo Bonzini
    if (!has_force) {
2186 6e37fb81 Paolo Bonzini
        force = false;
2187 6e37fb81 Paolo Bonzini
    }
2188 6e37fb81 Paolo Bonzini
2189 370521a1 Stefan Hajnoczi
    if (!job) {
2190 7ef15070 Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device);
2191 370521a1 Stefan Hajnoczi
        return;
2192 370521a1 Stefan Hajnoczi
    }
2193 6e37fb81 Paolo Bonzini
    if (job->paused && !force) {
2194 8acc72a4 Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_PAUSED, device);
2195 8acc72a4 Paolo Bonzini
        return;
2196 8acc72a4 Paolo Bonzini
    }
2197 370521a1 Stefan Hajnoczi
2198 370521a1 Stefan Hajnoczi
    trace_qmp_block_job_cancel(job);
2199 370521a1 Stefan Hajnoczi
    block_job_cancel(job);
2200 370521a1 Stefan Hajnoczi
}
2201 fb5458cd Stefan Hajnoczi
2202 6e37fb81 Paolo Bonzini
void qmp_block_job_pause(const char *device, Error **errp)
2203 6e37fb81 Paolo Bonzini
{
2204 6e37fb81 Paolo Bonzini
    BlockJob *job = find_block_job(device);
2205 6e37fb81 Paolo Bonzini
2206 6e37fb81 Paolo Bonzini
    if (!job) {
2207 6e37fb81 Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device);
2208 6e37fb81 Paolo Bonzini
        return;
2209 6e37fb81 Paolo Bonzini
    }
2210 6e37fb81 Paolo Bonzini
2211 6e37fb81 Paolo Bonzini
    trace_qmp_block_job_pause(job);
2212 6e37fb81 Paolo Bonzini
    block_job_pause(job);
2213 6e37fb81 Paolo Bonzini
}
2214 6e37fb81 Paolo Bonzini
2215 6e37fb81 Paolo Bonzini
void qmp_block_job_resume(const char *device, Error **errp)
2216 6e37fb81 Paolo Bonzini
{
2217 6e37fb81 Paolo Bonzini
    BlockJob *job = find_block_job(device);
2218 6e37fb81 Paolo Bonzini
2219 6e37fb81 Paolo Bonzini
    if (!job) {
2220 6e37fb81 Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device);
2221 6e37fb81 Paolo Bonzini
        return;
2222 6e37fb81 Paolo Bonzini
    }
2223 6e37fb81 Paolo Bonzini
2224 6e37fb81 Paolo Bonzini
    trace_qmp_block_job_resume(job);
2225 6e37fb81 Paolo Bonzini
    block_job_resume(job);
2226 6e37fb81 Paolo Bonzini
}
2227 6e37fb81 Paolo Bonzini
2228 aeae883b Paolo Bonzini
void qmp_block_job_complete(const char *device, Error **errp)
2229 aeae883b Paolo Bonzini
{
2230 aeae883b Paolo Bonzini
    BlockJob *job = find_block_job(device);
2231 aeae883b Paolo Bonzini
2232 aeae883b Paolo Bonzini
    if (!job) {
2233 aeae883b Paolo Bonzini
        error_set(errp, QERR_BLOCK_JOB_NOT_ACTIVE, device);
2234 aeae883b Paolo Bonzini
        return;
2235 aeae883b Paolo Bonzini
    }
2236 aeae883b Paolo Bonzini
2237 aeae883b Paolo Bonzini
    trace_qmp_block_job_complete(job);
2238 aeae883b Paolo Bonzini
    block_job_complete(job, errp);
2239 aeae883b Paolo Bonzini
}
2240 aeae883b Paolo Bonzini
2241 d26c9a15 Kevin Wolf
void qmp_blockdev_add(BlockdevOptions *options, Error **errp)
2242 d26c9a15 Kevin Wolf
{
2243 d26c9a15 Kevin Wolf
    QmpOutputVisitor *ov = qmp_output_visitor_new();
2244 d26c9a15 Kevin Wolf
    QObject *obj;
2245 d26c9a15 Kevin Wolf
    QDict *qdict;
2246 d26c9a15 Kevin Wolf
    Error *local_err = NULL;
2247 d26c9a15 Kevin Wolf
2248 d26c9a15 Kevin Wolf
    /* Require an ID in the top level */
2249 d26c9a15 Kevin Wolf
    if (!options->has_id) {
2250 d26c9a15 Kevin Wolf
        error_setg(errp, "Block device needs an ID");
2251 d26c9a15 Kevin Wolf
        goto fail;
2252 d26c9a15 Kevin Wolf
    }
2253 d26c9a15 Kevin Wolf
2254 d26c9a15 Kevin Wolf
    /* TODO Sort it out in raw-posix and drive_init: Reject aio=native with
2255 d26c9a15 Kevin Wolf
     * cache.direct=false instead of silently switching to aio=threads, except
2256 d26c9a15 Kevin Wolf
     * if called from drive_init.
2257 d26c9a15 Kevin Wolf
     *
2258 d26c9a15 Kevin Wolf
     * For now, simply forbidding the combination for all drivers will do. */
2259 d26c9a15 Kevin Wolf
    if (options->has_aio && options->aio == BLOCKDEV_AIO_OPTIONS_NATIVE) {
2260 d26c9a15 Kevin Wolf
        bool direct = options->cache->has_direct && options->cache->direct;
2261 d26c9a15 Kevin Wolf
        if (!options->has_cache && !direct) {
2262 d26c9a15 Kevin Wolf
            error_setg(errp, "aio=native requires cache.direct=true");
2263 d26c9a15 Kevin Wolf
            goto fail;
2264 d26c9a15 Kevin Wolf
        }
2265 d26c9a15 Kevin Wolf
    }
2266 d26c9a15 Kevin Wolf
2267 d26c9a15 Kevin Wolf
    visit_type_BlockdevOptions(qmp_output_get_visitor(ov),
2268 d26c9a15 Kevin Wolf
                               &options, NULL, &local_err);
2269 d26c9a15 Kevin Wolf
    if (error_is_set(&local_err)) {
2270 d26c9a15 Kevin Wolf
        error_propagate(errp, local_err);
2271 d26c9a15 Kevin Wolf
        goto fail;
2272 d26c9a15 Kevin Wolf
    }
2273 d26c9a15 Kevin Wolf
2274 d26c9a15 Kevin Wolf
    obj = qmp_output_get_qobject(ov);
2275 d26c9a15 Kevin Wolf
    qdict = qobject_to_qdict(obj);
2276 d26c9a15 Kevin Wolf
2277 d26c9a15 Kevin Wolf
    qdict_flatten(qdict);
2278 d26c9a15 Kevin Wolf
2279 d095b465 Max Reitz
    blockdev_init(NULL, qdict, IF_NONE, &local_err);
2280 b681072d Kevin Wolf
    if (error_is_set(&local_err)) {
2281 b681072d Kevin Wolf
        error_propagate(errp, local_err);
2282 d26c9a15 Kevin Wolf
        goto fail;
2283 d26c9a15 Kevin Wolf
    }
2284 d26c9a15 Kevin Wolf
2285 d26c9a15 Kevin Wolf
fail:
2286 d26c9a15 Kevin Wolf
    qmp_output_visitor_cleanup(ov);
2287 d26c9a15 Kevin Wolf
}
2288 d26c9a15 Kevin Wolf
2289 fb5458cd Stefan Hajnoczi
static void do_qmp_query_block_jobs_one(void *opaque, BlockDriverState *bs)
2290 fb5458cd Stefan Hajnoczi
{
2291 fb5458cd Stefan Hajnoczi
    BlockJobInfoList **prev = opaque;
2292 fb5458cd Stefan Hajnoczi
    BlockJob *job = bs->job;
2293 fb5458cd Stefan Hajnoczi
2294 fb5458cd Stefan Hajnoczi
    if (job) {
2295 30e628b7 Paolo Bonzini
        BlockJobInfoList *elem = g_new0(BlockJobInfoList, 1);
2296 30e628b7 Paolo Bonzini
        elem->value = block_job_query(bs->job);
2297 fb5458cd Stefan Hajnoczi
        (*prev)->next = elem;
2298 fb5458cd Stefan Hajnoczi
        *prev = elem;
2299 fb5458cd Stefan Hajnoczi
    }
2300 fb5458cd Stefan Hajnoczi
}
2301 fb5458cd Stefan Hajnoczi
2302 fb5458cd Stefan Hajnoczi
BlockJobInfoList *qmp_query_block_jobs(Error **errp)
2303 fb5458cd Stefan Hajnoczi
{
2304 fb5458cd Stefan Hajnoczi
    /* Dummy is a fake list element for holding the head pointer */
2305 fb5458cd Stefan Hajnoczi
    BlockJobInfoList dummy = {};
2306 fb5458cd Stefan Hajnoczi
    BlockJobInfoList *prev = &dummy;
2307 fb5458cd Stefan Hajnoczi
    bdrv_iterate(do_qmp_query_block_jobs_one, &prev);
2308 fb5458cd Stefan Hajnoczi
    return dummy.next;
2309 fb5458cd Stefan Hajnoczi
}
2310 4d454574 Paolo Bonzini
2311 0006383e Kevin Wolf
QemuOptsList qemu_common_drive_opts = {
2312 4d454574 Paolo Bonzini
    .name = "drive",
2313 0006383e Kevin Wolf
    .head = QTAILQ_HEAD_INITIALIZER(qemu_common_drive_opts.head),
2314 4d454574 Paolo Bonzini
    .desc = {
2315 4d454574 Paolo Bonzini
        {
2316 4d454574 Paolo Bonzini
            .name = "snapshot",
2317 4d454574 Paolo Bonzini
            .type = QEMU_OPT_BOOL,
2318 4d454574 Paolo Bonzini
            .help = "enable/disable snapshot mode",
2319 4d454574 Paolo Bonzini
        },{
2320 a9384aff Paolo Bonzini
            .name = "discard",
2321 a9384aff Paolo Bonzini
            .type = QEMU_OPT_STRING,
2322 a9384aff Paolo Bonzini
            .help = "discard operation (ignore/off, unmap/on)",
2323 a9384aff Paolo Bonzini
        },{
2324 29c4e2b5 Kevin Wolf
            .name = "cache.writeback",
2325 29c4e2b5 Kevin Wolf
            .type = QEMU_OPT_BOOL,
2326 29c4e2b5 Kevin Wolf
            .help = "enables writeback mode for any caches",
2327 29c4e2b5 Kevin Wolf
        },{
2328 29c4e2b5 Kevin Wolf
            .name = "cache.direct",
2329 29c4e2b5 Kevin Wolf
            .type = QEMU_OPT_BOOL,
2330 29c4e2b5 Kevin Wolf
            .help = "enables use of O_DIRECT (bypass the host page cache)",
2331 29c4e2b5 Kevin Wolf
        },{
2332 29c4e2b5 Kevin Wolf
            .name = "cache.no-flush",
2333 29c4e2b5 Kevin Wolf
            .type = QEMU_OPT_BOOL,
2334 29c4e2b5 Kevin Wolf
            .help = "ignore any flush requests for the device",
2335 4d454574 Paolo Bonzini
        },{
2336 4d454574 Paolo Bonzini
            .name = "aio",
2337 4d454574 Paolo Bonzini
            .type = QEMU_OPT_STRING,
2338 4d454574 Paolo Bonzini
            .help = "host AIO implementation (threads, native)",
2339 4d454574 Paolo Bonzini
        },{
2340 4d454574 Paolo Bonzini
            .name = "format",
2341 4d454574 Paolo Bonzini
            .type = QEMU_OPT_STRING,
2342 4d454574 Paolo Bonzini
            .help = "disk format (raw, qcow2, ...)",
2343 4d454574 Paolo Bonzini
        },{
2344 4d454574 Paolo Bonzini
            .name = "serial",
2345 4d454574 Paolo Bonzini
            .type = QEMU_OPT_STRING,
2346 4d454574 Paolo Bonzini
            .help = "disk serial number",
2347 4d454574 Paolo Bonzini
        },{
2348 4d454574 Paolo Bonzini
            .name = "rerror",
2349 4d454574 Paolo Bonzini
            .type = QEMU_OPT_STRING,
2350 4d454574 Paolo Bonzini
            .help = "read error action",
2351 4d454574 Paolo Bonzini
        },{
2352 4d454574 Paolo Bonzini
            .name = "werror",
2353 4d454574 Paolo Bonzini
            .type = QEMU_OPT_STRING,
2354 4d454574 Paolo Bonzini
            .help = "write error action",
2355 4d454574 Paolo Bonzini
        },{
2356 0f227a94 Kevin Wolf
            .name = "read-only",
2357 4d454574 Paolo Bonzini
            .type = QEMU_OPT_BOOL,
2358 4d454574 Paolo Bonzini
            .help = "open drive file as read-only",
2359 4d454574 Paolo Bonzini
        },{
2360 57975222 Kevin Wolf
            .name = "throttling.iops-total",
2361 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2362 4d454574 Paolo Bonzini
            .help = "limit total I/O operations per second",
2363 4d454574 Paolo Bonzini
        },{
2364 57975222 Kevin Wolf
            .name = "throttling.iops-read",
2365 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2366 4d454574 Paolo Bonzini
            .help = "limit read operations per second",
2367 4d454574 Paolo Bonzini
        },{
2368 57975222 Kevin Wolf
            .name = "throttling.iops-write",
2369 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2370 4d454574 Paolo Bonzini
            .help = "limit write operations per second",
2371 4d454574 Paolo Bonzini
        },{
2372 57975222 Kevin Wolf
            .name = "throttling.bps-total",
2373 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2374 4d454574 Paolo Bonzini
            .help = "limit total bytes per second",
2375 4d454574 Paolo Bonzini
        },{
2376 57975222 Kevin Wolf
            .name = "throttling.bps-read",
2377 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2378 4d454574 Paolo Bonzini
            .help = "limit read bytes per second",
2379 4d454574 Paolo Bonzini
        },{
2380 57975222 Kevin Wolf
            .name = "throttling.bps-write",
2381 4d454574 Paolo Bonzini
            .type = QEMU_OPT_NUMBER,
2382 4d454574 Paolo Bonzini
            .help = "limit write bytes per second",
2383 4d454574 Paolo Bonzini
        },{
2384 3e9fab69 Benoît Canet
            .name = "throttling.iops-total-max",
2385 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2386 3e9fab69 Benoît Canet
            .help = "I/O operations burst",
2387 3e9fab69 Benoît Canet
        },{
2388 3e9fab69 Benoît Canet
            .name = "throttling.iops-read-max",
2389 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2390 3e9fab69 Benoît Canet
            .help = "I/O operations read burst",
2391 3e9fab69 Benoît Canet
        },{
2392 3e9fab69 Benoît Canet
            .name = "throttling.iops-write-max",
2393 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2394 3e9fab69 Benoît Canet
            .help = "I/O operations write burst",
2395 3e9fab69 Benoît Canet
        },{
2396 3e9fab69 Benoît Canet
            .name = "throttling.bps-total-max",
2397 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2398 3e9fab69 Benoît Canet
            .help = "total bytes burst",
2399 3e9fab69 Benoît Canet
        },{
2400 3e9fab69 Benoît Canet
            .name = "throttling.bps-read-max",
2401 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2402 3e9fab69 Benoît Canet
            .help = "total bytes read burst",
2403 3e9fab69 Benoît Canet
        },{
2404 3e9fab69 Benoît Canet
            .name = "throttling.bps-write-max",
2405 3e9fab69 Benoît Canet
            .type = QEMU_OPT_NUMBER,
2406 3e9fab69 Benoît Canet
            .help = "total bytes write burst",
2407 3e9fab69 Benoît Canet
        },{
2408 2024c1df Benoît Canet
            .name = "throttling.iops-size",
2409 2024c1df Benoît Canet
            .type = QEMU_OPT_NUMBER,
2410 2024c1df Benoît Canet
            .help = "when limiting by iops max size of an I/O in bytes",
2411 2024c1df Benoît Canet
        },{
2412 4d454574 Paolo Bonzini
            .name = "copy-on-read",
2413 4d454574 Paolo Bonzini
            .type = QEMU_OPT_BOOL,
2414 4d454574 Paolo Bonzini
            .help = "copy read data from backing file into image file",
2415 4d454574 Paolo Bonzini
        },
2416 4d454574 Paolo Bonzini
        { /* end of list */ }
2417 4d454574 Paolo Bonzini
    },
2418 4d454574 Paolo Bonzini
};
2419 0006383e Kevin Wolf
2420 0006383e Kevin Wolf
QemuOptsList qemu_drive_opts = {
2421 0006383e Kevin Wolf
    .name = "drive",
2422 0006383e Kevin Wolf
    .head = QTAILQ_HEAD_INITIALIZER(qemu_drive_opts.head),
2423 0006383e Kevin Wolf
    .desc = {
2424 492fdc6f Kevin Wolf
        /*
2425 492fdc6f Kevin Wolf
         * no elements => accept any params
2426 492fdc6f Kevin Wolf
         * validation will happen later
2427 492fdc6f Kevin Wolf
         */
2428 0006383e Kevin Wolf
        { /* end of list */ }
2429 0006383e Kevin Wolf
    },
2430 0006383e Kevin Wolf
};