Merge 3.4 (asyncio)

Lib/asyncio/sslproto.py

@@ -417,6 +417,7 @@ class SSLProtocol(protocols.Protocol):
         self._session_established = False
         self._in_handshake = False
         self._in_shutdown = False
+        self._transport = None
 
     def connection_made(self, transport):
         """Called when the low-level connection is made.

Lib/asyncio/subprocess.py

@@ -94,8 +94,11 @@ class SubprocessStreamProtocol(streams.FlowControlMixin,
                 reader.set_exception(exc)
 
     def process_exited(self):
-        # wake up futures waiting for wait()
         returncode = self._transport.get_returncode()
+        self._transport.close()
+        self._transport = None
+
+        # wake up futures waiting for wait()
         while self._waiters:
             waiter = self._waiters.popleft()
             if not waiter.cancelled():

Lib/asyncio/unix_events.py

@@ -516,7 +516,7 @@ class _UnixWritePipeTransport(transports._FlowControlMixin,
             self._loop.call_soon(self._call_connection_lost, None)
 
     def close(self):
-        if not self._closing:
+        if self._pipe is not None and not self._closing:
             # write_eof is all what we needed to close the write pipe
             self.write_eof()
 

Lib/test/test_asyncio/test_base_events.py

@@ -590,6 +590,7 @@ class BaseEventLoopTests(test_utils.TestCase):
                 raise ValueError('spam')
 
         loop = Loop()
+        self.addCleanup(loop.close)
         asyncio.set_event_loop(loop)
 
         def run_loop():