External/libvirt
1
0
Fork 0
mirror of https://gitlab.com/libvirt/libvirt.git synced 2025-03-07 17:28:15 +00:00
Code

qemu: Handle incoming migration in qemuMigrationAnyConnectionClosed

Browse Source 
Signed-off-by: Jiri Denemark <jdenemar@redhat.com>
Reviewed-by: Peter Krempa <pkrempa@redhat.com>
Reviewed-by: Pavel Hrdina <phrdina@redhat.com>
This commit is contained in:
Jiri Denemark 2022-05-19 16:44:41 +02:00
parent 5eec0b4b2d
commit 4f22d2f883
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/qemu/qemu_migration.c
View File

@ -2350,12 +2350,12 @@ qemuMigrationAnyConnectionClosed(virDomainObj *vm,
case QEMU_MIGRATION_PHASE_POSTCOPY_FAILED: case QEMU_MIGRATION_PHASE_POSTCOPY_FAILED:
case QEMU_MIGRATION_PHASE_BEGIN_RESUME: case QEMU_MIGRATION_PHASE_BEGIN_RESUME:
case QEMU_MIGRATION_PHASE_PERFORM_RESUME: case QEMU_MIGRATION_PHASE_PERFORM_RESUME:
case QEMU_MIGRATION_PHASE_PREPARE_RESUME:
VIR_DEBUG("Connection closed while resuming failed post-copy migration"); VIR_DEBUG("Connection closed while resuming failed post-copy migration");
postcopy = true; postcopy = true;
break; break;
case QEMU_MIGRATION_PHASE_PREPARE: case QEMU_MIGRATION_PHASE_PREPARE:
case QEMU_MIGRATION_PHASE_PREPARE_RESUME:
/* incoming migration; the domain will be autodestroyed */ /* incoming migration; the domain will be autodestroyed */
return; return;
@ -2379,6 +2379,8 @@ qemuMigrationAnyConnectionClosed(virDomainObj *vm,
if (postcopy) { if (postcopy) {
if (priv->job.asyncJob == VIR_ASYNC_JOB_MIGRATION_OUT) if (priv->job.asyncJob == VIR_ASYNC_JOB_MIGRATION_OUT)
qemuMigrationSrcPostcopyFailed(vm); qemuMigrationSrcPostcopyFailed(vm);
else
qemuMigrationDstPostcopyFailed(vm);
ignore_value(qemuMigrationJobSetPhase(vm, QEMU_MIGRATION_PHASE_POSTCOPY_FAILED)); ignore_value(qemuMigrationJobSetPhase(vm, QEMU_MIGRATION_PHASE_POSTCOPY_FAILED));
qemuDomainCleanupAdd(vm, qemuProcessCleanupMigrationJob); qemuDomainCleanupAdd(vm, qemuProcessCleanupMigrationJob);
qemuMigrationJobContinue(vm); qemuMigrationJobContinue(vm);