<fix>[storage]: mock ceph snap protect

before delete ceph volum, it will check
volume snapshot exists

Resolves: ZSTAC-56100

Change-Id: I726664777a68676a6c696e73627274616678646f

Author: MaJin1996

storage/src/main/java/org/zstack/storage/snapshot/reference/VolumeSnapshotReferenceTreeBase.java

@@ -20,7 +20,6 @@
 import org.zstack.header.storage.primary.GetVolumeBackingChainFromPrimaryStorageMsg;
 import org.zstack.header.storage.primary.GetVolumeBackingChainFromPrimaryStorageReply;
 import org.zstack.header.storage.primary.PrimaryStorageConstant;
-import org.zstack.header.storage.snapshot.VolumeSnapshotVO;
 import org.zstack.header.storage.snapshot.reference.DeleteVolumeSnapshotReferenceLeafMsg;
 import org.zstack.header.storage.snapshot.reference.DeleteVolumeSnapshotReferenceLeafReply;
 import org.zstack.header.storage.snapshot.reference.VolumeSnapshotReferenceInventory;
@@ -103,7 +102,7 @@ private void deleteSnapshotRefLeaf(DeleteVolumeSnapshotReferenceLeafMsg msg, Com
         Set<String> otherLeafDirectBackingInstallUrls = msg.getOtherLeafs().stream()
                 .map(VolumeSnapshotReferenceInventory::getDirectSnapshotInstallUrl)
                 .collect(Collectors.toSet());
-        if (hasSameVolumeResource(msg.getLeaf().getDirectSnapshotInstallUrl(), otherLeafDirectBackingInstallUrls)) {
+        if (otherLeafDirectBackingInstallUrls.contains(msg.getLeaf().getDirectSnapshotInstallUrl())) {
             logger.debug(String.format("other leafs has the same direct backing, skip delete leaf: [%d]", msg.getLeaf().getId()));
             completion.success();
             return;
@@ -191,7 +190,7 @@ public void run(FlowTrigger trigger, Map data) {
                         .filter(e -> !e.getKey().equals(startPath))
                         .flatMap(e -> e.getValue().stream()).collect(Collectors.toSet());
 
-                filterDeletePaths(toDeletePaths, usedByOthersPaths);
+                toDeletePaths.removeAll(usedByOthersPaths);
                 logger.debug("delete snapshot reference leafs: " + toDeletePaths);
                 trigger.next();
             }

testlib/src/main/java/org/zstack/testlib/CephPrimaryStorageSpec.groovy

@@ -744,10 +744,10 @@ class CephPrimaryStorageSpec extends PrimaryStorageSpec {
                     if (vfsPath.contains("@")) {
                         vfs.delete(vfsPath)
                         String volPath = vfsPath.split("@")[0]
-                        //assert getSnapshotPaths(vfs, volPath).isEmpty() : "the volume[%s] has snapshots, cannot delete it".format(volPath)
+                        assert getSnapshotPaths(vfs, volPath).isEmpty() : "the volume[%s] has snapshots, cannot delete it".format(volPath)
                         vfs.delete(volPath)
                     } else {
-                        //assert getSnapshotPaths(vfs, vfsPath).isEmpty() : "the volume[%s] has snapshots, cannot delete it".format(vfsPath)
+                        assert getSnapshotPaths(vfs, vfsPath).isEmpty() : "the volume[%s] has snapshots, cannot delete it".format(vfsPath)
                         vfs.delete(vfsPath)
                     }
                 }

testlib/src/main/java/org/zstack/testlib/vfs/CephRaw.groovy

@@ -44,6 +44,7 @@ class CephRaw extends Raw {
         }
 
         parent = null
+        update()
         return this
     }
 }