Synnefo » snf-ganeti » ganeti-local

from ganeti import utils

from ganeti import hypervisor

from ganeti import compat

from ganeti.confd import client as confd_client

                                      shutdown=True)

      rem_op = opcodes.OpInstanceRemove(instance_name=instance,

                                        ignore_failures=True)

      imp_op = opcodes.OpInstanceCreate(instance_name=instance,

                                        disks=[{"size": size}

                                               for size in self.disk_size],

  """Main function.

  """

                     debug=False, stderr_logging=True)

  return Burner().BurninCluster()

from ganeti import bootstrap

from ganeti import config

from ganeti import netutils

options = None

                    action="store_true", default=False,

                    help="Don't abort if hostname doesn't match")

  parser.add_option("--path", help="Convert configuration in this"

  parser.add_option("--no-verify",

                    help="Do not verify configuration after upgrade",

                    action="store_true", dest="no_verify", default=False)

from ganeti import serializer

from ganeti import utils

from ganeti import cli

options = None

  # file storage

  if "file_storage_dir" not in cluster:

  # candidate pool size

  if "candidate_pool_size" not in cluster:

  parser.add_option(cli.DEBUG_OPT)

  parser.add_option(cli.VERBOSE_OPT)

  parser.add_option("--path", help="Convert configuration in this"

  (options, args) = parser.parse_args()

  # We need to keep filenames locally because they might be renamed between

from ganeti import errors

from ganeti import ssh

from ganeti import utils

_GROUPS_MERGE = "merge"

                                 (cluster, result.fail_reason, result.output))

      instances = result.stdout.splitlines()

                            constants.SS_MASTER_NODE)

      result = self._RunCmd(cluster, "cat %s" % path, private_key=key_path)

      if result.failed:

    """Stop all daemons on merging nodes.

    """

    for data in self.merger_data:

      for node in data.nodes:

        result = self._RunCmd(node, cmd, max_attempts=3)

    """

    for data in self.merger_data:

      result = self._RunCmd(data.cluster, "cat %s" %

      if result.failed:

        raise errors.RemoteError("Unable to retrieve remote config on %s."

    @raise errors.CommandError: If unable to kill

    """

    if result.failed:

      raise errors.CommandError("Unable to stop master daemons."

                                " Fail reason: %s; output: %s" %

    if no_vote:

      env["EXTRA_MASTERD_ARGS"] = "--no-voting --yes-do-it"

    if result.failed:

      raise errors.CommandError("Couldn't start ganeti master."

                                " Fail reason: %s; output: %s" %

      rbsteps.append("Restore %s from another master candidate"

                     " and restart master daemon" %

      self._MergeConfig()

      self._StartMasterDaemon(no_vote=True)

from ganeti import constants

from ganeti import cli

from ganeti import utils

from ganeti.confd import client as confd_client

      Usage()

    if options.hmac is None:

    self.hmac_key = options.hmac

    self.mc_list = [options.mc]

from ganeti import constants

from ganeti import serializer

from ganeti import utils

from ganeti import cli

from ganeti.cli import cli_option

OPTS = [

  cli.VERBOSE_OPT,

  cli_option("--path", help="Convert this configuration file"

  cli_option("--sanitize-names", default="yes", type="bool",

             help="Randomize the cluster, node and instance names [yes]"),

  cli_option("--sanitize-ips", default="yes", type="bool",

from ganeti import ssconf

from ganeti import ssh

from ganeti import utils

class RemoteCommandError(errors.GenericError):

  ss_cluster_name_path = ss.KeyToFilename(constants.SS_CLUSTER_NAME)

  cluster_files = [

    (ss_cluster_name_path, utils.ReadFile(ss_cluster_name_path)),

    ]

  @param command: The daemon-util command to be run

  """

def _ReadSftpFile(sftp, filename):

  """

  priv_key, pub_key, auth_keys = ssh.GetUserFiles(constants.GANETI_RUNAS)

  keyfiles = [

    (priv_key, 0600),

    (pub_key, 0644),

    ]

  formatter = logging.Formatter(fmt)

  stderr_handler = logging.StreamHandler()

  stderr_handler.setFormatter(formatter)

  file_handler.setFormatter(formatter)