Commit 56aa9fd5 authored by Iustin Pop's avatar Iustin Pop
Browse files

Cleanup the config file on demotion from candidate

This patch adds a simple rpc which makes a backup of the config file and
then removes it. This is done so that cluster verify doesn't complain
immediately after demoting a node.

Reviewed-by: imsnah
parent cbfc4681
......@@ -472,6 +472,14 @@ class NodeHttpServer(http.server.HttpServer):
return backend.NodeVolumes()
def perspective_node_demote_from_mc(params):
"""Demote a node from the master candidate role.
return backend.DemoteFromMC()
# cluster --------------------------
......@@ -2051,6 +2051,26 @@ def ValidateHVParams(hvname, hvparams):
return (False, str(err))
def DemoteFromMC():
"""Demotes the current node from master candidate role.
# try to ensure we're not the master by mistake
master, myself = ssconf.GetMasterAndMyself()
if master == myself:
return (False, "ssconf status shows I'm the master node, will not demote")
pid_file = utils.DaemonPidFileName(constants.MASTERD_PID)
if utils.IsProcessAlive(utils.ReadPidFile(pid_file)):
return (False, "The master daemon is running, will not demote")
except EnvironmentError, err:
if err.errno != errno.ENOENT:
return (False, "Error while backing up cluster file: %s" % str(err))
return (True, "Done")
class HooksRunner(object):
"""Hook runner.
......@@ -2157,6 +2157,13 @@ class LUSetNodeParams(LogicalUnit):
if self.op.master_candidate is not None:
node.master_candidate = self.op.master_candidate
result.append(("master_candidate", str(self.op.master_candidate)))
if self.op.master_candidate == False:
rrc = self.rpc.call_node_demote_from_mc(
if (rrc.failed or not isinstance(, (tuple, list))
or len( != 2):
self.LogWarning("Node rpc error: %s" % rrc.error)
elif not[0]:
self.LogWarning("Node failed to demote itself: %s" %[1])
# this will trigger configuration file update, if needed
......@@ -828,6 +828,14 @@ class RpcRunner(object):
return self._MultiNodeCall(node_list, "node_volumes", [])
def call_node_demote_from_mc(self, node):
"""Demote a node from the master candidate role.
This is a single-node call.
return self._SingleNodeCall(node, "node_demote_from_mc", [])
def call_test_delay(self, node_list, duration):
"""Sleep for a fixed time on given node(s).
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment