|
 |
459f93 |
From 35f06623b82d99dd380340eef465394975dd1c80 Mon Sep 17 00:00:00 2001
|
|
|
459f93 |
Message-Id: <35f06623b82d99dd380340eef465394975dd1c80@dist-git>
|
|
|
459f93 |
From: Jiri Denemark <jdenemar@redhat.com>
|
|
|
459f93 |
Date: Wed, 22 Jun 2022 16:37:31 +0200
|
|
|
459f93 |
Subject: [PATCH] qemu_migration: Implement VIR_MIGRATE_ZEROCOPY flag
|
|
|
459f93 |
MIME-Version: 1.0
|
|
|
459f93 |
Content-Type: text/plain; charset=UTF-8
|
|
|
459f93 |
Content-Transfer-Encoding: 8bit
|
|
|
459f93 |
|
|
|
459f93 |
Resolves: https://gitlab.com/libvirt/libvirt/-/issues/306
|
|
|
459f93 |
|
|
|
459f93 |
Signed-off-by: Jiri Denemark <jdenemar@redhat.com>
|
|
|
459f93 |
Reviewed-by: Ján Tomko <jtomko@redhat.com>
|
|
|
459f93 |
(cherry picked from commit d375993ab314a41bca7ef6c846e07afc18c37774)
|
|
|
459f93 |
|
|
|
459f93 |
https://bugzilla.redhat.com/show_bug.cgi?id=2089433
|
|
|
459f93 |
|
|
|
459f93 |
Conflicts:
|
|
|
459f93 |
src/qemu/qemu_migration.c
|
|
|
459f93 |
src/qemu/qemu_migration.h
|
|
|
459f93 |
- post-copy recovery not bacported
|
|
|
459f93 |
|
|
|
459f93 |
Signed-off-by: Jiri Denemark <jdenemar@redhat.com>
|
|
|
459f93 |
---
|
|
|
459f93 |
src/qemu/qemu_migration.c | 21 +++++++++++++++++++++
|
|
|
459f93 |
src/qemu/qemu_migration.h | 1 +
|
|
|
459f93 |
src/qemu/qemu_migration_params.c | 6 ++++++
|
|
|
459f93 |
src/qemu/qemu_migration_params.h | 1 +
|
|
|
459f93 |
4 files changed, 29 insertions(+)
|
|
|
459f93 |
|
|
|
459f93 |
diff --git a/src/qemu/qemu_migration.c b/src/qemu/qemu_migration.c
|
|
|
459f93 |
index 35ad201580..db5163e993 100644
|
|
|
459f93 |
--- a/src/qemu/qemu_migration.c
|
|
|
459f93 |
+++ b/src/qemu/qemu_migration.c
|
|
|
459f93 |
@@ -2366,6 +2366,12 @@ qemuMigrationSrcBeginPhase(virQEMUDriver *driver,
|
|
|
459f93 |
return NULL;
|
|
|
459f93 |
}
|
|
|
459f93 |
|
|
|
459f93 |
+ if (flags & VIR_MIGRATE_ZEROCOPY && !(flags & VIR_MIGRATE_PARALLEL)) {
|
|
|
459f93 |
+ virReportError(VIR_ERR_OPERATION_INVALID, "%s",
|
|
|
459f93 |
+ _("zero-copy is only available for parallel migration"));
|
|
|
459f93 |
+ return NULL;
|
|
|
459f93 |
+ }
|
|
|
459f93 |
+
|
|
|
459f93 |
if (flags & (VIR_MIGRATE_NON_SHARED_DISK | VIR_MIGRATE_NON_SHARED_INC)) {
|
|
|
459f93 |
if (flags & VIR_MIGRATE_NON_SHARED_SYNCHRONOUS_WRITES &&
|
|
|
459f93 |
!virQEMUCapsGet(priv->qemuCaps, QEMU_CAPS_BLOCKDEV)) {
|
|
|
459f93 |
@@ -4137,6 +4143,21 @@ qemuMigrationSrcRun(virQEMUDriver *driver,
|
|
|
459f93 |
migParams) < 0)
|
|
|
459f93 |
goto error;
|
|
|
459f93 |
|
|
|
459f93 |
+ if (flags & VIR_MIGRATE_ZEROCOPY) {
|
|
|
459f93 |
+ /* Zero-copy requires pages in transfer to be locked in host memory.
|
|
|
459f93 |
+ * Unfortunately, we have no reliable way of computing how many pages
|
|
|
459f93 |
+ * will need to be locked at the same time. Thus we set the limit to
|
|
|
459f93 |
+ * the whole guest memory and reset it back once migration is done. */
|
|
|
459f93 |
+ unsigned long long limit;
|
|
|
459f93 |
+
|
|
|
459f93 |
+ if (virMemoryLimitIsSet(vm->def->mem.hard_limit))
|
|
|
459f93 |
+ limit = vm->def->mem.hard_limit;
|
|
|
459f93 |
+ else
|
|
|
459f93 |
+ limit = virDomainDefGetMemoryTotal(vm->def);
|
|
|
459f93 |
+
|
|
|
459f93 |
+ if (qemuDomainSetMaxMemLock(vm, limit << 10, &priv->preMigrationMemlock) < 0)
|
|
|
459f93 |
+ goto error;
|
|
|
459f93 |
+ }
|
|
|
459f93 |
|
|
|
459f93 |
if (storageMigration) {
|
|
|
459f93 |
if (mig->nbd) {
|
|
|
459f93 |
diff --git a/src/qemu/qemu_migration.h b/src/qemu/qemu_migration.h
|
|
|
459f93 |
index b233358a51..6f737f7b4c 100644
|
|
|
459f93 |
--- a/src/qemu/qemu_migration.h
|
|
|
459f93 |
+++ b/src/qemu/qemu_migration.h
|
|
|
459f93 |
@@ -60,6 +60,7 @@
|
|
|
459f93 |
VIR_MIGRATE_TLS | \
|
|
|
459f93 |
VIR_MIGRATE_PARALLEL | \
|
|
|
459f93 |
VIR_MIGRATE_NON_SHARED_SYNCHRONOUS_WRITES | \
|
|
|
459f93 |
+ VIR_MIGRATE_ZEROCOPY | \
|
|
|
459f93 |
0)
|
|
|
459f93 |
|
|
|
459f93 |
/* All supported migration parameters and their types. */
|
|
|
459f93 |
diff --git a/src/qemu/qemu_migration_params.c b/src/qemu/qemu_migration_params.c
|
|
|
459f93 |
index 7b225fdf4b..c985583861 100644
|
|
|
459f93 |
--- a/src/qemu/qemu_migration_params.c
|
|
|
459f93 |
+++ b/src/qemu/qemu_migration_params.c
|
|
|
459f93 |
@@ -96,6 +96,7 @@ VIR_ENUM_IMPL(qemuMigrationCapability,
|
|
|
459f93 |
"multifd",
|
|
|
459f93 |
"dirty-bitmaps",
|
|
|
459f93 |
"return-path",
|
|
|
459f93 |
+ "zero-copy-send",
|
|
|
459f93 |
);
|
|
|
459f93 |
|
|
|
459f93 |
|
|
|
459f93 |
@@ -177,6 +178,11 @@ static const qemuMigrationParamsFlagMapItem qemuMigrationParamsFlagMap[] = {
|
|
|
459f93 |
VIR_MIGRATE_TUNNELLED,
|
|
|
459f93 |
QEMU_MIGRATION_CAP_RETURN_PATH,
|
|
|
459f93 |
QEMU_MIGRATION_SOURCE | QEMU_MIGRATION_DESTINATION},
|
|
|
459f93 |
+
|
|
|
459f93 |
+ {QEMU_MIGRATION_FLAG_REQUIRED,
|
|
|
459f93 |
+ VIR_MIGRATE_ZEROCOPY,
|
|
|
459f93 |
+ QEMU_MIGRATION_CAP_ZERO_COPY_SEND,
|
|
|
459f93 |
+ QEMU_MIGRATION_SOURCE},
|
|
|
459f93 |
};
|
|
|
459f93 |
|
|
|
459f93 |
/* Translation from VIR_MIGRATE_PARAM_* typed parameters to
|
|
|
459f93 |
diff --git a/src/qemu/qemu_migration_params.h b/src/qemu/qemu_migration_params.h
|
|
|
459f93 |
index b4de8dda7b..caa5e47f0f 100644
|
|
|
459f93 |
--- a/src/qemu/qemu_migration_params.h
|
|
|
459f93 |
+++ b/src/qemu/qemu_migration_params.h
|
|
|
459f93 |
@@ -41,6 +41,7 @@ typedef enum {
|
|
|
459f93 |
QEMU_MIGRATION_CAP_MULTIFD,
|
|
|
459f93 |
QEMU_MIGRATION_CAP_BLOCK_DIRTY_BITMAPS,
|
|
|
459f93 |
QEMU_MIGRATION_CAP_RETURN_PATH,
|
|
|
459f93 |
+ QEMU_MIGRATION_CAP_ZERO_COPY_SEND,
|
|
|
459f93 |
|
|
|
459f93 |
QEMU_MIGRATION_CAP_LAST
|
|
|
459f93 |
} qemuMigrationCapability;
|
|
|
459f93 |
--
|
|
|
459f93 |
2.35.1
|
|
|
459f93 |
|