Commit 82a4da79 authored by Paolo Bonzini's avatar Paolo Bonzini
Browse files

migration: move process_incoming_migration to a coroutine 



The final part of incoming migration, which now consists of
process_incoming_migration for all protocols, is thus made non-blocking.

Reviewed-by: default avatarOrit Wasserman <owasserm@redhat.com>
Signed-off-by: default avatarPaolo Bonzini <pbonzini@redhat.com>
parent 595ab641

migration.c

+20 −1
Original line number Diff line number Diff line
@@ -83,11 +83,13 @@ void qemu_start_incoming_migration(const char *uri, Error **errp) 
    }

}



void process_incoming_migration(QEMUFile *f)

static void process_incoming_migration_co(void *opaque)

{

    QEMUFile *f = opaque;

    int ret;



    ret = qemu_loadvm_state(f);

    qemu_set_fd_handler(qemu_get_fd(f), NULL, NULL, NULL);

    qemu_fclose(f);

    if (ret < 0) {

        fprintf(stderr, "load of migration failed\n");
@@ -107,6 +109,23 @@ void process_incoming_migration(QEMUFile *f) 
    }

}



static void enter_migration_coroutine(void *opaque)

{

    Coroutine *co = opaque;

    qemu_coroutine_enter(co, NULL);

}



void process_incoming_migration(QEMUFile *f)

{

    Coroutine *co = qemu_coroutine_create(process_incoming_migration_co);

    int fd = qemu_get_fd(f);



    assert(fd != -1);

    socket_set_nonblock(fd);

    qemu_set_fd_handler(fd, enter_migration_coroutine, NULL, co);

    qemu_coroutine_enter(co, f);

}



/* amount of nanoseconds we are willing to wait for migration to be down.

 * the choice of nanoseconds is because it is the maximum resolution that

 * get_clock() can achieve. It is an internal measure. All user-visible