|
 |
4a2fec |
From 2dc02b39b051394ddbd01aec19bf2f0658d9b56c Mon Sep 17 00:00:00 2001
|
|
|
4a2fec |
From: "Dr. David Alan Gilbert" <dgilbert@redhat.com>
|
|
|
4a2fec |
Date: Wed, 25 Oct 2017 18:28:38 +0200
|
|
|
4a2fec |
Subject: [PATCH 19/19] migration: pause-before-switchover for postcopy
|
|
|
4a2fec |
|
|
|
4a2fec |
RH-Author: Dr. David Alan Gilbert <dgilbert@redhat.com>
|
|
|
4a2fec |
Message-id: <20171025182838.31829-8-dgilbert@redhat.com>
|
|
|
4a2fec |
Patchwork-id: 77441
|
|
|
4a2fec |
O-Subject: [RHV-7.5 qemu-kvm-rhev PATCH 7/7] migration: pause-before-switchover for postcopy
|
|
|
4a2fec |
Bugzilla: 1497120
|
|
|
4a2fec |
RH-Acked-by: Peter Xu <peterx@redhat.com>
|
|
|
4a2fec |
RH-Acked-by: Juan Quintela <quintela@redhat.com>
|
|
|
4a2fec |
RH-Acked-by: Miroslav Rezanina <mrezanin@redhat.com>
|
|
|
4a2fec |
|
|
|
4a2fec |
From: "Dr. David Alan Gilbert" <dgilbert@redhat.com>
|
|
|
4a2fec |
|
|
|
4a2fec |
Add pause-before-switchover support for postcopy.
|
|
|
4a2fec |
After starting postcopy it will transition
|
|
|
4a2fec |
active->pre-switchover->postcopy_active
|
|
|
4a2fec |
|
|
|
4a2fec |
Signed-off-by: Dr. David Alan Gilbert <dgilbert@redhat.com>
|
|
|
4a2fec |
Reviewed-by: Peter Xu <peterx@redhat.com>
|
|
|
4a2fec |
Reviewed-by: Juan Quintela <quintela@redhat.com>
|
|
|
4a2fec |
Signed-off-by: Juan Quintela <quintela@redhat.com>
|
|
|
4a2fec |
(cherry picked from commit 0331c8cabf6168aa263aa0b25f5e135b328606ac)
|
|
|
4a2fec |
Signed-off-by: Miroslav Rezanina <mrezanin@redhat.com>
|
|
|
4a2fec |
---
|
|
|
4a2fec |
migration/migration.c | 29 ++++++++++++++++++++++-------
|
|
|
4a2fec |
1 file changed, 22 insertions(+), 7 deletions(-)
|
|
|
4a2fec |
|
|
|
4a2fec |
diff --git a/migration/migration.c b/migration/migration.c
|
|
|
4a2fec |
index 3f23ed0..1288697 100644
|
|
|
4a2fec |
--- a/migration/migration.c
|
|
|
4a2fec |
+++ b/migration/migration.c
|
|
|
4a2fec |
@@ -105,6 +105,9 @@ bool migrate_pre_2_2;
|
|
|
4a2fec |
static MigrationState *current_migration;
|
|
|
4a2fec |
|
|
|
4a2fec |
static bool migration_object_check(MigrationState *ms, Error **errp);
|
|
|
4a2fec |
+static int migration_maybe_pause(MigrationState *s,
|
|
|
4a2fec |
+ int *current_active_state,
|
|
|
4a2fec |
+ int new_state);
|
|
|
4a2fec |
|
|
|
4a2fec |
void migration_object_init(void)
|
|
|
4a2fec |
{
|
|
|
4a2fec |
@@ -1717,8 +1720,11 @@ static int postcopy_start(MigrationState *ms, bool *old_vm_running)
|
|
|
4a2fec |
QEMUFile *fb;
|
|
|
4a2fec |
int64_t time_at_stop = qemu_clock_get_ms(QEMU_CLOCK_REALTIME);
|
|
|
4a2fec |
bool restart_block = false;
|
|
|
4a2fec |
- migrate_set_state(&ms->state, MIGRATION_STATUS_ACTIVE,
|
|
|
4a2fec |
- MIGRATION_STATUS_POSTCOPY_ACTIVE);
|
|
|
4a2fec |
+ int cur_state = MIGRATION_STATUS_ACTIVE;
|
|
|
4a2fec |
+ if (!migrate_pause_before_switchover()) {
|
|
|
4a2fec |
+ migrate_set_state(&ms->state, MIGRATION_STATUS_ACTIVE,
|
|
|
4a2fec |
+ MIGRATION_STATUS_POSTCOPY_ACTIVE);
|
|
|
4a2fec |
+ }
|
|
|
4a2fec |
|
|
|
4a2fec |
trace_postcopy_start();
|
|
|
4a2fec |
qemu_mutex_lock_iothread();
|
|
|
4a2fec |
@@ -1732,6 +1738,12 @@ static int postcopy_start(MigrationState *ms, bool *old_vm_running)
|
|
|
4a2fec |
goto fail;
|
|
|
4a2fec |
}
|
|
|
4a2fec |
|
|
|
4a2fec |
+ ret = migration_maybe_pause(ms, &cur_state,
|
|
|
4a2fec |
+ MIGRATION_STATUS_POSTCOPY_ACTIVE);
|
|
|
4a2fec |
+ if (ret < 0) {
|
|
|
4a2fec |
+ goto fail;
|
|
|
4a2fec |
+ }
|
|
|
4a2fec |
+
|
|
|
4a2fec |
ret = bdrv_inactivate_all();
|
|
|
4a2fec |
if (ret < 0) {
|
|
|
4a2fec |
goto fail;
|
|
|
4a2fec |
@@ -1866,7 +1878,9 @@ fail:
|
|
|
4a2fec |
* migrate_pause_before_switchover called with the iothread locked
|
|
|
4a2fec |
* Returns: 0 on success
|
|
|
4a2fec |
*/
|
|
|
4a2fec |
-static int migration_maybe_pause(MigrationState *s, int *current_active_state)
|
|
|
4a2fec |
+static int migration_maybe_pause(MigrationState *s,
|
|
|
4a2fec |
+ int *current_active_state,
|
|
|
4a2fec |
+ int new_state)
|
|
|
4a2fec |
{
|
|
|
4a2fec |
if (!migrate_pause_before_switchover()) {
|
|
|
4a2fec |
return 0;
|
|
|
4a2fec |
@@ -1887,11 +1901,11 @@ static int migration_maybe_pause(MigrationState *s, int *current_active_state)
|
|
|
4a2fec |
MIGRATION_STATUS_PRE_SWITCHOVER);
|
|
|
4a2fec |
qemu_sem_wait(&s->pause_sem);
|
|
|
4a2fec |
migrate_set_state(&s->state, MIGRATION_STATUS_PRE_SWITCHOVER,
|
|
|
4a2fec |
- MIGRATION_STATUS_DEVICE);
|
|
|
4a2fec |
- *current_active_state = MIGRATION_STATUS_DEVICE;
|
|
|
4a2fec |
+ new_state);
|
|
|
4a2fec |
+ *current_active_state = new_state;
|
|
|
4a2fec |
qemu_mutex_lock_iothread();
|
|
|
4a2fec |
|
|
|
4a2fec |
- return s->state == MIGRATION_STATUS_DEVICE ? 0 : -EINVAL;
|
|
|
4a2fec |
+ return s->state == new_state ? 0 : -EINVAL;
|
|
|
4a2fec |
}
|
|
|
4a2fec |
|
|
|
4a2fec |
/**
|
|
|
4a2fec |
@@ -1920,7 +1934,8 @@ static void migration_completion(MigrationState *s, int current_active_state,
|
|
|
4a2fec |
bool inactivate = !migrate_colo_enabled();
|
|
|
4a2fec |
ret = vm_stop_force_state(RUN_STATE_FINISH_MIGRATE);
|
|
|
4a2fec |
if (ret >= 0) {
|
|
|
4a2fec |
- ret = migration_maybe_pause(s, ¤t_active_state);
|
|
|
4a2fec |
+ ret = migration_maybe_pause(s, ¤t_active_state,
|
|
|
4a2fec |
+ MIGRATION_STATUS_DEVICE);
|
|
|
4a2fec |
}
|
|
|
4a2fec |
if (ret >= 0) {
|
|
|
4a2fec |
qemu_file_set_rate_limit(s->to_dst_file, INT64_MAX);
|
|
|
4a2fec |
--
|
|
|
4a2fec |
1.8.3.1
|
|
|
4a2fec |
|