Synnefo » snf-ganeti » ganeti-local

                                shutdown=opts.shutdown,

                                shutdown_timeout=opts.shutdown_timeout)

  if not isinstance(dlist, list):

    ToStderr("Cannot parse execution results")

    return 1

  """

  op = opcodes.OpRemoveExport(instance_name=args[0])

  return 0

                        modify_ssh_setup=opts.modify_ssh_setup,

                        )

  op = opcodes.OpPostInitCluster()

  return 0

    return 1

  op = opcodes.OpDestroyCluster()

  # if we reached this, the opcode didn't fail; we can proceed to

  # shutdown all the daemons

  bootstrap.FinalizeClusterDestroy(master)

      return 1

  op = opcodes.OpRenameCluster(name=name)

  return 0

                               verbose=opts.verbose,

                               error_codes=opts.error_codes,

                               debug_simulate_errors=opts.simulate_errors)

    return 0

  else:

    return 1

  """

  op = opcodes.OpVerifyDisks()

  if not isinstance(result, (list, tuple)) or len(result) != 3:

    raise errors.ProgrammerError("Unknown result type for OpVerifyDisks")

      op = opcodes.OpActivateInstanceDisks(instance_name=iname)

      try:

        ToStdout("Activating disks for instance '%s'", iname)

      except errors.GenericError, err:

        nret, msg = FormatError(err)

        retcode |= nret

  """

  op = opcodes.OpRepairDiskSizes(instances=args)

@UsesRPC

  """

  op = opcodes.OpSearchTags(pattern=args[0])

  if not result:

    return 1

  result = list(result)

                                  beparams=beparams,

                                  nicparams=nicparams,

                                  candidate_pool_size=opts.candidate_pool_size)

  return 0

  op = opcodes.OpTestDelay(duration=delay,

                           on_master=opts.on_master,

                           on_nodes=opts.on_nodes)

  return 0

                               direction=opts.direction,

                               allocator=opts.iallocator,

                               )

  ToStdout("%s" % result)

  return 0

  if opts.select_os is True:

    op = opcodes.OpDiagnoseOS(output_fields=["name", "valid", "variants"],

                              names=[])

    if not result:

      ToStdout("Can't get the OS list")

  op = opcodes.OpMigrateInstance(instance_name=instance_name, live=opts.live,

                                 cleanup=opts.cleanup)

  return 0

  instance_name = args[0]

  op = opcodes.OpConnectConsole(instance_name=instance_name)

  if opts.show_command:

    ToStdout("%s", utils.ShellQuoteArgs(cmd))

  retcode = 0

  op = opcodes.OpQueryInstanceData(instances=args, static=opts.static)

  if not result:

    ToStdout("No instances.")

    return 1

  op = opcodes.OpAddNode(node_name=args[0], secondary_ip=sip,

                         readd=opts.readd)

def ListNodes(opts, args):

  op = opcodes.OpEvacuateNode(node_name=args[0], remote_node=dst_node,

                              iallocator=iallocator)

def FailoverNode(opts, args):

    return 2

  op = opcodes.OpMigrateNode(node_name=args[0], live=opts.live)

def ShowNodeConfig(opts, args):

  """

  op = opcodes.OpRemoveNode(node_name=args[0])

  return 0

    return 2

  op = opcodes.OpPowercycleNode(node_name=node, force=opts.force)

  ToStderr(result)

  return 0

    selected_fields = opts.output.split(",")

  op = opcodes.OpQueryNodeVolumes(nodes=args, output_fields=selected_fields)

  if not opts.no_headers:

    headers = {"node": "Node", "phys": "PhysDev",

  op = opcodes.OpQueryNodeStorage(nodes=args,

                                  storage_type=storage_type,

                                  output_fields=selected_fields)

  if not opts.no_headers:

    headers = {

                                     storage_type=storage_type,

                                     name=volume_name,

                                     changes=changes)

  else:

    ToStderr("No changes to perform, exiting.")

                                   storage_type=storage_type,

                                   name=volume_name,

                                   ignore_consistency=opts.ignore_consistency)

def SetNodeParams(opts, args):

  """

  op = opcodes.OpDiagnoseOS(output_fields=["name", "valid", "variants"],

                            names=[])

  if not result:

    ToStderr("Can't get the OS list")

  """

  op = opcodes.OpDiagnoseOS(output_fields=["name", "valid", "variants",

                                           "node_status"], names=[])

  if not result:

    ToStderr("Can't get the OS list")