Synnefo » snf-ganeti » ganeti-local

	  echo "LOCALSTATEDIR = '$(localstatedir)'"; \

	  echo "SYSCONFDIR = '$(sysconfdir)'"; \

	  echo "SSH_CONFIG_DIR = '$(SSH_CONFIG_DIR)'"; \

	  echo "EXPORT_DIR = '$(EXPORT_DIR)'"; \

	  echo "OS_SEARCH_PATH = [$(OS_SEARCH_PATH)]"; \

	  echo "XEN_BOOTLOADER = '$(XEN_BOOTLOADER)'"; \

  [lvm_stripecount="1"])

AC_SUBST(LVM_STRIPECOUNT, $lvm_stripecount)

# --with-default-user=...

AC_ARG_WITH([default-user],

  [AS_HELP_STRING([--with-default-user=USERNAME],

  if modify_ssh_setup:

    try:

      utils.RemoveAuthorizedKey(auth_keys, utils.ReadFile(pub_key))

                                " oflag=dsync", dest_path)

  remotecmd = _GetSshRunner(cluster_name).BuildCmd(dest_node,

                                                   destcmd)

  # all commands have been checked, so we're safe to combine them

  permitted hosts and adds the hostkey to its own known hosts.

  """

  for name in priv_key, pub_key:

    if os.path.exists(name):

  mycommand = ("%s stop-all; %s start %s" %

               (pathutils.DAEMON_UTIL, pathutils.DAEMON_UTIL, constants.NODED))

                         ask_key=ssh_key_check,

                         use_cluster_key=True,

                         strict_host_check=ssh_key_check)

      # No need to use SSH

      result = utils.RunCmd(cmd)

    else:

    if result.failed:

      errmsg = ["Failed to run command %s" % result.cmd]

    nodes.append(master_node)

  for name in nodes:

    ToStdout("------------------------------------------------")

    if opts.show_machine_names:

      for line in result.output.splitlines():

CONFD_GROUP = _autoconf.CONFD_GROUP

NODED_USER = _autoconf.NODED_USER

NODED_GROUP = _autoconf.NODED_GROUP

# cpu pinning separators and constants

CPU_PINNING_SEP = ":"

IP6_FAMILY = socket.AF_INET6

TCP_PING_TIMEOUT = 10

DEFAULT_VG = "xenvg"

DEFAULT_DRBD_HELPER = "/bin/true"

MIN_VG_SIZE = 20480

    return objects.InstanceConsole(instance=instance.name,

                                   kind=constants.CONS_SSH,

                                   host=instance.primary_node,

                                   command=["chroot", root_dir])

  def Verify(self):

      return objects.InstanceConsole(instance=instance.name,

                                     kind=constants.CONS_SSH,

                                     host=instance.primary_node,

                                     command=cmd)

    vnc_bind_address = hvparams[constants.HV_VNC_BIND_ADDRESS]

    return objects.InstanceConsole(instance=instance.name,

                                   kind=constants.CONS_SSH,

                                   host=instance.primary_node,

                                   command=["lxc-console", "-n", instance.name])

  def Verify(self):

    return objects.InstanceConsole(instance=instance.name,

                                   kind=constants.CONS_SSH,

                                   host=instance.primary_node,

                                   command=[pathutils.XM_CONSOLE_WRAPPER,

                                            instance.name])

           "else"

           "  echo \"$GANETI_HOSTNAME\";"

           "fi")

    if retval.failed:

      msg = "ssh problem"

    consinfo["inst7"] = \

      objects.InstanceConsole(instance="inst7", kind=constants.CONS_SSH,

                              host=instbyname["inst7"].primary_node,

                              command=["hostname"]).ToDict()

    iqd = query.InstanceQueryData(instances, cluster, disk_usage,

  @param transport: The paramiko transport instance

  """

  keyfiles = [

    (pathutils.SSH_HOST_DSA_PRIV, 0600),

    (pathutils.SSH_HOST_DSA_PUB, 0644),

  """

  program = os.path.basename(sys.argv[0])

  parser = optparse.OptionParser(usage=("%prog [--debug|--verbose] [--force]"

                                        " <node> <node...>"), prog=program)

  parser.add_option(cli.DEBUG_OPT)

  parser.add_option(cli.VERBOSE_OPT)

  parser.add_option(cli.NOSSH_KEYCHECK_OPT)

  parser.add_option(optparse.Option("-f", dest="private_key",

                                    default=default_key,

                                    help="The private key to (try to) use for"

  @return: paramiko.util.load_host_keys dict

  """

  known_hosts = os.path.join(homedir, ".ssh", "known_hosts")

  try:

  all_keys = LoadPrivateKeys(options)

  passwd = None

  ssh_port = netutils.GetDaemonPort("ssh")

  host_keys = LoadKnownHosts()