diff options
| author | Victor Stinner <vstinner@redhat.com> | 2015-07-20 17:18:59 +0200 |
|---|---|---|
| committer | Victor Stinner <vstinner@redhat.com> | 2015-07-20 17:36:41 +0200 |
| commit | 13b71a16ee9d5af4939a7e214e92fa89cb96f6a3 (patch) | |
| tree | cb9525ce018206804591e7e255c5745a044018c6 /asyncio/unix_events.py | |
| parent | 9bb67431adc916d9d4b4e23ca257658c980d035d (diff) | |
| download | trollius-git-closing.tar.gz | |
Add closing read-only property to transportsclosing
* Disallow write() on closing transports
* Disallow aslo calling pause_writing() and resume_writing() on
StreamReaderProtocol if the transport is closing
Diffstat (limited to 'asyncio/unix_events.py')
| -rw-r--r-- | asyncio/unix_events.py | 2 |
1 files changed, 0 insertions, 2 deletions
diff --git a/asyncio/unix_events.py b/asyncio/unix_events.py index 75e7c9c..323a27a 100644 --- a/asyncio/unix_events.py +++ b/asyncio/unix_events.py @@ -311,7 +311,6 @@ class _UnixReadPipeTransport(transports.ReadTransport): raise ValueError("Pipe transport is for pipes/sockets only.") _set_nonblocking(self._fileno) self._protocol = protocol - self._closing = False self._loop.call_soon(self._protocol.connection_made, self) # only start reading when connection_made() has been called self._loop.call_soon(self._loop.add_reader, @@ -424,7 +423,6 @@ class _UnixWritePipeTransport(transports._FlowControlMixin, self._protocol = protocol self._buffer = [] self._conn_lost = 0 - self._closing = False # Set when close() or write_eof() called. self._loop.call_soon(self._protocol.connection_made, self) |