error.py
257 lines
| 8.1 KiB
| text/x-python
|
PythonLexer
/ mercurial / error.py
|
r8226 | # error.py - Mercurial exceptions | ||
# | ||||
# Copyright 2005-2008 Matt Mackall <mpm@selenic.com> | ||||
# | ||||
# This software may be used and distributed according to the terms of the | ||||
|
r10263 | # GNU General Public License version 2 or any later version. | ||
|
r7633 | |||
|
r8227 | """Mercurial exceptions. | ||
This allows us to catch exceptions at higher levels without forcing | ||||
imports. | ||||
""" | ||||
|
r25945 | from __future__ import absolute_import | ||
|
r7633 | # Do not import anything here, please | ||
|
r29509 | class Hint(object): | ||
"""Mix-in to provide a hint of an error | ||||
|
r29510 | This should come first in the inheritance list to consume a hint and | ||
pass remaining arguments to the exception class. | ||||
|
r29509 | """ | ||
|
r25248 | def __init__(self, *args, **kw): | ||
|
r31503 | self.hint = kw.pop(r'hint', None) | ||
|
r29510 | super(Hint, self).__init__(*args, **kw) | ||
|
r25248 | |||
|
r29509 | class RevlogError(Hint, Exception): | ||
|
r7633 | pass | ||
|
r23014 | class FilteredIndexError(IndexError): | ||
pass | ||||
|
r7633 | class LookupError(RevlogError, KeyError): | ||
def __init__(self, name, index, message): | ||||
self.name = name | ||||
|
r24038 | self.index = index | ||
|
r24137 | # this can't be called 'message' because at least some installs of | ||
# Python 2.6+ complain about the 'message' property being deprecated | ||||
self.lookupmessage = message | ||||
|
r7633 | if isinstance(name, str) and len(name) == 20: | ||
|
r25945 | from .node import short | ||
|
r7633 | name = short(name) | ||
RevlogError.__init__(self, '%s@%s: %s' % (index, name, message)) | ||||
def __str__(self): | ||||
return RevlogError.__str__(self) | ||||
|
r7636 | |||
|
r23015 | class FilteredLookupError(LookupError): | ||
pass | ||||
|
r18855 | class ManifestLookupError(LookupError): | ||
pass | ||||
|
r11287 | class CommandError(Exception): | ||
|
r7636 | """Exception raised on errors in parsing the command line.""" | ||
|
r7637 | |||
|
r29509 | class InterventionRequired(Hint, Exception): | ||
|
r18931 | """Exception raised when a command requires human intervention.""" | ||
|
r29509 | class Abort(Hint, Exception): | ||
|
r11288 | """Raised if a command needs to print an error and exit.""" | ||
|
r26692 | class HookLoadError(Abort): | ||
"""raised when loading a hook fails, aborting an operation | ||||
Exists to allow more specialized catching.""" | ||||
|
r23415 | class HookAbort(Abort): | ||
"""raised when a validation hook fails, aborting an operation | ||||
Exists to allow more specialized catching.""" | ||||
|
r11288 | class ConfigError(Abort): | ||
|
r22359 | """Exception raised when parsing config files""" | ||
|
r8144 | |||
|
r26683 | class UpdateAbort(Abort): | ||
"""Raised when an update is aborted for destination issue""" | ||||
|
r28141 | class MergeDestAbort(Abort): | ||
"""Raised when an update is aborted for destination issues""" | ||||
class NoMergeDestAbort(MergeDestAbort): | ||||
"""Raised when an update is aborted because there is nothing to merge""" | ||||
class ManyMergeDestAbort(MergeDestAbort): | ||||
|
r30332 | """Raised when an update is aborted because destination is ambiguous""" | ||
|
r28141 | |||
|
r26896 | class ResponseExpected(Abort): | ||
"""Raised when an EOF is received for a prompt""" | ||||
def __init__(self): | ||||
from .i18n import _ | ||||
Abort.__init__(self, _('response expected')) | ||||
|
r29509 | class OutOfBandError(Hint, Exception): | ||
|
r22359 | """Exception raised when a remote repo reports failure""" | ||
|
r15017 | |||
|
r29509 | class ParseError(Hint, Exception): | ||
|
r24040 | """Raised when parsing config files and {rev,file}sets (msg[, pos])""" | ||
|
r11288 | |||
|
r24217 | class UnknownIdentifier(ParseError): | ||
"""Exception raised when a {rev,file}set references an unknown identifier""" | ||||
def __init__(self, function, symbols): | ||||
|
r25945 | from .i18n import _ | ||
|
r24217 | ParseError.__init__(self, _("unknown identifier: %s") % function) | ||
self.function = function | ||||
self.symbols = symbols | ||||
|
r29509 | class RepoError(Hint, Exception): | ||
|
r25248 | pass | ||
|
r7637 | |||
|
r9423 | class RepoLookupError(RepoError): | ||
pass | ||||
|
r23016 | class FilteredRepoLookupError(RepoLookupError): | ||
pass | ||||
|
r7637 | class CapabilityError(RepoError): | ||
pass | ||||
|
r7640 | |||
|
r13447 | class RequirementError(RepoError): | ||
"""Exception raised if .hg/requires has an unknown entry.""" | ||||
|
r31959 | class StdioError(IOError): | ||
"""Raised if I/O to stdout or stderr fails""" | ||||
def __init__(self, err): | ||||
IOError.__init__(self, err.errno, err.strerror) | ||||
|
r26985 | class UnsupportedMergeRecords(Abort): | ||
def __init__(self, recordtypes): | ||||
from .i18n import _ | ||||
self.recordtypes = sorted(recordtypes) | ||||
s = ' '.join(self.recordtypes) | ||||
Abort.__init__( | ||||
self, _('unsupported merge state records: %s') % s, | ||||
hint=_('see https://mercurial-scm.org/wiki/MergeStateRecords for ' | ||||
'more information')) | ||||
|
r7640 | class LockError(IOError): | ||
def __init__(self, errno, strerror, filename, desc): | ||||
IOError.__init__(self, errno, strerror, filename) | ||||
self.desc = desc | ||||
class LockHeld(LockError): | ||||
def __init__(self, errno, filename, desc, locker): | ||||
LockError.__init__(self, errno, 'Lock held', filename, desc) | ||||
self.locker = locker | ||||
class LockUnavailable(LockError): | ||||
pass | ||||
|
r7641 | |||
|
r26355 | # LockError is for errors while acquiring the lock -- this is unrelated | ||
|
r26438 | class LockInheritanceContractViolation(RuntimeError): | ||
|
r26355 | pass | ||
|
r7641 | class ResponseError(Exception): | ||
"""Raised to print an error with part of output and exit.""" | ||||
|
r7643 | class UnknownCommand(Exception): | ||
"""Exception raised if command is not in the command table.""" | ||||
class AmbiguousCommand(Exception): | ||||
"""Exception raised if command shortcut matches more than one command.""" | ||||
|
r7644 | # derived from KeyboardInterrupt to simplify some breakout code | ||
class SignalInterrupt(KeyboardInterrupt): | ||||
"""Exception raised on SIGTERM and SIGHUP.""" | ||||
|
r7646 | |||
class SignatureError(Exception): | ||||
pass | ||||
|
r21184 | |||
class PushRaced(RuntimeError): | ||||
"""An exception raised during unbundling that indicate a push race""" | ||||
|
r32340 | class ProgrammingError(Hint, RuntimeError): | ||
|
r30585 | """Raised if a mercurial (core or extension) developer made a mistake""" | ||
|
r30573 | |||
|
r21618 | # bundle2 related errors | ||
class BundleValueError(ValueError): | ||||
|
r21621 | """error raised when bundle2 cannot be processed""" | ||
|
r21620 | |||
|
r26393 | class BundleUnknownFeatureError(BundleValueError): | ||
|
r26394 | def __init__(self, parttype=None, params=(), values=()): | ||
|
r21620 | self.parttype = parttype | ||
|
r21621 | self.params = params | ||
|
r26394 | self.values = values | ||
|
r21627 | if self.parttype is None: | ||
msg = 'Stream Parameter' | ||||
else: | ||||
msg = parttype | ||||
|
r26394 | entries = self.params | ||
if self.params and self.values: | ||||
assert len(self.params) == len(self.values) | ||||
entries = [] | ||||
for idx, par in enumerate(self.params): | ||||
val = self.values[idx] | ||||
if val is None: | ||||
entries.append(val) | ||||
else: | ||||
entries.append("%s=%r" % (par, val)) | ||||
if entries: | ||||
msg = '%s - %s' % (msg, ', '.join(entries)) | ||||
|
r21747 | ValueError.__init__(self, msg) | ||
|
r21618 | |||
class ReadOnlyPartError(RuntimeError): | ||||
"""error raised when code tries to alter a part being generated""" | ||||
|
r25484 | class PushkeyFailed(Abort): | ||
"""error raised when a pushkey part failed to update a value""" | ||||
def __init__(self, partid, namespace=None, key=None, new=None, old=None, | ||||
ret=None): | ||||
self.partid = partid | ||||
self.namespace = namespace | ||||
self.key = key | ||||
self.new = new | ||||
self.old = old | ||||
self.ret = ret | ||||
# no i18n expected to be processed into a better message | ||||
Abort.__init__(self, 'failed to update value for "%s/%s"' | ||||
% (namespace, key)) | ||||
|
r22595 | class CensoredNodeError(RevlogError): | ||
|
r24190 | """error raised when content verification fails on a censored node | ||
|
r22595 | |||
|
r24190 | Also contains the tombstone data substituted for the uncensored data. | ||
""" | ||||
def __init__(self, filename, node, tombstone): | ||||
|
r25945 | from .node import short | ||
|
r22595 | RevlogError.__init__(self, '%s:%s' % (filename, short(node))) | ||
|
r24190 | self.tombstone = tombstone | ||
|
r24120 | |||
class CensoredBaseError(RevlogError): | ||||
"""error raised when a delta is rejected because its base is censored | ||||
A delta based on a censored revision must be formed as single patch | ||||
operation which replaces the entire base with new content. This ensures | ||||
the delta may be applied by clones which have not censored the base. | ||||
""" | ||||
|
r26640 | |||
class InvalidBundleSpecification(Exception): | ||||
"""error raised when a bundle specification is invalid. | ||||
This is used for syntax errors as opposed to support errors. | ||||
""" | ||||
class UnsupportedBundleSpecification(Exception): | ||||
"""error raised when a bundle specification is not supported.""" | ||||
|
r29536 | |||
class CorruptedState(Exception): | ||||
"""error raised when a command is not able to read its state from file""" | ||||
|
r32002 | |||
|
r32023 | class PeerTransportError(Abort): | ||
"""Transport-level I/O error when communicating with a peer repo.""" | ||||