(self, exc, message='Fatal error on pipe transport')
| 597 | self._pipe.close() |
| 598 | |
| 599 | def _fatal_error(self, exc, message='Fatal error on pipe transport'): |
| 600 | # should be called by exception handler only |
| 601 | if (isinstance(exc, OSError) and exc.errno == errno.EIO): |
| 602 | if self._loop.get_debug(): |
| 603 | logger.debug("%r: %s", self, message, exc_info=True) |
| 604 | else: |
| 605 | self._loop.call_exception_handler({ |
| 606 | 'message': message, |
| 607 | 'exception': exc, |
| 608 | 'transport': self, |
| 609 | 'protocol': self._protocol, |
| 610 | }) |
| 611 | self._close(exc) |
| 612 | |
| 613 | def _close(self, exc): |
| 614 | self._closing = True |
no test coverage detected