(self)
| 700 | self._fatal_error(ex, 'Fatal error on SSL protocol') |
| 701 | |
| 702 | def _do_write(self): |
| 703 | try: |
| 704 | while self._write_backlog: |
| 705 | data = self._write_backlog[0] |
| 706 | count = self._sslobj.write(data) |
| 707 | data_len = len(data) |
| 708 | if count < data_len: |
| 709 | self._write_backlog[0] = data[count:] |
| 710 | self._write_buffer_size -= count |
| 711 | else: |
| 712 | del self._write_backlog[0] |
| 713 | self._write_buffer_size -= data_len |
| 714 | except SSLAgainErrors: |
| 715 | pass |
| 716 | self._process_outgoing() |
| 717 | |
| 718 | def _process_outgoing(self): |
| 719 | if not self._ssl_writing_paused: |
no test coverage detected