diff options
author | Donald Stufft <donald@stufft.io> | 2014-05-16 22:21:32 -0400 |
---|---|---|
committer | Donald Stufft <donald@stufft.io> | 2014-05-16 22:21:32 -0400 |
commit | 81f21f2261d422d243f66b2dfeef0faae72ab119 (patch) | |
tree | 564425afe21fd919eadebce74fb8e35ba765392e /pip/_vendor/requests/adapters.py | |
parent | 6c71953b543cd15e611b2cc05178902e0e4afe42 (diff) | |
parent | 52ffb9f9ea88596e7a7953eaf04eaed681bf19cf (diff) | |
download | pip-81f21f2261d422d243f66b2dfeef0faae72ab119.tar.gz |
Merge branch '1.5.X'1.5.6
Conflicts:
CHANGES.txt
Diffstat (limited to 'pip/_vendor/requests/adapters.py')
-rw-r--r-- | pip/_vendor/requests/adapters.py | 24 |
1 files changed, 8 insertions, 16 deletions
diff --git a/pip/_vendor/requests/adapters.py b/pip/_vendor/requests/adapters.py index dd10e9593..eb7a2d282 100644 --- a/pip/_vendor/requests/adapters.py +++ b/pip/_vendor/requests/adapters.py @@ -16,7 +16,7 @@ from .packages.urllib3.response import HTTPResponse from .packages.urllib3.util import Timeout as TimeoutSauce from .compat import urlparse, basestring, urldefrag, unquote from .utils import (DEFAULT_CA_BUNDLE_PATH, get_encoding_from_headers, - except_on_missing_scheme, get_auth_from_url) + prepend_scheme_if_needed, get_auth_from_url) from .structures import CaseInsensitiveDict from .packages.urllib3.exceptions import MaxRetryError from .packages.urllib3.exceptions import TimeoutError @@ -203,7 +203,7 @@ class HTTPAdapter(BaseAdapter): proxy = proxies.get(urlparse(url.lower()).scheme) if proxy: - except_on_missing_scheme(proxy) + proxy = prepend_scheme_if_needed(proxy, 'http') proxy_headers = self.proxy_headers(proxy) if not proxy in self.proxy_manager: @@ -310,10 +310,7 @@ class HTTPAdapter(BaseAdapter): chunked = not (request.body is None or 'Content-Length' in request.headers) - if stream: - timeout = TimeoutSauce(connect=timeout) - else: - timeout = TimeoutSauce(connect=timeout, read=timeout) + timeout = TimeoutSauce(connect=timeout, read=timeout) try: if not chunked: @@ -372,25 +369,20 @@ class HTTPAdapter(BaseAdapter): conn._put_conn(low_conn) except socket.error as sockerr: - raise ConnectionError(sockerr) + raise ConnectionError(sockerr, request=request) except MaxRetryError as e: - raise ConnectionError(e) + raise ConnectionError(e, request=request) except _ProxyError as e: raise ProxyError(e) except (_SSLError, _HTTPError) as e: if isinstance(e, _SSLError): - raise SSLError(e) + raise SSLError(e, request=request) elif isinstance(e, TimeoutError): - raise Timeout(e) + raise Timeout(e, request=request) else: raise - r = self.build_response(request, resp) - - if not stream: - r.content - - return r + return self.build_response(request, resp) |