@@ -1330,6 +1330,7 @@ def __init__(self,
13301330 verify_nqns : Optional [bool ] = True ,
13311331 allowed_consecutive_spdk_ping_failures : Optional [int ] = 1 ,
13321332 spdk_ping_interval_in_seconds : Optional [float ] = 2.0 ,
1333+ ping_spdk_under_lock : Optional [bool ] = False ,
13331334 server_key : Optional [str ] = None ,
13341335 server_cert : Optional [str ] = None ,
13351336 client_key : Optional [str ] = None ,
@@ -1338,9 +1339,9 @@ def __init__(self,
13381339 spdk_path : Optional [str ] = None ,
13391340 tgt_path : Optional [str ] = None ,
13401341 spdk_timeout : Optional [float ] = 60.0 ,
1341- spdk_log_level : Optional [str ] = '' ,
1342- spdk_protocol_log_level : Optional [str ] = 'WARNING ' ,
1343- rpc_socket : Optional [str ] = '/var/tmp/ spdk.sock' ,
1342+ spdk_log_level : Optional [str ] = 'WARNING ' ,
1343+ rpc_socket_dir : Optional [str ] = '/var/tmp/ ' ,
1344+ rpc_socket_name : Optional [str ] = 'spdk.sock' ,
13441345 conn_retries : Optional [int ] = 10 ,
13451346 transports : Optional [str ] = 'tcp' ,
13461347 transport_tcp_options : Optional [Dict [str , int ]] =
@@ -1407,6 +1408,8 @@ def __init__(self,
14071408 self .allowed_consecutive_spdk_ping_failures = allowed_consecutive_spdk_ping_failures
14081409 #: ``spdk_ping_interval_in_seconds`` sleep interval in seconds between SPDK pings
14091410 self .spdk_ping_interval_in_seconds = spdk_ping_interval_in_seconds
1411+ #: ``ping_spdk_under_lock`` whether or not we should perform SPDK ping under the RPC lock
1412+ self .ping_spdk_under_lock = ping_spdk_under_lock
14101413 #: ``bdevs_per_cluster`` number of bdevs per cluster
14111414 self .bdevs_per_cluster = bdevs_per_cluster
14121415 #: ``server_key`` gateway server key
@@ -1426,11 +1429,11 @@ def __init__(self,
14261429 #: ``spdk_timeout`` SPDK connectivity timeout
14271430 self .spdk_timeout = spdk_timeout
14281431 #: ``spdk_log_level`` the SPDK log level
1429- self .spdk_log_level = spdk_log_level
1430- #: ``spdk_protocol_log_level `` the SPDK-GW protocol log level
1431- self .spdk_protocol_log_level = spdk_protocol_log_level or 'WARNING '
1432- #: ``rpc_socket `` the SPDK RPC socket file path
1433- self .rpc_socket = rpc_socket or '/var/tmp/ spdk.sock'
1432+ self .spdk_log_level = spdk_log_level or 'WARNING'
1433+ #: ``rpc_socket_dir `` the SPDK RPC socket file directory
1434+ self .rpc_socket_dir = rpc_socket_dir or '/var/tmp/ '
1435+ #: ``rpc_socket_name `` the SPDK RPC socket file name
1436+ self .rpc_socket_name = rpc_socket_name or 'spdk.sock'
14341437 #: ``conn_retries`` ceph connection retries number
14351438 self .conn_retries = conn_retries
14361439 #: ``transports`` tcp
@@ -1508,16 +1511,6 @@ def validate(self) -> None:
15081511 'Invalid SPDK log level. Valid values are: '
15091512 'DEBUG, INFO, WARNING, ERROR, NOTICE' )
15101513
1511- if self .spdk_protocol_log_level :
1512- if self .spdk_protocol_log_level .lower () not in ['debug' ,
1513- 'info' ,
1514- 'warning' ,
1515- 'error' ,
1516- 'notice' ]:
1517- raise SpecValidationError (
1518- 'Invalid SPDK protocol log level. Valid values are: '
1519- 'DEBUG, INFO, WARNING, ERROR, NOTICE' )
1520-
15211514 if (
15221515 self .spdk_ping_interval_in_seconds
15231516 and self .spdk_ping_interval_in_seconds < 1.0
0 commit comments