(self, exc, message='Fatal error on transport')
| 914 | self._process_outgoing() |
| 915 | |
| 916 | def _fatal_error(self, exc, message='Fatal error on transport'): |
| 917 | if self._transport: |
| 918 | self._transport._force_close(exc) |
| 919 | |
| 920 | if isinstance(exc, OSError): |
| 921 | if self._loop.get_debug(): |
| 922 | logger.debug("%r: %s", self, message, exc_info=True) |
| 923 | elif not isinstance(exc, exceptions.CancelledError): |
| 924 | self._loop.call_exception_handler({ |
| 925 | 'message': message, |
| 926 | 'exception': exc, |
| 927 | 'transport': self._transport, |
| 928 | 'protocol': self, |
| 929 | }) |