static void thread_pool_init_one(ThreadPool *pool, AioContext *ctx)

{

    if (!ctx) {

        ctx = qemu_get_aio_context();

    }



    memset(pool, 0, sizeof(*pool));

    event_notifier_init(&pool->notifier, false);

    pool->ctx = ctx;

    qemu_mutex_init(&pool->lock);

    qemu_cond_init(&pool->check_cancel);

    qemu_cond_init(&pool->worker_stopped);

    qemu_sem_init(&pool->sem, 0);

    pool->max_threads = 64;

    pool->new_thread_bh = aio_bh_new(ctx, spawn_thread_bh_fn, pool);



    QLIST_INIT(&pool->head);

    QTAILQ_INIT(&pool->request_list);



    aio_set_event_notifier(ctx, &pool->notifier, event_notifier_ready);

}

static void thread_pool_init_one(ThreadPool *pool, AioContext *ctx)

{

    if (!ctx) {

        ctx = qemu_get_aio_context();

    }



    memset(pool, 0, sizeof(*pool));

    event_notifier_init(&pool->notifier, false);

    pool->ctx = ctx;

    qemu_mutex_init(&pool->lock);

    qemu_cond_init(&pool->check_cancel);

    qemu_cond_init(&pool->worker_stopped);

    qemu_sem_init(&pool->sem, 0);

    pool->max_threads = 64;

    pool->new_thread_bh = aio_bh_new(ctx, spawn_thread_bh_fn, pool);



    QLIST_INIT(&pool->head);

    QTAILQ_INIT(&pool->request_list);



    aio_set_event_notifier(ctx, &pool->notifier, event_notifier_ready);

}

static void FUNC_0(ThreadPool *VAR_0, AioContext *VAR_1)

{

    if (!VAR_1) {

        VAR_1 = qemu_get_aio_context();

    }



    memset(VAR_0, 0, sizeof(*VAR_0));

    event_notifier_init(&VAR_0->notifier, false);

    VAR_0->VAR_1 = VAR_1;

    qemu_mutex_init(&VAR_0->lock);

    qemu_cond_init(&VAR_0->check_cancel);

    qemu_cond_init(&VAR_0->worker_stopped);

    qemu_sem_init(&VAR_0->sem, 0);

    VAR_0->max_threads = 64;

    VAR_0->new_thread_bh = aio_bh_new(VAR_1, spawn_thread_bh_fn, VAR_0);



    QLIST_INIT(&VAR_0->head);

    QTAILQ_INIT(&VAR_0->request_list);



    aio_set_event_notifier(VAR_1, &VAR_0->notifier, event_notifier_ready);

}

static void FUNC_0(ThreadPool *VAR_0, AioContext *VAR_1)
{ if (!VAR_1) { VAR_1 = qemu_get_aio_context(); } memset(VAR_0, 0, sizeof(*VAR_0)); event_notifier_init(&VAR_0->notifier, false); VAR_0->VAR_1 = VAR_1; qemu_mutex_init(&VAR_0->lock); qemu_cond_init(&VAR_0->check_cancel); qemu_cond_init(&VAR_0->worker_stopped); qemu_sem_init(&VAR_0->sem, 0); VAR_0->max_threads = 64; VAR_0->new_thread_bh = aio_bh_new(VAR_1, spawn_thread_bh_fn, VAR_0); QLIST_INIT(&VAR_0->head); QTAILQ_INIT(&VAR_0->request_list); aio_set_event_notifier(VAR_1, &VAR_0->notifier, event_notifier_ready); }