diff options
author | Antoine Pitrou <solipsis@pitrou.net> | 2013-02-02 22:49:34 +0100 |
---|---|---|
committer | Antoine Pitrou <solipsis@pitrou.net> | 2013-02-02 22:49:34 +0100 |
commit | d66c0ee76ebda143ff838cc62c0356701d5709e5 (patch) | |
tree | 5bf0fa419ab52a31e9ba1e464aa725cf5abe40f3 /Lib/test/test_httplib.py | |
parent | 1efd9824d892b514d879dffe09c16b009363f132 (diff) | |
download | cpython-git-d66c0ee76ebda143ff838cc62c0356701d5709e5.tar.gz |
Issue #15633: httplib.HTTPResponse is now mark closed when the server sends less than the advertised Content-Length.
Diffstat (limited to 'Lib/test/test_httplib.py')
-rw-r--r-- | Lib/test/test_httplib.py | 18 |
1 files changed, 15 insertions, 3 deletions
diff --git a/Lib/test/test_httplib.py b/Lib/test/test_httplib.py index bd48fea241..3e81a2c0f9 100644 --- a/Lib/test/test_httplib.py +++ b/Lib/test/test_httplib.py @@ -190,6 +190,19 @@ class BasicTest(TestCase): self.assertEqual(resp.read(1), '') self.assertTrue(resp.isclosed()) + def test_partial_reads_incomplete_body(self): + # if the server shuts down the connection before the whole + # content-length is delivered, the socket is gracefully closed + body = "HTTP/1.1 200 Ok\r\nContent-Length: 10\r\n\r\nText" + sock = FakeSocket(body) + resp = httplib.HTTPResponse(sock) + resp.begin() + self.assertEqual(resp.read(2), 'Te') + self.assertFalse(resp.isclosed()) + self.assertEqual(resp.read(2), 'xt') + self.assertEqual(resp.read(1), '') + self.assertTrue(resp.isclosed()) + def test_host_port(self): # Check invalid host_port @@ -320,7 +333,7 @@ class BasicTest(TestCase): resp = httplib.HTTPResponse(sock, method="GET") resp.begin() self.assertEqual(resp.read(), 'Hello\r\n') - resp.close() + self.assertTrue(resp.isclosed()) def test_incomplete_read(self): sock = FakeSocket('HTTP/1.1 200 OK\r\nContent-Length: 10\r\n\r\nHello\r\n') @@ -334,10 +347,9 @@ class BasicTest(TestCase): "IncompleteRead(7 bytes read, 3 more expected)") self.assertEqual(str(i), "IncompleteRead(7 bytes read, 3 more expected)") + self.assertTrue(resp.isclosed()) else: self.fail('IncompleteRead expected') - finally: - resp.close() def test_epipe(self): sock = EPipeSocket( |