관리-도구
편집 파일: poolmanager.cpython-33.pyc
� 7�Re# c @ s d d l Z y d d l m Z Wn" e k rD d d l m Z Yn Xd d l m Z d d l 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 Gd d � d e � Z Gd d � d e � Z d d � Z d S( i N( u urljoini ( u RecentlyUsedContainer( u HTTPConnectionPoolu HTTPSConnectionPool( u port_by_scheme( u RequestMethods( u parse_urlu PoolManageru ProxyManageru proxy_from_urlu httpu httpsu key_fileu cert_fileu cert_reqsu ca_certsu ssl_versionc B sw | Ee Z d Z d Z d Z d d d d � Z d d � Z d d � Z d d d d � Z d d � Z d d d � Z d S( u PoolManageru& 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 s8 t j | | � | | _ t | d d d � �| _ d S( Nu dispose_funcc S s | j � S( N( u close( u p( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu <lambda>E s u& PoolManager.__init__.<locals>.<lambda>( u RequestMethodsu __init__u connection_pool_kwu RecentlyUsedContaineru pools( u selfu num_poolsu headersu connection_pool_kw( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu __init__A s u PoolManager.__init__c C sb t | } | j } | d k rR | j j � } x! t D] } | j | d � q5 Wn | | | | � S( u 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. u httpN( u pool_classes_by_schemeu connection_pool_kwu copyu SSL_KEYWORDSu popu None( u selfu schemeu hostu portu pool_clsu kwargsu kw( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu _new_poolG s u PoolManager._new_poolc C s | j j � d S( u� 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( u poolsu clear( u self( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu clearX s u PoolManager.clearu httpc C s� | p d } | p! t j | d � } | | | f } | j j �C | j j | � } | r\ | S| j | | | � } | | j | <Wd QX| S( u� 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``. u httpiP N( u port_by_schemeu getu poolsu locku _new_pool( u selfu hostu portu schemeu pool_keyu pool( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu connection_from_hosta s u PoolManager.connection_from_hostc C s. t | � } | j | j d | j d | j �S( u* 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. u portu scheme( u parse_urlu connection_from_hostu hostu portu scheme( u selfu urlu u( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu connection_from_url{ s u PoolManager.connection_from_urlc K s? t | � } | j | j d | j d | j �} d | d <d | d <d | k r` | 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 t j d | | f � | j d d � d | d <| | d <| j | | | � S( u] 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. u portu schemeu assert_same_hostu redirectu headersu httpi/ u GETu Redirecting %s -> %su retriesi i FN( u parse_urlu connection_from_hostu hostu portu schemeu Falseu headersu proxyu Noneu urlopenu request_uriu get_redirect_locationu urljoinu statusu logu infou get( u selfu methodu urlu redirectu kwu uu connu responseu redirect_location( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu urlopen� s& $ u PoolManager.urlopenNT( u __name__u __module__u __qualname__u __doc__u Noneu proxyu __init__u _new_poolu clearu connection_from_hostu connection_from_urlu Trueu urlopen( u __locals__( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu PoolManager# s c sq | Ee Z d Z d Z d d d � f d d � Z d d � f d d � Z d d d � Z d � f d d � Z � S( u ProxyManageruw 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 s� t | t � r. d | j | j | j f } n t | � } | j sm t j | j d � } | j d | � } n | | _ | p i | _ | j j d k s� t d | j j � � | j | d <| j | d <t t | � j | | | � d S( Nu %s://%s:%iiP u portu httpu httpsu Not supported proxy scheme %su _proxyu _proxy_headers( u httpu https( u isinstanceu HTTPConnectionPoolu schemeu hostu portu parse_urlu port_by_schemeu getu _replaceu proxyu proxy_headersu AssertionErroru superu ProxyManageru __init__( u selfu proxy_urlu num_poolsu headersu proxy_headersu connection_pool_kwu proxyu port( u __class__( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu __init__� s u ProxyManager.__init__u httpc sV | d k r( t t | � j | | | � St t | � j | j j | j j | j j � S( Nu https( u superu ProxyManageru connection_from_hostu proxyu hostu portu scheme( u selfu hostu portu scheme( u __class__( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu connection_from_host� s u! ProxyManager.connection_from_hostc C sI i d d 6} t | � j } | r/ | | d <n | rE | j | � n | S( u� Sets headers needed by proxies: specifically, the Accept and Host headers. Only sets headers not provided by the user. u */*u Acceptu Host( u parse_urlu netlocu update( u selfu urlu headersu headers_u netloc( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu _set_proxy_headers� s u ProxyManager._set_proxy_headersc sb t | � } | j d k rC | j | | j d | j � � | d <n t t | � j | | | | � S( u@ Same as HTTP(S)ConnectionPool.urlopen, ``url`` must be absolute.u httpu headers( u parse_urlu schemeu _set_proxy_headersu getu headersu superu ProxyManageru urlopen( u selfu methodu urlu redirectu kwu u( u __class__( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu urlopen� s u ProxyManager.urlopenNT( u __name__u __module__u __qualname__u __doc__u Noneu __init__u connection_from_hostu _set_proxy_headersu Trueu urlopen( u __locals__( ( u __class__uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu ProxyManager� s c K s t d | | � S( Nu proxy_url( u ProxyManager( u urlu kw( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu proxy_from_url s ( u key_fileu cert_fileu cert_reqsu ca_certsu ssl_version( u loggingu urllib.parseu urljoinu ImportErroru urlparseu _collectionsu RecentlyUsedContaineru connectionpoolu HTTPConnectionPoolu HTTPSConnectionPoolu port_by_schemeu requestu RequestMethodsu utilu parse_urlu __all__u pool_classes_by_schemeu getLoggeru __name__u logu SSL_KEYWORDSu PoolManageru ProxyManageru proxy_from_url( ( ( uJ /tmp/pip-zej_zi-build/pip/_vendor/requests/packages/urllib3/poolmanager.pyu <module> s& �S