diff options
author | Antoine Pitrou <solipsis@pitrou.net> | 2013-02-02 22:06:22 (GMT) |
---|---|---|
committer | Antoine Pitrou <solipsis@pitrou.net> | 2013-02-02 22:06:22 (GMT) |
commit | b5032c85af4b76c9e10b179efa841a2109793f8e (patch) | |
tree | 8c67e81c89cab8d74b3c794d7be64fad63bdde57 /Lib/http | |
parent | 3a9ae7fd984ea9e5c9d3e22c87c61c02c03dd1c9 (diff) | |
parent | 6a35e18161c4d06015aeb79c951df04bcea9ca9a (diff) | |
download | cpython-b5032c85af4b76c9e10b179efa841a2109793f8e.zip cpython-b5032c85af4b76c9e10b179efa841a2109793f8e.tar.gz cpython-b5032c85af4b76c9e10b179efa841a2109793f8e.tar.bz2 |
Issue #15633: httplib.HTTPResponse is now mark closed when the server sends less than the advertised Content-Length.
Diffstat (limited to 'Lib/http')
-rw-r--r-- | Lib/http/client.py | 15 |
1 files changed, 10 insertions, 5 deletions
diff --git a/Lib/http/client.py b/Lib/http/client.py index 7db79b3..ce6e581 100644 --- a/Lib/http/client.py +++ b/Lib/http/client.py @@ -507,7 +507,11 @@ class HTTPResponse(io.RawIOBase): if self.length is None: s = self.fp.read() else: - s = self._safe_read(self.length) + try: + s = self._safe_read(self.length) + except IncompleteRead: + self.close() + raise self.length = 0 self.close() # we read everything return s @@ -532,13 +536,14 @@ class HTTPResponse(io.RawIOBase): # connection, and the user is reading more bytes than will be provided # (for example, reading in 1k chunks) n = self.fp.readinto(b) - if self.length is not None: + if not n: + # Ideally, we would raise IncompleteRead if the content-length + # wasn't satisfied, but it might break compatibility. + self.close() + elif self.length is not None: self.length -= n if not self.length: self.close() - else: - if not n: - self.close() return n def _read_next_chunk_size(self): |