Synnefo » snf-ganeti

from ganeti import errors

from ganeti import constants

from ganeti import opcodes

import ganeti.rpc.node as rpc

from ganeti import ssh

from ganeti import compat

    obuf.write("Parameter Error: %s" % msg)

  elif isinstance(err, errors.ParameterError):

    obuf.write("Failure: unknown/wrong parameter name '%s'" % msg)

    if err.args[0] == pathutils.MASTER_SOCKET:

      daemon = "the master daemon"

    elif err.args[0] == pathutils.QUERY_SOCKET:

      daemon = "socket '%s'" % str(err.args[0])

    obuf.write("Cannot communicate with %s.\nIs the process running"

               " and listening for connections?" % daemon)

    obuf.write("Timeout while talking to the master daemon. Jobs might have"

               " been submitted and will continue to run even if the call"

               " timed out. Useful commands in this situation are \"gnt-job"

               " list\", \"gnt-job cancel\" and \"gnt-job watch\". Error:\n")

    obuf.write(msg)

    obuf.write("It seems you don't have permissions to connect to the"

               " master daemon.\nPlease retry as a different user.")

    obuf.write("Unhandled protocol error while talking to the master daemon:\n"

               "%s" % msg)

  elif isinstance(err, errors.JobLost):

  try:

    result = func(options, args)

          JobSubmittedException), err:

    result, err_msg = FormatError(err)

    logging.exception("Error during command processing")

        ToStderr("Job %s%s has been archived, cannot check its result",

                 jid, self._IfName(name, " for %s"))

        success = False

        _, job_result = FormatError(err)

        success = False

        # the error message will always be shown, verbose or not

from ganeti import objects

import ganeti.rpc.client as cl

from ganeti.rpc.transport import Transport

__all__ = [

  # classes:

  "Client"

  ]

DEF_RWTO = constants.LUXI_DEF_RWTO

WFJC_TIMEOUT = constants.LUXI_WFJC_TIMEOUT

class Client(cl.AbstractClient):

  """High-level client implementation.

import logging

from ganeti import luxi

from ganeti import rapi

from ganeti import http

from ganeti import errors

    # Could be a function, pylint: disable=R0201

    try:

      return self._client_cls(address=address)

      raise http.HttpBadGateway("Can't connect to master daemon: %s" % err)

      raise http.HttpInternalServerError("Internal error: no permission to"

                                         " connect to the master daemon")

      raise http.HttpServiceUnavailable("Job queue is full, needs archiving")

    except errors.JobQueueDrainError:

      raise http.HttpServiceUnavailable("Job queue is drained, cannot submit")

      raise http.HttpBadGateway("Master seems to be unreachable: %s" % err)

      raise http.HttpInternalServerError("Internal error: no permission to"

                                         " connect to the master daemon")

      raise http.HttpGatewayTimeout("Timeout while talking to the master"

                                    " daemon: %s" % err)

from ganeti import jqueue

from ganeti import locking

from ganeti import luxi

from ganeti import utils

from ganeti import errors

from ganeti import ssconf

    try:

      (method, args, ver) = rpccl.ParseRequest(message)

      logging.error("Protocol Error: %s", err)

      client.close_log()

      return

from ganeti import http

from ganeti import daemon

from ganeti import ssconf

from ganeti import serializer

from ganeti import compat

from ganeti import utils

    try:

      result = ctx.handler_fn()

      raise http.HttpGatewayTimeout()

      raise http.HttpBadGateway(str(err))

    req.resp_headers[http.HTTP_CONTENT_TYPE] = http.HTTP_APP_JSON

from ganeti import errors

from ganeti import opcodes

from ganeti import cli

from ganeti import rapi

from ganeti import netutils

from ganeti import qlang

    # this is, from cli.GetClient, a not-master case

    raise NotMasterError("Not on master node (%s)" % err)

    if not try_restart:

      raise

from ganeti import compat

from ganeti import http

from ganeti import query

from ganeti import errors

from ganeti import rapi

class TestClientConnectError(unittest.TestCase):

  @staticmethod

  def _FailingClient(address=None):

  def test(self):

    resources = [