Synnefo » snf-ganeti

import re

from ganeti import errors

from ganeti import logger

from ganeti import utils

from ganeti import constants

from ganeti import ssconf

def ValidateConfig():

  sstore = ssconf.SimpleStore()

  """

  def __init__(self, cfg_file=None, offline=False):

    self.write_count = 0

    self._config_data = None

    self._config_time = None

    self._config_size = None

    """

    return os.path.exists(constants.CLUSTER_CONF_FILE)

  def GenerateMAC(self):

    """Generate a MAC for an instance.

      raise errors.ConfigurationError("Can't generate unique MAC")

    return mac

  def IsMacInUse(self, mac):

    """Predicate: check if the specified MAC is in use in the Ganeti cluster.

        lvnames.update(lv_list)

    return lvnames

  def GenerateUniqueID(self, exceptions=None):

    """Generate an unique disk name.

    return result

  def VerifyConfig(self):

    """Stub verify function.

    """

          seen_macs.append(nic.mac)

    return result

    """Convert the unique ID to the ID needed on the target nodes.

    This is used only for drbd, which needs ip/port configuration.

    this helps when the only the top device is passed to the remote

    node.

    """

    if disk.children:

      for child in disk.children:

    if disk.logical_id is None and disk.physical_id is not None:

      return

      if node_name not in (pnode, snode):

        raise errors.ConfigurationError("DRBD device not knowing node %s" %

                                        node_name)

      if pnode_info is None or snode_info is None:

        raise errors.ConfigurationError("Can't find primary or secondary node"

                                        " for %s" % str(disk))

      disk.physical_id = disk.logical_id

    return

  def AddTcpUdpPort(self, port):

    """Adds a new port to the available port pool.

    self._config_data.cluster.tcpudp_port_pool.add(port)

    self._WriteConfig()

  def GetPortList(self):

    """Returns a copy of the current port list.

    self._OpenConfig()

    return self._config_data.cluster.tcpudp_port_pool.copy()

  def AllocatePort(self):

    """Allocate a port.

    self._WriteConfig()

    return port

  def GetHostKey(self):

    """Return the rsa hostkey from the config.

    self._OpenConfig()

    return self._config_data.cluster.rsahostkeypub

  def AddInstance(self, instance):

    """Add an instance to the config.

      instance.status = status

      self._WriteConfig()

  def MarkInstanceUp(self, instance_name):

    """Mark the instance status to up in the config.

    """

    self._SetInstanceStatus(instance_name, "up")

  def RemoveInstance(self, instance_name):

    """Remove the instance from the configuration.

    del self._config_data.instances[instance_name]

    self._WriteConfig()

  def RenameInstance(self, old_name, new_name):

    """Rename an instance.

    self._config_data.instances[inst.name] = inst

    self._WriteConfig()

  def MarkInstanceDown(self, instance_name):

    """Mark the status of an instance to down in the configuration.

    """

    self._SetInstanceStatus(instance_name, "down")

  def GetInstanceList(self):

    """Get the list of instances.

    return self._config_data.instances.keys()

  def ExpandInstanceName(self, short_name):

    """Attempt to expand an incomplete instance name.

    return utils.MatchNameComponent(short_name,

                                    self._config_data.instances.keys())

  def GetInstanceInfo(self, instance_name):

    """Returns informations about an instance.

    return self._config_data.instances[instance_name]

  def AddNode(self, node):

    """Add a node to the configuration.

    self._config_data.nodes[node.name] = node

    self._WriteConfig()

  def RemoveNode(self, node_name):

    """Remove a node from the configuration.

    del self._config_data.nodes[node_name]

    self._WriteConfig()

  def ExpandNodeName(self, short_name):

    """Attempt to expand an incomplete instance name.

    return utils.MatchNameComponent(short_name,

                                    self._config_data.nodes.keys())

    """Get the configuration of a node, as stored in the config.

    Args: node: nodename (tuple) of the node

    Returns: the node object

    return self._config_data.nodes[node_name]

    """Return the list of nodes which are in the configuration.

    """

    self._OpenConfig()

    return self._config_data.nodes.keys()

  def DumpConfig(self):

    """Return the entire configuration of the cluster.

    """

    if self._offline:

      return True

    bad = False

    myhostname = self._my_hostname

    try:

    # and redistribute the config file

    self._DistributeConfig()

  def InitConfig(self, node, primary_ip, secondary_ip,

                 hostkeypub, mac_prefix, vg_name, def_bridge):

    """Create the initial cluster configuration.

                                           cluster=globalconfig)

    self._WriteConfig()

  def GetVGName(self):

    """Return the volume group name.

    self._OpenConfig()

    return self._config_data.cluster.volume_group_name

  def SetVGName(self, vg_name):

    """Set the volume group name.

    self._config_data.cluster.volume_group_name = vg_name

    self._WriteConfig()

  def GetDefBridge(self):

    """Return the default bridge.

    self._OpenConfig()

    return self._config_data.cluster.default_bridge

  def GetMACPrefix(self):

    """Return the mac prefix.

    self._OpenConfig()

    return self._config_data.cluster.mac_prefix

  def GetClusterInfo(self):

    """Returns informations about the cluster

    return self._config_data.cluster

  def Update(self, target):

    """Notify function to be called after updates.