fix(linstorvolumemanager): don't allow InUse volumes to be deleted

Check for usage status before deleting a linstor volume and raise an appropriate error if this happens

Signed-off-by: Antoine Bartuccio <antoine.bartuccio@vates.tech>

Author: klmp200

drivers/linstorvolumemanager.py

@@ -15,7 +15,7 @@
 # along with this program.  If not, see <https://www.gnu.org/licenses/>.
 #
 
-from sm_typing import override
+from sm_typing import Any, Dict, override
 
 import errno
 import json
@@ -302,7 +302,8 @@ class LinstorVolumeManager(object):
         '_base_group_name', '_group_name', '_ha_group_name',
         '_volumes', '_storage_pools', '_storage_pools_time',
         '_kv_cache', '_resource_cache', '_volume_info_cache',
-        '_kv_cache_dirty', '_resource_cache_dirty', '_volume_info_cache_dirty'
+        '_kv_cache_dirty', '_resource_cache_dirty', '_volume_info_cache_dirty',
+        '_resources_info_cache',
     )
 
     DEV_ROOT_PATH = DRBD_BY_RES_PATH
@@ -427,6 +428,7 @@ def __init__(
         self._resource_cache_dirty = True
         self._volume_info_cache = None
         self._volume_info_cache_dirty = True
+        self._resources_info_cache = None
         self._build_volumes(repair=repair)
 
     @property
@@ -686,6 +688,13 @@ def destroy_volume(self, volume_uuid):
         self._ensure_volume_exists(volume_uuid)
         self.ensure_volume_is_not_locked(volume_uuid)
 
+        is_volume_in_use = any(node["in-use"] for node in self.get_resource_info(volume_uuid)["nodes"].values())
+        if is_volume_in_use:
+            raise LinstorVolumeManagerError(
+                f"Could not destroy volume `{volume_uuid}` as it is currently in use",
+                LinstorVolumeManagerError.ERR_VOLUME_DESTROY
+            )
+
         # Mark volume as destroyed.
         volume_properties = self._get_volume_properties(volume_uuid)
         volume_properties[self.PROP_NOT_EXISTS] = self.STATE_NOT_EXISTS
@@ -1683,6 +1692,9 @@ def get_resources_info(self):
         Give all resources of current group name.
         :rtype: dict(str, list)
         """
+        if self._resources_info_cache and not self._resource_cache_dirty:
+            return self._resources_info_cache
+
         resources = {}
         resource_list = self._get_resource_cache()
         volume_names = self.get_volumes_with_name()
@@ -1739,7 +1751,23 @@ def get_resources_info(self):
             if resource:
                 resource['uuid'] = volume_uuid
 
-        return resources
+        self._resources_info_cache = resources
+        return self._resources_info_cache
+
+    def get_resource_info(self, volume_uuid: str) -> Dict[str, Any]:
+        """
+        Give all resources info with provided uuid on current group name.
+        :param volume_uuid str: volume uuid to search for
+        :rtype: dict
+        """
+        for volume in self.get_resources_info().values():
+            if volume["uuid"] == volume_uuid:
+                return volume
+
+        raise LinstorVolumeManagerError(
+            f"Could not find info about volume `{volume_uuid}`",
+            LinstorVolumeManagerError.ERR_VOLUME_NOT_EXISTS
+        )
 
     def get_database_path(self):
         """