void iothread_stop(IOThread *iothread)

{

    if (!iothread->ctx || iothread->stopping) {

        return;

    }

    iothread->stopping = true;

    aio_notify(iothread->ctx);

    if (atomic_read(&iothread->main_loop)) {

        g_main_loop_quit(iothread->main_loop);

    }

    qemu_thread_join(&iothread->thread);

}

void iothread_stop(IOThread *iothread)

{

    if (!iothread->ctx || iothread->stopping) {

        return;

    }

    iothread->stopping = true;

    aio_notify(iothread->ctx);

    if (atomic_read(&iothread->main_loop)) {

        g_main_loop_quit(iothread->main_loop);

    }

    qemu_thread_join(&iothread->thread);

}

    aio_notify(iothread->ctx);     if (atomic_read(&iothread->main_loop)) {         g_main_loop_quit(iothread->main_loop);
void FUNC_0(IOThread *VAR_0)

{

    if (!VAR_0->ctx || VAR_0->stopping) {

        return;

    }

    VAR_0->stopping = true;

    aio_notify(VAR_0->ctx);

    if (atomic_read(&VAR_0->main_loop)) {

        g_main_loop_quit(VAR_0->main_loop);

    }

    qemu_thread_join(&VAR_0->thread);

}

void FUNC_0(IOThread *VAR_0)
{ if (!VAR_0->ctx || VAR_0->stopping) { return; } VAR_0->stopping = true; aio_notify(VAR_0->ctx); if (atomic_read(&VAR_0->main_loop)) { g_main_loop_quit(VAR_0->main_loop); } qemu_thread_join(&VAR_0->thread); }