MatheMatrix · MatheMatrix · Jul 3, 2026
diff --git a/...rc/main/java/org/zstack/header/storage/addon/primary/ExternalPrimaryStorageInventory.java b/...rc/main/java/org/zstack/header/storage/addon/primary/ExternalPrimaryStorageInventory.java
@@ -100,6 +100,7 @@ private static String desensitizeUrl(String url) {
         return url;
     }
 
+    @Override
     public String getIdentity() {
         return identity;
     }

diff --git a/...er/src/main/java/org/zstack/header/storage/addon/primary/PrimaryStorageControllerSvc.java b/...er/src/main/java/org/zstack/header/storage/addon/primary/PrimaryStorageControllerSvc.java
@@ -5,6 +5,7 @@
 import org.zstack.header.core.ReturnValueCompletion;
 import org.zstack.header.host.HostInventory;
 import org.zstack.header.storage.addon.*;
+import org.zstack.header.storage.primary.StorageResourceStats;
 import org.zstack.header.storage.snapshot.VolumeSnapshotStats;
 import org.zstack.header.volume.VolumeProtocol;
 import org.zstack.header.volume.VolumeStats;
@@ -64,7 +65,7 @@ public interface PrimaryStorageControllerSvc {
     // support uri or path
     void stats(String installPath, ReturnValueCompletion<VolumeStats> comp);
 
-    void batchStats(Collection<String> installPath, ReturnValueCompletion<List<VolumeStats>> comp);
+    void batchStats(Collection<String> installPaths, ReturnValueCompletion<List<StorageResourceStats>> comp);
 
     void expandVolume(String installPath, long size, ReturnValueCompletion<VolumeStats> comp);
     void setVolumeQos(BaseVolumeInfo v, Completion comp);

diff --git a/header/src/main/java/org/zstack/header/storage/primary/AskVolumeSnapshotCapabilityMsg.java b/header/src/main/java/org/zstack/header/storage/primary/AskVolumeSnapshotCapabilityMsg.java
@@ -9,6 +9,7 @@
 public class AskVolumeSnapshotCapabilityMsg extends NeedReplyMessage implements PrimaryStorageMessage {
     private String primaryStorageUuid;
     private VolumeInventory volume;
+    private String volumeType;
 
     @Override
     public String getPrimaryStorageUuid() {
@@ -26,4 +27,12 @@ public VolumeInventory getVolume() {
     public void setVolume(VolumeInventory volume) {
         this.volume = volume;
     }
+
+    public String getVolumeType() {
+        return volumeType != null ? volumeType : volume == null ? null : volume.getType();
+    }
+
+    public void setVolumeType(String volumeType) {
+        this.volumeType = volumeType;
+    }
 }
diff --git a/header/src/main/java/org/zstack/header/storage/primary/PrimaryStorageInventory.java b/header/src/main/java/org/zstack/header/storage/primary/PrimaryStorageInventory.java
@@ -290,6 +290,10 @@ public String getType() {
         return type;
     }
 
+    public String getIdentity() {
+        return type;
+    }
+
     public void setType(String type) {
         this.type = type;
     }

diff --git a/header/src/main/java/org/zstack/header/storage/primary/StorageResourceStats.java b/header/src/main/java/org/zstack/header/storage/primary/StorageResourceStats.java
@@ -0,0 +1,31 @@
+package org.zstack.header.storage.primary;
+
+public class StorageResourceStats {
+    protected String installPath;
+    protected Long actualSize;
+    protected Long size;
+
+    public String getInstallPath() {
+        return installPath;
+    }
+
+    public void setInstallPath(String installPath) {
+        this.installPath = installPath;
+    }
+
+    public Long getActualSize() {
+        return actualSize;
+    }
+
+    public void setActualSize(Long actualSize) {
+        this.actualSize = actualSize;
+    }
+
+    public Long getSize() {
+        return size;
+    }
+
+    public void setSize(long size) {
+        this.size = size;
+    }
+}
diff --git a/header/src/main/java/org/zstack/header/storage/primary/VolumeSnapshotCapability.java b/header/src/main/java/org/zstack/header/storage/primary/VolumeSnapshotCapability.java
@@ -16,6 +16,11 @@ public static enum VolumeSnapshotPlacementType {
         EXTERNAL,
     }
 
+    public static enum VolumeSnapshotMode {
+        REDIRECT_ON_WRITE,
+        COPY_ON_WRITE,
+    }
+
     private boolean support;
 
     /***
@@ -34,6 +39,8 @@ public static enum VolumeSnapshotPlacementType {
     private VolumeSnapshotArrangementType arrangementType;
 
     private VolumeSnapshotPlacementType placementType;
+
+    private VolumeSnapshotMode mode;
 
     /***
      * If volume snapshot is inner snapshot on volume, it must be set.
@@ -66,6 +73,14 @@ public void setPlacementType(VolumeSnapshotPlacementType placementType) {
         this.placementType = placementType;
     }
 
+    public VolumeSnapshotMode getMode() {
+        return mode;
+    }
+
+    public void setMode(VolumeSnapshotMode mode) {
+        this.mode = mode;
+    }
+
     public boolean isSupportCreateOnHypervisor() {
         return supportCreateOnHypervisor;
     }

diff --git a/header/src/main/java/org/zstack/header/storage/snapshot/VolumeSnapshotStats.java b/header/src/main/java/org/zstack/header/storage/snapshot/VolumeSnapshotStats.java
@@ -1,22 +1,6 @@
 package org.zstack.header.storage.snapshot;
 
-public class VolumeSnapshotStats {
-    private String installPath;
-    private long actualSize;
+import org.zstack.header.storage.primary.StorageResourceStats;
 
-    public String getInstallPath() {
-        return installPath;
-    }
-
-    public void setInstallPath(String installPath) {
-        this.installPath = installPath;
-    }
-
-    public long getActualSize() {
-        return actualSize;
-    }
-
-    public void setActualSize(long actualSize) {
-        this.actualSize = actualSize;
-    }
+public class VolumeSnapshotStats extends StorageResourceStats {
 }
diff --git a/...tchSyncVolumeSizeOnPrimaryStorageMsg.java → ...olumeResourceSizeOnPrimaryStorageMsg.java b/...tchSyncVolumeSizeOnPrimaryStorageMsg.java → ...olumeResourceSizeOnPrimaryStorageMsg.java
@@ -5,13 +5,17 @@
 
 import java.util.Map;
 
-public class BatchSyncVolumeSizeOnPrimaryStorageMsg extends NeedReplyMessage implements PrimaryStorageMessage {
+public class BatchSyncVolumeResourceSizeOnPrimaryStorageMsg extends NeedReplyMessage implements PrimaryStorageMessage {
     private String hostUuid;
 
     private String primaryStorageUuid;
 
     private Map<String, String> volumeUuidInstallPaths;
 
+    private Map<String, String> snapshotUuidInstallPaths;
+
+    private boolean withSnapshot;
+
     public void setHostUuid(String hostUuid) {
         this.hostUuid = hostUuid;
     }
@@ -35,4 +39,20 @@ public void setVolumeUuidInstallPaths(Map<String, String> volumeUuidInstallPaths
     public Map<String, String> getVolumeUuidInstallPaths() {
         return volumeUuidInstallPaths;
     }
+
+    public Map<String, String> getSnapshotUuidInstallPaths() {
+        return snapshotUuidInstallPaths;
+    }
+
+    public void setSnapshotUuidInstallPaths(Map<String, String> snapshotUuidInstallPaths) {
+        this.snapshotUuidInstallPaths = snapshotUuidInstallPaths;
+    }
+
+    public boolean isWithSnapshot() {
+        return withSnapshot;
+    }
+
+    public void setWithSnapshot(boolean withSnapshot) {
+        this.withSnapshot = withSnapshot;
+    }
 }
diff --git a/.../main/java/org/zstack/header/volume/BatchSyncVolumeResourceSizeOnPrimaryStorageReply.java b/.../main/java/org/zstack/header/volume/BatchSyncVolumeResourceSizeOnPrimaryStorageReply.java
@@ -0,0 +1,28 @@
+package org.zstack.header.volume;
+
+import org.zstack.header.message.MessageReply;
+
+import java.util.HashMap;
+import java.util.Map;
+
+public class BatchSyncVolumeResourceSizeOnPrimaryStorageReply extends MessageReply {
+    private Map<String, Long> actualSizes = new HashMap<>();
+
+    private Map<String, Long> snapshotActualSizes = new HashMap<>();
+
+    public void setActualSizes(Map<String, Long> actualSizes) {
+        this.actualSizes = actualSizes;
+    }
+
+    public Map<String, Long> getActualSizes() {
+        return actualSizes;
+    }
+
+    public Map<String, Long> getSnapshotActualSizes() {
+        return snapshotActualSizes;
+    }
+
+    public void setSnapshotActualSizes(Map<String, Long> snapshotActualSizes) {
+        this.snapshotActualSizes = snapshotActualSizes;
+    }
+}
diff --git a/header/src/main/java/org/zstack/header/volume/BatchSyncVolumeSizeOnPrimaryStorageReply.java b/header/src/main/java/org/zstack/header/volume/BatchSyncVolumeSizeOnPrimaryStorageReply.java
diff --git a/header/src/main/java/org/zstack/header/volume/VolumeStats.java b/header/src/main/java/org/zstack/header/volume/VolumeStats.java
@@ -1,10 +1,9 @@
 package org.zstack.header.volume;
 
-public class VolumeStats {
-    protected String installPath;
+import org.zstack.header.storage.primary.StorageResourceStats;
+
+public class VolumeStats extends StorageResourceStats {
     protected String format;
-    protected Long actualSize;
-    protected Long size;
     /**
      * The parent uri of the volume, vendor://pool/path@snapshot or snapshot://uuid
      */
@@ -29,30 +28,6 @@ public VolumeStats(String installPath, Long actualSize, Long size) {
     public VolumeStats() {
     }
 
-    public String getInstallPath() {
-        return installPath;
-    }
-
-    public void setInstallPath(String installPath) {
-        this.installPath = installPath;
-    }
-
-    public Long getActualSize() {
-        return actualSize;
-    }
-
-    public void setActualSize(Long actualSize) {
-        this.actualSize = actualSize;
-    }
-
-    public Long getSize() {
-        return size;
-    }
-
-    public void setSize(long size) {
-        this.size = size;
-    }
-
     public void setFormat(String format) {
         this.format = format;
     }

diff --git a/plugin/ceph/src/main/java/org/zstack/storage/ceph/primary/CephPrimaryStorageBase.java b/plugin/ceph/src/main/java/org/zstack/storage/ceph/primary/CephPrimaryStorageBase.java
@@ -3325,11 +3325,12 @@ protected void handle(AskVolumeSnapshotCapabilityMsg msg) {
         AskVolumeSnapshotCapabilityReply reply = new AskVolumeSnapshotCapabilityReply();
         VolumeSnapshotCapability cap = new VolumeSnapshotCapability();
 
-        String volumeType = msg.getVolume().getType();
+        String volumeType = msg.getVolumeType();
         if (VolumeType.Data.toString().equals(volumeType) || VolumeType.Root.toString().equals(volumeType)) {
             cap.setSupport(true);
             cap.setArrangementType(VolumeSnapshotArrangementType.INDIVIDUAL);
             cap.setPlacementType(VolumeSnapshotCapability.VolumeSnapshotPlacementType.INTERNAL);
+            cap.setMode(VolumeSnapshotCapability.VolumeSnapshotMode.REDIRECT_ON_WRITE);
             cap.setVolumePathFromInternalSnapshotRegex("^[^@]+");
         } else if (VolumeType.Memory.toString().equals(volumeType)) {
             cap.setSupport(false);
@@ -3397,10 +3398,10 @@ public void fail(ErrorCode errorCode) {
     }
 
     @Override
-    protected void handle(BatchSyncVolumeSizeOnPrimaryStorageMsg msg) {
+    protected void handle(BatchSyncVolumeResourceSizeOnPrimaryStorageMsg msg) {
         inQueue().name(String.format("batch-sync-volume-size-on-primarystorage-%s", self.getUuid()))
                 .asyncBackup(msg)
-                .run(chain -> BatchSyncVolumeSizeOnPrimaryStorage(msg, new NoErrorCompletion(chain) {
+                .run(chain -> BatchSyncVolumeResourceSizeOnPrimaryStorage(msg, new NoErrorCompletion(chain) {
                     @Override
                     public void done() {
                         chain.next();
@@ -3419,8 +3420,8 @@ protected void syncVolumeSize(String volumeUuid, String installPath, final Retur
         httpCall(GET_VOLUME_SIZE_PATH, cmd, GetVolumeSizeRsp.class, completion);
     }
 
-    private void BatchSyncVolumeSizeOnPrimaryStorage(BatchSyncVolumeSizeOnPrimaryStorageMsg msg, NoErrorCompletion completion) {
-        BatchSyncVolumeSizeOnPrimaryStorageReply reply = new BatchSyncVolumeSizeOnPrimaryStorageReply();
+    private void BatchSyncVolumeResourceSizeOnPrimaryStorage(BatchSyncVolumeResourceSizeOnPrimaryStorageMsg msg, NoErrorCompletion completion) {
+        BatchSyncVolumeResourceSizeOnPrimaryStorageReply reply = new BatchSyncVolumeResourceSizeOnPrimaryStorageReply();
 
         GetBatchVolumeSizeCmd cmd = new GetBatchVolumeSizeCmd();
         cmd.volumeUuidInstallPaths = msg.getVolumeUuidInstallPaths();

diff --git a/plugin/expon/src/main/java/org/zstack/expon/ExponStorageController.java b/plugin/expon/src/main/java/org/zstack/expon/ExponStorageController.java
@@ -36,6 +36,7 @@
 import org.zstack.header.storage.addon.*;
 import org.zstack.header.storage.addon.primary.*;
 import org.zstack.header.storage.primary.ImageCacheInventory;
+import org.zstack.header.storage.primary.StorageResourceStats;
 import org.zstack.header.storage.primary.VolumeSnapshotCapability;
 import org.zstack.header.storage.snapshot.VolumeSnapshotStats;
 import org.zstack.header.volume.*;
@@ -93,6 +94,7 @@ public class ExponStorageController implements PrimaryStorageControllerSvc, Prim
         scap.setSupport(true);
         scap.setArrangementType(VolumeSnapshotCapability.VolumeSnapshotArrangementType.INDIVIDUAL);
         scap.setPlacementType(VolumeSnapshotCapability.VolumeSnapshotPlacementType.INTERNAL);
+        scap.setMode(VolumeSnapshotCapability.VolumeSnapshotMode.REDIRECT_ON_WRITE);
         scap.setSupportCreateOnHypervisor(false);
         scap.setSupportLazyDelete(true);
         scap.setVolumePathFromInternalSnapshotRegex("^[^@]+");
@@ -1158,15 +1160,15 @@ public void stats(String installPath, ReturnValueCompletion<VolumeStats> comp) {
     }
 
     @Override
-    public void batchStats(Collection<String> installPath, ReturnValueCompletion<List<VolumeStats>> comp) {
-        List<VolumeStats> stats = installPath.stream().map(it -> {
+    public void batchStats(Collection<String> installPaths, ReturnValueCompletion<List<StorageResourceStats>> comp) {
+        List<StorageResourceStats> stats = installPaths.stream().map(it -> {
             VolumeModule vol = apiHelper.getVolume(getVolIdFromPath(it));
             VolumeStats s = new VolumeStats();
             s.setInstallPath(it);
             s.setSize(vol.getVolumeSize());
             s.setActualSize(vol.getDataSize());
             s.setFormat(VolumeConstant.VOLUME_FORMAT_RAW);
-            return s;
+            return (StorageResourceStats) s;
         }).collect(Collectors.toList());
         comp.success(stats);
     }

diff --git a/plugin/localstorage/src/main/java/org/zstack/storage/primary/local/LocalStorageBase.java b/plugin/localstorage/src/main/java/org/zstack/storage/primary/local/LocalStorageBase.java
@@ -2677,10 +2677,11 @@ protected void handle(AskVolumeSnapshotCapabilityMsg msg) {
         VolumeSnapshotCapability capability = new VolumeSnapshotCapability();
         capability.setSupport(true);
 
-        String volumeType = msg.getVolume().getType();
+        String volumeType = msg.getVolumeType();
         if (VolumeType.Data.toString().equals(volumeType) || VolumeType.Root.toString().equals(volumeType)) {
             capability.setArrangementType(VolumeSnapshotArrangementType.CHAIN);
             capability.setPlacementType(VolumeSnapshotCapability.VolumeSnapshotPlacementType.EXTERNAL);
+            capability.setMode(VolumeSnapshotCapability.VolumeSnapshotMode.REDIRECT_ON_WRITE);
         } else if (VolumeType.Memory.toString().equals(volumeType)) {
             capability.setArrangementType(VolumeSnapshotArrangementType.INDIVIDUAL);
         } else {
@@ -2733,17 +2734,17 @@ public void fail(ErrorCode errorCode) {
     }
 
     @Override
-    protected void handle(BatchSyncVolumeSizeOnPrimaryStorageMsg msg) {
+    protected void handle(BatchSyncVolumeResourceSizeOnPrimaryStorageMsg msg) {
         LocalStorageHypervisorFactory f = getHypervisorBackendFactoryByHostUuid(msg.getHostUuid());
         LocalStorageHypervisorBackend bkd = f.getHypervisorBackend(self);
-        bkd.handle(msg, msg.getHostUuid(), new ReturnValueCompletion<BatchSyncVolumeSizeOnPrimaryStorageReply>(msg) {
+        bkd.handle(msg, msg.getHostUuid(), new ReturnValueCompletion<BatchSyncVolumeResourceSizeOnPrimaryStorageReply>(msg) {
             @Override
-            public void success(BatchSyncVolumeSizeOnPrimaryStorageReply returnValue) {
+            public void success(BatchSyncVolumeResourceSizeOnPrimaryStorageReply returnValue) {
                 bus.reply(msg, returnValue);
             }
             @Override
             public void fail(ErrorCode errorCode) {
-                BatchSyncVolumeSizeOnPrimaryStorageReply reply = new BatchSyncVolumeSizeOnPrimaryStorageReply();
+                BatchSyncVolumeResourceSizeOnPrimaryStorageReply reply = new BatchSyncVolumeResourceSizeOnPrimaryStorageReply();
                 reply.setError(errorCode);
                 bus.reply(msg, reply);
             }

diff --git a/...storage/src/main/java/org/zstack/storage/primary/local/LocalStorageHypervisorBackend.java b/...storage/src/main/java/org/zstack/storage/primary/local/LocalStorageHypervisorBackend.java
@@ -72,7 +72,7 @@ public LocalStorageHypervisorBackend(PrimaryStorageVO self) {
 
     abstract void handle(EstimateVolumeTemplateSizeOnPrimaryStorageMsg msg, String huuid, ReturnValueCompletion<EstimateVolumeTemplateSizeOnPrimaryStorageReply> completion);
 
-    abstract void handle(BatchSyncVolumeSizeOnPrimaryStorageMsg msg, String hostUuid, ReturnValueCompletion<BatchSyncVolumeSizeOnPrimaryStorageReply> completion);
+    abstract void handle(BatchSyncVolumeResourceSizeOnPrimaryStorageMsg msg, String hostUuid, ReturnValueCompletion<BatchSyncVolumeResourceSizeOnPrimaryStorageReply> completion);
 
     abstract void handle(CreateImageCacheFromVolumeOnPrimaryStorageMsg msg, ReturnValueCompletion<CreateImageCacheFromVolumeOnPrimaryStorageReply> completion);