Synnefo » snf-ganeti » ganeti-local

      # Verify global configuration

      jobs.append([

        ])

      # Always depend on global verification

    """

    env = {

      }

    env.update(("NODE_TAGS_%s" % node.name, " ".join(node.GetTags()))

                                 target_node=self.op.target_node,

                                 allow_runtime_changes=allow_runtime_changes,

                                 ignore_ipolicy=self.op.ignore_ipolicy)]

    # TODO: Run iallocator in this opcode and pass correct placement options to

    # OpInstanceMigrate. Since other jobs can modify the cluster between

                                        for i in range(disk_count)])

    if template_name == constants.DT_PLAIN:

      def logical_id_fn(idx, _, disk):

        vg = disk.get(constants.IDISK_VG, vgname)

        return (vg, names[idx])

    elif template_name in (constants.DT_FILE, constants.DT_SHARED_FILE):

      logical_id_fn = \

        lambda _, disk_index, disk: (file_driver,

        if self.op.conflicts_check:

          _CheckForConflictingIp(self, nic.ip, self.pnode.name)

    # mirror node verification

    if self.op.disk_template in constants.DTS_INT_MIRROR:

      if self.op.snode == pnode.name:

                                        disks=[],

                                        mode=constants.REPLACE_DISK_CHG,

                                        early_release=self.op.early_release)]

    else:

      raise errors.ProgrammerError("No iallocator or remote node")

                                     " in cluster" % mac,

                                     errors.ECODE_NOTUNIQUE)

    elif new_net != old_net:

      def get_net_prefix(net):

        if net:

          uuid = self.cfg.LookupNetwork(net)

            nobj = self.cfg.GetNetwork(uuid)

            return nobj.mac_prefix

        return None

      new_prefix = get_net_prefix(new_net)

      old_prefix = get_net_prefix(old_net)

      if old_prefix != new_prefix:

      result = ial.out_text

    return result

# Network LUs

class LUNetworkAdd(LogicalUnit):

  """Logical unit for creating networks.

                                 self.op.network, errors.ECODE_EXISTS)

    if self.op.mac_prefix:

    # Check tag validity

    for tag in self.op.tags:

      objects.TaggableObject.ValidateTag(tag)

  def BuildHooksEnv(self):

    """Build hooks env.

      locking.LEVEL_NETWORK: [self.network_uuid],

      }

  def CheckPrereq(self):

    """Check prerequisites.

      raise errors.OpPrereqError("Cannot modify gateway and reserved ips"

                                 " at once", errors.ECODE_INVAL)

  def ExpandNames(self):

    self.network_uuid = self.cfg.LookupNetwork(self.op.network_name)

    self.network = self.cfg.GetNetwork(self.network_uuid)

      if self.op.mac_prefix == constants.VALUE_NONE:

        self.mac_prefix = None

      else:

        self.mac_prefix = self.op.mac_prefix

    if self.op.gateway6:

      else:

        self.network6 = self.op.network6

  def BuildHooksEnv(self):

    """Build hooks env.

        all_nodes = lu.cfg.GetAllNodesInfo()

        network_to_instances = dict((uuid, []) for uuid in self.wanted)

      for group in all_groups.values():

        if do_instances:

          group_nodes = [node.name for node in all_nodes.values() if

    return self.nq.OldStyleQuery(self)

class LUNetworkConnect(LogicalUnit):

  """Connect a network to a nodegroup

    nodes = self.cfg.GetNodeGroup(self.group_uuid).members

    return (nodes, nodes)

  def CheckPrereq(self):

    l = lambda value: ", ".join("%s: %s/%s" % (i[0], i[1], i[2])

                                   for i in value)

    nodes = self.cfg.GetNodeGroup(self.group_uuid).members

    return (nodes, nodes)

  def CheckPrereq(self):

    l = lambda value: ", ".join("%s: %s/%s" % (i[0], i[1], i[2])

                                   for i in value)

    raise errors.OpPrereqError("Unknown query resource '%s'" % name,

                               errors.ECODE_INVAL)

def _CheckForConflictingIp(lu, ip, node):

  """In case of conflicting ip raise error.