static void run_block_job(BlockJob *job, Error **errp)

{

    AioContext *aio_context = blk_get_aio_context(job->blk);



    /* FIXME In error cases, the job simply goes away and we access a dangling

     * pointer below. */

    aio_context_acquire(aio_context);

    do {

        aio_poll(aio_context, true);

        qemu_progress_print(job->len ?

                            ((float)job->offset / job->len * 100.f) : 0.0f, 0);

    } while (!job->ready);



    block_job_complete_sync(job, errp);

    aio_context_release(aio_context);



    /* A block job may finish instantaneously without publishing any progress,

     * so just signal completion here */

    qemu_progress_print(100.f, 0);

}

static void run_block_job(BlockJob *job, Error **errp)

{

    AioContext *aio_context = blk_get_aio_context(job->blk);



    



    aio_context_acquire(aio_context);

    do {

        aio_poll(aio_context, true);

        qemu_progress_print(job->len ?

                            ((float)job->offset / job->len * 100.f) : 0.0f, 0);

    } while (!job->ready);



    block_job_complete_sync(job, errp);

    aio_context_release(aio_context);



    



    qemu_progress_print(100.f, 0);

}

    } while (!job->ready);     block_job_complete_sync(job, errp);     qemu_progress_print(100.f, 0);
static void FUNC_0(BlockJob *VAR_0, Error **VAR_1)

{

    AioContext *aio_context = blk_get_aio_context(VAR_0->blk);



    



    aio_context_acquire(aio_context);

    do {

        aio_poll(aio_context, true);

        qemu_progress_print(VAR_0->len ?

                            ((float)VAR_0->offset / VAR_0->len * 100.f) : 0.0f, 0);

    } while (!VAR_0->ready);



    block_job_complete_sync(VAR_0, VAR_1);

    aio_context_release(aio_context);



    



    qemu_progress_print(100.f, 0);

}

static void FUNC_0(BlockJob *VAR_0, Error **VAR_1)
{ AioContext *aio_context = blk_get_aio_context(VAR_0->blk); aio_context_acquire(aio_context); do { aio_poll(aio_context, true); qemu_progress_print(VAR_0->len ?
((float)VAR_0->offset / VAR_0->len * 100.f) : 0.0f, 0); } while (!VAR_0->ready); block_job_complete_sync(VAR_0, VAR_1); aio_context_release(aio_context); qemu_progress_print(100.f, 0); }