lywsvip/cloudpods
1
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-06-01 21:41:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: fail to delete storages with fake-deleted snapshots

Browse Source
This commit is contained in:
Qiu Jian
2022-04-25 22:40:57 +08:00
parent 69a3dd46b0
commit e735c800a2
2 changed files with 31 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
pkg/compute/models/storages.go
View File

@@ -174,7 +174,28 @@ func (self *SStorage) AllowDeleteItem(ctx context.Context, userCred mcclient.Tok
return db.IsAdminAllowDelete(userCred, self)
}
func (self *SStorage) getFakeDeletedSnapshots() ([]SSnapshot, error) {
q := SnapshotManager.Query().Equals("storage_id", self.Id).IsTrue("fake_deleted")
snapshots := make([]SSnapshot, 0)
err := db.FetchModelObjects(SnapshotManager, q, &snapshots)
if err != nil {
return nil, errors.Wrap(err, "FetchModelObjects")
}
return snapshots, nil
}
func (self *SStorage) Delete(ctx context.Context, userCred mcclient.TokenCredential) error {
// delete all hidden snapshots
fakeDeletedSnapshots, err := self.getFakeDeletedSnapshots()
if err != nil {
return errors.Wrap(err, "getFakeDeletedSnapshots")
}
for i := range fakeDeletedSnapshots {
err := fakeDeletedSnapshots[i].Delete(ctx, userCred)
if err != nil {
return errors.Wrap(err, "fakeDeletedSnapshots.Delete")
}
}
DeleteResourceJointSchedtags(self, ctx, userCred)
return self.SEnabledStatusInfrasResourceBase.Delete(ctx, userCred)
}
@@ -265,9 +286,9 @@ func (self *SStorage) ValidateDeleteCondition(ctx context.Context, info jsonutil
if cnt > 0 {
return httperrors.NewNotEmptyError("storage has disks")
}
cnt, err = self.GetSnapshotCount()
cnt, err = self.GetVisibleSnapshotCount()
if err != nil {
return httperrors.NewInternalServerError("GetSnapshotCount fail %s", err)
return httperrors.NewInternalServerError("GetVisibleSnapshotCount fail %s", err)
}
if cnt > 0 {
return httperrors.NewNotEmptyError("storage has snapshots")
@@ -400,8 +421,8 @@ func (self *SStorage) GetDisks() []SDisk {
return disks
}
func (self *SStorage) GetSnapshotCount() (int, error) {
return SnapshotManager.Query().Equals("storage_id", self.Id).CountWithError()
func (self *SStorage) GetVisibleSnapshotCount() (int, error) {
return SnapshotManager.Query().Equals("storage_id", self.Id).IsFalse("fake_deleted").CountWithError()
}
func (self *SStorage) IsLocal() bool {

9
pkg/compute/storagedrivers/base.go
View File

@@ -58,9 +58,12 @@ func (self *SBaseStorageDriver) ValidateSnapshotDelete(ctx context.Context, snap
}
if !snapshot.OutOfChain && snapshot.FakeDeleted {
_, err := models.SnapshotManager.GetConvertSnapshot(snapshot)
if err != nil {
return httperrors.NewBadRequestError("disk need at least one of snapshot as backing file")
disk, _ := snapshot.GetDisk()
if disk != nil {
_, err := models.SnapshotManager.GetConvertSnapshot(snapshot)
if err != nil {
return httperrors.NewBadRequestError("disk need at least one of snapshot as backing file")
}
}
}
return nil