opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-11-04 05:22:40 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: handle exception that qemu quit or cancel migrate during migration

Browse Source
This commit is contained in:
Qiu Jian
2022-01-16 15:33:37 +08:00
parent 4935993b85
commit e18da15479
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/hostman/guestman/guesttasks.go
+9 -2
View File
@@ -682,7 +682,14 @@ func (s *SGuestLiveMigrateTask) startMigrateStatusCheck(res string) {
s.c = nil
break
case <-time.After(time.Second * 5):
s.Monitor.GetMigrateStatus(s.onGetMigrateStatus)
if s.Monitor != nil {
s.Monitor.GetMigrateStatus(s.onGetMigrateStatus)
} else {
log.Errorf("server %s(%s) migrate stopped unexpectedly", s.GetId(), s.GetName())
s.migrateTask = nil
hostutils.TaskFailed(s.ctx, fmt.Sprintf("Migrate error: %s", res))
return
}
}
}
}
@@ -690,7 +697,7 @@ func (s *SGuestLiveMigrateTask) startMigrateStatusCheck(res string) {
func (s *SGuestLiveMigrateTask) onGetMigrateStatus(status string) {
if status == "completed" {
s.migrateComplete()
} else if status == "failed" {
} else if status == "failed" || status == "cancelled" {
s.migrateTask = nil
close(s.c)
hostutils.TaskFailed(s.ctx, fmt.Sprintf("Query migrate got status: %s", status))