From 498c43866af3ae3496ae8d1aa8a8cfdc5b6a7866 Mon Sep 17 00:00:00 2001 From: Antoine Pitrou Date: Mon, 22 Mar 2010 15:12:58 +0000 Subject: [PATCH] Merged revisions 79226 via svnmerge from svn+ssh://pythondev@svn.python.org/python/trunk ........ r79226 | antoine.pitrou | 2010-03-21 20:33:38 +0100 (dim., 21 mars 2010) | 4 lines Issue #3890: Fix recv() and recv_into() on non-blocking SSL sockets. ........ --- Lib/ssl.py | 26 ++++++-------------------- Misc/NEWS | 2 ++ 2 files changed, 8 insertions(+), 20 deletions(-) diff --git a/Lib/ssl.py b/Lib/ssl.py index 40e3e2dff68..58fd2b042da 100644 --- a/Lib/ssl.py +++ b/Lib/ssl.py @@ -210,16 +210,9 @@ class SSLSocket(socket): if self._sslobj: if flags != 0: raise ValueError( - "non-zero flags not allowed in calls to sendall() on %s" % + "non-zero flags not allowed in calls to recv() on %s" % self.__class__) - while True: - try: - return self.read(buflen) - except SSLError, x: - if x.args[0] == SSL_ERROR_WANT_READ: - continue - else: - raise x + return self.read(buflen) else: return socket.recv(self, buflen, flags) @@ -233,17 +226,10 @@ class SSLSocket(socket): raise ValueError( "non-zero flags not allowed in calls to recv_into() on %s" % self.__class__) - while True: - try: - tmp_buffer = self.read(nbytes) - v = len(tmp_buffer) - buffer[:v] = tmp_buffer - return v - except SSLError as x: - if x.args[0] == SSL_ERROR_WANT_READ: - continue - else: - raise x + tmp_buffer = self.read(nbytes) + v = len(tmp_buffer) + buffer[:v] = tmp_buffer + return v else: return socket.recv_into(self, buffer, nbytes, flags) diff --git a/Misc/NEWS b/Misc/NEWS index d4a11dc7348..7fcbc17ea30 100644 --- a/Misc/NEWS +++ b/Misc/NEWS @@ -23,6 +23,8 @@ Core and Builtins Library ------- +- Issue #3890: Fix recv() and recv_into() on non-blocking SSL sockets. + - Issue #6544: fix a reference leak in the kqueue implementation's error handling.