[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [v8 10/14] migration: Add the core code for decompression
From: |
Liang Li |
Subject: |
[Qemu-devel] [v8 10/14] migration: Add the core code for decompression |
Date: |
Wed, 15 Apr 2015 17:26:19 +0800 |
Implement the core logic of multiple thread decompression,
the decompression can work now.
Signed-off-by: Liang Li <address@hidden>
Signed-off-by: Yang Zhang <address@hidden>
---
arch_init.c | 51 ++++++++++++++++++++++++++++++++++++++++++++++++---
1 file changed, 48 insertions(+), 3 deletions(-)
diff --git a/arch_init.c b/arch_init.c
index 8fb2ea4..a4020d5 100644
--- a/arch_init.c
+++ b/arch_init.c
@@ -889,7 +889,6 @@ static inline void start_compression(CompressParam *param)
qemu_mutex_unlock(¶m->mutex);
}
-
static uint64_t bytes_transferred;
static void flush_compressed_data(QEMUFile *f)
@@ -1458,8 +1457,28 @@ void ram_handle_compressed(void *host, uint8_t ch,
uint64_t size)
static void *do_data_decompress(void *opaque)
{
+ DecompressParam *param = opaque;
+ size_t pagesize;
+
while (true) {
- /* To be done */
+ qemu_mutex_lock(¶m->mutex);
+ while (!param->start && !param->quit) {
+ qemu_cond_wait(¶m->cond, ¶m->mutex);
+ }
+ if (param->quit) {
+ qemu_mutex_unlock(¶m->mutex);
+ break;
+ }
+ pagesize = TARGET_PAGE_SIZE;
+ /* uncompress() will return failed in some case, especially
+ * when the page is dirted when doing the compression, it's
+ * not a problem because the dirty page will be retransferred
+ * and uncompress() won't break the data in other pages.
+ */
+ uncompress((Bytef *)param->des, &pagesize,
+ (const Bytef *)param->compbuf, param->len);
+ param->start = false;
+ qemu_mutex_unlock(¶m->mutex);
}
return NULL;
@@ -1489,6 +1508,12 @@ void migrate_decompress_threads_join(void)
thread_count = migrate_decompress_threads();
for (i = 0; i < thread_count; i++) {
+ qemu_mutex_lock(&decomp_param[i].mutex);
+ decomp_param[i].quit = true;
+ qemu_cond_signal(&decomp_param[i].cond);
+ qemu_mutex_unlock(&decomp_param[i].mutex);
+ }
+ for (i = 0; i < thread_count; i++) {
qemu_thread_join(decompress_threads + i);
qemu_mutex_destroy(&decomp_param[i].mutex);
qemu_cond_destroy(&decomp_param[i].cond);
@@ -1505,7 +1530,27 @@ void migrate_decompress_threads_join(void)
static void decompress_data_with_multi_threads(uint8_t *compbuf,
void *host, int len)
{
- /* To be done */
+ int idx, thread_count;
+
+ thread_count = migrate_decompress_threads();
+ while (true) {
+ for (idx = 0; idx < thread_count; idx++) {
+ qemu_mutex_lock(&decomp_param[idx].mutex);
+ if (!decomp_param[idx].start) {
+ memcpy(decomp_param[idx].compbuf, compbuf, len);
+ decomp_param[idx].des = host;
+ decomp_param[idx].len = len;
+ decomp_param[idx].start = true;
+ qemu_cond_signal(&decomp_param[idx].cond);
+ qemu_mutex_unlock(&decomp_param[idx].mutex);
+ break;
+ }
+ qemu_mutex_unlock(&decomp_param[idx].mutex);
+ }
+ if (idx < thread_count) {
+ break;
+ }
+ }
}
static int ram_load(QEMUFile *f, void *opaque, int version_id)
--
1.9.1
- [Qemu-devel] [PATCH v8 0/14] migration: Add a new feature to do live migration, Liang Li, 2015/04/15
- [Qemu-devel] [v8 01/14] docs: Add a doc about multiple thread compression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 02/14] migration: Add the framework of multi-thread compression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 04/14] qemu-file: Add compression functions to QEMUFile, Liang Li, 2015/04/15
- [Qemu-devel] [v8 05/14] arch_init: Alloc and free data struct for compression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 03/14] migration: Add the framework of multi-thread decompression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 06/14] arch_init: Add and free data struct for decompression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 08/14] migration: Add the core code of multi-thread compression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 07/14] migration: Split save_zero_page from ram_save_page, Liang Li, 2015/04/15
- [Qemu-devel] [v8 10/14] migration: Add the core code for decompression,
Liang Li <=
- [Qemu-devel] [v8 09/14] migration: Make compression co-work with xbzrle, Liang Li, 2015/04/15
- [Qemu-devel] [v8 11/14] migration: Add interface to control compression, Liang Li, 2015/04/15
- [Qemu-devel] [v8 12/14] migration: Use an array instead of 3 parameters, Liang Li, 2015/04/15
- [Qemu-devel] [v8 13/14] migration: Add qmp commands to set and query parameters, Liang Li, 2015/04/15
- [Qemu-devel] [v8 14/14] migration: Add hmp interface to set and query parameters, Liang Li, 2015/04/15