Rename SSH Update evaluation function more expressively
authorHelga Velroyen <helgav@google.com>
Thu, 23 Apr 2015 14:45:26 +0000 (16:45 +0200)
committerHelga Velroyen <helgav@google.com>
Tue, 28 Apr 2015 15:00:04 +0000 (17:00 +0200)
As it emits warnings for any unupdated nodes, lets name
it appropriately.

Signed-off-by: Helga Velroyen <helgav@google.com>
Reviewed-by: Hrvoje Ribicic <riba@google.com>

lib/cmdlib/cluster.py
lib/cmdlib/common.py
lib/cmdlib/node.py

index f4bf913..7594d18 100644 (file)
@@ -69,7 +69,7 @@ from ganeti.cmdlib.common import ShareAll, RunPostHook, \
   AddInstanceCommunicationNetworkOp, ConnectInstanceCommunicationNetworkOp, \
   CheckImageValidity, \
   CheckDiskAccessModeConsistency, CreateNewClientCert, EnsureKvmdOnNodes, \
-  EvaluateSshUpdateRPC
+  WarnAboutFailedSshUpdates
 
 import ganeti.masterd.instance
 
@@ -272,7 +272,7 @@ class LUClusterRenewCrypto(NoHooksLU):
     result[master_uuid].Raise("Could not renew the SSH keys of all nodes")
 
     # Process any non-disruptive errors (a few nodes unreachable etc.)
-    EvaluateSshUpdateRPC(result, master_uuid, feedback_fn)
+    WarnAboutFailedSshUpdates(result, master_uuid, feedback_fn)
 
   def Exec(self, feedback_fn):
     if self.op.node_certificates:
index 5e5f573..dd34bc5 100644 (file)
@@ -1556,7 +1556,7 @@ def EnsureKvmdOnNodes(lu, feedback_fn, nodes=None):
                               node_uuid, feedback_fn)
 
 
-def EvaluateSshUpdateRPC(result, master_uuid, feedback_fn):
+def WarnAboutFailedSshUpdates(result, master_uuid, feedback_fn):
   node_errors = result[master_uuid].payload
   if node_errors:
     feedback_fn("Some nodes' SSH key files could not be updated:")
index 41451b3..18d4f34 100644 (file)
@@ -53,7 +53,8 @@ from ganeti.cmdlib.common import CheckParamsNotGlobal, \
   GetWantedNodes, MapInstanceLvsToNodes, RunPostHook, \
   FindFaultyInstanceDisks, CheckStorageTypeEnabled, CreateNewClientCert, \
   AddNodeCertToCandidateCerts, RemoveNodeCertFromCandidateCerts, \
-  EnsureKvmdOnNodes, EvaluateSshUpdateRPC
+  EnsureKvmdOnNodes, WarnAboutFailedSshUpdates
+
 from ganeti.ssh import GetSshPortMap
 
 
@@ -366,7 +367,7 @@ class LUNodeAdd(LogicalUnit):
       remove_result[master_node].Raise(
         "Could not remove SSH keys of node %s before readding,"
         " (UUID: %s)." % (new_node_name, new_node_uuid))
-      EvaluateSshUpdateRPC(remove_result, master_node, feedback_fn)
+      WarnAboutFailedSshUpdates(remove_result, master_node, feedback_fn)
 
     result = rpcrunner.call_node_ssh_key_add(
       [master_node], new_node_uuid, new_node_name,
@@ -375,7 +376,7 @@ class LUNodeAdd(LogicalUnit):
       is_potential_master_candidate)
 
     result[master_node].Raise("Could not update the node's SSH setup.")
-    EvaluateSshUpdateRPC(result, master_node, feedback_fn)
+    WarnAboutFailedSshUpdates(result, master_node, feedback_fn)
 
   def Exec(self, feedback_fn):
     """Adds the new node to the cluster.
@@ -886,7 +887,7 @@ class LUNodeSetParams(LogicalUnit):
           ssh_result[master_node].Raise(
             "Could not adjust the SSH setup after demoting node '%s'"
             " (UUID: %s)." % (node.name, node.uuid))
-          EvaluateSshUpdateRPC(ssh_result, master_node, feedback_fn)
+          WarnAboutFailedSshUpdates(ssh_result, master_node, feedback_fn)
 
         if self.new_role == self._ROLE_CANDIDATE:
           ssh_result = self.rpc.call_node_ssh_key_add(
@@ -898,7 +899,7 @@ class LUNodeSetParams(LogicalUnit):
           ssh_result[master_node].Raise(
             "Could not update the SSH setup of node '%s' after promotion"
             " (UUID: %s)." % (node.name, node.uuid))
-          EvaluateSshUpdateRPC(ssh_result, master_node, feedback_fn)
+          WarnAboutFailedSshUpdates(ssh_result, master_node, feedback_fn)
 
     return result
 
@@ -1595,7 +1596,7 @@ class LUNodeRemove(LogicalUnit):
       result[master_node].Raise(
         "Could not remove the SSH key of node '%s' (UUID: %s)." %
         (self.op.node_name, self.node.uuid))
-      EvaluateSshUpdateRPC(result, master_node, feedback_fn)
+      WarnAboutFailedSshUpdates(result, master_node, feedback_fn)
 
     # Promote nodes to master candidate as needed
     AdjustCandidatePool(self, [self.node.uuid])