[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[Qemu-devel] [PATCH v6 12/28] migration: rebuild channel on source
From: |
Peter Xu |
Subject: |
[Qemu-devel] [PATCH v6 12/28] migration: rebuild channel on source |
Date: |
Thu, 8 Feb 2018 18:31:16 +0800 |
This patch detects the "resume" flag of migration command, rebuild the
channels only if the flag is set.
Reviewed-by: Dr. David Alan Gilbert <address@hidden>
Signed-off-by: Peter Xu <address@hidden>
---
migration/migration.c | 91 +++++++++++++++++++++++++++++++++++++++------------
1 file changed, 70 insertions(+), 21 deletions(-)
diff --git a/migration/migration.c b/migration/migration.c
index 37b7170c20..2088a1d1bf 100644
--- a/migration/migration.c
+++ b/migration/migration.c
@@ -1357,49 +1357,75 @@ bool migration_is_blocked(Error **errp)
return false;
}
-void qmp_migrate(const char *uri, bool has_blk, bool blk,
- bool has_inc, bool inc, bool has_detach, bool detach,
- bool has_resume, bool resume, Error **errp)
+/* Returns true if continue to migrate, or false if error detected */
+static bool migrate_prepare(MigrationState *s, bool blk, bool blk_inc,
+ bool resume, Error **errp)
{
Error *local_err = NULL;
- MigrationState *s = migrate_get_current();
- const char *p;
+
+ if (resume) {
+ if (s->state != MIGRATION_STATUS_POSTCOPY_PAUSED) {
+ error_setg(errp, "Cannot resume if there is no "
+ "paused migration");
+ return false;
+ }
+ /* This is a resume, skip init status */
+ return true;
+ }
if (migration_is_setup_or_active(s->state) ||
s->state == MIGRATION_STATUS_CANCELLING ||
s->state == MIGRATION_STATUS_COLO) {
error_setg(errp, QERR_MIGRATION_ACTIVE);
- return;
+ return false;
}
+
if (runstate_check(RUN_STATE_INMIGRATE)) {
error_setg(errp, "Guest is waiting for an incoming migration");
- return;
+ return false;
}
if (migration_is_blocked(errp)) {
- return;
+ return false;
}
- if ((has_blk && blk) || (has_inc && inc)) {
+ if (blk || blk_inc) {
if (migrate_use_block() || migrate_use_block_incremental()) {
error_setg(errp, "Command options are incompatible with "
"current migration capabilities");
- return;
+ return false;
}
migrate_set_block_enabled(true, &local_err);
if (local_err) {
error_propagate(errp, local_err);
- return;
+ return false;
}
s->must_remove_block_options = true;
}
- if (has_inc && inc) {
+ if (blk_inc) {
migrate_set_block_incremental(s, true);
}
migrate_init(s);
+ return true;
+}
+
+void qmp_migrate(const char *uri, bool has_blk, bool blk,
+ bool has_inc, bool inc, bool has_detach, bool detach,
+ bool has_resume, bool resume, Error **errp)
+{
+ Error *local_err = NULL;
+ MigrationState *s = migrate_get_current();
+ const char *p;
+
+ if (!migrate_prepare(s, has_blk && blk, has_inc && inc,
+ has_resume && resume, errp)) {
+ /* Error detected, put into errp */
+ return;
+ }
+
if (strstart(uri, "tcp:", &p)) {
tcp_start_outgoing_migration(s, p, &local_err);
#ifdef CONFIG_RDMA
@@ -1855,7 +1881,8 @@ out:
return NULL;
}
-static int open_return_path_on_source(MigrationState *ms)
+static int open_return_path_on_source(MigrationState *ms,
+ bool create_thread)
{
ms->rp_state.from_dst_file = qemu_file_get_return_path(ms->to_dst_file);
@@ -1864,6 +1891,12 @@ static int open_return_path_on_source(MigrationState *ms)
}
trace_open_return_path_on_source();
+
+ if (!create_thread) {
+ /* We're done */
+ return 0;
+ }
+
qemu_thread_create(&ms->rp_state.rp_thread, "return path",
source_return_path_thread, ms, QEMU_THREAD_JOINABLE);
@@ -2520,6 +2553,9 @@ static void *migration_thread(void *opaque)
void migrate_fd_connect(MigrationState *s, Error *error_in)
{
+ int64_t rate_limit;
+ bool resume = s->state == MIGRATION_STATUS_POSTCOPY_PAUSED;
+
s->expected_downtime = s->parameters.downtime_limit;
s->cleanup_bh = qemu_bh_new(migrate_fd_cleanup, s);
if (error_in) {
@@ -2528,12 +2564,21 @@ void migrate_fd_connect(MigrationState *s, Error
*error_in)
return;
}
- qemu_file_set_blocking(s->to_dst_file, true);
- qemu_file_set_rate_limit(s->to_dst_file,
- s->parameters.max_bandwidth / XFER_LIMIT_RATIO);
+ if (resume) {
+ /* This is a resumed migration */
+ rate_limit = INT64_MAX;
+ } else {
+ /* This is a fresh new migration */
+ rate_limit = s->parameters.max_bandwidth / XFER_LIMIT_RATIO;
+ s->expected_downtime = s->parameters.downtime_limit;
+ s->cleanup_bh = qemu_bh_new(migrate_fd_cleanup, s);
- /* Notify before starting migration thread */
- notifier_list_notify(&migration_state_notifiers, s);
+ /* Notify before starting migration thread */
+ notifier_list_notify(&migration_state_notifiers, s);
+ }
+
+ qemu_file_set_rate_limit(s->to_dst_file, rate_limit);
+ qemu_file_set_blocking(s->to_dst_file, true);
/*
* Open the return path. For postcopy, it is used exclusively. For
@@ -2541,15 +2586,19 @@ void migrate_fd_connect(MigrationState *s, Error
*error_in)
* QEMU uses the return path.
*/
if (migrate_postcopy_ram() || migrate_use_return_path()) {
- if (open_return_path_on_source(s)) {
+ if (open_return_path_on_source(s, !resume)) {
error_report("Unable to open return-path for postcopy");
- migrate_set_state(&s->state, MIGRATION_STATUS_SETUP,
- MIGRATION_STATUS_FAILED);
+ migrate_set_state(&s->state, s->state, MIGRATION_STATUS_FAILED);
migrate_fd_cleanup(s);
return;
}
}
+ if (resume) {
+ /* TODO: do the resume logic */
+ return;
+ }
+
if (multifd_save_setup() != 0) {
migrate_set_state(&s->state, MIGRATION_STATUS_SETUP,
MIGRATION_STATUS_FAILED);
--
2.14.3
- [Qemu-devel] [PATCH v6 03/28] migration: provide postcopy_fault_thread_notify(), (continued)
- [Qemu-devel] [PATCH v6 03/28] migration: provide postcopy_fault_thread_notify(), Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 02/28] migration: reuse mis->userfault_quit_fd, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 05/28] migration: implement "postcopy-pause" src logic, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 04/28] migration: new postcopy-pause state, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 06/28] migration: allow dst vm pause on postcopy, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 07/28] migration: allow src return path to pause, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 08/28] migration: allow send_rq to fail, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 09/28] migration: allow fault thread to pause, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 10/28] qmp: hmp: add migrate "resume" option, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 11/28] migration: pass MigrationState to migrate_init(), Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 12/28] migration: rebuild channel on source,
Peter Xu <=
- [Qemu-devel] [PATCH v6 13/28] migration: new state "postcopy-recover", Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 14/28] migration: wakeup dst ram-load-thread for recover, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 15/28] migration: new cmd MIG_CMD_RECV_BITMAP, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 16/28] migration: new message MIG_RP_MSG_RECV_BITMAP, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 17/28] migration: new cmd MIG_CMD_POSTCOPY_RESUME, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 18/28] migration: new message MIG_RP_MSG_RESUME_ACK, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 19/28] migration: introduce SaveVMHandlers.resume_prepare, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 20/28] migration: synchronize dirty bitmap for resume, Peter Xu, 2018/02/08
- [Qemu-devel] [PATCH v6 21/28] migration: setup ramstate for resume, Peter Xu, 2018/02/08