File: //lib/python2.7/site-packages/botocore/httpsession.pyc
�
N$�_c @ sJ d d l Z d d l Z d d l Z d d l m Z d d l m Z m Z m Z m
Z
d d l m Z d d l
m Z m Z m Z m Z m Z d d l m Z d d l m Z d d l m Z d d l m Z m Z m Z y d d
l m Z Wn! e k
rd d l
m Z n Xd d l! Z" d d l# m$ Z$ d d
l% m& Z& d d l' m( Z( m) Z) d d l* m+ Z+ m, Z, m- Z- m Z m. Z. m Z m Z e( � e j/ e0 � Z1 d Z2 d Z3 e j4 j5 e j4 j6 e7 � d � Z8 y d d l9 m: Z: Wn e k
r�d � Z: n Xd � Z; d d d d d � Z= d e> f d � � YZ? d e> f d � � YZ@ d S( i����N( t b64encode( t PoolManagert ProxyManagert proxy_from_urlt Timeout( t Retry( t sslt OP_NO_SSLv2t OP_NO_SSLv3t OP_NO_COMPRESSIONt DEFAULT_CIPHERS( t SSLError( t ReadTimeoutError( t ConnectTimeoutError( t NewConnectionErrort
ProtocolErrort
ProxyError( t orig_util_SSLContext( t
SSLContext( t six( t unquote( t filter_ssl_warningst urlparse( t ConnectionClosedErrort EndpointConnectionErrort HTTPClientErrorR t ProxyConnectionErrorR
R i< i
s
cacert.pem( t wherec C s t S( N( t DEFAULT_CA_BUNDLE( ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR ' s c C s | t k r | St � S( N( t TrueR ( t verify( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt
get_cert_path+ s c C s� t | p t j � } | d k r* t j n | } | d k rc d } | t O} | t O} | t O} n | j | O_ t | d t
� r� | j | p� t � n | | _
t | d d � d k r� t | _ n | S( s� This function is a vendored version of the same function in urllib3
We vendor this function to ensure that the SSL contexts we construct
always use the std lib SSLContext instead of pyopenssl.
i t supports_set_cipherst check_hostnameN( R R t PROTOCOL_SSLv23t Nonet
CERT_REQUIREDR R R t optionst getattrR t set_ciphersR
t verify_modet FalseR! ( t ssl_versiont cert_reqsR% t cipherst context( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt create_urllib3_context2 s
t ProxyConfigurationc B sG e Z d Z d d � Z d � Z d � Z d � Z d � Z d � Z RS( s� Represents a proxy configuration dictionary.
This class represents a proxy configuration dictionary and provides utility
functions to retreive well structured proxy urls and proxy headers from the
proxy configuration dictionary.
c C s" | d k r i } n | | _ d S( N( R# t _proxies( t selft proxies( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt __init__^ s c C s= t | � } | j j | j � } | r9 | j | � } n | S( s7 Retrieves the corresponding proxy url for a given url. ( R R0 t gett schemet _fix_proxy_url( R1 t urlt
parsed_urlt proxy( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt
proxy_url_forc s
c C sJ i } | j | � \ } } | rF | rF | j | | � } | | d <n | S( sA Retrieves the corresponding proxy headers for a given proxy url. s Proxy-Authorization( t _get_auth_from_urlt _construct_basic_auth( R1 t proxy_urlt headerst usernamet passwordt
basic_auth( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt proxy_headers_fork s
c C sE | j d � s | j d � r" | S| j d � r9 d | Sd | Sd S( Ns http:s https:s //s http://( t
startswith( R1 R= ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR6 t s
c C s@ d j | | � } t | j d � � j � j � } d j | � S( Ns {0}:{1}t asciis Basic {0}( t formatR t encodet stript decode( R1 R? R@ t auth_strt encoded_str( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR< | s !c C sK t | � } y t | j � t | j � f SWn t t f k
rF d SXd S( N( NN( R R R? R@ t AttributeErrort TypeErrorR# ( R1 R7 R8 ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR; � s
N(
t __name__t
__module__t __doc__R# R3 R: RB R6 R< R; ( ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR/ W s t URLLib3Sessionc B s} e Z d Z e d d e d d d � Z d � Z d � Z d � Z d � Z
d � Z d d � Z d � Z
d � Z d
� Z RS( s_ A basic HTTP client that supports connection pooling and proxies.
This class is inspired by requests.adapters.HTTPAdapter, but has been
boiled down to meet the use cases needed by botocore. For the most part
this classes matches the functionality of HTTPAdapter in requests v2.7.0
(the same as our vendored version). The only major difference of note is
that we currently do not support sending chunked requests. While requests
v2.7.0 implemented this themselves, later version urllib3 support this
directly via a flag to urlopen so enabling it if needed should be trivial.
c C s= | | _ t d | � | _ i t j j d 6t j j d 6| _ | d k rS t } n t
| t t f � s� t
d | d d | d � } n d | _ d | _ t
| t � r� | | _ n$ t
| t � r� | \ | _ | _ n | | _ | | _ | | _ | d k r g | _ n i | _ t | j � � | _ | j | j _ d S( NR2 t httpt httpst connecti t readi ( t _verifyR/ t
_proxy_configt botocoret
awsrequestt AWSHTTPConnectionPoolt AWSHTTPSConnectionPoolt _pool_classes_by_schemeR# t DEFAULT_TIMEOUTt
isinstancet intt floatR t
_cert_filet _key_filet strt tuplet _timeoutt _max_pool_connectionst _socket_optionst _proxy_managersR t _get_pool_manager_kwargst _managert pool_classes_by_scheme( R1 R R2 t timeoutt max_pool_connectionst socket_optionst client_cert( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyR3 � s.
c K s] i t d 6| j d 6| j d 6| j � d 6| j d 6| j d 6| j d 6} | j | � | S( Nt strictRk t maxsizet ssl_contextRm t cert_filet key_file( R Rd Re t _get_ssl_contextRf R` Ra t update( R1 t extra_kwargst pool_manager_kwargs( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyRh � s
c C s t � S( N( R. ( R1 ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyRt � s c C si | | j k r^ | j j | � } | j d | � } t | | � } | j | _ | | j | <n | j | S( Nt
proxy_headers( Rg RV RB Rh R R[ Rj ( R1 R= Rx t proxy_manager_kwargst
proxy_manager( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _get_proxy_manager� s c C sE t | � } | j } | s$ d } n | j rA | d | j } n | S( Nt /t ?( R t patht query( R1 R7 R8 R~ ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _path_url� s c C sL | j � j d � r6 | r6 d | _ t | � | _ n d | _ d | _ d S( NRR R$ t CERT_NONE( t lowerRC R+ R t ca_certsR# ( R1 t connR7 R ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _setup_ssl_cert� s
c C s% | r | j | � } n | j } | S( N( R{ Ri ( R1 R7 R= t manager( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _get_connection_manager� s c C s* | r | j d � r | S| j | � Sd S( Ns http:( RC R� ( R1 R7 R= ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _get_request_target� s c C s | j d d � d k S( Ns Transfer-Encodingt t chunked( R4 ( R1 R> ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt _chunked� s c
C sP y| j j | j � } | j | j | � } | j | j � } | j | | j | j � | j | j | � } | j d | j d | d | j
d | j d t t
� d t
d t
d t
d | j | j � � } t j j | j | j | j | � } | j s| j n | SWnCt k
r3} t d
| j d | � � nt t j f k
rf} t d
| j d | � � n� t k
r�} t d | d | � � n� t k
r�} t d
| j d | � � n� t k
r�} t d
| j d | � � nk t! k
r} t" d | d
| d
| j � � n; t# k
rK} d } t$ j% | d t& �t' d | � � n Xd S( Nt methodR7 t bodyR> t retriest assert_same_hostt preload_contentt decode_contentR� t endpoint_urlt errorR= t requests4 Exception received when sending urllib3 HTTP requestt exc_info(( RV R: R7 R� t connection_from_urlR� RU R� t urlopenR� R� R> R R) R� RW RX t AWSResponset statust
stream_outputt contentt URLLib3SSLErrorR R t sockett gaierrorR R R t URLLib3ConnectTimeoutErrorR
t URLLib3ReadTimeoutErrorR R R t Exceptiont loggert debugR R (
R1 R� R= R� R� t request_targett urllib_responset
http_responset et message( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt send� sV
N( RM RN RO R R# t MAX_POOL_CONNECTIONSR3 Rh Rt R{ R� R� R� R� R� R� ( ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyRP � s
(A t os.patht ost loggingR� t base64R t urllib3R R R R t urllib3.util.retryR t urllib3.util.ssl_R R R R R
t urllib3.exceptionsR R� R R� R
R� R R R t urllib3.contrib.pyopensslR R t ImportErrort botocore.awsrequestRW t botocore.vendoredR t( botocore.vendored.six.moves.urllib_parseR t botocore.compatR R t botocore.exceptionsR R R R t getLoggerRM R� R\ R� R~ t joint dirnamet __file__R t certifiR R R# R. t objectR/ RP ( ( ( s8 /usr/lib/python2.7/site-packages/botocore/httpsession.pyt <module> sB "(
4!
$2