SSL fix for non-blocking reads

pika · Apr 14, 2015 · 635957f · 635957f
1 parent 7d457f5
commit 635957f
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/pika/adapters/base_connection.py b/pika/adapters/base_connection.py
@@ -353,6 +353,11 @@ def _handle_read(self):
         except socket.timeout:
             self._handle_timeout()
             return 0
+
+        except ssl.SSLWantReadError:
+            # ssl wants more data but there is nothing currently
+            # available in the socket, wait for it to become readable.
+            return 0
 
         except socket.error as error:
             if error.errno in (errno.EAGAIN, errno.EWOULDBLOCK):