Synnefo » snf-ganeti » ganeti-local

New features

~~~~~~~~~~~~

  so that disk and NIC modifications take effect without the need of actual

- The :doc:`Remote API <rapi>` daemon now supports a command line flag

  to always require authentication, ``--require-authentication``. It can

  be specified in ``$sysconfdir/default/ganeti``.

HOTPLUG_OPT = cli_option("--hotplug", dest="hotplug",

                         action="store_true", default=False,

#: Options provided by all commands

COMMON_OPTS = [DEBUG_OPT, REASON_OPT]

  nics = _ConvertNicDiskModifications(opts.nics)

  for action, _, __ in nics:

      usertext = ("You are about to hot-modify a NIC. This will be done"

                  " by removing the exisiting and then adding a new one."

                  " Network connection might be lost. Continue?")

    ToStdout("Modified instance %s", args[0])

    for param, data in result:

      ToStdout(" - %-5s -> %s", param, data)

  return 0

      if op == constants.DDM_REMOVE:

        assert not params

        changes = [("%s/%s" % (kind, absidx), "remove")]

        assert container[absidx] == item

        del container[absidx]

      elif op == constants.DDM_MODIFY:

  def _HotplugDevice(self, action, dev_type, device, extra, seq):

    self.LogInfo("Trying to hotplug device...")

    result = self.rpc.call_hotplug_device(self.instance.primary_node,

                                          self.instance, action, dev_type,

                                          (device, self.instance),

    if result.fail_msg:

      self.LogWarning("Could not hotplug device: %s" % result.fail_msg)

      self.LogInfo("Continuing execution..")

    else:

      self.LogInfo("Hotplug done.")

  def _CreateNewDisk(self, idx, params, _):

    """Creates a new disk.

                         disks=[(idx, disk, 0)],

                         cleanup=new_disks)

    if self.op.hotplug:

      self.cfg.SetDiskID(disk, self.instance.primary_node)

      result = self.rpc.call_blockdev_assemble(self.instance.primary_node,

                                               (disk, self.instance),

                                               self.instance.name, True, idx)

      if result.fail_msg:

        self.LogWarning("Can't assemble newly created disk %d: %s",

                        idx, result.fail_msg)

      else:

        _, link_name = result.payload

  def _ModifyDisk(self, idx, disk, params, _):

    """Modifies a disk.

    """Removes a disk.

    """

    if self.op.hotplug:

      ShutdownInstanceDisks(self, self.instance, [root])

    (anno_disk,) = AnnotateDiskParams(self.instance, [root], self.cfg)

    if root.dev_type in constants.LDS_DRBD:

      self.cfg.AddTcpUdpPort(root.logical_id[2])

  def _CreateNewNic(self, idx, params, private):

    """Creates data structure for a new network interface.

                       nicparams=nicparams)

    nobj.uuid = self.cfg.GenerateUniqueID(self.proc.GetECId())

      ("nic.%d" % idx,

       "add:mac=%s,ip=%s,mode=%s,link=%s,network=%s" %

       (mac, ip, private.filled[constants.NIC_MODE],

       private.filled[constants.NIC_LINK], net)),

      ]

  def _ApplyNicMods(self, idx, nic, params, private):

    """Modifies a network interface.

        changes.append(("nic.%s/%d" % (key, idx), val))

    if self.op.hotplug:

    return changes

  def _RemoveNic(self, idx, nic, _):

    if self.op.hotplug:

  def Exec(self, feedback_fn):

    """Modifies an instance.

If ``--ignore-ipolicy`` is given any instance policy violations occuring

during this operation are ignored.

effect without the need of actual reboot. Please note that this feature

See **ganeti**\(7) for a description of ``--submit`` and other common

options.

    qa_config.TestEnabled("instance-device-hotplug"):

    args.extend([

      ["--net", "-1:add", "--hotplug"],

      ["--net", "-1:remove", "--hotplug"],

      ["--disk", "-1:add,size=1G", "--hotplug"],

      ["--disk", "-1:remove", "--hotplug"],