mirrors/cpython
1
0
Fork 0
mirror of https://github.com/python/cpython.git synced 2025-11-03 19:34:08 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 9

asyncio.subprocess: Fix a race condition in communicate()

Browse source 
Use self._loop instead of self._transport._loop, because transport._loop is set
to None at process exit.
This commit is contained in:
Victor Stinner 2014-02-20 10:12:59 +01:00
parent 88a928b614
commit cdb476bd43
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
Lib/asyncio/subprocess.py
View file

@ -146,7 +146,6 @@ class Process:
@tasks.coroutine @tasks.coroutine
def communicate(self, input=None): def communicate(self, input=None):
loop = self._transport._loop
if input: if input:
stdin = self._feed_stdin(input) stdin = self._feed_stdin(input)
else: else:
@ -160,7 +159,7 @@ class Process:
else: else:
stderr = self._noop() stderr = self._noop()
stdin, stdout, stderr = yield from tasks.gather(stdin, stdout, stderr, stdin, stdout, stderr = yield from tasks.gather(stdin, stdout, stderr,
loop=loop) loop=self._loop)
yield from self.wait() yield from self.wait()
return (stdout, stderr) return (stdout, stderr)