diff options
author | John Snow | 2020-10-07 01:58:10 +0200 |
---|---|---|
committer | John Snow | 2020-10-20 15:37:57 +0200 |
commit | 6cf4cce7cb489fb5ed7eb72124f6b0c422155ebc (patch) | |
tree | cd5b06a21ed97c844211307333e7b47f56207821 /python/qemu | |
parent | python/qemu/console_socket.py: Correct type of recv() (diff) | |
download | qemu-6cf4cce7cb489fb5ed7eb72124f6b0c422155ebc.tar.gz qemu-6cf4cce7cb489fb5ed7eb72124f6b0c422155ebc.tar.xz qemu-6cf4cce7cb489fb5ed7eb72124f6b0c422155ebc.zip |
python/qemu/console_socket.py: fix typing of settimeout
The types and names of the parameters must match the socket.socket interface.
Signed-off-by: John Snow <jsnow@redhat.com>
Reviewed-by: Kevin Wolf <kwolf@redhat.com>
Message-id: 20201006235817.3280413-14-jsnow@redhat.com
Signed-off-by: John Snow <jsnow@redhat.com>
Diffstat (limited to 'python/qemu')
-rw-r--r-- | python/qemu/console_socket.py | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/python/qemu/console_socket.py b/python/qemu/console_socket.py index cb3400a038..3945682506 100644 --- a/python/qemu/console_socket.py +++ b/python/qemu/console_socket.py @@ -17,6 +17,7 @@ from collections import deque import socket import threading import time +from typing import Optional class ConsoleSocket(socket.socket): @@ -31,6 +32,7 @@ class ConsoleSocket(socket.socket): """ def __init__(self, address, file=None, drain=False): self._recv_timeout_sec = 300 + self._recv_timeout_sec = 300.0 self._sleep_time = 0.5 self._buffer = deque() socket.socket.__init__(self, socket.AF_UNIX, socket.SOCK_STREAM) @@ -120,11 +122,11 @@ class ConsoleSocket(socket.socket): if self._drain_thread is None: socket.socket.setblocking(self, value) - def settimeout(self, seconds): + def settimeout(self, value: Optional[float]) -> None: """When not draining we pass thru to the socket, since when draining we control the timeout. """ - if seconds is not None: - self._recv_timeout_sec = seconds + if value is not None: + self._recv_timeout_sec = value if self._drain_thread is None: - socket.socket.settimeout(self, seconds) + socket.socket.settimeout(self, value) |