static inline void terminate_compression_threads(void)

{

    int idx, thread_count;



    thread_count = migrate_compress_threads();

    quit_comp_thread = true;

    for (idx = 0; idx < thread_count; idx++) {

        qemu_mutex_lock(&comp_param[idx].mutex);

        qemu_cond_signal(&comp_param[idx].cond);

        qemu_mutex_unlock(&comp_param[idx].mutex);

    }

}

static inline void terminate_compression_threads(void)

{

    int idx, thread_count;



    thread_count = migrate_compress_threads();

    quit_comp_thread = true;

    for (idx = 0; idx < thread_count; idx++) {

        qemu_mutex_lock(&comp_param[idx].mutex);

        qemu_cond_signal(&comp_param[idx].cond);

        qemu_mutex_unlock(&comp_param[idx].mutex);

    }

}

static inline void FUNC_0(void)

{

    int VAR_0, VAR_1;



    VAR_1 = migrate_compress_threads();

    quit_comp_thread = true;

    for (VAR_0 = 0; VAR_0 < VAR_1; VAR_0++) {

        qemu_mutex_lock(&comp_param[VAR_0].mutex);

        qemu_cond_signal(&comp_param[VAR_0].cond);

        qemu_mutex_unlock(&comp_param[VAR_0].mutex);

    }

}

static inline void FUNC_0(void)
{ int VAR_0, VAR_1; VAR_1 = migrate_compress_threads(); quit_comp_thread = true; for (VAR_0 = 0; VAR_0 < VAR_1; VAR_0++) { qemu_mutex_lock(&comp_param[VAR_0].mutex); qemu_cond_signal(&comp_param[VAR_0].cond); qemu_mutex_unlock(&comp_param[VAR_0].mutex); } }