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

vstinner · vstinner · commit 00c6c1bd65b6 · 2014-02-20T10:05:40.000+01:00
Use self._loop instead of self._transport._loop, because transport._loop is set
to None at process exit.
diff --git a/asyncio/subprocess.py b/asyncio/subprocess.py
@@ -146,7 +146,6 @@ def _read_stream(self, fd):
 
     @tasks.coroutine
     def communicate(self, input=None):
-        loop = self._transport._loop
         if input:
             stdin = self._feed_stdin(input)
         else:
@@ -160,7 +159,7 @@ def communicate(self, input=None):
         else:
             stderr = self._noop()
         stdin, stdout, stderr = yield from tasks.gather(stdin, stdout, stderr,
-                                                        loop=loop)
+                                                        loop=self._loop)
         yield from self.wait()
         return (stdout, stderr)
 
