提交 e595a01a 编写于 作者: J Juan Quintela

migration: Split migration_fd_process_incoming

We need that on later patches.
Signed-off-by: NJuan Quintela <quintela@redhat.com>
Reviewed-by: NDr. David Alan Gilbert <dgilbert@redhat.com>
Reviewed-by: NPeter Xu <peterx@redhat.com>
Reviewed-by: NDaniel P. Berrange <berrange@redhat.com>
上级 f986c3d2
......@@ -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) {
......@@ -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();
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册