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