|
29 | 29 | """Module implementing low-level socket communication with MySQL servers.
|
30 | 30 | """
|
31 | 31 |
|
| 32 | +# pylint: disable=overlapping-except |
| 33 | + |
32 | 34 | import socket
|
33 | 35 | import struct
|
34 | 36 | import warnings
|
@@ -162,7 +164,7 @@ def _send_pkt(self, sock: socket.socket, address: str, pkt: bytes) -> None:
|
162 | 164 | """Write packet to the comm channel."""
|
163 | 165 | try:
|
164 | 166 | sock.sendall(pkt)
|
165 |
| - except TimeoutError as err: |
| 167 | + except (socket.timeout, TimeoutError) as err: |
166 | 168 | raise WriteTimeoutError(errno=3024) from err
|
167 | 169 | except IOError as err:
|
168 | 170 | raise OperationalError(
|
@@ -241,7 +243,7 @@ def recv(self, sock: socket.socket, address: str) -> bytearray:
|
241 | 243 |
|
242 | 244 | # Read the payload, and return packet
|
243 | 245 | return header + self._recv_chunk(sock, size=payload_len)
|
244 |
| - except TimeoutError as err: |
| 246 | + except (socket.timeout, TimeoutError) as err: |
245 | 247 | raise ReadTimeoutError(errno=3024, msg=err.strerror) from err
|
246 | 248 | except IOError as err:
|
247 | 249 | raise OperationalError(
|
@@ -427,7 +429,7 @@ def recv(self, sock: socket.socket, address: str) -> bytearray:
|
427 | 429 | struct.unpack("<I", header[4:7] + b"\x00")[0],
|
428 | 430 | )
|
429 | 431 | self._recv_compressed_pkt(sock, compressed_pll, uncompressed_pll)
|
430 |
| - except TimeoutError as err: |
| 432 | + except (socket.timeout, TimeoutError) as err: |
431 | 433 | raise ReadTimeoutError(errno=3024) from err
|
432 | 434 | except IOError as err:
|
433 | 435 | raise OperationalError(
|
@@ -700,7 +702,7 @@ def open_connection(self) -> None:
|
700 | 702 | )
|
701 | 703 | self.sock.settimeout(self._connection_timeout)
|
702 | 704 | self.sock.connect(self.unix_socket)
|
703 |
| - except TimeoutError as err: |
| 705 | + except (socket.timeout, TimeoutError) as err: |
704 | 706 | raise ConnectionTimeoutError(
|
705 | 707 | errno=2002,
|
706 | 708 | values=(
|
@@ -795,7 +797,7 @@ def open_connection(self) -> None:
|
795 | 797 | self.sock = socket.socket(self._family, socktype, proto)
|
796 | 798 | self.sock.settimeout(self._connection_timeout)
|
797 | 799 | self.sock.connect(sockaddr)
|
798 |
| - except TimeoutError as err: |
| 800 | + except (socket.timeout, TimeoutError) as err: |
799 | 801 | raise ConnectionTimeoutError(
|
800 | 802 | errno=2003,
|
801 | 803 | values=(
|
|
0 commit comments