Synnefo » snf-ganeti » ganeti-local

  "DISK_OPT",

  "DISK_TEMPLATE_OPT",

  "DRAINED_OPT",

  "ENABLED_HV_OPT",

  "ERROR_CODES_OPT",

  "FIELDS_OPT",

                         default=constants.DEFAULT_SHUTDOWN_TIMEOUT,

                         help="Maximum time to wait for instance shutdown")

def _ParseArgs(argv, commands, aliases):

  """Parser for the command line arguments.

      self.op.remote_node = None

    if not hasattr(self.op, "iallocator"):

      self.op.iallocator = None

    TLReplaceDisks.CheckArguments(self.op.mode, self.op.remote_node,

                                  self.op.iallocator)

    self.replacer = TLReplaceDisks(self, self.op.instance_name, self.op.mode,

                                   self.op.iallocator, self.op.remote_node,

    self.tasklets = [self.replacer]

      self.op.remote_node = None

    if not hasattr(self.op, "iallocator"):

      self.op.iallocator = None

    TLReplaceDisks.CheckArguments(constants.REPLACE_DISK_CHG,

                                  self.op.remote_node,

      replacer = TLReplaceDisks(self, inst.name, constants.REPLACE_DISK_CHG,

                                self.op.iallocator, self.op.remote_node, [],

      tasklets.append(replacer)

    self.tasklets = tasklets

  """

  def __init__(self, lu, instance_name, mode, iallocator_name, remote_node,

    """Initializes this class.

    """

    self.remote_node = remote_node

    self.disks = disks

    self.delay_iallocator = delay_iallocator

    # Runtime data

    self.instance = None

          self.lu.LogWarning("Can't remove old LV: %s" % msg,

                             hint="remove unused LVs manually")

  def _ExecDrbd8DiskOnly(self, feedback_fn):

    """Replace a disk on the primary or secondary for DRBD 8.

      self.cfg.Update(self.instance, feedback_fn)

    # Wait for sync

    # This can fail as the old devices are degraded and _WaitForSync

    # does a combined result over all disks, so we don't check its return value

    _WaitForSync(self.lu, self.instance)

    # Check all devices manually

    self._CheckDevices(self.instance.primary_node, iv_names)

    # Step: remove old storage

  def _ExecDrbd8Secondary(self, feedback_fn):

    """Replace the secondary node for DRBD 8.

                           to_node, msg,

                           hint=("please do a gnt-instance info to see the"

                                 " status of disks"))

    # Wait for sync

    # This can fail as the old devices are degraded and _WaitForSync

    # does a combined result over all disks, so we don't check its return value

    _WaitForSync(self.lu, self.instance)

    # Check all devices manually

    self._CheckDevices(self.instance.primary_node, iv_names)

    # Step: remove old storage

class LURepairNodeStorage(NoHooksLU):

  OP_ID = "OP_NODE_EVACUATE"

  OP_DSC_FIELD = "node_name"

  __slots__ = [

    ]

  OP_DSC_FIELD = "instance_name"

  __slots__ = [

    "instance_name", "remote_node", "mode", "disks", "iallocator",

    ]

        <cmdsynopsis>

          <command>replace-disks</command>

          <arg>--submit</arg>

          <arg choice="req">-p</arg>

          <arg>--disks <replaceable>idx</replaceable></arg>

          <arg choice="req"><replaceable>instance</replaceable></arg>

        <cmdsynopsis>

          <command>replace-disks</command>

          <arg>--submit</arg>

          <arg choice="req">-s</arg>

          <arg>--disks <replaceable>idx</replaceable></arg>

          <arg choice="req"><replaceable>instance</replaceable></arg>

        <cmdsynopsis>

          <command>replace-disks</command>

          <arg>--submit</arg>

          <group choice="req">

            <arg>--iallocator <replaceable>name</replaceable></arg>

            <arg>--new-secondary <replaceable>NODE</replaceable></arg>

        <cmdsynopsis>

          <command>replace-disks</command>

          <arg>--submit</arg>

          <arg choice="req">--auto</arg>

          <arg choice="req"><replaceable>instance</replaceable></arg>

        </cmdsynopsis>

        </para>

        <para>

          Note that it is not possible to select an offline or drained

          node as a new secondary.

        </para>

      <cmdsynopsis>

        <command>evacuate</command>

        <arg>-f</arg>

        <group>

          <arg>--iallocator <replaceable>NAME</replaceable></arg>

          <arg>--new-secondary <replaceable>destination_node</replaceable></arg>

      </para>

      <para>

        Example:

        <screen>

          # gnt-node evacuate -I dumb node3.example.com

  op = opcodes.OpReplaceDisks(instance_name=args[0], disks=disks,

                              remote_node=new_2ndary, mode=mode,

  SubmitOrSend(op, opts)

  return 0

    "<instance> <new_name>", "Rename the instance"),

  'replace-disks': (

    ReplaceDisks, ARGS_ONE_INSTANCE,

     NEW_SECONDARY_OPT, ON_PRIMARY_OPT, ON_SECONDARY_OPT, SUBMIT_OPT],

    "[-s|-p|-n NODE|-I NAME] <instance>",

    "Replaces all disks for the instance"),

  cli.VERBOSE_OPT,

  cli.NOIPCHECK_OPT,

  cli.NONAMECHECK_OPT,

  cli.cli_option("--no-replace1", dest="do_replace1",

                 help="Skip disk replacement with the same secondary",

                 action="store_false", default=True),

      for mode in constants.REPLACE_DISK_SEC, constants.REPLACE_DISK_PRI:

        op = opcodes.OpReplaceDisks(instance_name=instance,

                                    mode=mode,

        Log("run %s" % mode, indent=2)

        ops.append(op)

      self.ExecOrQueue(instance, *ops) # pylint: disable-msg=W0142

                                  mode=mode,

                                  remote_node=tnode,

                                  iallocator=self.opts.iallocator,

      Log("run %s %s" % (mode, msg), indent=2)

      self.ExecOrQueue(instance, op)