diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2015-01-14 22:55:43 +0100 |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2015-01-14 22:55:43 +0100 |
| commit | 3fd2599228979af641ae452fa8b6d69e403d115d (patch) | |
| tree | 06b1dc6bc054fe4676bd8d3abe10070c9e35dc86 | |
| parent | 0acde31423c4a9704a2f38dbc6eab4a8c681b3dd (diff) | |
| download | trollius-git-3fd2599228979af641ae452fa8b6d69e403d115d.tar.gz | |
UNIX pipe transports: add closed/closing in repr()
Add "closed" or "closing" state in the __repr__() method of
_UnixReadPipeTransport and _UnixWritePipeTransport classes.
| -rw-r--r-- | asyncio/unix_events.py | 14 |
1 files changed, 12 insertions, 2 deletions
diff --git a/asyncio/unix_events.py b/asyncio/unix_events.py index 1a4d418..14b4843 100644 --- a/asyncio/unix_events.py +++ b/asyncio/unix_events.py @@ -301,7 +301,12 @@ class _UnixReadPipeTransport(transports.ReadTransport): self._loop.call_soon(waiter._set_result_unless_cancelled, None) def __repr__(self): - info = [self.__class__.__name__, 'fd=%s' % self._fileno] + info = [self.__class__.__name__] + if self._pipe is None: + info.append('closed') + elif self._closing: + info.append('closing') + info.append('fd=%s' % self._fileno) if self._pipe is not None: polling = selector_events._test_selector_event( self._loop._selector, @@ -404,7 +409,12 @@ class _UnixWritePipeTransport(transports._FlowControlMixin, self._loop.call_soon(waiter._set_result_unless_cancelled, None) def __repr__(self): - info = [self.__class__.__name__, 'fd=%s' % self._fileno] + info = [self.__class__.__name__] + if self._pipe is None: + info.append('closed') + elif self._closing: + info.append('closing') + info.append('fd=%s' % self._fileno) if self._pipe is not None: polling = selector_events._test_selector_event( self._loop._selector, |