diff options
author | Jenkins <jenkins@review.openstack.org> | 2015-02-25 13:54:14 +0000 |
---|---|---|
committer | Gerrit Code Review <review@openstack.org> | 2015-02-25 13:54:14 +0000 |
commit | 925c01ebfbdfb6478a3786f24a9572deae40f8f8 (patch) | |
tree | 5b5f92b5dd4f6d576f4df55b448fcf729119a8cc | |
parent | 771383145b02f2a4b3ec546e3727f9b90fed22a8 (diff) | |
parent | 8756591b0ad24320a0b6fa3b2f7513e17ec46b6c (diff) | |
download | python-swiftclient-925c01ebfbdfb6478a3786f24a9572deae40f8f8.tar.gz |
Merge "Release connection after consuming the content"
-rw-r--r-- | swiftclient/client.py | 17 |
1 files changed, 14 insertions, 3 deletions
diff --git a/swiftclient/client.py b/swiftclient/client.py index 985cad8..0c6d8d3 100644 --- a/swiftclient/client.py +++ b/swiftclient/client.py @@ -21,7 +21,6 @@ import socket import requests import logging import warnings -import functools try: from simplejson import loads as json_loads except ImportError: @@ -233,10 +232,22 @@ class HTTPConnection(object): def getheader(k, v=None): return old_getheader(k.lower(), v) + def releasing_read(*args, **kwargs): + kwargs['decode_content'] = True + chunk = self.resp.raw.read(*args, **kwargs) + if not chunk: + # NOTE(sigmavirus24): Release the connection back to the + # urllib3's connection pool. This will reduce the number of + # log messages seen in bug #1341777. This does not actually + # close a socket. It will also prevent people from being + # mislead as to the cause of a bug as in bug #1424732. + self.resp.close() + return chunk + self.resp.getheaders = getheaders self.resp.getheader = getheader - self.resp.read = functools.partial(self.resp.raw.read, - decode_content=True) + self.resp.read = releasing_read + return self.resp |