aboutsummaryrefslogtreecommitdiff
path: root/arch_init.c
diff options
context:
space:
mode:
authorLiang Li <liang.z.li@intel.com>2015-03-23 16:32:21 +0800
committerJuan Quintela <quintela@redhat.com>2015-05-06 17:36:57 +0200
commit3caf633dbde8a347cff49e960691c7fa6a82afa1 (patch)
tree39fddf2b14dcab77ddbe58de4e6efad500d87168 /arch_init.c
parent474ddaf6e3aebc470f4665ef4f7ce6578448c6d1 (diff)
downloadqemu-3caf633dbde8a347cff49e960691c7fa6a82afa1.zip
qemu-3caf633dbde8a347cff49e960691c7fa6a82afa1.tar.gz
qemu-3caf633dbde8a347cff49e960691c7fa6a82afa1.tar.bz2
arch_init: Add and free data struct for decompression
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 <liang.z.li@intel.com> Signed-off-by: Yang Zhang <yang.z.zhang@intel.com> Reviewed-by: Dr.David Alan Gilbert <dgilbert@redhat.com> Reviewed-by: Juan Quintela <quintela@redhat.com> Signed-off-by: Juan Quintela <quintela@redhat.com>
Diffstat (limited to 'arch_init.c')
-rw-r--r--arch_init.c13
1 files changed, 12 insertions, 1 deletions
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);