Synnefo » snf-ganeti

    instance = self.instance

    mods = [] # keeps track of needed logical_id changes

    for idx, disk in enumerate(instance.disks):

          # need to update the nodes and minors

          assert len(disk.logical_id) == 6 # otherwise disk internals

                                           # have changed

          (_, _, old_port, _, _, old_secret) = disk.logical_id

          new_minors = self.cfg.AllocateDRBDMinor(self.op.nodes, instance.name)

          new_id = (self.op.nodes[0], self.op.nodes[1], old_port,

                    new_minors[0], new_minors[1], old_secret)

          assert len(disk.logical_id) == len(new_id)

          mods.append((idx, new_id))

    # now that we have passed all asserts above, we can apply the mods

    # in a single run (to avoid partial changes)

    for idx, new_id in mods:

      instance.disks[idx].logical_id = new_id

    # change primary node, if needed

    if self.op.nodes:

      instance.primary_node = self.op.nodes[0]

      self.LogWarning("Changing the instance's nodes, you will have to"

                      " remove any disks left on the older nodes manually")

      self.cfg.Update(instance, feedback_fn)

    _CreateDisks(self, instance, to_skip=to_skip)