python/aqmp: rename AQMPError to QMPError
This is in preparation for renaming qemu.aqmp to qemu.qmp. I should have done this from this from the very beginning, but it's a convenient time to make sure this churn is taken care of. Signed-off-by: John Snow <jsnow@redhat.com> Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@virtuozzo.com>
This commit is contained in:
parent
728dcac5e3
commit
6e7751dc38
@ -6,7 +6,7 @@ asynchronously with QMP protocol servers, as implemented by QEMU, the
|
||||
QEMU Guest Agent, and the QEMU Storage Daemon.
|
||||
|
||||
`QMPClient` provides the main functionality of this package. All errors
|
||||
raised by this library derive from `AQMPError`, see `aqmp.error` for
|
||||
raised by this library derive from `QMPError`, see `aqmp.error` for
|
||||
additional detail. See `aqmp.events` for an in-depth tutorial on
|
||||
managing QMP events.
|
||||
"""
|
||||
@ -23,7 +23,7 @@ managing QMP events.
|
||||
|
||||
import logging
|
||||
|
||||
from .error import AQMPError
|
||||
from .error import QMPError
|
||||
from .events import EventListener
|
||||
from .message import Message
|
||||
from .protocol import (
|
||||
@ -48,7 +48,7 @@ __all__ = (
|
||||
'Runstate',
|
||||
|
||||
# Exceptions, most generic to most explicit
|
||||
'AQMPError',
|
||||
'QMPError',
|
||||
'StateError',
|
||||
'ConnectError',
|
||||
'ExecuteError',
|
||||
|
@ -1,21 +1,21 @@
|
||||
"""
|
||||
AQMP Error Classes
|
||||
QMP Error Classes
|
||||
|
||||
This package seeks to provide semantic error classes that are intended
|
||||
to be used directly by clients when they would like to handle particular
|
||||
semantic failures (e.g. "failed to connect") without needing to know the
|
||||
enumeration of possible reasons for that failure.
|
||||
|
||||
AQMPError serves as the ancestor for all exceptions raised by this
|
||||
QMPError serves as the ancestor for all exceptions raised by this
|
||||
package, and is suitable for use in handling semantic errors from this
|
||||
library. In most cases, individual public methods will attempt to catch
|
||||
and re-encapsulate various exceptions to provide a semantic
|
||||
error-handling interface.
|
||||
|
||||
.. admonition:: AQMP Exception Hierarchy Reference
|
||||
.. admonition:: QMP Exception Hierarchy Reference
|
||||
|
||||
| `Exception`
|
||||
| +-- `AQMPError`
|
||||
| +-- `QMPError`
|
||||
| +-- `ConnectError`
|
||||
| +-- `StateError`
|
||||
| +-- `ExecInterruptedError`
|
||||
@ -31,11 +31,11 @@ error-handling interface.
|
||||
"""
|
||||
|
||||
|
||||
class AQMPError(Exception):
|
||||
class QMPError(Exception):
|
||||
"""Abstract error class for all errors originating from this package."""
|
||||
|
||||
|
||||
class ProtocolError(AQMPError):
|
||||
class ProtocolError(QMPError):
|
||||
"""
|
||||
Abstract error class for protocol failures.
|
||||
|
||||
|
@ -443,7 +443,7 @@ from typing import (
|
||||
Union,
|
||||
)
|
||||
|
||||
from .error import AQMPError
|
||||
from .error import QMPError
|
||||
from .message import Message
|
||||
|
||||
|
||||
@ -451,7 +451,7 @@ EventNames = Union[str, Iterable[str], None]
|
||||
EventFilter = Callable[[Message], bool]
|
||||
|
||||
|
||||
class ListenerError(AQMPError):
|
||||
class ListenerError(QMPError):
|
||||
"""
|
||||
Generic error class for `EventListener`-related problems.
|
||||
"""
|
||||
|
@ -17,7 +17,7 @@ from typing import (
|
||||
|
||||
import qemu.qmp
|
||||
|
||||
from .error import AQMPError
|
||||
from .error import QMPError
|
||||
from .protocol import Runstate, SocketAddrT
|
||||
from .qmp_client import QMPClient
|
||||
|
||||
@ -168,7 +168,7 @@ class QEMUMonitorProtocol(qemu.qmp.QEMUMonitorProtocol):
|
||||
# Nothing we can do about it now, but if we don't raise our
|
||||
# own error, the user will be treated to a lot of traceback
|
||||
# they might not understand.
|
||||
raise AQMPError(
|
||||
raise QMPError(
|
||||
"QEMUMonitorProtocol.close()"
|
||||
" was not called before object was garbage collected"
|
||||
)
|
||||
|
@ -29,7 +29,7 @@ from typing import (
|
||||
cast,
|
||||
)
|
||||
|
||||
from .error import AQMPError
|
||||
from .error import QMPError
|
||||
from .util import (
|
||||
bottom_half,
|
||||
create_task,
|
||||
@ -65,7 +65,7 @@ class Runstate(Enum):
|
||||
DISCONNECTING = 3
|
||||
|
||||
|
||||
class ConnectError(AQMPError):
|
||||
class ConnectError(QMPError):
|
||||
"""
|
||||
Raised when the initial connection process has failed.
|
||||
|
||||
@ -90,7 +90,7 @@ class ConnectError(AQMPError):
|
||||
return f"{self.error_message}: {cause}"
|
||||
|
||||
|
||||
class StateError(AQMPError):
|
||||
class StateError(QMPError):
|
||||
"""
|
||||
An API command (connect, execute, etc) was issued at an inappropriate time.
|
||||
|
||||
@ -363,7 +363,7 @@ class AsyncProtocol(Generic[T]):
|
||||
This exception will wrap a more concrete one. In most cases,
|
||||
the wrapped exception will be `OSError` or `EOFError`. If a
|
||||
protocol-level failure occurs while establishing a new
|
||||
session, the wrapped error may also be an `AQMPError`.
|
||||
session, the wrapped error may also be an `QMPError`.
|
||||
"""
|
||||
assert self.runstate == Runstate.IDLE
|
||||
|
||||
|
@ -20,7 +20,7 @@ from typing import (
|
||||
cast,
|
||||
)
|
||||
|
||||
from .error import AQMPError, ProtocolError
|
||||
from .error import ProtocolError, QMPError
|
||||
from .events import Events
|
||||
from .message import Message
|
||||
from .models import ErrorResponse, Greeting
|
||||
@ -66,7 +66,7 @@ class NegotiationError(_WrappedProtocolError):
|
||||
"""
|
||||
|
||||
|
||||
class ExecuteError(AQMPError):
|
||||
class ExecuteError(QMPError):
|
||||
"""
|
||||
Exception raised by `QMPClient.execute()` on RPC failure.
|
||||
|
||||
@ -87,7 +87,7 @@ class ExecuteError(AQMPError):
|
||||
self.error_class: str = error_response.error.class_
|
||||
|
||||
|
||||
class ExecInterruptedError(AQMPError):
|
||||
class ExecInterruptedError(QMPError):
|
||||
"""
|
||||
Exception raised by `execute()` (et al) when an RPC is interrupted.
|
||||
|
||||
@ -641,7 +641,7 @@ class QMPClient(AsyncProtocol[Message], Events):
|
||||
sock = self._writer.transport.get_extra_info('socket')
|
||||
|
||||
if sock.family != socket.AF_UNIX:
|
||||
raise AQMPError("Sending file descriptors requires a UNIX socket.")
|
||||
raise QMPError("Sending file descriptors requires a UNIX socket.")
|
||||
|
||||
if not hasattr(sock, 'sendmsg'):
|
||||
# We need to void the warranty sticker.
|
||||
|
Loading…
Reference in New Issue
Block a user