관리-도구
편집 파일: httppeer.pyc
� Hq�Qc @ s d d l m Z 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 Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d � Z d e j f d � � YZ d e f d � � YZ d � Z d S( i����( t nullid( t _Nc 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 decompressobjt utilt filechunkitert decompresst unconsumed_tailt httplibt HTTPExceptiont IOErrort NoneR t flush( t ft zdt chunk( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt zgenerator s t httppeerc B sk e 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 | _ t j | � } | j sE | j rm t j t d � | j pc | j � � n | j � \ | _ } | | _ | j j d | j � t j | | � | _ d S( Ns unsupported URL component: "%s"s using %s ( t pathR t capst handlert urlopenerR t urlt queryt fragmentt AbortR t authinfot _urlt uit debugt opener( t selfR R t uR ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt __init__ s c C sG | j rC x7 | j j D]& } | j � t | d d � � � q Wn d S( Nt close_allc S s d S( N( R ( ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt <lambda>1 s ( R t handlerst closet getattr( R t h( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt __del__- s c C s | j S( N( R ( R ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyR 3 s c C s" t | j d � j � � | _ d S( Nt capabilities( t sett _callt splitR ( R ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _fetchcaps8 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 R- t errort RepoErrorR* R R t join( R ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _capabilities; s c C s t j t d � � � d S( Ns! operation not supported over http( R R R ( R ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt lockE s c K s� | d k r d | d <n | j d d � } d } t j | d � rO | j } n | d k rj t | � } n | j d i � } | d k r� d | k r� d | d <n | r� | j j d d t � r� d | d <d | d <n | j j d | � d | f g } d } t | � d k rE| j d � } | rEt | j d � d � } qEn | d k r(t j t | j � � � } d } | t | d d � } d } xO t d t | � | � D]5 } | d 7} | t | � } | | | | !| | <q�Wg t d | d � D] } | t | � ^ q�} d j | � | d <n | t | j � � 7} d t j | � } d | j | f } t j | | | � } | d k r�| j j d | � | j d d | � n y | j j | � } Wn� t j k r} | j d k rt j t d � � � n � nk t j k rM} | j j d | � | j j! � t" d | � � n& t# k rrt j t d � � � n X| j$ � } | j% | � r�| t | � } n | j j& d! � | j& d! � k r�| j j' s�| j j( t d" � | � q�n | | _ y | j) d# � } Wn& t* k r3| j+ j, d# d � } n Xt j- | j � } | j. d$ � rmt/ j0 | j1 � � � n | j. d% � p�| j. d& � r�| j+ j, d' � p�| j. d( � s�| j j d) t j- | � � t/ j2 t d* � | | p�d+ | j1 d, � f � � n | j. d% � r�yH | j d- d � d } t3 g | j d. � D] } t | � ^ q9� } Wn0 t4 k r�t/ j2 t d/ � | | f � � n X| d1 k r�t/ j2 t d0 � | | f � � q�n | S(2 Nt pushkeyt t datai t lengtht headerss Content-Types application/mercurial-0.1R t usehttp2s 100-Continuet Expectt 1s X-HgHttp2s sending %s command t cmdt httpheadert ,s X-HgArg-%st 000s : i t Varys ?%ss %s%ss 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 (5 t popR R t safehasattrR8 t lenR t configboolt FalseR t capablet intR, t urllibt urlencodet sortedt itemst xranget strt rangeR2 R t urllib2t Requestt add_unredirected_headerR t opent HTTPErrort codeR R R R t tracebackR t IndexErrort geturlt endswitht rstript quiett warnt getheadert AttributeErrorR9 t gett hidepasswordt startswithR0 t OutOfBandErrort readR1 t tuplet ValueError( R R= t argsR7 t sizeR9 t qt headersizeR> t encargst headerfmtt contentlent headernumt it headerR' t varyheaderst qst cut reqt respt instt resp_urlt protot safeurlt versiont nt version_info( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _callstreamH s� 0 ! %2 c K s2 | j | | � } z | j � SWd | j � Xd S( N( R Rf R% ( R R= Ri t fp( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyR+ � 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 | d | � } t j | j | d � } i d d 6} z� ye | j | d | d | | �} | j d d � } t | � d k rt j t d � | � � n | SWnn t j k r{} | j d t j t j f k rbt j t d � | j d � � n t j | j d � � n XWd | j � t j | � Xd S( Nt unbundleR? R6 t rbs application/mercurial-0.1s Content-TypeR7 R9 s i i s unexpected response:i s push failed: %s( RJ R, Ra t changegroupt bundletypest writebundleR t httpconnectiont httpsendfileR R+ RG R0 t ResponseErrorR t socketRi t errnot ECONNRESETt EPIPER R R% t ost unlink( R R= t cgRi t typest xt typet tempnameR� R9 t rt valst err( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _callpush� s2 # c C s | � d S( N( ( R t exception( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _abort� s c C s t j t | � � S( N( R t chunkbufferR ( R t stream( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt _decompress� s ( t __name__t __module__R! R( R R- R3 R4 R R+ R� R� R� ( ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyR s b $ 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 ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyR! � s ( R� R� R! ( ( ( s8 /usr/lib64/python2.7/site-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| SWna t j k r� } y. t j | d | | � } | j 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 Rd R� R R- R0 R1 t betweenR t statichttprepot instancet note( R R t createRx t httpexceptionR� ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyR� � s$ ( t nodeR t i18nR R� R� R0 R� R R t wireprotoR� RL RS R R R� R� R t wirepeerR R� R� ( ( ( s8 /usr/lib64/python2.7/site-packages/mercurial/httppeer.pyt <module> s T< �