Lines Matching refs:decomp_param
455 static DecompressParam *decomp_param; variable
3774 while (!decomp_param[idx].done) { in wait_for_decompress_done()
3795 if (!decomp_param[i].compbuf) { in compress_threads_load_cleanup()
3799 qemu_mutex_lock(&decomp_param[i].mutex); in compress_threads_load_cleanup()
3800 decomp_param[i].quit = true; in compress_threads_load_cleanup()
3801 qemu_cond_signal(&decomp_param[i].cond); in compress_threads_load_cleanup()
3802 qemu_mutex_unlock(&decomp_param[i].mutex); in compress_threads_load_cleanup()
3805 if (!decomp_param[i].compbuf) { in compress_threads_load_cleanup()
3810 qemu_mutex_destroy(&decomp_param[i].mutex); in compress_threads_load_cleanup()
3811 qemu_cond_destroy(&decomp_param[i].cond); in compress_threads_load_cleanup()
3812 inflateEnd(&decomp_param[i].stream); in compress_threads_load_cleanup()
3813 g_free(decomp_param[i].compbuf); in compress_threads_load_cleanup()
3814 decomp_param[i].compbuf = NULL; in compress_threads_load_cleanup()
3817 g_free(decomp_param); in compress_threads_load_cleanup()
3819 decomp_param = NULL; in compress_threads_load_cleanup()
3833 decomp_param = g_new0(DecompressParam, thread_count); in compress_threads_load_setup()
3838 if (inflateInit(&decomp_param[i].stream) != Z_OK) { in compress_threads_load_setup()
3842 decomp_param[i].compbuf = g_malloc0(compressBound(TARGET_PAGE_SIZE)); in compress_threads_load_setup()
3843 qemu_mutex_init(&decomp_param[i].mutex); in compress_threads_load_setup()
3844 qemu_cond_init(&decomp_param[i].cond); in compress_threads_load_setup()
3845 decomp_param[i].done = true; in compress_threads_load_setup()
3846 decomp_param[i].quit = false; in compress_threads_load_setup()
3848 do_data_decompress, decomp_param + i, in compress_threads_load_setup()
3866 if (decomp_param[idx].done) { in decompress_data_with_multi_threads()
3867 decomp_param[idx].done = false; in decompress_data_with_multi_threads()
3868 qemu_mutex_lock(&decomp_param[idx].mutex); in decompress_data_with_multi_threads()
3869 qemu_get_buffer(f, decomp_param[idx].compbuf, len); in decompress_data_with_multi_threads()
3870 decomp_param[idx].des = host; in decompress_data_with_multi_threads()
3871 decomp_param[idx].len = len; in decompress_data_with_multi_threads()
3872 qemu_cond_signal(&decomp_param[idx].cond); in decompress_data_with_multi_threads()
3873 qemu_mutex_unlock(&decomp_param[idx].mutex); in decompress_data_with_multi_threads()