]> Git Repo - qemu.git/blame - block/blkdebug.c
target-arm: Add arm_boot_info secure_boot control
[qemu.git] / block / blkdebug.c
CommitLineData
6a143727
KW
1/*
2 * Block protocol for I/O error injection
3 *
4 * Copyright (c) 2010 Kevin Wolf <[email protected]>
5 *
6 * Permission is hereby granted, free of charge, to any person obtaining a copy
7 * of this software and associated documentation files (the "Software"), to deal
8 * in the Software without restriction, including without limitation the rights
9 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
10 * copies of the Software, and to permit persons to whom the Software is
11 * furnished to do so, subject to the following conditions:
12 *
13 * The above copyright notice and this permission notice shall be included in
14 * all copies or substantial portions of the Software.
15 *
16 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
17 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
18 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
19 * THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
20 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
21 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN
22 * THE SOFTWARE.
23 */
24
25#include "qemu-common.h"
1de7afc9 26#include "qemu/config-file.h"
737e150e 27#include "block/block_int.h"
1de7afc9 28#include "qemu/module.h"
2c31b04c
HR
29#include "qapi/qmp/qbool.h"
30#include "qapi/qmp/qdict.h"
31#include "qapi/qmp/qint.h"
32#include "qapi/qmp/qstring.h"
6a143727
KW
33
34typedef struct BDRVBlkdebugState {
571cd43e 35 int state;
8f96b5be 36 int new_state;
3c90c65d 37
571cd43e
PB
38 QLIST_HEAD(, BlkdebugRule) rules[BLKDBG_EVENT_MAX];
39 QSIMPLEQ_HEAD(, BlkdebugRule) active_rules;
3c90c65d 40 QLIST_HEAD(, BlkdebugSuspendedReq) suspended_reqs;
6a143727
KW
41} BDRVBlkdebugState;
42
b9f66d96 43typedef struct BlkdebugAIOCB {
7c84b1b8 44 BlockAIOCB common;
b9f66d96
KW
45 QEMUBH *bh;
46 int ret;
47} BlkdebugAIOCB;
48
3c90c65d
KW
49typedef struct BlkdebugSuspendedReq {
50 Coroutine *co;
51 char *tag;
52 QLIST_ENTRY(BlkdebugSuspendedReq) next;
53} BlkdebugSuspendedReq;
54
d7331bed 55static const AIOCBInfo blkdebug_aiocb_info = {
4c781717 56 .aiocb_size = sizeof(BlkdebugAIOCB),
b9f66d96
KW
57};
58
8b9b0cc2
KW
59enum {
60 ACTION_INJECT_ERROR,
61 ACTION_SET_STATE,
3c90c65d 62 ACTION_SUSPEND,
8b9b0cc2
KW
63};
64
65typedef struct BlkdebugRule {
66 BlkDebugEvent event;
67 int action;
68 int state;
69 union {
70 struct {
71 int error;
72 int immediately;
73 int once;
e4780db4 74 int64_t sector;
8b9b0cc2
KW
75 } inject;
76 struct {
77 int new_state;
78 } set_state;
3c90c65d
KW
79 struct {
80 char *tag;
81 } suspend;
8b9b0cc2
KW
82 } options;
83 QLIST_ENTRY(BlkdebugRule) next;
571cd43e 84 QSIMPLEQ_ENTRY(BlkdebugRule) active_next;
8b9b0cc2
KW
85} BlkdebugRule;
86
87static QemuOptsList inject_error_opts = {
88 .name = "inject-error",
89 .head = QTAILQ_HEAD_INITIALIZER(inject_error_opts.head),
90 .desc = {
91 {
92 .name = "event",
93 .type = QEMU_OPT_STRING,
94 },
95 {
96 .name = "state",
97 .type = QEMU_OPT_NUMBER,
98 },
99 {
100 .name = "errno",
101 .type = QEMU_OPT_NUMBER,
102 },
e4780db4
PB
103 {
104 .name = "sector",
105 .type = QEMU_OPT_NUMBER,
106 },
8b9b0cc2
KW
107 {
108 .name = "once",
109 .type = QEMU_OPT_BOOL,
110 },
111 {
112 .name = "immediately",
113 .type = QEMU_OPT_BOOL,
114 },
115 { /* end of list */ }
116 },
117};
118
119static QemuOptsList set_state_opts = {
120 .name = "set-state",
327cdad4 121 .head = QTAILQ_HEAD_INITIALIZER(set_state_opts.head),
8b9b0cc2
KW
122 .desc = {
123 {
124 .name = "event",
125 .type = QEMU_OPT_STRING,
126 },
127 {
128 .name = "state",
129 .type = QEMU_OPT_NUMBER,
130 },
131 {
132 .name = "new_state",
133 .type = QEMU_OPT_NUMBER,
134 },
135 { /* end of list */ }
136 },
137};
138
139static QemuOptsList *config_groups[] = {
140 &inject_error_opts,
141 &set_state_opts,
142 NULL
143};
144
145static const char *event_names[BLKDBG_EVENT_MAX] = {
8252278a
KW
146 [BLKDBG_L1_UPDATE] = "l1_update",
147 [BLKDBG_L1_GROW_ALLOC_TABLE] = "l1_grow.alloc_table",
148 [BLKDBG_L1_GROW_WRITE_TABLE] = "l1_grow.write_table",
149 [BLKDBG_L1_GROW_ACTIVATE_TABLE] = "l1_grow.activate_table",
150
151 [BLKDBG_L2_LOAD] = "l2_load",
152 [BLKDBG_L2_UPDATE] = "l2_update",
153 [BLKDBG_L2_UPDATE_COMPRESSED] = "l2_update_compressed",
154 [BLKDBG_L2_ALLOC_COW_READ] = "l2_alloc.cow_read",
155 [BLKDBG_L2_ALLOC_WRITE] = "l2_alloc.write",
156
8252278a 157 [BLKDBG_READ_AIO] = "read_aio",
8252278a
KW
158 [BLKDBG_READ_BACKING_AIO] = "read_backing_aio",
159 [BLKDBG_READ_COMPRESSED] = "read_compressed",
160
161 [BLKDBG_WRITE_AIO] = "write_aio",
162 [BLKDBG_WRITE_COMPRESSED] = "write_compressed",
163
164 [BLKDBG_VMSTATE_LOAD] = "vmstate_load",
165 [BLKDBG_VMSTATE_SAVE] = "vmstate_save",
166
167 [BLKDBG_COW_READ] = "cow_read",
168 [BLKDBG_COW_WRITE] = "cow_write",
169
170 [BLKDBG_REFTABLE_LOAD] = "reftable_load",
171 [BLKDBG_REFTABLE_GROW] = "reftable_grow",
afa50193 172 [BLKDBG_REFTABLE_UPDATE] = "reftable_update",
8252278a
KW
173
174 [BLKDBG_REFBLOCK_LOAD] = "refblock_load",
175 [BLKDBG_REFBLOCK_UPDATE] = "refblock_update",
176 [BLKDBG_REFBLOCK_UPDATE_PART] = "refblock_update_part",
177 [BLKDBG_REFBLOCK_ALLOC] = "refblock_alloc",
178 [BLKDBG_REFBLOCK_ALLOC_HOOKUP] = "refblock_alloc.hookup",
179 [BLKDBG_REFBLOCK_ALLOC_WRITE] = "refblock_alloc.write",
180 [BLKDBG_REFBLOCK_ALLOC_WRITE_BLOCKS] = "refblock_alloc.write_blocks",
181 [BLKDBG_REFBLOCK_ALLOC_WRITE_TABLE] = "refblock_alloc.write_table",
182 [BLKDBG_REFBLOCK_ALLOC_SWITCH_TABLE] = "refblock_alloc.switch_table",
183
184 [BLKDBG_CLUSTER_ALLOC] = "cluster_alloc",
185 [BLKDBG_CLUSTER_ALLOC_BYTES] = "cluster_alloc_bytes",
186 [BLKDBG_CLUSTER_FREE] = "cluster_free",
bf736fe3
KW
187
188 [BLKDBG_FLUSH_TO_OS] = "flush_to_os",
189 [BLKDBG_FLUSH_TO_DISK] = "flush_to_disk",
9e1cb96d
KW
190
191 [BLKDBG_PWRITEV_RMW_HEAD] = "pwritev_rmw.head",
192 [BLKDBG_PWRITEV_RMW_AFTER_HEAD] = "pwritev_rmw.after_head",
193 [BLKDBG_PWRITEV_RMW_TAIL] = "pwritev_rmw.tail",
194 [BLKDBG_PWRITEV_RMW_AFTER_TAIL] = "pwritev_rmw.after_tail",
195 [BLKDBG_PWRITEV] = "pwritev",
196 [BLKDBG_PWRITEV_ZERO] = "pwritev_zero",
197 [BLKDBG_PWRITEV_DONE] = "pwritev_done",
94054183
HR
198
199 [BLKDBG_EMPTY_IMAGE_PREPARE] = "empty_image_prepare",
8b9b0cc2
KW
200};
201
202static int get_event_by_name(const char *name, BlkDebugEvent *event)
203{
204 int i;
205
206 for (i = 0; i < BLKDBG_EVENT_MAX; i++) {
207 if (!strcmp(event_names[i], name)) {
208 *event = i;
209 return 0;
210 }
211 }
212
213 return -1;
214}
215
216struct add_rule_data {
217 BDRVBlkdebugState *s;
218 int action;
d4362d64 219 Error **errp;
8b9b0cc2
KW
220};
221
222static int add_rule(QemuOpts *opts, void *opaque)
223{
224 struct add_rule_data *d = opaque;
225 BDRVBlkdebugState *s = d->s;
226 const char* event_name;
227 BlkDebugEvent event;
228 struct BlkdebugRule *rule;
229
230 /* Find the right event for the rule */
231 event_name = qemu_opt_get(opts, "event");
d4362d64
SH
232 if (!event_name) {
233 error_setg(d->errp, "Missing event name for rule");
234 return -1;
235 } else if (get_event_by_name(event_name, &event) < 0) {
236 error_setg(d->errp, "Invalid event name \"%s\"", event_name);
8b9b0cc2
KW
237 return -1;
238 }
239
240 /* Set attributes common for all actions */
7267c094 241 rule = g_malloc0(sizeof(*rule));
8b9b0cc2
KW
242 *rule = (struct BlkdebugRule) {
243 .event = event,
244 .action = d->action,
245 .state = qemu_opt_get_number(opts, "state", 0),
246 };
247
248 /* Parse action-specific options */
249 switch (d->action) {
250 case ACTION_INJECT_ERROR:
251 rule->options.inject.error = qemu_opt_get_number(opts, "errno", EIO);
252 rule->options.inject.once = qemu_opt_get_bool(opts, "once", 0);
253 rule->options.inject.immediately =
254 qemu_opt_get_bool(opts, "immediately", 0);
e4780db4 255 rule->options.inject.sector = qemu_opt_get_number(opts, "sector", -1);
8b9b0cc2
KW
256 break;
257
258 case ACTION_SET_STATE:
259 rule->options.set_state.new_state =
260 qemu_opt_get_number(opts, "new_state", 0);
261 break;
3c90c65d
KW
262
263 case ACTION_SUSPEND:
264 rule->options.suspend.tag =
265 g_strdup(qemu_opt_get(opts, "tag"));
266 break;
8b9b0cc2
KW
267 };
268
269 /* Add the rule */
270 QLIST_INSERT_HEAD(&s->rules[event], rule, next);
271
272 return 0;
273}
274
9e35542b
KW
275static void remove_rule(BlkdebugRule *rule)
276{
277 switch (rule->action) {
278 case ACTION_INJECT_ERROR:
279 case ACTION_SET_STATE:
280 break;
3c90c65d
KW
281 case ACTION_SUSPEND:
282 g_free(rule->options.suspend.tag);
283 break;
9e35542b
KW
284 }
285
286 QLIST_REMOVE(rule, next);
287 g_free(rule);
288}
289
89f2b21e
HR
290static int read_config(BDRVBlkdebugState *s, const char *filename,
291 QDict *options, Error **errp)
8b9b0cc2 292{
85a040e5 293 FILE *f = NULL;
8b9b0cc2
KW
294 int ret;
295 struct add_rule_data d;
89f2b21e 296 Error *local_err = NULL;
8b9b0cc2 297
85a040e5
HR
298 if (filename) {
299 f = fopen(filename, "r");
300 if (f == NULL) {
301 error_setg_errno(errp, errno, "Could not read blkdebug config file");
302 return -errno;
303 }
8b9b0cc2 304
85a040e5
HR
305 ret = qemu_config_parse(f, config_groups, filename);
306 if (ret < 0) {
307 error_setg(errp, "Could not parse blkdebug config file");
308 ret = -EINVAL;
309 goto fail;
310 }
8b9b0cc2
KW
311 }
312
89f2b21e 313 qemu_config_parse_qdict(options, config_groups, &local_err);
84d18f06 314 if (local_err) {
89f2b21e
HR
315 error_propagate(errp, local_err);
316 ret = -EINVAL;
317 goto fail;
318 }
319
8b9b0cc2
KW
320 d.s = s;
321 d.action = ACTION_INJECT_ERROR;
d4362d64
SH
322 d.errp = &local_err;
323 qemu_opts_foreach(&inject_error_opts, add_rule, &d, 1);
324 if (local_err) {
325 error_propagate(errp, local_err);
326 ret = -EINVAL;
327 goto fail;
328 }
8b9b0cc2
KW
329
330 d.action = ACTION_SET_STATE;
d4362d64
SH
331 qemu_opts_foreach(&set_state_opts, add_rule, &d, 1);
332 if (local_err) {
333 error_propagate(errp, local_err);
334 ret = -EINVAL;
335 goto fail;
336 }
8b9b0cc2
KW
337
338 ret = 0;
339fail:
698f0d52
KW
340 qemu_opts_reset(&inject_error_opts);
341 qemu_opts_reset(&set_state_opts);
85a040e5
HR
342 if (f) {
343 fclose(f);
344 }
8b9b0cc2
KW
345 return ret;
346}
347
348/* Valid blkdebug filenames look like blkdebug:path/to/config:path/to/image */
f4681212
KW
349static void blkdebug_parse_filename(const char *filename, QDict *options,
350 Error **errp)
6a143727 351{
f4681212 352 const char *c;
6a143727 353
8b9b0cc2 354 /* Parse the blkdebug: prefix */
f4681212 355 if (!strstart(filename, "blkdebug:", &filename)) {
d4881b9b
HR
356 /* There was no prefix; therefore, all options have to be already
357 present in the QDict (except for the filename) */
358 qdict_put(options, "x-image", qstring_from_str(filename));
f4681212 359 return;
6a143727 360 }
6a143727 361
f4681212 362 /* Parse config file path */
8b9b0cc2
KW
363 c = strchr(filename, ':');
364 if (c == NULL) {
f4681212
KW
365 error_setg(errp, "blkdebug requires both config file and image path");
366 return;
8b9b0cc2
KW
367 }
368
f4681212
KW
369 if (c != filename) {
370 QString *config_path;
371 config_path = qstring_from_substr(filename, 0, c - filename - 1);
372 qdict_put(options, "config", config_path);
8b9b0cc2 373 }
f4681212
KW
374
375 /* TODO Allow multi-level nesting and set file.filename here */
8b9b0cc2 376 filename = c + 1;
f4681212
KW
377 qdict_put(options, "x-image", qstring_from_str(filename));
378}
379
380static QemuOptsList runtime_opts = {
381 .name = "blkdebug",
382 .head = QTAILQ_HEAD_INITIALIZER(runtime_opts.head),
383 .desc = {
384 {
385 .name = "config",
386 .type = QEMU_OPT_STRING,
387 .help = "Path to the configuration file",
388 },
389 {
390 .name = "x-image",
391 .type = QEMU_OPT_STRING,
392 .help = "[internal use only, will be removed]",
393 },
b35ee7fb
KW
394 {
395 .name = "align",
396 .type = QEMU_OPT_SIZE,
397 .help = "Required alignment in bytes",
398 },
f4681212
KW
399 { /* end of list */ }
400 },
401};
402
015a1036
HR
403static int blkdebug_open(BlockDriverState *bs, QDict *options, int flags,
404 Error **errp)
f4681212
KW
405{
406 BDRVBlkdebugState *s = bs->opaque;
407 QemuOpts *opts;
408 Error *local_err = NULL;
4373593d 409 const char *config;
b35ee7fb 410 uint64_t align;
f4681212
KW
411 int ret;
412
87ea75d5 413 opts = qemu_opts_create(&runtime_opts, NULL, 0, &error_abort);
f4681212 414 qemu_opts_absorb_qdict(opts, options, &local_err);
84d18f06 415 if (local_err) {
10ffa72f 416 error_propagate(errp, local_err);
f4681212 417 ret = -EINVAL;
eaf944a4 418 goto out;
f4681212
KW
419 }
420
89f2b21e 421 /* Read rules from config file or command line options */
f4681212 422 config = qemu_opt_get(opts, "config");
89f2b21e 423 ret = read_config(s, config, options, errp);
85a040e5 424 if (ret) {
eaf944a4 425 goto out;
f4681212 426 }
8b9b0cc2 427
8db520ce 428 /* Set initial state */
571cd43e 429 s->state = 1;
8db520ce 430
8b9b0cc2 431 /* Open the backing file */
f67503e5 432 assert(bs->file == NULL);
4373593d 433 ret = bdrv_open_image(&bs->file, qemu_opt_get(opts, "x-image"), options, "image",
f7d9fd8c 434 flags | BDRV_O_PROTOCOL, false, &local_err);
8b9b0cc2 435 if (ret < 0) {
10ffa72f 436 error_propagate(errp, local_err);
eaf944a4 437 goto out;
8b9b0cc2
KW
438 }
439
b35ee7fb
KW
440 /* Set request alignment */
441 align = qemu_opt_get_size(opts, "align", bs->request_alignment);
442 if (align > 0 && align < INT_MAX && !(align & (align - 1))) {
443 bs->request_alignment = align;
444 } else {
445 error_setg(errp, "Invalid alignment");
446 ret = -EINVAL;
eaf944a4 447 goto fail_unref;
b35ee7fb
KW
448 }
449
f4681212 450 ret = 0;
eaf944a4
KW
451 goto out;
452
453fail_unref:
454 bdrv_unref(bs->file);
455out:
f4681212
KW
456 qemu_opts_del(opts);
457 return ret;
6a143727
KW
458}
459
b9f66d96
KW
460static void error_callback_bh(void *opaque)
461{
462 struct BlkdebugAIOCB *acb = opaque;
463 qemu_bh_delete(acb->bh);
464 acb->common.cb(acb->common.opaque, acb->ret);
8007429a 465 qemu_aio_unref(acb);
b9f66d96
KW
466}
467
7c84b1b8 468static BlockAIOCB *inject_error(BlockDriverState *bs,
097310b5 469 BlockCompletionFunc *cb, void *opaque, BlkdebugRule *rule)
b9f66d96
KW
470{
471 BDRVBlkdebugState *s = bs->opaque;
571cd43e 472 int error = rule->options.inject.error;
b9f66d96
KW
473 struct BlkdebugAIOCB *acb;
474 QEMUBH *bh;
475
571cd43e
PB
476 if (rule->options.inject.once) {
477 QSIMPLEQ_INIT(&s->active_rules);
b9f66d96
KW
478 }
479
571cd43e 480 if (rule->options.inject.immediately) {
b9f66d96
KW
481 return NULL;
482 }
483
d7331bed 484 acb = qemu_aio_get(&blkdebug_aiocb_info, bs, cb, opaque);
b9f66d96
KW
485 acb->ret = -error;
486
7e1efdf0 487 bh = aio_bh_new(bdrv_get_aio_context(bs), error_callback_bh, acb);
b9f66d96
KW
488 acb->bh = bh;
489 qemu_bh_schedule(bh);
490
b666d239 491 return &acb->common;
b9f66d96
KW
492}
493
7c84b1b8 494static BlockAIOCB *blkdebug_aio_readv(BlockDriverState *bs,
6a143727 495 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
097310b5 496 BlockCompletionFunc *cb, void *opaque)
6a143727
KW
497{
498 BDRVBlkdebugState *s = bs->opaque;
e4780db4
PB
499 BlkdebugRule *rule = NULL;
500
501 QSIMPLEQ_FOREACH(rule, &s->active_rules, active_next) {
502 if (rule->options.inject.sector == -1 ||
503 (rule->options.inject.sector >= sector_num &&
504 rule->options.inject.sector < sector_num + nb_sectors)) {
505 break;
506 }
507 }
b9f66d96 508
571cd43e
PB
509 if (rule && rule->options.inject.error) {
510 return inject_error(bs, cb, opaque, rule);
b9f66d96
KW
511 }
512
368e8dd1 513 return bdrv_aio_readv(bs->file, sector_num, qiov, nb_sectors, cb, opaque);
6a143727
KW
514}
515
7c84b1b8 516static BlockAIOCB *blkdebug_aio_writev(BlockDriverState *bs,
6a143727 517 int64_t sector_num, QEMUIOVector *qiov, int nb_sectors,
097310b5 518 BlockCompletionFunc *cb, void *opaque)
6a143727
KW
519{
520 BDRVBlkdebugState *s = bs->opaque;
e4780db4
PB
521 BlkdebugRule *rule = NULL;
522
523 QSIMPLEQ_FOREACH(rule, &s->active_rules, active_next) {
524 if (rule->options.inject.sector == -1 ||
525 (rule->options.inject.sector >= sector_num &&
526 rule->options.inject.sector < sector_num + nb_sectors)) {
527 break;
528 }
529 }
b9f66d96 530
571cd43e
PB
531 if (rule && rule->options.inject.error) {
532 return inject_error(bs, cb, opaque, rule);
b9f66d96
KW
533 }
534
368e8dd1 535 return bdrv_aio_writev(bs->file, sector_num, qiov, nb_sectors, cb, opaque);
6a143727
KW
536}
537
7c84b1b8 538static BlockAIOCB *blkdebug_aio_flush(BlockDriverState *bs,
097310b5 539 BlockCompletionFunc *cb, void *opaque)
9e52c53b
PB
540{
541 BDRVBlkdebugState *s = bs->opaque;
542 BlkdebugRule *rule = NULL;
543
544 QSIMPLEQ_FOREACH(rule, &s->active_rules, active_next) {
545 if (rule->options.inject.sector == -1) {
546 break;
547 }
548 }
549
550 if (rule && rule->options.inject.error) {
551 return inject_error(bs, cb, opaque, rule);
552 }
553
554 return bdrv_aio_flush(bs->file, cb, opaque);
555}
556
3c90c65d 557
6a143727
KW
558static void blkdebug_close(BlockDriverState *bs)
559{
560 BDRVBlkdebugState *s = bs->opaque;
8b9b0cc2
KW
561 BlkdebugRule *rule, *next;
562 int i;
563
564 for (i = 0; i < BLKDBG_EVENT_MAX; i++) {
565 QLIST_FOREACH_SAFE(rule, &s->rules[i], next, next) {
9e35542b 566 remove_rule(rule);
8b9b0cc2
KW
567 }
568 }
6a143727
KW
569}
570
3c90c65d
KW
571static void suspend_request(BlockDriverState *bs, BlkdebugRule *rule)
572{
573 BDRVBlkdebugState *s = bs->opaque;
574 BlkdebugSuspendedReq r;
575
576 r = (BlkdebugSuspendedReq) {
577 .co = qemu_coroutine_self(),
578 .tag = g_strdup(rule->options.suspend.tag),
579 };
580
581 remove_rule(rule);
582 QLIST_INSERT_HEAD(&s->suspended_reqs, &r, next);
583
584 printf("blkdebug: Suspended request '%s'\n", r.tag);
585 qemu_coroutine_yield();
586 printf("blkdebug: Resuming request '%s'\n", r.tag);
587
588 QLIST_REMOVE(&r, next);
589 g_free(r.tag);
590}
591
571cd43e 592static bool process_rule(BlockDriverState *bs, struct BlkdebugRule *rule,
8f96b5be 593 bool injected)
8b9b0cc2
KW
594{
595 BDRVBlkdebugState *s = bs->opaque;
8b9b0cc2
KW
596
597 /* Only process rules for the current state */
8f96b5be 598 if (rule->state && rule->state != s->state) {
571cd43e 599 return injected;
8b9b0cc2
KW
600 }
601
602 /* Take the action */
603 switch (rule->action) {
604 case ACTION_INJECT_ERROR:
571cd43e
PB
605 if (!injected) {
606 QSIMPLEQ_INIT(&s->active_rules);
607 injected = true;
608 }
609 QSIMPLEQ_INSERT_HEAD(&s->active_rules, rule, active_next);
8b9b0cc2
KW
610 break;
611
612 case ACTION_SET_STATE:
8f96b5be 613 s->new_state = rule->options.set_state.new_state;
8b9b0cc2 614 break;
3c90c65d
KW
615
616 case ACTION_SUSPEND:
617 suspend_request(bs, rule);
618 break;
8b9b0cc2 619 }
571cd43e 620 return injected;
8b9b0cc2
KW
621}
622
623static void blkdebug_debug_event(BlockDriverState *bs, BlkDebugEvent event)
624{
625 BDRVBlkdebugState *s = bs->opaque;
3c90c65d 626 struct BlkdebugRule *rule, *next;
571cd43e 627 bool injected;
8b9b0cc2 628
95ee3914 629 assert((int)event >= 0 && event < BLKDBG_EVENT_MAX);
8b9b0cc2 630
571cd43e 631 injected = false;
8f96b5be 632 s->new_state = s->state;
3c90c65d 633 QLIST_FOREACH_SAFE(rule, &s->rules[event], next, next) {
8f96b5be 634 injected = process_rule(bs, rule, injected);
8b9b0cc2 635 }
8f96b5be 636 s->state = s->new_state;
8b9b0cc2
KW
637}
638
3c90c65d
KW
639static int blkdebug_debug_breakpoint(BlockDriverState *bs, const char *event,
640 const char *tag)
641{
642 BDRVBlkdebugState *s = bs->opaque;
643 struct BlkdebugRule *rule;
644 BlkDebugEvent blkdebug_event;
645
646 if (get_event_by_name(event, &blkdebug_event) < 0) {
647 return -ENOENT;
648 }
649
650
651 rule = g_malloc(sizeof(*rule));
652 *rule = (struct BlkdebugRule) {
653 .event = blkdebug_event,
654 .action = ACTION_SUSPEND,
655 .state = 0,
656 .options.suspend.tag = g_strdup(tag),
657 };
658
659 QLIST_INSERT_HEAD(&s->rules[blkdebug_event], rule, next);
660
661 return 0;
662}
663
664static int blkdebug_debug_resume(BlockDriverState *bs, const char *tag)
665{
666 BDRVBlkdebugState *s = bs->opaque;
c547e564 667 BlkdebugSuspendedReq *r, *next;
3c90c65d 668
c547e564 669 QLIST_FOREACH_SAFE(r, &s->suspended_reqs, next, next) {
3c90c65d
KW
670 if (!strcmp(r->tag, tag)) {
671 qemu_coroutine_enter(r->co, NULL);
672 return 0;
673 }
674 }
675 return -ENOENT;
676}
677
4cc70e93
FZ
678static int blkdebug_debug_remove_breakpoint(BlockDriverState *bs,
679 const char *tag)
680{
681 BDRVBlkdebugState *s = bs->opaque;
c547e564 682 BlkdebugSuspendedReq *r, *r_next;
4cc70e93
FZ
683 BlkdebugRule *rule, *next;
684 int i, ret = -ENOENT;
685
686 for (i = 0; i < BLKDBG_EVENT_MAX; i++) {
687 QLIST_FOREACH_SAFE(rule, &s->rules[i], next, next) {
688 if (rule->action == ACTION_SUSPEND &&
689 !strcmp(rule->options.suspend.tag, tag)) {
690 remove_rule(rule);
691 ret = 0;
692 }
693 }
694 }
c547e564 695 QLIST_FOREACH_SAFE(r, &s->suspended_reqs, next, r_next) {
4cc70e93
FZ
696 if (!strcmp(r->tag, tag)) {
697 qemu_coroutine_enter(r->co, NULL);
698 ret = 0;
699 }
700 }
701 return ret;
702}
3c90c65d
KW
703
704static bool blkdebug_debug_is_suspended(BlockDriverState *bs, const char *tag)
705{
706 BDRVBlkdebugState *s = bs->opaque;
707 BlkdebugSuspendedReq *r;
708
709 QLIST_FOREACH(r, &s->suspended_reqs, next) {
710 if (!strcmp(r->tag, tag)) {
711 return true;
712 }
713 }
714 return false;
715}
716
e1302255
PB
717static int64_t blkdebug_getlength(BlockDriverState *bs)
718{
719 return bdrv_getlength(bs->file);
720}
721
2c31b04c
HR
722static void blkdebug_refresh_filename(BlockDriverState *bs)
723{
2c31b04c 724 QDict *opts;
8779441b
HR
725 const QDictEntry *e;
726 bool force_json = false;
727
728 for (e = qdict_first(bs->options); e; e = qdict_next(bs->options, e)) {
729 if (strcmp(qdict_entry_key(e), "config") &&
730 strcmp(qdict_entry_key(e), "x-image") &&
731 strcmp(qdict_entry_key(e), "image") &&
732 strncmp(qdict_entry_key(e), "image.", strlen("image.")))
733 {
734 force_json = true;
735 break;
736 }
737 }
2c31b04c 738
8779441b 739 if (force_json && !bs->file->full_open_options) {
2c31b04c
HR
740 /* The config file cannot be recreated, so creating a plain filename
741 * is impossible */
742 return;
743 }
744
8779441b
HR
745 if (!force_json && bs->file->exact_filename[0]) {
746 snprintf(bs->exact_filename, sizeof(bs->exact_filename),
747 "blkdebug:%s:%s",
748 qdict_get_try_str(bs->options, "config") ?: "",
749 bs->file->exact_filename);
750 }
751
2c31b04c
HR
752 opts = qdict_new();
753 qdict_put_obj(opts, "driver", QOBJECT(qstring_from_str("blkdebug")));
754
755 QINCREF(bs->file->full_open_options);
756 qdict_put_obj(opts, "image", QOBJECT(bs->file->full_open_options));
757
8779441b
HR
758 for (e = qdict_first(bs->options); e; e = qdict_next(bs->options, e)) {
759 if (strcmp(qdict_entry_key(e), "x-image") &&
760 strcmp(qdict_entry_key(e), "image") &&
761 strncmp(qdict_entry_key(e), "image.", strlen("image.")))
762 {
763 qobject_incref(qdict_entry_value(e));
764 qdict_put_obj(opts, qdict_entry_key(e), qdict_entry_value(e));
2c31b04c
HR
765 }
766 }
767
2c31b04c
HR
768 bs->full_open_options = opts;
769}
770
6a143727 771static BlockDriver bdrv_blkdebug = {
f4681212
KW
772 .format_name = "blkdebug",
773 .protocol_name = "blkdebug",
774 .instance_size = sizeof(BDRVBlkdebugState),
6a143727 775
f4681212
KW
776 .bdrv_parse_filename = blkdebug_parse_filename,
777 .bdrv_file_open = blkdebug_open,
778 .bdrv_close = blkdebug_close,
779 .bdrv_getlength = blkdebug_getlength,
2c31b04c 780 .bdrv_refresh_filename = blkdebug_refresh_filename,
6a143727 781
f4681212
KW
782 .bdrv_aio_readv = blkdebug_aio_readv,
783 .bdrv_aio_writev = blkdebug_aio_writev,
9e52c53b 784 .bdrv_aio_flush = blkdebug_aio_flush,
8b9b0cc2 785
3c90c65d
KW
786 .bdrv_debug_event = blkdebug_debug_event,
787 .bdrv_debug_breakpoint = blkdebug_debug_breakpoint,
4cc70e93
FZ
788 .bdrv_debug_remove_breakpoint
789 = blkdebug_debug_remove_breakpoint,
3c90c65d
KW
790 .bdrv_debug_resume = blkdebug_debug_resume,
791 .bdrv_debug_is_suspended = blkdebug_debug_is_suspended,
6a143727
KW
792};
793
794static void bdrv_blkdebug_init(void)
795{
796 bdrv_register(&bdrv_blkdebug);
797}
798
799block_init(bdrv_blkdebug_init);
This page took 0.419924 seconds and 4 git commands to generate.