(self, exc)
| 890 | self._force_close(exc) |
| 891 | |
| 892 | def _force_close(self, exc): |
| 893 | if self._conn_lost: |
| 894 | return |
| 895 | if self._buffer: |
| 896 | self._buffer.clear() |
| 897 | self._loop._remove_writer(self._sock_fd) |
| 898 | if not self._closing: |
| 899 | self._closing = True |
| 900 | self._loop._remove_reader(self._sock_fd) |
| 901 | self._conn_lost += 1 |
| 902 | self._loop.call_soon(self._call_connection_lost, exc) |
| 903 | |
| 904 | def _call_connection_lost(self, exc): |
| 905 | try: |
no test coverage detected