#!/usr/bin/python
#
-# Copyright (C) 2006, 2007, 2008 Google Inc.
+# Copyright (C) 2006, 2007, 2008, 2009, 2010 Google Inc.
#
# This program is free software; you can redistribute it and/or modify
# it under the terms of the GNU General Public License as published by
"""Node related commands"""
-# pylint: disable-msg=W0401,W0614,C0103
+# pylint: disable-msg=W0401,W0613,W0614,C0103
# W0401: Wildcard import ganeti.cli
+# W0613: Unused argument, since all functions follow the same API
# W0614: Unused import %s from wildcard import (since we need cli)
# C0103: Invalid name gnt-node
import sys
from ganeti.cli import *
-from ganeti import cli
from ganeti import opcodes
from ganeti import utils
from ganeti import constants
+from ganeti import compat
from ganeti import errors
from ganeti import bootstrap
+from ganeti import netutils
#: default list of field for L{ListNodes}
"""
cl = GetClient()
- dns_data = utils.GetHostInfo(args[0])
- node = dns_data.name
+ node = netutils.GetHostname(name=args[0]).name
readd = opts.readd
try:
op = opcodes.OpAddNode(node_name=args[0], secondary_ip=sip,
readd=opts.readd)
- SubmitOpCode(op)
+ SubmitOpCode(op, opts=opts)
def ListNodes(opts, args):
val = utils.FormatTime(val)
elif val is None:
val = "?"
+ elif opts.roman_integers and isinstance(val, int):
+ val = compat.TryToRoman(val)
row[idx] = str(val)
data = GenerateTable(separator=opts.separator, headers=headers,
dst_node = opts.dst_node
iallocator = opts.iallocator
- cnt = [dst_node, iallocator].count(None)
- if cnt != 1:
- raise errors.OpPrereqError("One and only one of the -n and -I"
- " options must be passed", errors.ECODE_INVAL)
+ op = opcodes.OpNodeEvacuationStrategy(nodes=args,
+ iallocator=iallocator,
+ remote_node=dst_node)
- selected_fields = ["name", "sinst_list"]
- src_node = args[0]
-
- result = cl.QueryNodes(names=[src_node], fields=selected_fields,
- use_locking=False)
- src_node, sinst = result[0]
-
- if not sinst:
- ToStderr("No secondary instances on node %s, exiting.", src_node)
+ result = SubmitOpCode(op, cl=cl, opts=opts)
+ if not result:
+ # no instances to migrate
+ ToStderr("No secondary instances on node(s) %s, exiting.",
+ utils.CommaJoin(args))
return constants.EXIT_SUCCESS
- if dst_node is not None:
- result = cl.QueryNodes(names=[dst_node], fields=["name"],
- use_locking=False)
- 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, errors.ECODE_INVAL)
- txt_msg = "to node %s" % dst_node
- else:
- txt_msg = "using iallocator %s" % iallocator
-
- sinst = utils.NiceSort(sinst)
-
- if not force and not AskUser("Relocate instance(s) %s from node\n"
- " %s %s?" %
- (",".join("'%s'" % name for name in sinst),
- src_node, txt_msg)):
+ if not force and not AskUser("Relocate instance(s) %s from node(s) %s?" %
+ (",".join("'%s'" % name[0] for name in result),
+ utils.CommaJoin(args))):
return constants.EXIT_CONFIRMATION
- op = opcodes.OpEvacuateNode(node_name=args[0], remote_node=dst_node,
- iallocator=iallocator)
- SubmitOpCode(op, cl=cl)
+ jex = JobExecutor(cl=cl, opts=opts)
+ for row in result:
+ iname = row[0]
+ node = row[1]
+ ToStdout("Will relocate instance %s to node %s", iname, node)
+ op = opcodes.OpReplaceDisks(instance_name=iname,
+ remote_node=node, disks=[],
+ mode=constants.REPLACE_DISK_CHG,
+ early_release=opts.early_release)
+ jex.QueueJob(iname, op)
+ results = jex.GetResults()
+ bad_cnt = len([row for row in results if not row[0]])
+ if bad_cnt == 0:
+ ToStdout("All %d instance(s) failed over successfully.", len(results))
+ rcode = constants.EXIT_SUCCESS
+ else:
+ ToStdout("There were errors during the failover:\n"
+ "%d error(s) out of %d instance(s).", bad_cnt, len(results))
+ rcode = constants.EXIT_FAILURE
+ return rcode
def FailoverNode(opts, args):
(",".join("'%s'" % name for name in pinst))):
return 2
- jex = JobExecutor(cl=cl)
+ jex = JobExecutor(cl=cl, opts=opts)
for iname in pinst:
op = opcodes.OpFailoverInstance(instance_name=iname,
ignore_consistency=opts.ignore_consistency)
pinst = utils.NiceSort(pinst)
- retcode = 0
-
if not force and not AskUser("Migrate instance(s) %s?" %
(",".join("'%s'" % name for name in pinst))):
return 2
- op = opcodes.OpMigrateNode(node_name=args[0], live=opts.live)
- SubmitOpCode(op, cl=cl)
+ # this should be removed once --non-live is deprecated
+ if not opts.live and opts.migration_mode is not None:
+ raise errors.OpPrereqError("Only one of the --non-live and "
+ "--migration-mode options can be passed",
+ errors.ECODE_INVAL)
+ if not opts.live: # --non-live passed
+ mode = constants.HT_MIGRATION_NONLIVE
+ else:
+ mode = opts.migration_mode
+ op = opcodes.OpMigrateNode(node_name=args[0], mode=mode)
+ SubmitOpCode(op, cl=cl, opts=opts)
def ShowNodeConfig(opts, args):
"""
op = opcodes.OpRemoveNode(node_name=args[0])
- SubmitOpCode(op)
+ SubmitOpCode(op, opts=opts)
return 0
return 2
op = opcodes.OpPowercycleNode(node_name=node, force=opts.force)
- result = SubmitOpCode(op)
+ result = SubmitOpCode(op, opts=opts)
ToStderr(result)
return 0
selected_fields = opts.output.split(",")
op = opcodes.OpQueryNodeVolumes(nodes=args, output_fields=selected_fields)
- output = SubmitOpCode(op)
+ output = SubmitOpCode(op, opts=opts)
if not opts.no_headers:
headers = {"node": "Node", "phys": "PhysDev",
op = opcodes.OpQueryNodeStorage(nodes=args,
storage_type=storage_type,
output_fields=selected_fields)
- output = SubmitOpCode(op)
+ output = SubmitOpCode(op, opts=opts)
if not opts.no_headers:
headers = {
changes = {}
if opts.allocatable is not None:
- changes[constants.SF_ALLOCATABLE] = (opts.allocatable == "yes")
+ changes[constants.SF_ALLOCATABLE] = opts.allocatable
if changes:
op = opcodes.OpModifyNodeStorage(node_name=node_name,
storage_type=storage_type,
name=volume_name,
changes=changes)
- SubmitOpCode(op)
+ SubmitOpCode(op, opts=opts)
else:
ToStderr("No changes to perform, exiting.")
storage_type=storage_type,
name=volume_name,
ignore_consistency=opts.ignore_consistency)
- SubmitOpCode(op)
+ SubmitOpCode(op, opts=opts)
def SetNodeParams(opts, args):
ToStderr("Please give at least one of the parameters.")
return 1
- if opts.master_candidate is not None:
- candidate = opts.master_candidate == 'yes'
- else:
- candidate = None
- if opts.offline is not None:
- offline = opts.offline == 'yes'
- else:
- offline = None
-
- if opts.drained is not None:
- drained = opts.drained == 'yes'
- else:
- drained = None
op = opcodes.OpSetNodeParams(node_name=args[0],
- master_candidate=candidate,
- offline=offline,
- drained=drained,
- force=opts.force)
+ master_candidate=opts.master_candidate,
+ offline=opts.offline,
+ drained=opts.drained,
+ force=opts.force,
+ auto_promote=opts.auto_promote)
# even if here we process the result, we allow submit only
result = SubmitOrSend(op, opts)
"[-s ip] [--readd] [--no-ssh-key-check] <node_name>",
"Add a node to the cluster"),
'evacuate': (
- EvacuateNode, ARGS_ONE_NODE,
- [FORCE_OPT, IALLOCATOR_OPT, NEW_SECONDARY_OPT],
+ EvacuateNode, [ArgNode(min=1)],
+ [FORCE_OPT, IALLOCATOR_OPT, NEW_SECONDARY_OPT, EARLY_RELEASE_OPT],
"[-f] {-I <iallocator> | -n <dst>} <node>",
"Relocate the secondary instances from a node"
" to other nodes (only for instances with drbd disk template)"),
"Stops the primary instances on a node and start them on their"
" secondary node (only for instances with drbd disk template)"),
'migrate': (
- MigrateNode, ARGS_ONE_NODE, [FORCE_OPT, NONLIVE_OPT],
+ MigrateNode, ARGS_ONE_NODE, [FORCE_OPT, NONLIVE_OPT, MIGRATION_MODE_OPT],
"[-f] <node>",
"Migrate all the primary instance on a node away from it"
" (only for instances of type drbd)"),
"[<node_name>...]", "Show information about the node(s)"),
'list': (
ListNodes, ARGS_MANY_NODES,
- [NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT, SYNC_OPT],
+ [NOHDR_OPT, SEP_OPT, USEUNITS_OPT, FIELDS_OPT, SYNC_OPT, ROMAN_OPT],
"[nodes...]",
"Lists the nodes in the cluster. The available fields are (see the man"
" page for details): %s. The default field list is (in order): %s." %
(utils.CommaJoin(_LIST_HEADERS), utils.CommaJoin(_LIST_DEF_FIELDS))),
'modify': (
SetNodeParams, ARGS_ONE_NODE,
- [FORCE_OPT, SUBMIT_OPT, MC_OPT, DRAINED_OPT, OFFLINE_OPT],
+ [FORCE_OPT, SUBMIT_OPT, MC_OPT, DRAINED_OPT, OFFLINE_OPT,
+ AUTO_PROMOTE_OPT],
"<node_name>", "Alters the parameters of a node"),
'powercycle': (
PowercycleNode, ARGS_ONE_NODE,
projects / ganeti-local / blobdiff