File: //usr/lib/python2.7/dist-packages/mercurial/httppeer.pyc
ó
ÛXc @@ s d d l m Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
d d l m Z m
Z
m Z m Z m Z m Z m Z e j Z e j Z e j Z d „ Z d e j f d „ ƒ YZ d
e f d „ ƒ YZ d „ Z d S(
i ( t absolute_importNi ( t _( t nullid( t bundle2t errort httpconnectiont statichttprepot urlt utilt wireprotoc c@ sŒ t j ƒ } yE x> t j | ƒ D]- } x$ | rK | j | d ƒ V| j } q( Wq WWn) t j k
r| t d t
d ƒ ƒ ‚ n X| j ƒ Vd S( Ni i s connection ended unexpectedlyi ( t zlibt
decompressobjR t
filechunkitert
decompresst unconsumed_tailt httplibt
HTTPExceptiont IOErrort NoneR t flush( t ft zdt chunk( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt
zgenerator! s t httppeerc B@ st e Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d
„ Z d „ Z
RS( c C@ sÐ | | _ d | _ d | _ d | _ d | _ t j | ƒ } | j sN | j rv t
j t d ƒ | j pl | j ƒ ‚ n | j
ƒ \ | _ } | | _ | j j d | j ƒ t j | | ƒ | _ t j | _ d S( Ns unsupported URL component: "%s"s using %s
( t pathR t capst handlert urlopenert requestbuilderR R t queryt fragmentR t AbortR t authinfot _urlt uit debugt openert urlreqt request( t selfR# R t uR! ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt __init__- s c C@ sS t | d d ƒ } | rO x4 | j D]& } | j ƒ t | d d „ ƒ ƒ q" Wn d S( NR t close_allc S@ s d S( N( R ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt <lambda>F s ( t getattrR t handlerst close( R( R t h( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt __del__A s
c C@ s | j S( N( R ( R( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR H s c C@ s" t | j d ƒ j ƒ ƒ | _ d S( Nt capabilities( t sett _callt splitR ( R( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt
_fetchcapsM s c C@ ss | j d k rl y | j ƒ Wn t j k
r? t ƒ | _ n X| j j d d j | j pa d g ƒ ƒ n | j S( Ns capabilities: %s
t t none( R R R6 R t RepoErrorR3 R# R$ t join( R( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt
_capabilitiesP s c C@ s t j t d ƒ ƒ ‚ d S( Ns! operation not supported over http( R R R ( R( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt lockZ s c K@ sE | d k r d | d <n | j d d ƒ } | j d i ƒ } | j j d | ƒ d | f g } d } | j d k o d | j k } | p— t | t ƒ } | r| rt j t | j
ƒ ƒ ƒ } | r-| sÖ | } n t | t ƒ rò | | } n t | ƒ | d <q-n%t | ƒ d k rQ| j d
ƒ }
|
rQt
|
j d d ƒ d ƒ } qQn | d k rt j t | j
ƒ ƒ ƒ } d
} | t | d d ƒ }
d } g } x\ t d t | ƒ |
ƒ D]B } | d 7} | t | ƒ } | | | |
!| | <| j | ƒ q»Wd j | ƒ | d <n | t | j
ƒ ƒ 7} d t j | ƒ } d | j | f } d } t j | d ƒ rw| j } n | d k r’t | ƒ } n | rÇ| j j d d t ƒ rÇd | d <d | d <n | d k rìd | k rìd | d <n | j | | | ƒ } | d k r8| j j d | ƒ | j d d | ƒ n y | j j | ƒ } Wnª t j k
r} | j d k rŠt j! t" d ƒ ƒ ‚ n ‚ nk t# j$ k
rÕ} | j j d! | ƒ | j j% ƒ t& d | ƒ ‚ n& t' k
rút j! t" d" ƒ ƒ ‚ n X| j( ƒ } | j) | ƒ r*| t | ƒ } n | j j* d# ƒ | j* d# ƒ k rw| j j+ sw| j j, t" d$ ƒ | ƒ qwn | | _ y | j- d% ƒ } Wn& t. k
r»| j/ j0 d% d ƒ } n Xt j1 | j ƒ } | j2 d& ƒ rõt j3 | j4 ƒ ƒ ‚ n | j2 d' ƒ p2| j2 d( ƒ r&| j/ j0 d) ƒ p2| j2 d* ƒ s†| j j d+ t j1 | ƒ ƒ t j5 t" d, ƒ | | pmd- | j4 d. ƒ f ƒ ‚ n | j2 d' ƒ rAyH | j d/ d ƒ d } t6 g | j d0 ƒ D] } t
| ƒ ^ qÁƒ } Wn0 t7 k
rt j5 t" d1 ƒ | | f ƒ ‚ n X| d3 k rAt j5 t" d2 ƒ | | f ƒ ‚ qAn | S(4 Nt pushkeyt t datat headerss sending %s command
t cmdi t httppostargss
X-HgArgs-Postt
httpheadert ,i s
X-HgArg-%st 000s :
t Varys ?%ss %s%st lengthR# t usehttp2s 100-Continuet Expectt 1s X-HgHttp2s Content-Types application/mercurial-0.1s sending %s bytes
s Content-Lengths %di‘ s authorization faileds$ http error while sending %s command
s, http error, possibly caused by proxy settingt /s real URL is %s
s content-types application/hg-errors application/mercurial-s
text/plains content-lengths application/hg-changegroups requested URL: '%s'
sI '%s' does not appear to be an hg repository:
---%%<--- (%s)
%s
---%%<---
s no content-typei t -t .s+ '%s' sent a broken Content-Type header (%s)s '%s' uses newer protocol %s( i i (8 t popR R# R$ R t
isinstancet
basestringR& t urlencodet sortedt itemst lent capablet intR5 t xranget strt appendR: R" R t safehasattrRG t
configboolt FalseR t add_unredirected_headerR t opent urlerrt httperrort codeR R R R R t tracebackR t
IndexErrort geturlt endswitht rstript quiett warnt getheadert AttributeErrorR@ t gett hidepasswordt
startswitht OutOfBandErrort readR9 t tuplet
ValueError( R( RA t argsR? R@ t qt
headersizet
postargsokt canmungedatat strargsRC t encargst headerfmtt
contentlent headernumt varyheaderst it headert qst cut sizet reqt respt instt resp_urlt protot safeurlt versiont nt version_info( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt _callstream] s¾
"
!
%2
c K@ s2 | j | | } z | j ƒ SWd | j ƒ Xd S( N( R‹ Ro R/ ( R( RA Rr t fp( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR4 Î s c
K@ s¢ | j d ƒ } y | j d ƒ } Wn t k
r> d g } n Xx' | D] } | t j k rF | } PqF qF Wt j | j | d | ƒ } t j | j | d ƒ } i d d 6} zÚ ye | j
| d | d | | }
|
j d d
ƒ } t | ƒ d k r t j
t d ƒ |
ƒ ‚ n | SWnn t j k
r} | j d
t j t j f k rht j t d ƒ | j d
ƒ ‚ n t j | j d
ƒ ‚ n XWd | j ƒ t j | ƒ Xd S( Nt unbundleRD R> t rbs application/mercurial-0.1s Content-TypeR? R@ s
i i s unexpected response:i s push failed: %s( RU R5 Rj R t bundletypest writebundleR# R R t httpsendfileR4 RT R t
ResponseErrorR t socketRr t errnot
ECONNRESETt EPIPER R/ t ost unlink(
R( RA t cgRr t typest xt typet tempnameRŒ R@ t rt valst err( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt _callpushÖ s2
#
c
K@ s d } d } d } z· t j d d d d ƒ \ } } t j | d ƒ } | j d ƒ } x& | r| | j | ƒ | j d ƒ } qW W| j ƒ t j | j
| d ƒ } i d d 6} | j | d
| d | | SWd | d k rå | j ƒ n | d k r | j ƒ t j | ƒ n Xd S( Nt prefixs
hg-bundle-t suffixs .hgt wbi RŽ s application/mercurial-0.1s Content-TypeR? R@ (
R t tempfilet mkstempR— t fdopenRo t writeR/ R R‘ R# R‹ R˜ (
R( RA RŒ Rr t fht fp_t filenamet fdt dR@ ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt _calltwowaystreamù s&
c K@ s% | j | | } t j t | ƒ ƒ S( N( R‹ R t chunkbufferR ( R( RA Rr t stream( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt _callcompressable s c C@ s
| ‚ d S( N( ( R( t exception( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt _abort s ( t __name__t
__module__R* R1 R R6 R; R< R‹ R4 R¡ R® R± R³ ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR , s
q # t httpspeerc B@ s e Z d „ Z RS( c C@ s8 t j s! t j t d ƒ ƒ ‚ n t j | | | ƒ d S( Ns1 Python support for SSL and HTTPS is not installed( R t has_httpsR R R R R* ( R( R# R ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR* s ( R´ Rµ R* ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR¶ s c C@ sÿ | r t j t d ƒ ƒ ‚ n ys | j d ƒ rB t | | ƒ } n t | | ƒ } y | j ƒ Wn* t j k
r‹ | j t t f g ƒ n X| SWng t j k
rú } y4 t
j | d | | ƒ } | j t d ƒ ƒ | SWqû t j k
rö | ‚ qû Xn Xd S( Ns! cannot create new http repositorys https:s static-s (falling back to static-http)
(
R R R Rm R¶ R R6 R9 t betweenR R t instancet note( R# R t createR„ t
httpexceptionRž ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyR¹ s$ ( t
__future__R R” R— R“ R¥ R
t i18nR t nodeR R> R R R R R R R R R_ R& R t wirepeerR R¶ R¹ ( ( ( s6 /usr/lib/python2.7/dist-packages/mercurial/httppeer.pyt <module> s 4
ì