diff options
author | Florian Bruhin <me@the-compiler.org> | 2020-11-25 18:24:26 +0100 |
---|---|---|
committer | Florian Bruhin <me@the-compiler.org> | 2020-11-25 18:24:26 +0100 |
commit | 434bb1d202ede17848319fa183edcd684144c968 (patch) | |
tree | 83e2ded8a5647e71f039819b0a76da5e949b67e8 | |
parent | c8c07da10b08e4d9ce15d67769152b1f978d6bf9 (diff) | |
download | qutebrowser-434bb1d202ede17848319fa183edcd684144c968.tar.gz qutebrowser-434bb1d202ede17848319fa183edcd684144c968.zip |
Revert "ipc: Avoid starting timeout timer if socket is None"
Causes issues, let's keep this in master instead.
This reverts commit 5628d8309b329e686f03cf06d469fa1a5136b990.
-rw-r--r-- | qutebrowser/misc/ipc.py | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/qutebrowser/misc/ipc.py b/qutebrowser/misc/ipc.py index ab06ac16a..207915a57 100644 --- a/qutebrowser/misc/ipc.py +++ b/qutebrowser/misc/ipc.py @@ -269,8 +269,8 @@ class IPCServer(QObject): "No new connection to handle.") return log.ipc.debug("Client connected (socket 0x{:x}).".format(id(socket))) - self._socket = socket self._timer.start() + self._socket = socket socket.readyRead.connect( # type: ignore[attr-defined] self.on_ready_read) if socket.canReadLine(): @@ -310,7 +310,7 @@ class IPCServer(QObject): self._socket.disconnectFromServer() def _handle_data(self, data): - """Handle data (as bytes) we got from on_ready_read.""" + """Handle data (as bytes) we got from on_ready_ready_read.""" try: decoded = data.decode('utf-8') except UnicodeDecodeError: @@ -383,13 +383,14 @@ class IPCServer(QObject): log.ipc.debug("Read from socket 0x{:x}: {!r}".format( id(socket), data)) self._handle_data(data) - - if self._socket is not None: - self._timer.start() + self._timer.start() @pyqtSlot() def on_timeout(self): """Cancel the current connection if it was idle for too long.""" + if self._socket is None: # pragma: no cover + log.ipc.debug("on_timeout got called with None socket!") + return log.ipc.error("IPC connection timed out " "(socket 0x{:x}).".format(id(self._socket))) self._socket.disconnectFromServer() |