The function can be used as a callback for qemuDomainCleanupAdd to
automatically clean up a migration job when a domain is destroyed.
Signed-off-by: Jiri Denemark <jdenemar@xxxxxxxxxx>
---
src/qemu/qemu_process.c | 25 +++++++++++++++++++++++++
src/qemu/qemu_process.h | 3 +++
2 files changed, 28 insertions(+)
diff --git a/src/qemu/qemu_process.c b/src/qemu/qemu_process.c
index a3192a7196..dba3ad8c87 100644
--- a/src/qemu/qemu_process.c
+++ b/src/qemu/qemu_process.c
@@ -3431,6 +3431,31 @@ qemuProcessUpdateState(virQEMUDriver *driver, virDomainObj *vm)
return 0;
}
+
+void
+qemuProcessCleanupMigrationJob(virQEMUDriver *driver,
+ virDomainObj *vm)
+{
+ qemuDomainObjPrivate *priv = vm->privateData;
+ virDomainState state;
+ int reason;
+
+ state = virDomainObjGetState(vm, &reason);
+
+ VIR_DEBUG("driver=%p, vm=%s, asyncJob=%s, state=%s, reason=%s",
+ driver, vm->def->name,
+ virDomainAsyncJobTypeToString(priv->job.asyncJob),
+ virDomainStateTypeToString(state),
+ virDomainStateReasonToString(state, reason));
+
+ if (priv->job.asyncJob != VIR_ASYNC_JOB_MIGRATION_IN &&
+ priv->job.asyncJob != VIR_ASYNC_JOB_MIGRATION_OUT)
+ return;
+
+ qemuDomainObjDiscardAsyncJob(vm);
+}
+
+
static int
qemuProcessRecoverMigrationIn(virQEMUDriver *driver,
virDomainObj *vm,
diff --git a/src/qemu/qemu_process.h b/src/qemu/qemu_process.h
index f81bfd930a..73e6110eee 100644
--- a/src/qemu/qemu_process.h
+++ b/src/qemu/qemu_process.h
@@ -244,3 +244,6 @@ G_DEFINE_AUTOPTR_CLEANUP_FUNC(qemuProcessQMP, qemuProcessQMPFree);
int qemuProcessQMPStart(qemuProcessQMP *proc);
bool qemuProcessRebootAllowed(const virDomainDef *def);
+
+void qemuProcessCleanupMigrationJob(virQEMUDriver *driver,
+ virDomainObj *vm);
--
2.35.1
