aboutsummaryrefslogtreecommitdiff
path: root/python/qemu
diff options
context:
space:
mode:
authorWainer dos Santos Moschetta <wainersm@redhat.com>2020-02-04 11:11:10 -0300
committerPhilippe Mathieu-Daudé <philmd@redhat.com>2020-02-07 15:12:48 +0100
commit07608e807d4e7bd2daa7fe154bd9dc2235c1a323 (patch)
tree38a24e66e3b91d3e5985ff50d03659d7a37d6bd5 /python/qemu
parent54aafc2fc65231871e744308705c4aa6d283a22d (diff)
downloadqemu-07608e807d4e7bd2daa7fe154bd9dc2235c1a323.zip
qemu-07608e807d4e7bd2daa7fe154bd9dc2235c1a323.tar.gz
qemu-07608e807d4e7bd2daa7fe154bd9dc2235c1a323.tar.bz2
python/qemu: qmp: Make QEMUMonitorProtocol a context manager
This implement the __enter__ and __exit__ functions on QEMUMonitorProtocol class so that it can be used on 'with' statement and the resources will be free up on block end: with QEMUMonitorProtocol(socket_path) as qmp: qmp.connect() qmp.command('query-status') Signed-off-by: Wainer dos Santos Moschetta <wainersm@redhat.com> Reviewed-by: John Snow <jsnow@redhat.com> Message-Id: <20200204141111.3207-5-wainersm@redhat.com> Signed-off-by: Philippe Mathieu-Daudé <philmd@redhat.com>
Diffstat (limited to 'python/qemu')
-rw-r--r--python/qemu/qmp.py15
1 files changed, 13 insertions, 2 deletions
diff --git a/python/qemu/qmp.py b/python/qemu/qmp.py
index 0e07d80..486a566 100644
--- a/python/qemu/qmp.py
+++ b/python/qemu/qmp.py
@@ -139,6 +139,15 @@ class QEMUMonitorProtocol:
raise QMPConnectError("Error while reading from socket")
self.__sock.settimeout(None)
+ def __enter__(self):
+ # Implement context manager enter function.
+ return self
+
+ def __exit__(self, exc_type, exc_value, exc_traceback):
+ # Implement context manager exit function.
+ self.close()
+ return False
+
def connect(self, negotiate=True):
"""
Connect to the QMP Monitor and perform capabilities negotiation.
@@ -265,8 +274,10 @@ class QEMUMonitorProtocol:
"""
Close the socket and socket file.
"""
- self.__sock.close()
- self.__sockfile.close()
+ if self.__sock:
+ self.__sock.close()
+ if self.__sockfile:
+ self.__sockfile.close()
def settimeout(self, timeout):
"""