diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2014-10-29 18:40:17 +0100 |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2014-10-29 18:40:17 +0100 |
| commit | 47f6e7f94030811e54c5de380f39af2acc8e993d (patch) | |
| tree | 4b0018ae3ee5131d92b0c498f2dbeedd31a48763 | |
| parent | 382369a1fc1311e696a2ddeb13e5334fe27d8d0c (diff) | |
| download | trollius-47f6e7f94030811e54c5de380f39af2acc8e993d.tar.gz | |
Use the source traceback in repr() of transports
| -rw-r--r-- | asyncio/proactor_events.py | 3 | ||||
| -rw-r--r-- | asyncio/selector_events.py | 3 | ||||
| -rw-r--r-- | asyncio/unix_events.py | 6 | ||||
| -rw-r--r-- | tests/test_proactor_events.py | 1 |
4 files changed, 13 insertions, 0 deletions
diff --git a/asyncio/proactor_events.py b/asyncio/proactor_events.py index ad69ed5..2e38a15 100644 --- a/asyncio/proactor_events.py +++ b/asyncio/proactor_events.py @@ -59,6 +59,9 @@ class _ProactorBasePipeTransport(transports._FlowControlMixin, info.append('write_bufsize=%s' % bufsize) if self._eof_written: info.append('EOF written') + if self._source_traceback: + frame = self._source_traceback[-1] + info.append('created at %s:%s' % (frame[0], frame[1])) return '<%s>' % ' '.join(info) def _set_extra(self, sock): diff --git a/asyncio/selector_events.py b/asyncio/selector_events.py index c68f399..45d8787 100644 --- a/asyncio/selector_events.py +++ b/asyncio/selector_events.py @@ -501,6 +501,9 @@ class _SelectorTransport(transports._FlowControlMixin, bufsize = self.get_write_buffer_size() info.append('write=<%s, bufsize=%s>' % (state, bufsize)) + if self._source_traceback: + frame = self._source_traceback[-1] + info.append('created at %s:%s' % (frame[0], frame[1])) return '<%s>' % ' '.join(info) def abort(self): diff --git a/asyncio/unix_events.py b/asyncio/unix_events.py index ae11d9f..67f59fe 100644 --- a/asyncio/unix_events.py +++ b/asyncio/unix_events.py @@ -317,6 +317,9 @@ class _UnixReadPipeTransport(transports.ReadTransport): info.append('idle') else: info.append('closed') + if self._source_traceback: + frame = self._source_traceback[-1] + info.append('created at %s:%s' % (frame[0], frame[1])) return '<%s>' % ' '.join(info) def _read_ready(self): @@ -428,6 +431,9 @@ class _UnixWritePipeTransport(transports._FlowControlMixin, info.append('bufsize=%s' % bufsize) else: info.append('closed') + if self._source_traceback: + frame = self._source_traceback[-1] + info.append('created at %s:%s' % (frame[0], frame[1])) return '<%s>' % ' '.join(info) def get_write_buffer_size(self): diff --git a/tests/test_proactor_events.py b/tests/test_proactor_events.py index 0c53698..2654ed9 100644 --- a/tests/test_proactor_events.py +++ b/tests/test_proactor_events.py @@ -20,6 +20,7 @@ class ProactorSocketTransportTests(test_utils.TestCase): self.loop._proactor = self.proactor self.protocol = test_utils.make_test_protocol(asyncio.Protocol) self.sock = mock.Mock(socket.socket) + self.sock.fileno.return_value = 6 def test_ctor(self): fut = asyncio.Future(loop=self.loop) |