σ ^†κWc@@sGddlmZddlZyddlmZWn!ek rSddlmZnXddlmZddl m Z m Z ddl m Z ddl mZmZmZdd lmZdd lmZdd lmZd d dgZejeƒZdZie d6e d6Zd efd„ƒYZd efd„ƒYZd„ZdS(i(tabsolute_importN(turljoini(tRecentlyUsedContainer(tHTTPConnectionPooltHTTPSConnectionPool(tport_by_scheme(tLocationValueErrort MaxRetryErrortProxySchemeUnknown(tRequestMethods(t parse_url(tRetryt PoolManagert ProxyManagertproxy_from_urltkey_filet cert_filet cert_reqstca_certst ssl_versiont ca_cert_dirthttpthttpscB@skeZdZd Zdd d„Zd„Zd„Zd„Zd„Z d dd„Z d „Z e d „Z RS( s$ Allows for arbitrary requests while transparently keeping track of necessary connection pools for you. :param num_pools: Number of connection pools to cache before discarding the least recently used pool. :param headers: Headers to include with all requests, unless other headers are given explicitly. :param \**connection_pool_kw: Additional parameters are used to create fresh :class:`urllib3.connectionpool.ConnectionPool` instances. Example:: >>> manager = PoolManager(num_pools=2) >>> r = manager.request('GET', 'http://google.com/') >>> r = manager.request('GET', 'http://google.com/mail') >>> r = manager.request('GET', 'http://yahoo.com/') >>> len(manager.pools) 2 i cK@s>tj||ƒ||_t|dd„ƒ|_t|_dS(Nt dispose_funccS@s |jƒS(N(tclose(tp((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pytBs(R t__init__tconnection_pool_kwRtpoolstpool_classes_by_scheme(tselft num_poolstheadersR((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyR>s   cC@s|S(N((R((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyt __enter__GscC@s|jƒtS(N(tcleartFalse(Rtexc_typetexc_valtexc_tb((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyt__exit__Js cC@se|j|}|j}|dkrU|jjƒ}x!tD]}|j|dƒq8Wn||||S(s Create a new :class:`ConnectionPool` based on host, port and scheme. This method is used to actually create the connection pools handed out by :meth:`connection_from_url` and companion methods. It is intended to be overridden for customization. RN(RRtcopyt SSL_KEYWORDStpoptNone(Rtschemethosttporttpool_clstkwargstkw((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyt _new_poolOs    cC@s|jjƒdS(s΄ Empty our store of pools and direct them all to close. This will not affect in-flight connections, but they will not be re-used after completion. N(RR#(R((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyR#`sRcC@s|stdƒ‚n|pd}|p6tj|dƒ}|||f}|jjC|jj|ƒ}|rq|S|j|||ƒ}||j| %sN(R R8R.R/R-R$R!tproxyR,turlopent request_uritget_redirect_locationRtstatusR4t isinstanceR tfrom_intt incrementRtraise_on_redirecttlogtinfo( RtmethodR9R=R2R:tconnR@tredirect_locationR?((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyRC‘s8 $    "    N(t__name__t __module__t__doc__R,RBRR"R(R3R#R8R;tTrueRC(((s‚/private/var/folders/3n/6h2rwf155rn1m71wwyxn79n80000gn/T/pip-build-IcAT_k/pip/pip/_vendor/requests/packages/urllib3/poolmanager.pyR s     cB@sGeZdZdddd„Zddd„Zdd„Zed„ZRS(sw Behaves just like :class:`PoolManager`, but sends all requests through the defined proxy, using the CONNECT method for HTTPS URLs. :param proxy_url: The URL of the proxy to be used. :param proxy_headers: A dictionary contaning headers that will be sent to the proxy. In case of HTTP they are being sent with each request, while in the HTTPS/CONNECT case they are sent only once. Could be used for proxy authentication. Example: >>> proxy = urllib3.ProxyManager('http://localhost:3128/') >>> r1 = proxy.request('GET', 'http://google.com/') >>> r2 = proxy.request('GET', 'http://httpbin.org/') >>> len(proxy.pools) 1 >>> r3 = proxy.request('GET', 'https://httpbin.org/') >>> r4 = proxy.request('GET', 'https://twitter.com/') >>> len(proxy.pools) 3 i cK@sΰt|tƒr.d|j|j|jf}nt|ƒ}|jsmtj|jdƒ}|jd|ƒ}n|jdkrŽt |jƒ‚n||_ |p i|_ |j |d<|j |ds,   €W