File: //usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyc
ó
ÛXc @@ sò d d l m Z 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
e
j Z e
j Z d e
f d „ ƒ YZ d „ Z d e j f d
„ ƒ YZ d e j f d „ ƒ YZ e a d
Z d e j e j f d „ ƒ YZ d S( i ( t absolute_importNi ( t _( t
httpclientt sslutilt utilt httpsendfilec B@ s2 e Z d Z d „ Z d „ Z d „ Z d „ Z RS( sð This is a wrapper around the objects returned by python's "open".
Its purpose is to send file-like objects via HTTP.
It do however not define a __len__ attribute because the length
might be more than Py_ssize_t can handle.
c O@ s‡ | | _ t | | Ž | _ | j j | _ | j j | _ | j j | _ t j | j j ƒ ƒ j | _
d | _ | j
d d | _ d S( Ni i i (
t uit opent _datat seekt closet writet ost fstatt filenot st_sizet lengtht _post _total( t selfR t argst kwargs( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt __init__$ s c O@ s” y | j j | | Ž } Wn* t k
rE | j j t d ƒ d ƒ n X| j t | ƒ 7_ | j j t d ƒ | j d d t d ƒ d | j ƒ| S( Nt sendingi t unitt kbt total(
R t readt EOFErrorR t progressR t NoneR t lenR ( R R R t ret( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR . s
c C@ s | S( N( ( R ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt __enter__= s c C@ s | j ƒ d S( N( R
( R t exc_typet exc_valt exc_tb( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt __exit__@ s ( t __name__t
__module__t __doc__R R R! R% ( ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR s
c C@ s- t ƒ } x› | j d ƒ D]Š \ } } d | k rN | j t d ƒ | ƒ q n | j d d ƒ \ } } | j | t ƒ ƒ } | d k r™ t j | ƒ } n | | | <q W| j d d ƒ \ } }
d } d } d }
xU| j
ƒ D]G\ } } | r| | j d | ƒ k rqÞ n | j d
ƒ } | s)qÞ n | j d d ƒ } t | ƒ d k rh| d g | d } } n | j d ƒ pzd j ƒ } | d
k sž|
j
| ƒ rÞ t | ƒ | k sÕt | ƒ | k rÞ | rÞ d | k rÞ | | k rÞ t | ƒ } | | f }
| j d ƒ } | r%| r%| | d <q%qÞ qÞ W|
S( Nt autht .s! ignoring invalid [auth] key '%s'
i t usernamet certt keys ://i t prefixt schemest httpst *( R+ R, R- ( t dictt configitemst warnR t rsplitt
setdefaultR t
expandpatht splitR t iteritemst getR t
startswith( R t urit usert configR- t valt groupt settingt gdictt schemet hostpatht bestusert bestlent bestauthR) R. t pR/ ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt readauthforuriD sD $
t HTTPResponsec B@ s e Z d „ Z RS( c C@ s d S( N( ( R ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR
r s ( R& R' R
( ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyRJ q s t HTTPConnectionc B@ s e Z e Z d d d „ Z RS( c C@ sZ | d k r i } n t | t ƒ r4 | j d ƒ n t j j | | | d | d | ƒd S( Ni t bodyt headers( R t
isinstanceR R R RK t request( R t methodR< RL RM ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyRO w s N( R& R' RJ t response_classR RO ( ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyRK u s s- %(levelname)s:%(name)s:%(lineno)d:%(message)st http2handlerc B@ sA e Z d „ Z d „ Z d „ Z d „ Z d „ Z d d „ Z RS( c C@ s· t j j | ƒ | | _ | | _ i | _ | j d d d d ƒ} | r³ t r³ t a t
j d ƒ } | j t
t
| j ƒ ƒ ƒ t
j ƒ } | j t
j t ƒ ƒ | j | ƒ n d S( NR t http2debuglevelt defaults mercurial.httpclient( t urlreqt abstracthttphandlerR R t pwmgrt _connectionsR> R t _configuredloggingt Truet loggingt getLoggert setLevelt getattrt uppert
StreamHandlert setFormattert Formattert LOGFMTt
addHandler( R R RW t loglevelt loggert handler( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR † s
c C@ sB x2 | j j ƒ D]! } x | D] } | j ƒ q Wq Wi | _ d S( s= Close and remove all connection objects being kept for reuse.N( RX t valuesR
( R t openconnst conn( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt close_all– s
c C@ sç t | d d
ƒ } | j ƒ } | r3 | } | } nM | j ƒ rz | j ƒ } | j ƒ j d d ƒ d j d d ƒ d } n d
} | r d | k r | j d d ƒ \ } } n d } | | f } n d
} | sà t j d ƒ ‚ n | | | f } | j j
| g ƒ }
g |
D] } | j ƒ s | ^ q } | r<| d }
nu |
rY| j j
d | ƒ n d
} | j t j k r}| j } n | | d
| d | ƒ}
| j j | g ƒ j |
ƒ t | j ƒ } | j | j ƒ t d „ | j ƒ Dƒ ƒ } y | j ƒ } d | k r0| j d d ƒ d j d d ƒ d } n | d d k rMd | } n |
j | j ƒ | | j | ƒ |
j ƒ } Wn% t j k
r } t j | ƒ ‚ n X| j | _ t j | | j | j! ƒ ƒ } | j" | _# | j$ | _% | S( s¦ Return an addinfourl object for the request, using http_class.
http_class must implement the HTTPConnection API from httplib.
The addinfourl return value is a file-like object. It also
has methods and attributes including:
- info(): return a mimetools.Message object for the headers
- geturl(): return the original request URL
- code: HTTP status code
t _tunnel_hosts ://i t /i t :i8 s
no host givens. all connections for %s busy, making a new one
t timeoutt proxy_hostportc s@ s' | ] \ } } | j ƒ | f Vq d S( N( t title( t .0t nameR? ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pys <genexpr>Ù s N(& R^ R t get_hostt has_proxyt get_selectorR8 R5 t urlerrt urlerrorRX R: t busyR t debugRo t sockett _GLOBAL_DEFAULT_TIMEOUTR6 t appendR2 RM t updatet unredirected_hdrst itemsRO t
get_methodt datat getresponset errorR t recvRU t
addinfourlt get_full_urlt statust codet reasont msg( R t
http_classt reqt use_sslt tunhostt hostt proxyhostt proxyportt proxyt connkeyt allconnst ct connst hRo RM t patht rt errt resp( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt do_openž sb / %
)
c C@ s> | j ƒ j d ƒ r" | j | ƒ Sd „ } | j | | t ƒ S( NR0 c _@ s# t | ƒ } t | d <t | | Ž S( NRŽ ( R2 t FalseRK ( R R t k2( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt makehttpconô s
( R‡ R; t
https_openR Rž ( R R R ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt http_openñ s
c C@ sŠ | j ƒ } | j j | ƒ \ } } t | j | | ƒ } | rk | \ } } | | _ | j j d | ƒ n d | _ | j | j | t
ƒ S( Ns# using auth.%s.* for authentication
( R‡ RW t find_stored_passwordRI R R) Rz R R t _makesslconnectionRZ ( R R t urlR= t passwordt resR@ R) ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR¡ ú s i» c O@ s2 d } d } | r$ | j d ƒ } n | r< | j d ƒ } n | j r€ d | j k r€ d | j k r€ | j d } | j d } n d | k r˜ d | k s¤ d | k rç | j d d ƒ \ } } t | ƒ } d | k rç | d d !} qç n | | d <| | d
<t | | d t d t j d
t j d | j
| } | S( Ni R- R, Rn t [s ]:i iÿÿÿÿt keyfilet certfileRŽ t ssl_wrap_sockett
ssl_validatorR ( R t popR) R5 t intRK RZ R t
wrapsockett validatesocketR ( R R t portR R R© Rª t con( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyR¤ s, '
$
( R& R' R Rk R R¢ R¡ R¤ ( ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyRR … s S ( t
__future__R R[ R R{ t i18nR t R R R Rw RU t objectR RI RJ RK Rž RY Rc t httphandlert httpshandlerRR ( ( ( s< /usr/lib/python2.7/dist-packages/mercurial/httpconnection.pyt <module> s ( -