[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[PATCH 03/15] python/aqmp: Return cleared events from EventListener.clea
From: |
John Snow |
Subject: |
[PATCH 03/15] python/aqmp: Return cleared events from EventListener.clear() |
Date: |
Fri, 17 Sep 2021 01:40:35 -0400 |
This serves two purposes:
(1) It is now possible to discern whether or not clear() removed any
event(s) from the queue with absolute certainty, and
(2) It is now very easy to get a List of all pending events in one
chunk, which is useful for the sync bridge.
Signed-off-by: John Snow <jsnow@redhat.com>
---
python/qemu/aqmp/events.py | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/python/qemu/aqmp/events.py b/python/qemu/aqmp/events.py
index 271899f6b8..5f7150c78d 100644
--- a/python/qemu/aqmp/events.py
+++ b/python/qemu/aqmp/events.py
@@ -562,7 +562,7 @@ def empty(self) -> bool:
"""
return self._queue.empty()
- def clear(self) -> None:
+ def clear(self) -> List[Message]:
"""
Clear this listener of all pending events.
@@ -570,17 +570,22 @@ def clear(self) -> None:
pending FIFO queue synchronously. It can be also be used to
manually clear any pending events, if desired.
+ :return: The cleared events, if any.
+
.. warning::
Take care when discarding events. Cleared events will be
silently tossed on the floor. All events that were ever
accepted by this listener are visible in `history()`.
"""
+ events = []
while True:
try:
- self._queue.get_nowait()
+ events.append(self._queue.get_nowait())
except asyncio.QueueEmpty:
break
+ return events
+
def __aiter__(self) -> AsyncIterator[Message]:
return self
--
2.31.1
- [PATCH 02/15] python/aqmp: add .empty() method to EventListener, (continued)
- [PATCH 02/15] python/aqmp: add .empty() method to EventListener, John Snow, 2021/09/17
- [PATCH 04/15] python/qmp: clear events on get_events() call, John Snow, 2021/09/17
- [PATCH 05/15] python/qmp: add send_fd_scm directly to QEMUMonitorProtocol, John Snow, 2021/09/17
- [PATCH 01/15] python/aqmp: add greeting property to QMPClient, John Snow, 2021/09/17
- [PATCH 03/15] python/aqmp: Return cleared events from EventListener.clear(),
John Snow <=
- [PATCH 07/15] python/aqmp: add send_fd_scm, John Snow, 2021/09/17
- [PATCH 06/15] python, iotests: remove socket_scm_helper, John Snow, 2021/09/17
- [PATCH 09/15] python/machine: remove has_quit argument, John Snow, 2021/09/17