@@ -807,33 +807,6 @@ def delete_lvol_from_node(lvol_id, node_id, clear_data=True):
807
807
lvol .write_to_db (db_controller .kv_store )
808
808
return True
809
809
810
- # 3- clear alceml devices
811
- if clear_data :
812
- logger .info (f"Clearing Alceml devices" )
813
- for node in db_controller .get_storage_nodes_by_cluster_id (snode .cluster_id ):
814
- if node .status == StorageNode .STATUS_ONLINE :
815
- rpc_node = RPCClient (node .mgmt_ip , node .rpc_port , node .rpc_username , node .rpc_password )
816
- for dev in node .nvme_devices :
817
- if dev .status != NVMeDevice .STATUS_JM :
818
- ret = rpc_node .alceml_unmap_vuid (dev .alceml_bdev , lvol .vuid )
819
-
820
- lvol .deletion_status = 'alceml_unmapped'
821
- lvol .write_to_db (db_controller .kv_store )
822
-
823
- # 4- clear JM
824
- jm_device = snode .jm_device
825
- ret = rpc_client .alceml_unmap_vuid (jm_device .alceml_bdev , lvol .vuid )
826
- if not ret :
827
- logger .error (f"Failed to unmap jm alceml { jm_device .alceml_bdev } with vuid { lvol .vuid } " )
828
- # ret = rpc_client.bdev_jm_unmap_vuid(jm_device.jm_bdev, lvol.vuid)
829
- # if not ret:
830
- # logger.error(f"Failed to unmap jm {jm_device.jm_bdev} with vuid {lvol.vuid}")
831
-
832
- lvol .deletion_status = 'jm_unmapped'
833
- lvol .write_to_db (db_controller .kv_store )
834
-
835
- return True
836
-
837
810
838
811
def delete_lvol (id_or_name , force_delete = False ):
839
812
lvol = db_controller .get_lvol_by_id (id_or_name )
@@ -1345,6 +1318,7 @@ def move(lvol_id, node_id, force=False):
1345
1318
logger .error ("Failed to migrate lvol" )
1346
1319
return False
1347
1320
1321
+
1348
1322
def inflate_lvol (lvol_id ):
1349
1323
1350
1324
lvol = db_controller .get_lvol_by_id (lvol_id )
0 commit comments