mirrors/qemu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

python/qemu/console_socket.py: fix typing of settimeout

Browse Source 
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>
This commit is contained in:
John Snow 2020-10-06 19:58:10 -04:00
parent ff3513e632
commit 6cf4cce7cb
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
python/qemu/console_socket.py
View File

@ -17,6 +17,7 @@ from collections import deque
import socket import socket
import threading import threading
import time import time
from typing import Optional
class ConsoleSocket(socket.socket): class ConsoleSocket(socket.socket):
@ -31,6 +32,7 @@ class ConsoleSocket(socket.socket):
""" """
def __init__(self, address, file=None, drain=False): def __init__(self, address, file=None, drain=False):
self._recv_timeout_sec = 300 self._recv_timeout_sec = 300
self._recv_timeout_sec = 300.0
self._sleep_time = 0.5 self._sleep_time = 0.5
self._buffer = deque() self._buffer = deque()
socket.socket.__init__(self, socket.AF_UNIX, socket.SOCK_STREAM) socket.socket.__init__(self, socket.AF_UNIX, socket.SOCK_STREAM)
@ -120,11 +122,11 @@ class ConsoleSocket(socket.socket):
if self._drain_thread is None: if self._drain_thread is None:
socket.socket.setblocking(self, value) 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, """When not draining we pass thru to the socket,
since when draining we control the timeout. since when draining we control the timeout.
""" """
if seconds is not None: if value is not None:
self._recv_timeout_sec = seconds self._recv_timeout_sec = value
if self._drain_thread is None: if self._drain_thread is None:
socket.socket.settimeout(self, seconds) socket.socket.settimeout(self, value)