static void decompress_data_with_multi_threads(QEMUFile *f,

                                               void *host, int len)

{

    int idx, thread_count;



    thread_count = migrate_decompress_threads();

    while (true) {

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

            if (!decomp_param[idx].start) {

                qemu_get_buffer(f, decomp_param[idx].compbuf, len);

                decomp_param[idx].des = host;

                decomp_param[idx].len = len;

                start_decompression(&decomp_param[idx]);

                break;

            }

        }

        if (idx < thread_count) {

            break;

        }

    }

}

static void decompress_data_with_multi_threads(QEMUFile *f,

                                               void *host, int len)

{

    int idx, thread_count;



    thread_count = migrate_decompress_threads();

    while (true) {

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

            if (!decomp_param[idx].start) {

                qemu_get_buffer(f, decomp_param[idx].compbuf, len);

                decomp_param[idx].des = host;

                decomp_param[idx].len = len;

                start_decompression(&decomp_param[idx]);

                break;

            }

        }

        if (idx < thread_count) {

            break;

        }

    }

}

            if (!decomp_param[idx].start) {
static void FUNC_0(QEMUFile *VAR_0,

                                               void *VAR_1, int VAR_2)

{

    int VAR_3, VAR_4;



    VAR_4 = migrate_decompress_threads();

    while (true) {

        for (VAR_3 = 0; VAR_3 < VAR_4; VAR_3++) {

            if (!decomp_param[VAR_3].start) {

                qemu_get_buffer(VAR_0, decomp_param[VAR_3].compbuf, VAR_2);

                decomp_param[VAR_3].des = VAR_1;

                decomp_param[VAR_3].VAR_2 = VAR_2;

                start_decompression(&decomp_param[VAR_3]);

                break;

            }

        }

        if (VAR_3 < VAR_4) {

            break;

        }

    }

}

static void FUNC_0(QEMUFile *VAR_0,
void *VAR_1, int VAR_2)
{ int VAR_3, VAR_4; VAR_4 = migrate_decompress_threads(); while (true) { for (VAR_3 = 0; VAR_3 < VAR_4; VAR_3++) { if (!decomp_param[VAR_3].start) { qemu_get_buffer(VAR_0, decomp_param[VAR_3].compbuf, VAR_2); decomp_param[VAR_3].des = VAR_1; decomp_param[VAR_3].VAR_2 = VAR_2; start_decompression(&decomp_param[VAR_3]); break; } } if (VAR_3 < VAR_4) { break; } } }