@@ -1261,6 +1261,9 @@ def resize_lvol(id, new_size):
1261
1261
logger .error (msg )
1262
1262
error = True
1263
1263
1264
+ if error :
1265
+ return False
1266
+
1264
1267
if primary_node :
1265
1268
1266
1269
rpc_client = RPCClient (primary_node .mgmt_ip , primary_node .rpc_port , primary_node .rpc_username ,
@@ -1281,32 +1284,12 @@ def resize_lvol(id, new_size):
1281
1284
sec_rpc_client = RPCClient (secondary_node .mgmt_ip , secondary_node .rpc_port , secondary_node .rpc_username ,
1282
1285
secondary_node .rpc_password )
1283
1286
1284
- if not is_node_leader (secondary_node , lvol .lvs_name ):
1285
- rpc_client .bdev_lvol_set_leader (False , lvs_name = lvol .lvs_name )
1286
-
1287
1287
ret = sec_rpc_client .bdev_lvol_resize (f"{ lvol .lvs_name } /{ lvol .lvol_bdev } " , size_in_mib )
1288
1288
if not ret :
1289
1289
logger .error (f"Error resizing lvol on node: { sec_node .get_id ()} " )
1290
1290
error = True
1291
1291
1292
1292
1293
- if snode .status == StorageNode .STATUS_ONLINE :
1294
- rpc_client = RPCClient (
1295
- snode .mgmt_ip , snode .rpc_port , snode .rpc_username , snode .rpc_password )
1296
- for iface in snode .data_nics :
1297
- if iface .ip4_address :
1298
- ret = rpc_client .nvmf_subsystem_listener_set_ana_state (
1299
- lvol .nqn , iface .ip4_address , lvol .subsys_port , True )
1300
-
1301
- sec_node = db_controller .get_storage_node_by_id (snode .secondary_node_id )
1302
- if sec_node and sec_node .status == StorageNode .STATUS_ONLINE :
1303
- sec_node_rpc_client = RPCClient (
1304
- sec_node .mgmt_ip , sec_node .rpc_port , sec_node .rpc_username , sec_node .rpc_password )
1305
- for iface in sec_node .data_nics :
1306
- if iface .ip4_address :
1307
- ret = sec_node_rpc_client .nvmf_subsystem_listener_set_ana_state (
1308
- lvol .nqn , iface .ip4_address , lvol .subsys_port , False )
1309
-
1310
1293
if not error :
1311
1294
lvol = db_controller .get_lvol_by_id (id )
1312
1295
lvol .size = new_size
0 commit comments