]> granicus.if.org Git - python/commitdiff
Merge 3.5 (issue #28990)
authorYury Selivanov <yury@magic.io>
Fri, 16 Dec 2016 16:51:57 +0000 (11:51 -0500)
committerYury Selivanov <yury@magic.io>
Fri, 16 Dec 2016 16:51:57 +0000 (11:51 -0500)
Lib/asyncio/sslproto.py
Lib/test/test_asyncio/test_sslproto.py
Misc/NEWS

index 991c77b48242eb7867458aa7ab1623fd873880ec..7ad28d6aa0089a67a8892558b983ebae1de7b7d1 100644 (file)
@@ -480,6 +480,7 @@ class SSLProtocol(protocols.Protocol):
             self._loop.call_soon(self._app_protocol.connection_lost, exc)
         self._transport = None
         self._app_transport = None
+        self._wakeup_waiter(exc)
 
     def pause_writing(self):
         """Called when the low-level transport's buffer goes over
index 0ca6d1bf2aabb1506be807517c17733220e3a8ef..59ff0f6967e5b5bbec3232a160d5c26d28986b79 100644 (file)
@@ -85,5 +85,15 @@ class SslProtoHandshakeTests(test_utils.TestCase):
             # Restore error logging.
             log.logger.setLevel(log_level)
 
+    def test_connection_lost(self):
+        # From issue #472.
+        # yield from waiter hang if lost_connection was called.
+        waiter = asyncio.Future(loop=self.loop)
+        ssl_proto = self.ssl_protocol(waiter)
+        self.connection_made(ssl_proto)
+        ssl_proto.connection_lost(ConnectionAbortedError)
+        test_utils.run_briefly(self.loop)
+        self.assertIsInstance(waiter.exception(), ConnectionAbortedError)
+
 if __name__ == '__main__':
     unittest.main()
index 5cf929f21f8e5d88bc8d9c54b2129e7571f523d1..dc8acc8b492c2b804c89dc2e71a702656b615867 100644 (file)
--- a/Misc/NEWS
+++ b/Misc/NEWS
@@ -14,6 +14,10 @@ Core and Builtins
   must not convert combined table into split table. Patch written by INADA
   Naoki.
 
+- Issue #28990: Fix SSL hanging if connection is closed before handshake
+  completed.
+  (Patch by HoHo-Ho)
+
 Windows
 -------