Dev: utils: Rename utils.node_reachable_check to utils.ssh_reachable_check

Author: liangxin1300

crmsh/bootstrap.py

@@ -275,7 +275,7 @@ def _validate_nodes_option(self):
             utils.fatal(f"Overriding current user '{self.current_user}' by '{user}'. Ouch, don't do it.")
         self.user_at_node_list = [value for (user, node), value in zip(li, self.user_at_node_list) if node != me]
         for user, node in (utils.parse_user_at_host(x) for x in self.user_at_node_list):
-            utils.node_reachable_check(node)
+            utils.ssh_reachable_check(node)
 
     def _validate_cluster_node(self):
         """
@@ -2449,7 +2449,7 @@ def bootstrap_join(context):
             _context.initialize_user()
 
         remote_user, cluster_node = _parse_user_at_host(_context.cluster_node, _context.current_user)
-        utils.node_reachable_check(cluster_node)
+        utils.ssh_reachable_check(cluster_node)
         join_ssh(cluster_node, remote_user)
         remote_user = utils.user_of(cluster_node)
 

crmsh/qdevice.py

@@ -208,7 +208,7 @@ def check_qnetd_addr(qnetd_addr):
         except socket.error:
             raise ValueError("host \"{}\" is unreachable".format(qnetd_addr))
 
-        utils.node_reachable_check(qnetd_addr)
+        utils.ssh_reachable_check(qnetd_addr)
 
         if utils.InterfacesInfo.ip_in_local(qnetd_ip):
             raise ValueError("host for qnetd must be a remote one")

crmsh/utils.py

@@ -2405,7 +2405,7 @@ def package_is_installed(pkg, remote_addr=None):
     return rc == 0
 
 
-def node_reachable_check(node):
+def ssh_reachable_check(node):
     """
     Check if node is reachable by checking SSH port is open
     """
@@ -2421,7 +2421,7 @@ def get_reachable_node_list(node_list:list[str]) -> list[str]:
     reachable_node_list = []
     for node in node_list:
         try:
-            if node_reachable_check(node):
+            if ssh_reachable_check(node):
                 reachable_node_list.append(node)
         except ValueError as e:
             logger.warning(str(e))
@@ -2465,7 +2465,7 @@ def check_all_nodes_reachable(action_to_do: str, peer_node: str = None):
     dead_nodes = []
     for node in offline_nodes:
         try:
-            node_reachable_check(node)
+            ssh_reachable_check(node)
         except ValueError:
             dead_nodes.append(node)
     if dead_nodes:
@@ -2479,7 +2479,7 @@ def check_all_nodes_reachable(action_to_do: str, peer_node: str = None):
     unreachable_nodes = []
     for node in online_nodes:
         try:
-            node_reachable_check(node)
+            ssh_reachable_check(node)
         except ValueError:
             unreachable_nodes.append(node)
     if unreachable_nodes: