(self, exc, message='Fatal error on pipe transport')
| 799 | self._close(None) |
| 800 | |
| 801 | def _fatal_error(self, exc, message='Fatal error on pipe transport'): |
| 802 | # should be called by exception handler only |
| 803 | if isinstance(exc, OSError): |
| 804 | if self._loop.get_debug(): |
| 805 | logger.debug("%r: %s", self, message, exc_info=True) |
| 806 | else: |
| 807 | self._loop.call_exception_handler({ |
| 808 | 'message': message, |
| 809 | 'exception': exc, |
| 810 | 'transport': self, |
| 811 | 'protocol': self._protocol, |
| 812 | }) |
| 813 | self._close(exc) |
| 814 | |
| 815 | def _close(self, exc=None): |
| 816 | self._closing = True |
no test coverage detected