(self, exc)
| 894 | self._force_close(exc) |
| 895 | |
| 896 | def _force_close(self, exc): |
| 897 | if self._conn_lost: |
| 898 | return |
| 899 | if self._buffer: |
| 900 | self._buffer.clear() |
| 901 | self._buffer_size = 0 |
| 902 | self._loop._remove_writer(self._sock_fd) |
| 903 | if not self._closing: |
| 904 | self._closing = True |
| 905 | self._loop._remove_reader(self._sock_fd) |
| 906 | self._conn_lost += 1 |
| 907 | self._call_soon(self._call_connection_lost, exc) |
| 908 | |
| 909 | def _call_connection_lost(self, exc): |
| 910 | try: |
no test coverage detected