[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [Qemu-devel] [v4 06/13] arch_init: Add and free data struct for deco
From: |
Dr. David Alan Gilbert |
Subject: |
Re: [Qemu-devel] [v4 06/13] arch_init: Add and free data struct for decompression |
Date: |
Fri, 6 Feb 2015 10:46:33 +0000 |
User-agent: |
Mutt/1.5.23 (2014-03-12) |
* Liang Li (address@hidden) wrote:
> 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>
> ---
> arch_init.c | 13 ++++++++++++-
> 1 file changed, 12 insertions(+), 1 deletion(-)
>
> diff --git a/arch_init.c b/arch_init.c
> index 87c4947..500f299 100644
> --- a/arch_init.c
> +++ b/arch_init.c
> @@ -345,7 +345,12 @@ struct CompressParam {
> typedef struct CompressParam CompressParam;
>
> struct DecompressParam {
> - /* To be done */
> + bool busy;
> + QemuMutex mutex;
> + QemuCond cond;
> + void *des;
> + uint8 *compbuf;
> + int len;
> };
> typedef struct DecompressParam DecompressParam;
>
> @@ -1188,6 +1193,9 @@ void migrate_decompress_threads_create(int count)
> compressed_data_buf = g_malloc0(compressBound(TARGET_PAGE_SIZE));
> quit_thread = false;
> for (i = 0; i < 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);
> @@ -1202,6 +1210,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);
> --
> 1.9.1
>
--
Dr. David Alan Gilbert / address@hidden / Manchester, UK
- Re: [Qemu-devel] [v4 07/13] migration: Split the function ram_save_page, (continued)
- [Qemu-devel] [v4 08/13] migration: Add the core code of multi-thread compression, Liang Li, 2015/02/02
- [Qemu-devel] [v4 09/13] migration: Make compression co-work with xbzrle, Liang Li, 2015/02/02
- [Qemu-devel] [v4 10/13] migration: Add the core code for decompression, Liang Li, 2015/02/02
- [Qemu-devel] [v4 11/13] migration: Add interface to control compression, Liang Li, 2015/02/02
- [Qemu-devel] [v4 06/13] arch_init: Add and free data struct for decompression, Liang Li, 2015/02/02
- Re: [Qemu-devel] [v4 06/13] arch_init: Add and free data struct for decompression,
Dr. David Alan Gilbert <=
- [Qemu-devel] [v4 13/13] migration: Add command to query migration parameter, Liang Li, 2015/02/02
- [Qemu-devel] [v4 02/13] migration: Add the framework of multi-thread compression, Liang Li, 2015/02/02
- [Qemu-devel] [v4 12/13] migration: Add command to set migration parameter, Liang Li, 2015/02/02