X-Git-Url: https://code.grnet.gr/git/ganeti-local/blobdiff_plain/38f9d2cff49ae868ec3d668b0da5be5439214092..934704ae32e1f4ef193a39356f87f9b554441b45:/lib/client/gnt_cluster.py diff --git a/lib/client/gnt_cluster.py b/lib/client/gnt_cluster.py index 7476a00..39c1a4e 100644 --- a/lib/client/gnt_cluster.py +++ b/lib/client/gnt_cluster.py @@ -70,6 +70,10 @@ def InitCluster(opts, args): if opts.drbd_storage and not opts.drbd_helper: drbd_helper = constants.DEFAULT_DRBD_HELPER + master_netdev = opts.master_netdev + if master_netdev is None: + master_netdev = constants.DEFAULT_BRIDGE + hvlist = opts.enabled_hypervisors if hvlist is None: hvlist = constants.DEFAULT_ENABLED_HYPERVISOR @@ -124,7 +128,7 @@ def InitCluster(opts, args): secondary_ip=opts.secondary_ip, vg_name=vg_name, mac_prefix=opts.mac_prefix, - master_netdev=opts.master_netdev, + master_netdev=master_netdev, file_storage_dir=opts.file_storage_dir, enabled_hypervisors=hvlist, hvparams=hvparams, @@ -141,7 +145,7 @@ def InitCluster(opts, args): primary_ip_version=primary_ip_version, prealloc_wipe_disks=opts.prealloc_wipe_disks, ) - op = opcodes.OpPostInitCluster() + op = opcodes.OpClusterPostInit() SubmitOpCode(op, opts=opts) return 0 @@ -162,7 +166,7 @@ def DestroyCluster(opts, args): " destroy this cluster, supply the --yes-do-it option.") return 1 - op = opcodes.OpDestroyCluster() + op = opcodes.OpClusterDestroy() master = SubmitOpCode(op, opts=opts) # if we reached this, the opcode didn't fail; we can proceed to # shutdown all the daemons @@ -194,7 +198,7 @@ def RenameCluster(opts, args): if not AskUser(usertext): return 1 - op = opcodes.OpRenameCluster(name=new_name) + op = opcodes.OpClusterRename(name=new_name) result = SubmitOpCode(op, opts=opts, cl=cl) if result: @@ -213,7 +217,7 @@ def RedistributeConfig(opts, args): @return: the desired exit code """ - op = opcodes.OpRedistributeConfig() + op = opcodes.OpClusterRedistConf() SubmitOrSend(op, opts) return 0 @@ -339,6 +343,9 @@ def ShowClusterConfig(opts, args): ToStdout(" - primary ip version: %d", result["primary_ip_version"]) ToStdout(" - preallocation wipe disks: %s", result["prealloc_wipe_disks"]) + ToStdout("Default node parameters:") + _PrintGroupedParams(result["ndparams"], roman=opts.roman_integers) + ToStdout("Default instance parameters:") _PrintGroupedParams(result["beparams"], roman=opts.roman_integers) @@ -428,7 +435,7 @@ def VerifyCluster(opts, args): skip_checks = [] if opts.skip_nplusone_mem: skip_checks.append(constants.VERIFY_NPLUSONE_MEM) - op = opcodes.OpVerifyCluster(skip_checks=skip_checks, + op = opcodes.OpClusterVerify(skip_checks=skip_checks, verbose=opts.verbose, error_codes=opts.error_codes, debug_simulate_errors=opts.simulate_errors) @@ -450,10 +457,10 @@ def VerifyDisks(opts, args): """ cl = GetClient() - op = opcodes.OpVerifyDisks() + op = opcodes.OpClusterVerifyDisks() result = SubmitOpCode(op, opts=opts, cl=cl) if not isinstance(result, (list, tuple)) or len(result) != 3: - raise errors.ProgrammerError("Unknown result type for OpVerifyDisks") + raise errors.ProgrammerError("Unknown result type for OpClusterVerifyDisks") bad_nodes, instances, missing = result @@ -513,7 +520,7 @@ def RepairDiskSizes(opts, args): @return: the desired exit code """ - op = opcodes.OpRepairDiskSizes(instances=args) + op = opcodes.OpClusterRepairDiskSizes(instances=args) SubmitOpCode(op, opts=opts) @@ -782,7 +789,7 @@ def SetClusterParams(opts, args): else: opts.reserved_lvs = utils.UnescapeAndSplit(opts.reserved_lvs, sep=",") - op = opcodes.OpSetClusterParams(vg_name=vg_name, + op = opcodes.OpClusterSetParams(vg_name=vg_name, drbd_helper=drbd_helper, enabled_hypervisors=hvlist, hvparams=hvparams,