From: Kenneth Reitz Date: Mon, 19 Mar 2012 02:15:05 +0000 (-0400) Subject: Merge #491 X-Git-Tag: v0.11.1~11^2~2 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=76bf523a1f5d20de70e7ff5ddf2a681bea8987f8;p=services%2Fpython-requests.git Merge #491 --- diff --git a/AUTHORS.rst b/AUTHORS.rst index 243033f..f381622 100644 --- a/AUTHORS.rst +++ b/AUTHORS.rst @@ -89,4 +89,5 @@ Patches and Suggestions - Danver Braganza - Max Countryman - Nick Chadwick -- Jonathan Drosdeck \ No newline at end of file +- Jonathan Drosdeck +- Jiri Machalek diff --git a/HISTORY.rst b/HISTORY.rst index d43585c..6604fbe 100644 --- a/HISTORY.rst +++ b/HISTORY.rst @@ -5,7 +5,7 @@ History +++++++++++++++++++ * Private SSL Certificate support -* +* Remove select.poll from Gevent monkeypatching 0.10.8 (2012-03-09) +++++++++++++++++++ diff --git a/requests/models.py b/requests/models.py index ac1a9e2..0c74afa 100644 --- a/requests/models.py +++ b/requests/models.py @@ -683,39 +683,7 @@ class Response(object): yield chunk self._content_consumed = True - def generate_chunked(): - resp = self.raw._original_response - fp = resp.fp - if resp.chunk_left is not None: - pending_bytes = resp.chunk_left - while pending_bytes: - chunk = fp.read(min(chunk_size, pending_bytes)) - pending_bytes -= len(chunk) - yield chunk - fp.read(2) # throw away crlf - while 1: - #XXX correct line size? (httplib has 64kb, seems insane) - pending_bytes = fp.readline(40).strip() - if not len(pending_bytes): - # No content, like a HEAD request. Break out. - break - pending_bytes = int(pending_bytes, 16) - if pending_bytes == 0: - break - while pending_bytes: - chunk = fp.read(min(chunk_size, pending_bytes)) - pending_bytes -= len(chunk) - yield chunk - fp.read(2) # throw away crlf - self._content_consumed = True - fp.close() - - if getattr(getattr(self.raw, '_original_response', None), 'chunked', False): - gen = generate_chunked() - else: - gen = generate() - - gen = stream_untransfer(gen, self) + gen = stream_untransfer(generate(), self) if decode_unicode: gen = stream_decode_response_unicode(gen, self)