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.h"
27#include "sysemu/block-backend.h"
28#include "qapi/error.h"
29
30static void test_drain_aio_error_flush_cb(void *opaque, int ret)
31{
32 bool *completed = opaque;
33
34 g_assert(ret == -ENOMEDIUM);
35 *completed = true;
36}
37
38static void test_drain_aio_error(void)
39{
40 BlockBackend *blk = blk_new(BLK_PERM_ALL, BLK_PERM_ALL);
41 BlockAIOCB *acb;
42 bool completed = false;
43
44 acb = blk_aio_flush(blk, test_drain_aio_error_flush_cb, &completed);
45 g_assert(acb != NULL);
46 g_assert(completed == false);
47
48 blk_drain(blk);
49 g_assert(completed == true);
50
51 blk_unref(blk);
52}
53
54static void test_drain_all_aio_error(void)
55{
56 BlockBackend *blk = blk_new(BLK_PERM_ALL, BLK_PERM_ALL);
57 BlockAIOCB *acb;
58 bool completed = false;
59
60 acb = blk_aio_flush(blk, test_drain_aio_error_flush_cb, &completed);
61 g_assert(acb != NULL);
62 g_assert(completed == false);
63
64 blk_drain_all();
65 g_assert(completed == true);
66
67 blk_unref(blk);
68}
69
70int main(int argc, char **argv)
71{
72 bdrv_init();
73 qemu_init_main_loop(&error_abort);
74
75 g_test_init(&argc, &argv, NULL);
76
77 g_test_add_func("/block-backend/drain_aio_error", test_drain_aio_error);
78 g_test_add_func("/block-backend/drain_all_aio_error",
79 test_drain_all_aio_error);
80
81 return g_test_run();
82}
83