mirror of
https://github.com/python/cpython.git
synced 2025-10-31 13:41:24 +00:00
d03acd7270
Co-authored-by: Yury Selivanov <yury@edgedb.com> Co-authored-by: Andrew Svetlov <andrew.svetlov@gmail.com>
62 lines
1.7 KiB
Python
62 lines
1.7 KiB
Python
"""asyncio exceptions."""
|
|
|
|
|
|
__all__ = ('BrokenBarrierError',
|
|
'CancelledError', 'InvalidStateError', 'TimeoutError',
|
|
'IncompleteReadError', 'LimitOverrunError',
|
|
'SendfileNotAvailableError')
|
|
|
|
|
|
class CancelledError(BaseException):
|
|
"""The Future or Task was cancelled."""
|
|
|
|
|
|
TimeoutError = TimeoutError # make local alias for the standard exception
|
|
|
|
|
|
class InvalidStateError(Exception):
|
|
"""The operation is not allowed in this state."""
|
|
|
|
|
|
class SendfileNotAvailableError(RuntimeError):
|
|
"""Sendfile syscall is not available.
|
|
|
|
Raised if OS does not support sendfile syscall for given socket or
|
|
file type.
|
|
"""
|
|
|
|
|
|
class IncompleteReadError(EOFError):
|
|
"""
|
|
Incomplete read error. Attributes:
|
|
|
|
- partial: read bytes string before the end of stream was reached
|
|
- expected: total number of expected bytes (or None if unknown)
|
|
"""
|
|
def __init__(self, partial, expected):
|
|
r_expected = 'undefined' if expected is None else repr(expected)
|
|
super().__init__(f'{len(partial)} bytes read on a total of '
|
|
f'{r_expected} expected bytes')
|
|
self.partial = partial
|
|
self.expected = expected
|
|
|
|
def __reduce__(self):
|
|
return type(self), (self.partial, self.expected)
|
|
|
|
|
|
class LimitOverrunError(Exception):
|
|
"""Reached the buffer limit while looking for a separator.
|
|
|
|
Attributes:
|
|
- consumed: total number of to be consumed bytes.
|
|
"""
|
|
def __init__(self, message, consumed):
|
|
super().__init__(message)
|
|
self.consumed = consumed
|
|
|
|
def __reduce__(self):
|
|
return type(self), (self.args[0], self.consumed)
|
|
|
|
|
|
class BrokenBarrierError(RuntimeError):
|
|
"""Barrier is broken by barrier.abort() call."""
|