Skip to content

Commit

Permalink
migration: Split migration_fd_process_incoming
Browse files Browse the repository at this point in the history
We need that on later patches.

Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
Reviewed-by: Peter Xu <peterx@redhat.com>
Reviewed-by: Daniel P. Berrange <berrange@redhat.com>
  • Loading branch information
Juan Quintela committed Sep 22, 2017
1 parent f986c3d commit e595a01
Showing 1 changed file with 12 additions and 2 deletions.
14 changes: 12 additions & 2 deletions migration/migration.c
Expand Up @@ -372,9 +372,8 @@ static void process_incoming_migration_co(void *opaque)
qemu_bh_schedule(mis->bh);
}

void migration_fd_process_incoming(QEMUFile *f)
static void migration_incoming_setup(QEMUFile *f)
{
Coroutine *co = qemu_coroutine_create(process_incoming_migration_co, NULL);
MigrationIncomingState *mis = migration_incoming_get_current();

if (multifd_load_setup() != 0) {
Expand All @@ -387,9 +386,20 @@ void migration_fd_process_incoming(QEMUFile *f)
mis->from_src_file = f;
}
qemu_file_set_blocking(f, false);
}

static void migration_incoming_process(void)
{
Coroutine *co = qemu_coroutine_create(process_incoming_migration_co, NULL);
qemu_coroutine_enter(co);
}

void migration_fd_process_incoming(QEMUFile *f)
{
migration_incoming_setup(f);
migration_incoming_process();
}

void migration_ioc_process_incoming(QIOChannel *ioc)
{
MigrationIncomingState *mis = migration_incoming_get_current();
Expand Down

0 comments on commit e595a01

Please sign in to comment.