(self, data: bytes)
| 347 | return self.socket.settimeout(timeout) |
| 348 | |
| 349 | def _send_until_done(self, data: bytes) -> int: |
| 350 | while True: |
| 351 | try: |
| 352 | return self.connection.send(data) # type: ignore[no-any-return] |
| 353 | except OpenSSL.SSL.WantWriteError as e: |
| 354 | if not util.wait_for_write(self.socket, self.socket.gettimeout()): |
| 355 | raise TimeoutError() from e |
| 356 | continue |
| 357 | except OpenSSL.SSL.SysCallError as e: |
| 358 | raise OSError(e.args[0], str(e)) from e |
| 359 | |
| 360 | def sendall(self, data: bytes) -> None: |
| 361 | total_sent = 0 |
no test coverage detected