1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25#include "qemu/osdep.h"
26#include "block/block_int.h"
27#include "qemu/job.h"
28#include "qemu/main-loop.h"
29#include "qapi/qapi-commands-block-core.h"
30#include "qapi/qapi-visit-block-core.h"
31#include "qapi/clone-visitor.h"
32#include "qapi/error.h"
33
34typedef struct BlockdevCreateJob {
35 Job common;
36 BlockDriver *drv;
37 BlockdevCreateOptions *opts;
38} BlockdevCreateJob;
39
40static int coroutine_fn blockdev_create_run(Job *job, Error **errp)
41{
42 BlockdevCreateJob *s = container_of(job, BlockdevCreateJob, common);
43 int ret;
44
45 job_progress_set_remaining(&s->common, 1);
46 ret = s->drv->bdrv_co_create(s->opts, errp);
47 job_progress_update(&s->common, 1);
48
49 qapi_free_BlockdevCreateOptions(s->opts);
50
51 return ret;
52}
53
54static const JobDriver blockdev_create_job_driver = {
55 .instance_size = sizeof(BlockdevCreateJob),
56 .job_type = JOB_TYPE_CREATE,
57 .run = blockdev_create_run,
58};
59
60void qmp_blockdev_create(const char *job_id, BlockdevCreateOptions *options,
61 Error **errp)
62{
63 BlockdevCreateJob *s;
64 const char *fmt = BlockdevDriver_str(options->driver);
65 BlockDriver *drv = bdrv_find_format(fmt);
66
67 if (!drv) {
68 error_setg(errp, "Block driver '%s' not found or not supported", fmt);
69 return;
70 }
71
72
73
74 if (bdrv_uses_whitelist() && !bdrv_is_whitelisted(drv, false)) {
75 error_setg(errp, "Driver is not whitelisted");
76 return;
77 }
78
79
80 if (!drv->bdrv_co_create) {
81 error_setg(errp, "Driver does not support blockdev-create");
82 return;
83 }
84
85
86
87
88 s = job_create(job_id, &blockdev_create_job_driver, NULL,
89 qemu_get_aio_context(), JOB_DEFAULT | JOB_MANUAL_DISMISS,
90 NULL, NULL, errp);
91 if (!s) {
92 return;
93 }
94
95 s->drv = drv,
96 s->opts = QAPI_CLONE(BlockdevCreateOptions, options),
97
98 job_start(&s->common);
99}
100