<fix>[storage]: safe

header/src/main/java/org/zstack/header/host/CommitVolumeSnapshotOnHypervisorMsg.java

@@ -13,6 +13,7 @@ public class CommitVolumeSnapshotOnHypervisorMsg extends NeedReplyMessage implem
     private VolumeSnapshotInventory srcSnapshot;
     private VolumeSnapshotInventory dstSnapshot;
     private List<String> srcChildrenInstallPathInDb = new ArrayList<>();
+    private List<String> chainInstallPathInDb = new ArrayList<>();
 
     @Override
     public String getHostUuid() {
@@ -54,4 +55,12 @@ public List<String> getSrcChildrenInstallPathInDb() {
     public void setSrcChildrenInstallPathInDb(List<String> srcChildrenInstallPathInDb) {
         this.srcChildrenInstallPathInDb = srcChildrenInstallPathInDb;
     }
+
+    public List<String> getChainInstallPathInDb() {
+        return chainInstallPathInDb;
+    }
+
+    public void setChainInstallPathInDb(List<String> chainInstallPathInDb) {
+        this.chainInstallPathInDb = chainInstallPathInDb;
+    }
 }

plugin/kvm/src/main/java/org/zstack/kvm/KVMAgentCommands.java

@@ -3771,6 +3771,7 @@ public static class BlockCommitCmd extends AgentCommand implements HasThreadCont
         private String top;
         private String base;
         private List<String> topChildrenInstallPathInDb = new ArrayList<>();
+        private List<String> chainInstallPathInDb = new ArrayList<>();
 
         public String getVmUuid() {
             return vmUuid;
@@ -3811,6 +3812,13 @@ public List<String> getTopChildrenInstallPathInDb() {
         public void setTopChildrenInstallPathInDb(List<String> topChildrenInstallPathInDb) {
             this.topChildrenInstallPathInDb = topChildrenInstallPathInDb;
         }
+        public List<String> getChainInstallPathInDb() {
+            return chainInstallPathInDb;
+        }
+
+        public void setChainInstallPathInDb(List<String> chainInstallPathInDb) {
+            this.chainInstallPathInDb = chainInstallPathInDb;
+        }
     }
 
     public static class BlockCommitResponse extends AgentResponse {

plugin/kvm/src/main/java/org/zstack/kvm/KVMHost.java

@@ -1016,6 +1016,7 @@ private void commitVolumeSnapshot(final CommitVolumeSnapshotOnHypervisorMsg msg,
         cmd.setTop(msg.getSrcSnapshot().getPrimaryStorageInstallPath());
         cmd.setBase(msg.getDstSnapshot().getPrimaryStorageInstallPath());
         cmd.setTopChildrenInstallPathInDb(msg.getSrcChildrenInstallPathInDb());
+        cmd.setChainInstallPathInDb(msg.getChainInstallPathInDb());
 
         FlowChain chain = FlowChainBuilder.newShareFlowChain();
         chain.setName(String.format("block-commit-for-volume-%s", msg.getVolume().getUuid()));

storage/src/main/java/org/zstack/storage/snapshot/VolumeSnapshotTreeBase.java

@@ -1019,6 +1019,7 @@ public void run(FlowTrigger trigger, Map data) {
                                     cmsg.setSrcSnapshot(srcSnapshotInv);
                                     cmsg.setDstSnapshot(dstSnapshotInv);
                                     cmsg.setSrcChildrenInstallPathInDb(childrenInstallPath);
+                                    cmsg.setChainInstallPathInDb(volumeTree.getAliveChainSnapshotInstallPath());
                                     bus.makeTargetServiceIdByResourceUuid(cmsg, HostConstant.SERVICE_ID, hostUuid);
                                     bus.send(cmsg, new CloudBusCallBack(trigger) {
                                         @Override

storage/src/main/java/org/zstack/storage/snapshot/VolumeTree.java

@@ -361,6 +361,10 @@ public List<String> getAliveChainSnapshotUuids() {
         return aliveChain.stream().map(VolumeSnapshotInventory::getUuid).collect(Collectors.toList());
     }
 
+    public List<String> getAliveChainSnapshotInstallPath() {
+        return aliveChain.stream().map(VolumeSnapshotInventory::getPrimaryStorageInstallPath).collect(Collectors.toList());
+    }
+
     public DeleteVolumeSnapshotDirection resolveDirection(String targetSnapshotUuid, String childSnapshotUuid, String initialDirection,
                                                           boolean targetSnapshotIsLatest, VmInstanceState vmState) {
         boolean online = (vmState == VmInstanceState.Running || vmState == VmInstanceState.Paused)