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): check disk is deleted on delete snapshot (#21367)

Browse Source
This commit is contained in:
wanyaoqi
2024-10-09 21:48:37 +08:00
committed by GitHub
parent 71fbb8336e
commit 1641c178b9
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/compute/storagedrivers/base.go
+8 -7
View File
@@ -113,15 +113,16 @@ func (self *SBaseStorageDriver) RequestDeleteSnapshot(ctx context.Context, snaps
if err != nil && err != sql.ErrNoRows {
return errors.Wrap(err, "get disk by snapshot")
}
sDisk, _ := disk.(*models.SDisk)
if sDisk.IsEncrypted() {
if encryptInfo, err := sDisk.GetEncryptInfo(ctx, task.GetUserCred()); err != nil {
return errors.Wrap(err, "faild get encryptInfo")
} else {
params.Set("encrypt_info", jsonutils.Marshal(encryptInfo))
if disk != nil {
sDisk, _ := disk.(*models.SDisk)
if sDisk.IsEncrypted() {
if encryptInfo, err := sDisk.GetEncryptInfo(ctx, task.GetUserCred()); err != nil {
return errors.Wrap(err, "faild get encryptInfo")
} else {
params.Set("encrypt_info", jsonutils.Marshal(encryptInfo))
}
}
}
if !snapshot.OutOfChain {
if convertSnapshot != nil {
params.Set("convert_snapshot", jsonutils.NewString(convertSnapshot.Id))