Commit 38977237 authored by Victor Stinner's avatar Victor Stinner

asyncio: _fatal_error() of _UnixWritePipeTransport and...

asyncio: _fatal_error() of _UnixWritePipeTransport and _ProactorBasePipeTransport shouldn't log BrokenPipeError nor ConnectionResetError.

(Same behaviour as _SelectorTransport._fatal_error().)
parent c4a2805a
...@@ -54,7 +54,8 @@ class _ProactorBasePipeTransport(transports.BaseTransport): ...@@ -54,7 +54,8 @@ class _ProactorBasePipeTransport(transports.BaseTransport):
self._read_fut.cancel() self._read_fut.cancel()
def _fatal_error(self, exc): def _fatal_error(self, exc):
logger.exception('Fatal error for %s', self) if not isinstance(exc, (BrokenPipeError, ConnectionResetError)):
logger.exception('Fatal error for %s', self)
self._force_close(exc) self._force_close(exc)
def _force_close(self, exc): def _force_close(self, exc):
......
...@@ -363,7 +363,8 @@ class _UnixWritePipeTransport(transports.WriteTransport): ...@@ -363,7 +363,8 @@ class _UnixWritePipeTransport(transports.WriteTransport):
def _fatal_error(self, exc): def _fatal_error(self, exc):
# should be called by exception handler only # should be called by exception handler only
logger.exception('Fatal error for %s', self) if not isinstance(exc, (BrokenPipeError, ConnectionResetError)):
logger.exception('Fatal error for %s', self)
self._close(exc) self._close(exc)
def _close(self, exc=None): def _close(self, exc=None):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment