]>
Commit | Line | Data |
---|---|---|
e9ee6d7c | 1 | From 92dd1098e6b4b1284f7eec46ab57a0db4e891dc3 Mon Sep 17 00:00:00 2001 |
ca0fe5f5 WB |
2 | From: Wolfgang Bumiller <w.bumiller@proxmox.com> |
3 | Date: Wed, 9 Dec 2015 15:40:42 +0100 | |
9c3bec39 | 4 | Subject: [PATCH 20/47] backup: vma: run flush inside coroutine |
ca0fe5f5 WB |
5 | |
6 | --- | |
7 | blockdev.c | 10 +++++++++- | |
8 | vma-writer.c | 4 ++++ | |
9 | 2 files changed, 13 insertions(+), 1 deletion(-) | |
10 | ||
11 | diff --git a/blockdev.c b/blockdev.c | |
e9ee6d7c | 12 | index 0c1815d..d9d2b20 100644 |
ca0fe5f5 WB |
13 | --- a/blockdev.c |
14 | +++ b/blockdev.c | |
1a91ab45 | 15 | @@ -3087,6 +3087,13 @@ static void pvebackup_cleanup(void) |
ca0fe5f5 WB |
16 | } |
17 | } | |
18 | ||
19 | +static void coroutine_fn backup_close_vma_stream(void *opaque) | |
20 | +{ | |
21 | + PVEBackupDevInfo *di = opaque; | |
22 | + | |
23 | + vma_writer_close_stream(backup_state.vmaw, di->dev_id); | |
24 | +} | |
25 | + | |
26 | static void pvebackup_complete_cb(void *opaque, int ret) | |
27 | { | |
28 | PVEBackupDevInfo *di = opaque; | |
1a91ab45 | 29 | @@ -3104,7 +3111,8 @@ static void pvebackup_complete_cb(void *opaque, int ret) |
ca0fe5f5 WB |
30 | di->target = NULL; |
31 | ||
32 | if (backup_state.vmaw) { | |
33 | - vma_writer_close_stream(backup_state.vmaw, di->dev_id); | |
68a30562 WB |
34 | + Coroutine *co = qemu_coroutine_create(backup_close_vma_stream, di); |
35 | + qemu_coroutine_enter(co); | |
ca0fe5f5 WB |
36 | } |
37 | ||
38 | block_job_cb(bs, ret); | |
39 | diff --git a/vma-writer.c b/vma-writer.c | |
1a91ab45 | 40 | index ec8da53..216577a 100644 |
ca0fe5f5 WB |
41 | --- a/vma-writer.c |
42 | +++ b/vma-writer.c | |
68a30562 | 43 | @@ -700,6 +700,10 @@ int vma_writer_close(VmaWriter *vmaw, Error **errp) |
ca0fe5f5 WB |
44 | |
45 | int i; | |
46 | ||
47 | + while (vmaw->co_writer) { | |
48 | + aio_poll(qemu_get_aio_context(), true); | |
49 | + } | |
50 | + | |
51 | assert(vmaw->co_writer == NULL); | |
52 | ||
53 | if (vmaw->cmd) { | |
54 | -- | |
55 | 2.1.4 | |
56 |