[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
Re: [PATCH RFC 12/32] python/qemu/lib: fix socket.makefile() typing
From: |
Philippe Mathieu-Daudé |
Subject: |
Re: [PATCH RFC 12/32] python/qemu/lib: fix socket.makefile() typing |
Date: |
Sun, 31 May 2020 11:59:14 +0200 |
User-agent: |
Mozilla/5.0 (X11; Linux x86_64; rv:68.0) Gecko/20100101 Thunderbird/68.5.0 |
On 5/14/20 7:53 AM, John Snow wrote:
> Note:
>
> A bug in typeshed (https://github.com/python/typeshed/issues/3977)
> misinterprets the type of makefile(). Work around this by explicitly
> stating that we are opening a text-mode file.
>
> Signed-off-by: John Snow <jsnow@redhat.com>
> ---
> python/qemu/lib/qmp.py | 10 +++++++---
> python/qemu/lib/qtest.py | 12 ++++++++----
> 2 files changed, 15 insertions(+), 7 deletions(-)
>
> diff --git a/python/qemu/lib/qmp.py b/python/qemu/lib/qmp.py
> index 6ae7693965..73d49050ed 100644
> --- a/python/qemu/lib/qmp.py
> +++ b/python/qemu/lib/qmp.py
> @@ -11,6 +11,10 @@
> import errno
> import socket
> import logging
> +from typing import (
> + Optional,
> + TextIO,
> +)
>
>
> class QMPError(Exception):
> @@ -61,7 +65,7 @@ def __init__(self, address, server=False, nickname=None):
> self.__events = []
> self.__address = address
> self.__sock = self.__get_sock()
> - self.__sockfile = None
> + self.__sockfile: Optional[TextIO] = None
> self._nickname = nickname
> if self._nickname:
> self.logger = logging.getLogger('QMP').getChild(self._nickname)
> @@ -157,7 +161,7 @@ def connect(self, negotiate=True):
> @raise QMPCapabilitiesError if fails to negotiate capabilities
> """
> self.__sock.connect(self.__address)
> - self.__sockfile = self.__sock.makefile()
> + self.__sockfile = self.__sock.makefile(mode='r')
> if negotiate:
> return self.__negotiate_capabilities()
> return None
> @@ -180,7 +184,7 @@ def accept(self, timeout=15.0):
> """
> self.__sock.settimeout(timeout)
> self.__sock, _ = self.__sock.accept()
> - self.__sockfile = self.__sock.makefile()
> + self.__sockfile = self.__sock.makefile(mode='r')
> return self.__negotiate_capabilities()
>
> def cmd_obj(self, qmp_cmd):
> diff --git a/python/qemu/lib/qtest.py b/python/qemu/lib/qtest.py
> index 7943487c2b..4c88590eb0 100644
> --- a/python/qemu/lib/qtest.py
> +++ b/python/qemu/lib/qtest.py
> @@ -19,6 +19,7 @@
>
> import socket
> import os
> +from typing import Optional, TextIO
>
> from .machine import QEMUMachine
>
> @@ -40,7 +41,7 @@ class QEMUQtestProtocol:
> def __init__(self, address, server=False):
> self._address = address
> self._sock = self._get_sock()
> - self._sockfile = None
> + self._sockfile: Optional[TextIO] = None
> if server:
> self._sock.bind(self._address)
> self._sock.listen(1)
> @@ -59,7 +60,7 @@ def connect(self):
> @raise socket.error on socket connection errors
> """
> self._sock.connect(self._address)
> - self._sockfile = self._sock.makefile()
> + self._sockfile = self._sock.makefile(mode='r')
>
> def accept(self):
> """
> @@ -68,7 +69,7 @@ def accept(self):
> @raise socket.error on socket connection errors
> """
> self._sock, _ = self._sock.accept()
> - self._sockfile = self._sock.makefile()
> + self._sockfile = self._sock.makefile(mode='r')
>
> def cmd(self, qtest_cmd):
> """
> @@ -76,6 +77,7 @@ def cmd(self, qtest_cmd):
>
> @param qtest_cmd: qtest command text to be sent
> """
> + assert self._sockfile is not None
> self._sock.sendall((qtest_cmd + "\n").encode('utf-8'))
> resp = self._sockfile.readline()
> return resp
> @@ -83,7 +85,9 @@ def cmd(self, qtest_cmd):
> def close(self):
> """Close this socket."""
> self._sock.close()
> - self._sockfile.close()
> + if self._sockfile:
> + self._sockfile.close()
> + self._sockfile = None
>
> def settimeout(self, timeout):
> """Set a timeout, in seconds."""
>
Reviewed-by: Philippe Mathieu-Daudé <philmd@redhat.com>
And applied to my python-next tree:
https://gitlab.com/philmd/qemu/commits/python-next
- Re: [PATCH RFC 23/32] python//machine.py: reorder __init__, (continued)
- [PATCH RFC 24/32] python//machine.py: Don't modify state in _base_args(), John Snow, 2020/05/14
- [PATCH RFC 25/32] python//machine.py: Handle None events in event_wait, John Snow, 2020/05/14
- [PATCH RFC 26/32] python//machine.py: use qmp.command, John Snow, 2020/05/14
- [PATCH RFC 28/32] python//machine.py: fix _popen access, John Snow, 2020/05/14
- [PATCH RFC 27/32] python//machine.py: Add _qmp access shim, John Snow, 2020/05/14
- [PATCH RFC 29/32] python//qtest.py: Check before accessing _qtest, John Snow, 2020/05/14
- [PATCH RFC 12/32] python/qemu/lib: fix socket.makefile() typing, John Snow, 2020/05/14
- Re: [PATCH RFC 12/32] python/qemu/lib: fix socket.makefile() typing,
Philippe Mathieu-Daudé <=
- [PATCH RFC 31/32] python/qemu: add mypy to Pipfile, John Snow, 2020/05/14
- [PATCH RFC 19/32] python//qmp.py: add QMPProtocolError, John Snow, 2020/05/14
- [PATCH RFC 13/32] python/qemu/lib: Adjust traceback typing, John Snow, 2020/05/14
- [PATCH RFC 30/32] python/qemu/lib: make 'args' style arguments immutable, John Snow, 2020/05/14
- [PATCH RFC 32/32] python/qemu/lib: Add mypy type annotations, John Snow, 2020/05/14
- Re: [PATCH RFC 00/32] python/qemu: refactor as installable package, Philippe Mathieu-Daudé, 2020/05/18