from ganeti import opcodes
from ganeti import logger
from ganeti import utils
+from ganeti import constants
+from ganeti import errors
def AddNode(opts, args):
"""Add node cli-to-processor bridge."""
+ logger.ToStderr("-- WARNING -- \n"
+ "Performing this operation is going to replace the ssh daemon keypair\n"
+ "on the target machine (%s) with the ones of the current one\n"
+ "and grant full intra-cluster ssh root access to/from it\n" % args[0])
op = opcodes.OpAddNode(node_name=args[0], secondary_ip=opts.secondary_ip)
SubmitOpCode(op)
if opts.output is None:
selected_fields = ["name", "dtotal", "dfree",
"mtotal", "mnode", "mfree",
- "pinst", "sinst"]
+ "pinst_cnt", "sinst_cnt"]
else:
selected_fields = opts.output.split(",")
- op = opcodes.OpQueryNodes(output_fields=selected_fields)
+ op = opcodes.OpQueryNodes(output_fields=selected_fields, names=[])
output = SubmitOpCode(op)
- mlens = [0 for name in selected_fields]
- format_fields = []
- unitformat_fields = ("dtotal", "dfree", "mtotal", "mnode", "mfree")
- for field in selected_fields:
- if field in ("dtotal", "dfree", "mtotal", "mnode",
- "mfree", "pinst", "sinst"):
- format_fields.append("%*s")
- else:
- format_fields.append("%-*s")
-
- separator = opts.separator
- if "%" in separator:
- separator = separator.replace("%", "%%")
- format = separator.join(format_fields)
+ if not opts.no_headers:
+ headers = {"name": "Node", "pinst_cnt": "Pinst", "sinst_cnt": "Sinst",
+ "pinst_list": "PriInstances", "sinst_list": "SecInstances",
+ "pip": "PrimaryIP", "sip": "SecondaryIP",
+ "dtotal": "DTotal", "dfree": "DFree",
+ "mtotal": "MTotal", "mnode": "MNode", "mfree": "MFree",
+ "bootid": "BootID"}
+ else:
+ headers = None
- for row in output:
- for idx, val in enumerate(row):
- if opts.human_readable and selected_fields[idx] in unitformat_fields:
- try:
- val = int(val)
- except ValueError:
- pass
- else:
- val = row[idx] = utils.FormatUnit(val)
- mlens[idx] = max(mlens[idx], len(val))
+ if opts.human_readable:
+ unitfields = ["dtotal", "dfree", "mtotal", "mnode", "mfree"]
+ else:
+ unitfields = None
- if not opts.no_headers:
- header_list = {"name": "Node", "pinst": "Pinst", "sinst": "Sinst",
- "pip": "PrimaryIP", "sip": "SecondaryIP",
- "dtotal": "DTotal", "dfree": "DFree",
- "mtotal": "MTotal", "mnode": "MNode", "mfree": "MFree"}
- args = []
- for idx, name in enumerate(selected_fields):
- hdr = header_list[name]
- mlens[idx] = max(mlens[idx], len(hdr))
- args.append(mlens[idx])
- args.append(hdr)
- logger.ToStdout(format % tuple(args))
+ numfields = ["dtotal", "dfree",
+ "mtotal", "mnode", "mfree",
+ "pinst_cnt", "sinst_cnt"]
+ # change raw values to nicer strings
for row in output:
- args = []
- for idx, val in enumerate(row):
- args.append(mlens[idx])
- args.append(val)
- logger.ToStdout(format % tuple(args))
+ for idx, field in enumerate(selected_fields):
+ val = row[idx]
+ if field == "pinst_list":
+ val = ",".join(val)
+ elif field == "sinst_list":
+ val = ",".join(val)
+ elif val is None:
+ val = "?"
+ row[idx] = str(val)
+
+ data = GenerateTable(separator=opts.separator, headers=headers,
+ fields=selected_fields, unitfields=unitfields,
+ numfields=numfields, data=output)
+ for line in data:
+ logger.ToStdout(line)
return 0
+def EvacuateNode(opts, args):
+ """Relocate all secondary instance from a node.
+
+ """
+ force = opts.force
+ selected_fields = ["name", "sinst_list"]
+ src_node, dst_node = args
+
+ op = opcodes.OpQueryNodes(output_fields=selected_fields, names=[src_node])
+ result = SubmitOpCode(op)
+ src_node, sinst = result[0]
+ op = opcodes.OpQueryNodes(output_fields=["name"], names=[dst_node])
+ result = SubmitOpCode(op)
+ dst_node = result[0][0]
+
+ if src_node == dst_node:
+ raise errors.OpPrereqError("Evacuate node needs different source and"
+ " target nodes (node %s given twice)" %
+ src_node)
+
+ if not sinst:
+ logger.ToStderr("No secondary instances on node %s, exiting." % src_node)
+ return constants.EXIT_SUCCESS
+
+ sinst = utils.NiceSort(sinst)
+
+ retcode = constants.EXIT_SUCCESS
+
+ if not force and not AskUser("Relocate instance(s) %s from node\n"
+ " %s to node\n %s?" %
+ (",".join("'%s'" % name for name in sinst),
+ src_node, dst_node)):
+ return constants.EXIT_CONFIRMATION
+
+ good_cnt = bad_cnt = 0
+ for iname in sinst:
+ op = opcodes.OpReplaceDisks(instance_name=iname,
+ remote_node=dst_node,
+ mode=constants.REPLACE_DISK_ALL,
+ disks=["sda", "sdb"])
+ try:
+ logger.ToStdout("Replacing disks for instance %s" % iname)
+ SubmitOpCode(op)
+ logger.ToStdout("Instance %s has been relocated" % iname)
+ good_cnt += 1
+ except errors.GenericError, err:
+ nret, msg = FormatError(err)
+ retcode |= nret
+ logger.ToStderr("Error replacing disks for instance %s: %s" %
+ (iname, msg))
+ bad_cnt += 1
+
+ if retcode == constants.EXIT_SUCCESS:
+ logger.ToStdout("All %d instance(s) relocated successfully." % good_cnt)
+ else:
+ logger.ToStdout("There were errors during the relocation:\n"
+ "%d error(s) out of %d instance(s)." %
+ (bad_cnt, good_cnt + bad_cnt))
+ return retcode
+
+
+def FailoverNode(opts, args):
+ """Failover all primary instance on a node.
+
+ """
+ force = opts.force
+ selected_fields = ["name", "pinst_list"]
+
+ op = opcodes.OpQueryNodes(output_fields=selected_fields, names=args)
+ result = SubmitOpCode(op)
+ node, pinst = result[0]
+
+ if not pinst:
+ logger.ToStderr("No primary instances on node %s, exiting." % node)
+ return 0
+
+ pinst = utils.NiceSort(pinst)
+
+ retcode = 0
+
+ if not force and not AskUser("Fail over instance(s) %s?" %
+ (",".join("'%s'" % name for name in pinst))):
+ return 2
+
+ good_cnt = bad_cnt = 0
+ for iname in pinst:
+ op = opcodes.OpFailoverInstance(instance_name=iname,
+ ignore_consistency=opts.ignore_consistency)
+ try:
+ logger.ToStdout("Failing over instance %s" % iname)
+ SubmitOpCode(op)
+ logger.ToStdout("Instance %s has been failed over" % iname)
+ good_cnt += 1
+ except errors.GenericError, err:
+ nret, msg = FormatError(err)
+ retcode |= nret
+ logger.ToStderr("Error failing over instance %s: %s" % (iname, msg))
+ bad_cnt += 1
+
+ if retcode == 0:
+ logger.ToStdout("All %d instance(s) failed over successfully." % good_cnt)
+ else:
+ logger.ToStdout("There were errors during the failover:\n"
+ "%d error(s) out of %d instance(s)." %
+ (bad_cnt, good_cnt + bad_cnt))
+ return retcode
+
+
def ShowNodeConfig(opts, args):
"""Show node information.
"""
- op = opcodes.OpQueryNodeData(nodes=args)
+ op = opcodes.OpQueryNodes(output_fields=["name", "pip", "sip",
+ "pinst_list", "sinst_list"],
+ names=args)
result = SubmitOpCode(op)
for name, primary_ip, secondary_ip, pinst, sinst in result:
op = opcodes.OpQueryNodeVolumes(nodes=args, output_fields=selected_fields)
output = SubmitOpCode(op)
- mlens = [0 for name in selected_fields]
- format_fields = []
- unitformat_fields = ("size",)
- for field in selected_fields:
- if field in unitformat_fields:
- format_fields.append("%*s")
- else:
- format_fields.append("%-*s")
+ if not opts.no_headers:
+ headers = {"node": "Node", "phys": "PhysDev",
+ "vg": "VG", "name": "Name",
+ "size": "Size", "instance": "Instance"}
+ else:
+ headers = None
- separator = opts.separator
- if "%" in separator:
- separator = separator.replace("%", "%%")
- format = separator.join(format_fields)
+ if opts.human_readable:
+ unitfields = ["size"]
+ else:
+ unitfields = None
- for row in output:
- for idx, val in enumerate(row):
- if opts.human_readable and selected_fields[idx] in unitformat_fields:
- try:
- val = int(val)
- except ValueError:
- pass
- else:
- val = row[idx] = utils.FormatUnit(val)
- mlens[idx] = max(mlens[idx], len(val))
+ numfields = ["size"]
- if not opts.no_headers:
- header_list = {"node": "Node", "phys": "PhysDev",
- "vg": "VG", "name": "Name",
- "size": "Size", "instance": "Instance"}
- args = []
- for idx, name in enumerate(selected_fields):
- hdr = header_list[name]
- mlens[idx] = max(mlens[idx], len(hdr))
- args.append(mlens[idx])
- args.append(hdr)
- logger.ToStdout(format % tuple(args))
+ data = GenerateTable(separator=opts.separator, headers=headers,
+ fields=selected_fields, unitfields=unitfields,
+ numfields=numfields, data=output)
- for row in output:
- args = []
- for idx, val in enumerate(row):
- args.append(mlens[idx])
- args.append(val)
- logger.ToStdout(format % tuple(args))
+ for line in data:
+ logger.ToStdout(line)
return 0
make_option("-s", "--secondary-ip", dest="secondary_ip",
help="Specify the secondary ip for the node",
metavar="ADDRESS", default=None),],
- "<node_name>", "Add a node to the cluster"),
+ "[-s ip] <node_name>", "Add a node to the cluster"),
+ 'evacuate': (EvacuateNode, ARGS_FIXED(2),
+ [DEBUG_OPT, FORCE_OPT],
+ "[-f] <src_node> <dst_node>",
+ "Relocate the secondary instances from the first node"
+ " to the second one (only for instances of type remote_raid1"
+ " drbd)"),
+ 'failover': (FailoverNode, ARGS_ONE,
+ [DEBUG_OPT, FORCE_OPT,
+ make_option("--ignore-consistency", dest="ignore_consistency",
+ action="store_true", default=False,
+ help="Ignore the consistency of the disks on"
+ " the secondary"),
+ ],
+ "[-f] <node>",
+ "Stops the primary instances on a node and start them on their"
+ " secondary node (only for instances of type remote_raid1)"),
'info': (ShowNodeConfig, ARGS_ANY, [DEBUG_OPT],
"[<node_name>...]", "Show information about the node(s)"),
'list': (ListNodes, ARGS_NONE,
[DEBUG_OPT, NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT],
- "", "Lists the nodes in the cluster"),
+ "", "Lists the nodes in the cluster. The available fields"
+ " are (see the man page for details): name, pinst_cnt, pinst_list,"
+ " sinst_cnt, sinst_list, pip, sip, dtotal, dfree, mtotal, mnode,"
+ " mfree, bootid. The default field list is (in order): name,"
+ " dtotal, dfree, mtotal, mnode, mfree, pinst_cnt, sinst_cnt."),
'remove': (RemoveNode, ARGS_ONE, [DEBUG_OPT],
"<node_name>", "Removes a node from the cluster"),
'volumes': (ListVolumes, ARGS_ANY,
[DEBUG_OPT, NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT],
"[<node_name>...]", "List logical volumes on node(s)"),
+ 'list-tags': (ListTags, ARGS_ONE, [DEBUG_OPT],
+ "<node_name>", "List the tags of the given node"),
+ 'add-tags': (AddTags, ARGS_ATLEAST(1), [DEBUG_OPT, TAG_SRC_OPT],
+ "<node_name> tag...", "Add tags to the given node"),
+ 'remove-tags': (RemoveTags, ARGS_ATLEAST(1), [DEBUG_OPT, TAG_SRC_OPT],
+ "<node_name> tag...", "Remove tags from the given node"),
}
if __name__ == '__main__':
- retcode = GenericMain(commands)
- sys.exit(retcode)
+ sys.exit(GenericMain(commands, override={"tag_type": constants.TAG_NODE}))
projects / ganeti-local / blobdiff