ó
]'v_c           @@  sG  d  d l  m Z d  d l Z y d  d l m Z Wn! e k
 rS d  d l m Z n Xd d l m Z d d l	 m
 Z
 m Z d d l	 m Z d d l m Z m Z m Z d d	 l m Z d d
 l m Z d d l m Z d d d g Z i e
 d 6e d 6Z e j e ƒ Z d Z d e f d „  ƒ  YZ d e f d „  ƒ  YZ d „  Z d S(   i    (   t   absolute_importN(   t   urljoini   (   t   RecentlyUsedContainer(   t   HTTPConnectionPoolt   HTTPSConnectionPool(   t   port_by_scheme(   t   LocationValueErrort   MaxRetryErrort   ProxySchemeUnknown(   t   RequestMethods(   t	   parse_url(   t   Retryt   PoolManagert   ProxyManagert   proxy_from_urlt   httpt   httpst   key_filet	   cert_filet	   cert_reqst   ca_certst   ssl_versiont   ca_cert_dirc           B@  sk   e  Z d  Z d Z d d d „ Z d „  Z d „  Z d „  Z d „  Z	 d d d „ 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
   c         K@  s5   t  j |  | ƒ | |  _ t | d d „  ƒ|  _ d  S(   Nt   dispose_funcc         S@  s
   |  j  ƒ  S(   N(   t   close(   t   p(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   <lambda>B   s    (   R	   t   __init__t   connection_pool_kwR   t   pools(   t   selft	   num_poolst   headersR   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR   >   s    		c         C@  s   |  S(   N(    (   R   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt	   __enter__D   s    c         C@  s   |  j  ƒ  t S(   N(   t   cleart   False(   R   t   exc_typet   exc_valt   exc_tb(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   __exit__G   s    
c         C@  sb   t  | } |  j } | d k rR |  j j ƒ  } x! t D] } | j | d ƒ q5 Wn  | | | |  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.
        R   N(   t   pool_classes_by_schemeR   t   copyt   SSL_KEYWORDSt   popt   None(   R   t   schemet   hostt   portt   pool_clst   kwargst   kw(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt	   _new_poolL   s    
	c         C@  s   |  j  j ƒ  d S(   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(   R   R"   (   R   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR"   ]   s    R   c         C@  s   | s t  d ƒ ‚ n  | p d } | p6 t j | d ƒ } | | | f } |  j j C |  j j | ƒ } | rq | S|  j | | | ƒ } | |  j | <Wd QX| S(   sÖ   
        Get a :class:`ConnectionPool` based on the host, port, and scheme.

        If ``port`` isn't given, it will be derived from the ``scheme`` using
        ``urllib3.connectionpool.port_by_scheme``.
        s   No host specified.R   iP   N(   R   R   t   getR   t   lockR3   (   R   R.   R/   R-   t   pool_keyt   pool(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   connection_from_hostf   s    c         C@  s.   t  | ƒ } |  j | j d | j d | j ƒS(   s*  
        Similar to :func:`urllib3.connectionpool.connection_from_url` but
        doesn't pass any additional parameters to the
        :class:`urllib3.connectionpool.ConnectionPool` constructor.

        Additional parameters are taken from the :class:`.PoolManager`
        constructor.
        R/   R-   (   R
   R8   R.   R/   R-   (   R   t   urlt   u(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   connection_from_url‚   s    	c         K@  sõ  t  | ƒ } |  j | j d | j d | j ƒ} t | d <t | d <d | k rf |  j j ƒ  | d <n  |  j d k	 rœ | j d k rœ | j
 | | |  } n | j
 | | j |  } | oÃ | j ƒ  } | sÐ | St | | ƒ } | j d k r÷ d } n  | j d	 ƒ }	 t |	 t ƒ s-t j |	 d | ƒ}	 n  |	 j rq| j | ƒ rqx( |	 j D] }
 | d j |
 d ƒ qPWn  y" |	 j | | d
 | d | ƒ}	 Wn! t k
 r¶|	 j r²‚  n  | SX|	 | d	 <| | d <t j d | | f ƒ |  j
 | | |  S(   s]  
        Same as :meth:`urllib3.connectionpool.HTTPConnectionPool.urlopen`
        with custom cross-host redirect logic and only sends the request-uri
        portion of the ``url``.

        The given ``url`` parameter must be absolute, such that an appropriate
        :class:`urllib3.connectionpool.ConnectionPool` can be chosen for it.
        R/   R-   t   assert_same_hostt   redirectR    R   i/  t   GETt   retriest   responset   _pools   Redirecting %s -> %sN(   R
   R8   R.   R/   R-   R#   R    R)   t   proxyR,   t   urlopent   request_urit   get_redirect_locationR   t   statusR4   t
   isinstanceR   t   from_intt   remove_headers_on_redirectt   is_same_hostR+   t	   incrementR   t   raise_on_redirectt   logt   info(   R   t   methodR9   R=   R2   R:   t   connR@   t   redirect_locationR?   t   header(    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyRC   Ž   s@    	$

		"	

N(   t   __name__t
   __module__t   __doc__R,   RB   R   R!   R'   R3   R"   R8   R;   t   TrueRC   (    (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR       s   						c           B@  sG   e  Z d  Z d d d d „ Z d d d „ Z d d „ Z e d „ Z RS(   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
   c         K@  sà   t  | t ƒ r. d | j | j | j f } n  t | ƒ } | j sm t j | j d ƒ } | j d | ƒ } n  | j d k rŽ t	 | j ƒ ‚ n  | |  _
 | p  i  |  _ |  j
 | d <|  j | d <t t |  ƒ j | | |  d  S(	   Ns
   %s://%s:%iiP   R/   R   R   t   _proxyt   _proxy_headers(   s   httpR   (   RG   R   R-   R.   R/   R
   R   R4   t   _replaceR   RB   t   proxy_headerst   superR   R   (   R   t	   proxy_urlR   R    RZ   R   RB   R/   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR   å   s    		R   c         C@  sV   | d k r( t  t |  ƒ j | | | ƒ St  t |  ƒ j |  j j |  j j |  j j ƒ S(   NR   (   R[   R   R8   RB   R.   R/   R-   (   R   R.   R/   R-   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR8   ü   s
    c         C@  sI   i d d 6} t  | ƒ j } | r/ | | d <n  | rE | j | ƒ n  | S(   s   
        Sets headers needed by proxies: specifically, the Accept and Host
        headers. Only sets headers not provided by the user.
        s   */*t   Acceptt   Host(   R
   t   netloct   update(   R   R9   R    t   headers_R_   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   _set_proxy_headers  s    c         K@  sk   t  | ƒ } | j d k rI | j d |  j ƒ } |  j | | ƒ | d <n  t t |  ƒ j | | d | | S(   s@   Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.R   R    R=   (   R
   R-   R4   R    Rb   R[   R   RC   (   R   RO   R9   R=   R2   R:   R    (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyRC     s
    N(	   RS   RT   RU   R,   R   R8   Rb   RV   RC   (    (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR   Ê   s   c         K@  s   t  d |  |  S(   NR\   (   R   (   R9   R2   (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyR   !  s    (   R   R   R   R   R   R   (    t
   __future__R    t   loggingt   urllib.parseR   t   ImportErrort   urlparset   _collectionsR   t   connectionpoolR   R   R   t
   exceptionsR   R   R   t   requestR	   t   util.urlR
   t
   util.retryR   t   __all__R(   t	   getLoggerRS   RM   R*   R   R   R   (    (    (    s7   /usr/lib/python2.7/dist-packages/urllib3/poolmanager.pyt   <module>   s,   
 ªW