Synnefo » snf-ganeti » ganeti-local

from ganeti import network

    networks = ["%s %s" % (net.uuid, net.name) for net in

                self._config_data.networks.values()]

    networks_data = fn(utils.NiceSort(networks))

      constants.SS_NETWORKS: networks_data,

  @locking.ssynchronized(_config_lock, shared=1)

  def GetAllNetworksInfo(self):

    """Get the configuration of all networks

    """

    return dict(self._config_data.networks)

  def _UnlockedGetNetworkList(self):

    """Get the list of networks.

    This function is for internal use, when the config lock is already held.

    """

    return self._config_data.networks.keys()

  @locking.ssynchronized(_config_lock, shared=1)

  def GetNetworkList(self):

    """Get the list of networks.

    @return: array of networks, ex. ["main", "vlan100", "200]

    """

    return self._UnlockedGetNetworkList()

  @locking.ssynchronized(_config_lock, shared=1)

  def GetNetworkNames(self):

    """Get a list of network names

    """

    names = [network.name

             for network in self._config_data.networks.values()]

    return names

  def _UnlockedGetNetwork(self, uuid):

    """Returns information about a network.

    This function is for internal use, when the config lock is already held.

    """

    if uuid not in self._config_data.networks:

      return None

    return self._config_data.networks[uuid]

  @locking.ssynchronized(_config_lock, shared=1)

  def GetNetwork(self, uuid):

    """Returns information about a network.

    It takes the information from the configuration file.

    @param uuid: UUID of the network

    @rtype: L{objects.Network}

    @return: the network object

    """

    return self._UnlockedGetNetwork(uuid)

  @locking.ssynchronized(_config_lock)

  def AddNetwork(self, net, ec_id, check_uuid=True):

    """Add a network to the configuration.

    @type net: L{objects.Network}

    @param net: the Network object to add

    @type ec_id: string

    @param ec_id: unique id for the job to use when creating a missing UUID

    """

    self._UnlockedAddNetwork(net, ec_id, check_uuid)

    self._WriteConfig()

  def _UnlockedAddNetwork(self, net, ec_id, check_uuid):

    """Add a network to the configuration.

    """

    logging.info("Adding network %s to configuration", net.name)

    if check_uuid:

      self._EnsureUUID(net, ec_id)

    existing_uuid = self._UnlockedLookupNetwork(net.name)

    if existing_uuid:

      raise errors.OpPrereqError("Desired network name '%s' already"

                                 " exists as a network (UUID: %s)" %

                                 (net.name, existing_uuid),

                                 errors.ECODE_EXISTS)

    net.serial_no = 1

    self._config_data.networks[net.uuid] = net

    self._config_data.cluster.serial_no += 1

  def _UnlockedLookupNetwork(self, target):

    """Lookup a network's UUID.

    @type target: string

    @param target: network name or UUID

    @rtype: string

    @return: network UUID

    @raises errors.OpPrereqError: when the target network cannot be found

    """

    if target in self._config_data.networks:

      return target

    for net in self._config_data.networks.values():

      if net.name == target:

        return net.uuid

    return None

  @locking.ssynchronized(_config_lock, shared=1)

  def LookupNetwork(self, target):

    """Lookup a network's UUID.

    This function is just a wrapper over L{_UnlockedLookupNetwork}.

    @type target: string

    @param target: network name or UUID

    @rtype: string

    @return: network UUID

    """

    return self._UnlockedLookupNetwork(target)

  @locking.ssynchronized(_config_lock)

  def RemoveNetwork(self, network_uuid):

    """Remove a network from the configuration.

    @type network_uuid: string

    @param network_uuid: the UUID of the network to remove

    """

    logging.info("Removing network %s from configuration", network_uuid)

    if network_uuid not in self._config_data.networks:

      raise errors.ConfigurationError("Unknown network '%s'" % network_uuid)

    del self._config_data.networks[network_uuid]

    self._config_data.cluster.serial_no += 1

    self._WriteConfig()