opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-19 02:37:24 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix ceph rescue mode migrate

Browse Source
This commit is contained in:
wanyaoqi
2019-08-15 16:00:03 +08:00
parent ceace185bb
commit 5029adcfd7
1 changed files with 12 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/tasks/guest_live_migrate_task.go
+12 -8
View File
@@ -130,14 +130,18 @@ func (self *GuestMigrateTask) OnCachedImageComplete(ctx context.Context, guest *
body.Set("live_migrate", jsonutils.JSONTrue)
}
host := guest.GetHost()
url := fmt.Sprintf("%s/servers/%s/src-prepare-migrate", host.ManagerUri, guest.Id)
self.SetStage("OnSrcPrepareComplete", nil)
_, _, err := httputils.JSONRequest(httputils.GetDefaultClient(), ctx, "POST",
url, header, body, false)
if err != nil {
self.TaskFailed(ctx, guest, fmt.Sprintf("Prepare migrage failed: %s", err))
return
if !jsonutils.QueryBoolean(self.Params, "is_rescue_mode", false) {
host := guest.GetHost()
url := fmt.Sprintf("%s/servers/%s/src-prepare-migrate", host.ManagerUri, guest.Id)
self.SetStage("OnSrcPrepareComplete", nil)
_, _, err := httputils.JSONRequest(httputils.GetDefaultClient(), ctx, "POST",
url, header, body, false)
if err != nil {
self.TaskFailed(ctx, guest, fmt.Sprintf("Prepare migrage failed: %s", err))
return
}
} else {
self.OnSrcPrepareComplete(ctx, guest, nil)
}
}