Synnefo » snf-ganeti

    client = GetClient()

  if mode == _SHUTDOWN_CLUSTER:

    if names:

    idata = client.QueryInstances([], ["name"], False)

    inames = [row[0] for row in idata]

                _SHUTDOWN_NODES_PRI,

                _SHUTDOWN_NODES_SEC):

    if not names:

    ndata = client.QueryNodes(names, ["name", "pinst_list", "sinst_list"],

                              False)

    ipri = [row[1] for row in ndata]

  elif mode == _SHUTDOWN_INSTANCES:

    if not names:

    idata = client.QueryInstances(names, ["name"], False)

    inames = [row[0] for row in idata]

  else:

  return inames

  result = client.QueryInstances(names, ["name"], False)

  for orig_name, row in zip(names, result):

    if row[0] is None:

def GenericManyOps(operation, fn):

    inames = _ExpandMultiNames(opts.multi_mode, args, client=cl)

    if not inames:

      raise errors.OpPrereqError("Selection filter does not match"

    multi_on = opts.multi_mode != _SHUTDOWN_INSTANCES or len(inames) > 1

    if not (opts.force_multi or not multi_on

            or _ConfirmOperation(inames, operation)):

    for required_field in ('os', 'template'):

      if required_field not in spec:

        raise errors.OpPrereqError('Required field "%s" is missing.' %

    # Validate special fields

    if spec['primary_node'] is not None:

      if (spec['template'] in constants.DTS_NET_MIRROR and

          spec['secondary_node'] is None):

        raise errors.OpPrereqError('Template requires secondary node, but'

    elif spec['iallocator'] is None:

      raise errors.OpPrereqError('You have to provide at least a primary_node'

    if (spec['hvparams'] and

        not isinstance(spec['hvparams'], dict)):

  json_filename = args[0]

  try:

      except ValueError, err:

        raise errors.OpPrereqError("Invalid disk size '%s' for"

                                   " instance %s: %s" %

      disks.append({"size": size})

    utils.ForceDictType(specs['backend'], constants.BES_PARAMETER_TYPES)

    if specs['nics'] is not None and tmp_nics:

      raise errors.OpPrereqError("'nics' list incompatible with using"

    elif specs['nics'] is not None:

      tmp_nics = specs['nics']

    elif not tmp_nics:

  inames = _ExpandMultiNames(opts.multi_mode, args)

  if not inames:

  # second, if requested, ask for an OS

  if opts.select_os is True:

  try:

    disk = int(disk)

  except ValueError, err:

  amount = utils.ParseUnit(args[2])

  op = opcodes.OpGrowDisk(instance_name=instance, disk=disk, amount=amount,

                          wait_for_sync=opts.wait_for_sync)

    try:

      disks = [int(i) for i in opts.disks.split(",")]

    except ValueError, err:

  cnt = [opts.on_primary, opts.on_secondary, opts.auto,

         new_2ndary is not None, iallocator is not None].count(True)

  if cnt != 1:

    raise errors.OpPrereqError("One and only one of the -p, -s, -a, -n and -i"

  elif opts.on_primary:

    mode = constants.REPLACE_DISK_PRI

  elif opts.on_secondary:

    mode = constants.REPLACE_DISK_AUTO

    if disks:

      raise errors.OpPrereqError("Cannot specify disks when using automatic"

  elif new_2ndary is not None or iallocator is not None:

    # replace secondary

    mode = constants.REPLACE_DISK_CHG

      pass

    if disk_op == constants.DDM_ADD:

      if 'size' not in disk_dict:

      disk_dict['size'] = utils.ParseUnit(disk_dict['size'])

  op = opcodes.OpSetInstanceParams(instance_name=args[0],