qemu-devel
[Top][All Lists]
Advanced

[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



reply via email to

[Prev in Thread] Current Thread [Next in Thread]