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

fix(host): dist prepare migrate_certs

Browse Source
This commit is contained in:
Zexi Li
2022-02-08 12:31:04 +08:00
parent d8e3cb0e56
commit 47691fae67
1 changed files with 11 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/hostman/guestman/guesthandlers/guesthandler.go
+11 -9
View File
@@ -311,16 +311,18 @@ func guestDestPrepareMigrate(ctx context.Context, sid string, body jsonutils.JSO
params.QemuVersion = qemuVersion
params.LiveMigrate = liveMigrate
params.SourceQemuCmdline = qemuCmdline
certsObj, err := body.Get("migrate_certs")
if err != nil {
return nil, httperrors.NewMissingParameterError("migrate_certs")
}
certs := map[string]string{}
if err := certsObj.Unmarshal(&certs); err != nil {
return nil, httperrors.NewInputParameterError("unmarshal migrate_certs to map: %s", err)
}
params.MigrateCerts = certs
params.EnableTLS = jsonutils.QueryBoolean(body, "enable_tls", false)
if params.EnableTLS {
certsObj, err := body.Get("migrate_certs")
if err != nil {
return nil, httperrors.NewMissingParameterError("migrate_certs")
}
certs := map[string]string{}
if err := certsObj.Unmarshal(&certs); err != nil {
return nil, httperrors.NewInputParameterError("unmarshal migrate_certs to map: %s", err)
}
params.MigrateCerts = certs
}
if isLocal {
serverUrl, err := body.GetString("server_url")
if err != nil {