[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PULL 06/16] arch_init: Add and free data struct for decomp
From: |
Juan Quintela |
Subject: |
[Qemu-devel] [PULL 06/16] arch_init: Add and free data struct for decompression |
Date: |
Thu, 7 May 2015 18:46:06 +0200 |
From: Liang Li <address@hidden>
Define the data structure and variables used to do multiple thread
decompression, and add the code to initialize and free them.
Signed-off-by: Liang Li <address@hidden>
Signed-off-by: Yang Zhang <address@hidden>
Reviewed-by: Dr.David Alan Gilbert <address@hidden>
Reviewed-by: Juan Quintela <address@hidden>
Signed-off-by: Juan Quintela <address@hidden>
---
arch_init.c | 13 ++++++++++++-
1 file changed, 12 insertions(+), 1 deletion(-)
diff --git a/arch_init.c b/arch_init.c
index 87dccef..ebd246f 100644
--- a/arch_init.c
+++ b/arch_init.c
@@ -330,7 +330,12 @@ struct CompressParam {
typedef struct CompressParam CompressParam;
struct DecompressParam {
- /* To be done */
+ bool start;
+ QemuMutex mutex;
+ QemuCond cond;
+ void *des;
+ uint8 *compbuf;
+ int len;
};
typedef struct DecompressParam DecompressParam;
@@ -1266,6 +1271,9 @@ void migrate_decompress_threads_create(void)
compressed_data_buf = g_malloc0(compressBound(TARGET_PAGE_SIZE));
quit_decomp_thread = false;
for (i = 0; i < thread_count; i++) {
+ qemu_mutex_init(&decomp_param[i].mutex);
+ qemu_cond_init(&decomp_param[i].cond);
+ decomp_param[i].compbuf = g_malloc0(compressBound(TARGET_PAGE_SIZE));
qemu_thread_create(decompress_threads + i, "decompress",
do_data_decompress, decomp_param + i,
QEMU_THREAD_JOINABLE);
@@ -1280,6 +1288,9 @@ void migrate_decompress_threads_join(void)
thread_count = migrate_decompress_threads();
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);
+ g_free(decomp_param[i].compbuf);
}
g_free(decompress_threads);
g_free(decomp_param);
--
2.4.0
- [Qemu-devel] [PULL 00/16] Migration pull requset (take 3), Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 02/16] migration: Add the framework of multi-thread compression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 01/16] docs: Add a doc about multiple thread compression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 04/16] qemu-file: Add compression functions to QEMUFile, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 03/16] migration: Add the framework of multi-thread decompression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 05/16] arch_init: Alloc and free data struct for compression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 06/16] arch_init: Add and free data struct for decompression,
Juan Quintela <=
- [Qemu-devel] [PULL 07/16] migration: Split save_zero_page from ram_save_page, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 09/16] migration: Make compression co-work with xbzrle, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 08/16] migration: Add the core code of multi-thread compression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 10/16] migration: Add the core code for decompression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 11/16] migration: Add interface to control compression, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 12/16] migration: Use an array instead of 3 parameters, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 15/16] migration: avoid divide by zero in xbzrle cache miss rate, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 13/16] migration: Add qmp commands to set and query parameters, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 16/16] migration: Fix migration state update issue, Juan Quintela, 2015/05/07
- [Qemu-devel] [PULL 14/16] migration: Add hmp interface to set and query parameters, Juan Quintela, 2015/05/07