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(region): insert iso sync guest status (#20535)

Browse Source
This commit is contained in:
wanyaoqi
2024-06-16 22:59:45 +08:00
committed by GitHub
parent 7d7ca5bdc4
commit 2ff45831c0
1 changed files with 16 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/tasks/storage_cache_image_task.go
+16 -2
View File
@@ -62,8 +62,6 @@ func (self *StorageCacheImageTask) OnRelinquishLeastUsedCachedImageComplete(ctx
db.OpsLog.LogEvent(storageCache, db.ACT_CACHING_IMAGE, imageId, self.UserCred)
self.SetStage("OnImageCacheComplete", nil)
var host *models.SHost
var err error
serverId, _ := self.Params.GetString("server_id")
@@ -75,6 +73,7 @@ func (self *StorageCacheImageTask) OnRelinquishLeastUsedCachedImageComplete(ctx
return
}
server := guest.(*models.SGuest)
self.Params.Set("guest_old_status", jsonutils.NewString(server.Status))
server.SetStatus(ctx, self.GetUserCred(), api.VM_IMAGE_CACHING, "")
host, _ = server.GetHost()
} else {
@@ -86,6 +85,7 @@ func (self *StorageCacheImageTask) OnRelinquishLeastUsedCachedImageComplete(ctx
}
}
self.SetStage("OnImageCacheComplete", nil)
err = host.GetHostDriver().CheckAndSetCacheImage(ctx, self.UserCred, host, storageCache, self)
if err != nil {
errData := taskman.Error2TaskData(err)
@@ -132,6 +132,20 @@ func (self *StorageCacheImageTask) OnCacheSucc(ctx context.Context, cache *model
if len(extImgId) > 0 && scimg.ExternalId != extImgId {
scimg.SetExternalId(extImgId)
}
serverId, _ := self.Params.GetString("server_id")
if len(serverId) > 0 {
guest, err := models.GuestManager.FetchById(serverId)
if err != nil {
errData := taskman.Error2TaskData(err)
self.OnImageCacheCompleteFailed(ctx, cache, errData)
return
}
server := guest.(*models.SGuest)
oldStatus, _ := self.Params.GetString("guest_old_status")
server.SetStatus(ctx, self.GetUserCred(), oldStatus, "on cache succ")
}
models.CachedimageManager.ImageAddRefCount(imageId)
db.OpsLog.LogEvent(cache, db.ACT_CACHED_IMAGE, imageId, self.UserCred)
self.SetStageComplete(ctx, data)