관리-도구
편집 파일: wireproto.pyc
� } �^c @ s� 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 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 i Z d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d � Z d d � Z d d � Z d � Z d � Z d � Z d e j f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ d e f d � � YZ! d � Z" d � Z# d d � Z$ d! e d" <d# � Z% d! e d$ <d% � Z& d! e d& <d' � Z' d! e d( <d) � Z( d! e d* <d+ � Z) d! e d, <d- � Z d! e d. <d/ � Z* d! e d0 <d1 � Z+ d! e d2 <d3 � Z, d! e d4 <d5 � Z- d! e d6 <d7 � Z. d! e d8 <d9 � Z/ d! e d: <d; � Z0 d! e d< <d= � Z1 d> e d? <d@ � Z2 dA � Z3 d! e dB <dC � Z4 d> e dD <dE � Z5 i e% dF f d" 6e& dG f d$ 6e' d f d& 6e( dH f d( 6e) d f d* 6e dI f d, 6e* dJ f d. 6e+ dK f d0 6e, dL f d2 6e- d f d4 6e. d f d6 6e1 dM f d< 6e/ dN f d8 6e0 dO f d: 6e2 dP f d? 6e4 d f dB 6e5 d4 f dD 6Z6 d S(Q i����N( t _( t bint hext futurec B s e Z d Z d � Z RS( s' placeholder for a value to be set laterc C s1 t j | d � r$ t j d � � n | | _ d S( Nt values future is already set( t utilt safehasattrt errort RepoErrorR ( t selfR ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt set s ( t __name__t __module__t __doc__R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR s t batcherc B s) e Z d Z d � Z d � Z d � Z RS( s' base class for batches of commands submittable in a single request All methods invoked on instances of this class are simply queued and return a a future for the result. Once you call submit(), all the queued calls are performed and the results set in their respective futures. c C s g | _ d S( N( t calls( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt __init__" s c s � � f d � } | S( Nc s) t � } � j j � | | | f � | S( N( R R t append( t argst optst resref( t nameR ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt call% s ( ( R R R ( ( R R s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt __getattr__$ s c C s d S( N( ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt submit* s ( R R R R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR s t localbatchc B s e Z d Z d � Z d � Z RS( s" performs the queued calls directlyc C s t j | � | | _ d S( N( R R t local( R R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR / s c C sF x? | j D]4 \ } } } } | j t | j | � | | � � q Wd S( N( R R t getattrR ( R R R R R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR 2 s ( R R R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR - s t remotebatchc B s) e Z d Z d � Z d � Z d � Z RS( s< batches the queued calls; uses as few roundtrips as possiblec C s t j | � | | _ d S( sN remote must support _submitbatch(encbatch) and _submitone(op, encargs)N( R R t remote( R R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR 8 s c C s g g } } x� | j D]� \ } } } } t | j | � } t | d d � } | d k r� | | j | | � } | j � \ } } | r� | j | | f � | j | | | f � q� | j | � q | r� | j | | � g g } } n | j | | | � � q W| r| j | | � n d S( Nt batchable( R R R t Nonet im_selft nextR R t _submitreq( R t reqt rspR R R R t mtdt batchablefnR t encargsorrest encresref( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR = s" c C se | j j | � } xL t | | � D]; \ } } | \ } } } | j | � | j | j � � q" Wd S( N( R t _submitbatcht zipR R! ( R R# R$ t encresultst encrest rR R( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR" Q s ( R R R R R R" ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR 6 s c s# � f d � } t | d � � | S( s� annotation for batchable methods Such methods must implement a coroutine as follows: @batchable def sample(self, one, two=None): # Handle locally computable results first: if not one: yield "a local result", None # Build list of encoded arguments suitable for your wire protocol: encargs = [('one', encode(one),), ('two', encode(two),)] # Create future for injection of encoded result: encresref = future() # Return encoded arguments and future: yield encargs, encresref # Assuming the future to be filled with the result from the batched # request now. Decode it: yield decode(encresref.value) The decorator returns a function which wraps this coroutine as a plain method, but adds the original method as an attribute called "batchable", which is used by remotebatch to split the call into separate encoding and decoding phases. c s[ � | | � } | j � \ } } | s+ | S| d } | j | j � j | � � | j � S( Ni ( R! R t _submitonet func_name( R R R R' R( R ( t f( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt plainq s R ( t setattr( R0 R1 ( ( R0 s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR X s t c C s | r t t | j | � � Sg S( N( t mapR t split( t lt sep( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt decodelist~ s c C s | j t t | � � S( N( t joinR4 R ( R6 R7 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt encodelist� s c C s4 | j d d � j d d � j d d � j d d � S( Nt :s ::t ,s :,t ;s :;t =s :=( t replace( R1 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt escapearg� s c C s4 | j d d � j d d � j d d � j d d � S( Ns :=R> s :;R= s :,R< s ::R; ( R? ( t escaped( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt unescapearg� s c K s | S( N( ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt todict� s t wirepeerc B s� e Z d � Z d � Z d � Z e d � � Z e d � � Z e d � � Z e d � � Z d � Z d � Z e d � � Z e d � � Z d � Z d � Z d � Z d d d � Z d � Z d d d d � Z RS( c C s t | � S( N( R ( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt batch� s c C s~ g } xJ | D]B \ } } d j d � | j � D� � } | j d | | f � q W| j d d d j | � �} | j d � S( NR< c s s | ] } d | Vq d S( s %s=%sN( ( t .0t p( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pys <genexpr>� s s %s %sRE t cmdsR= ( R9 t iteritemsR t _callR5 ( R R# RH t opt argsdictR R$ ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR) � s c C s | j | | � S( N( RJ ( R RK R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR. � s c c s� | j d t d � � t � } t d t j | � � | f V| j } | d j d d � \ } } t | � r{ t | � Vn | j t j | � � d S( Nt lookups look up remote revisiont keyi����R3 i ( t requirecapR R RC t encodingt fromlocalR R5 t intR t _abortR R ( R RN R0 t dt successt data( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRM � s c c sg t � } i | f V| j } y t | d � VWn0 t k rb | j t j t d � | � � n Xd S( Ni����s unexpected response:( R R R8 t ValueErrorRS R t ResponseErrorR ( R R0 RT ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt heads� s c c s� t � } t d t | � � | f V| j } y( g | D] } t t | � � ^ q6 VWn0 t k r� | j t j t d � | � � n Xd S( Nt nodess unexpected response:( R RC R: R t boolRR RW RS R RX R ( R RZ R0 RT ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt known� s ( c c s� t � } i | f V| j } yl i } xZ | j � D]L } | j d d � \ } } t j t j | � � } t | � } | | | <q3 W| VWn0 t k r� | j t j t d � | � � n Xd S( NR3 i s unexpected response:( R R t splitlinesR5 RP t tolocalt urllibt unquoteR8 t TypeErrorRS R RX R ( R R0 RT t branchmapt branchpartt branchnamet branchheads( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRb � s c C s� t | � } | j d d | �} y3 g | j � D] } t t | � � ^ q1 } | SWn0 t k r� | j t j t d � | � � n Xd S( Nt branchesRZ s unexpected response:( R: RJ R] t tupleR8 RW RS R RX R ( R RZ t nRT t bt br( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRf � s + c C s� d } g } x� t d t | � | � D]� } d j g | | | | !D] } t | d � ^ qC � } | j d d | �} y! | j d � | j � D� � Wq% t k r� | j t j t d � | � � q% Xq% W| S( Ni i R3 t -t betweent pairsc s s' | ] } | r t | � p g Vq d S( N( R8 ( RF R6 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pys <genexpr>� s s unexpected response:( t xranget lenR9 R: RJ t extendR] RW RS R RX R ( R Rm RE R- t iRG Rh RT ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRl � s 6! 'c c s) | j d � s t d f Vn t � } | j j d | | f � t d t j | � d t j | � d t j | � d t j | � � | f V| j } | j d d � \ } } y t t | � � } Wn) t k r� t j t d � | � � n Xx0 | j t � D] } | j j t d � | � q� W| Vd S( Nt pushkeys preparing pushkey for "%s:%s" t namespaceRN t oldt news i s" push failed (unexpected response):s remote: ( t capablet FalseR R t uit debugRC RP RQ R R5 R[ RR RW R RX R R] t Truet status( R Rs RN Rt Ru R0 RT t outputR6 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRr � s$ c c s� | j d � s i d f Vn t � } | j j d | � t d t j | � � | f V| j } i } xE | j � D]7 } | j d � \ } } t j | � | t j | � <qs W| Vd S( NRr s preparing listkeys for "%s" Rs s ( Rv R R Rx Ry RC RP RQ R R] R5 R^ ( R Rs R0 RT R- R6 t kt v( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt listkeys s c C s | j d � S( Nt stream_out( t _callstream( R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� s c C s: t | � } | j d d | �} t j | j | � d � S( Nt changegroupt rootst UN( R: R� t changegroupmodt unbundle10t _decompress( R RZ t kindRh R0 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� s c C sb | j d t d � � t | � } t | � } | j d d | d | �} t j | j | � d � S( Nt changegroupsubsets look up remote changest basesRY R� ( RO R R: R� R� R� R� ( R R� RY R� R0 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� s c C s� | j d t d � � i } | d k r; t | � | d <n | d k rZ t | � | d <n | j d | � } t j | j | � d � S( Nt getbundles look up remote changesRY t commonR� ( RO R R R: R� R� R� R� ( R t sourceRY R� R R0 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� s c C s | d g k rQ | j d � rQ t d t j d j t | � � � j � g � } n t | � } | j d | d | �\ } } | d k r� t j t d � | � � n y t | � } Wn) t k r� t j t d � | � � n Xx0 | j t � D] } | j j t d � | � q� W| S( s Send cg (a readable file-like object representing the changegroup to push, typically a chunkbuffer object) to the remote server as a bundle. Return an integer indicating the result of the push (see localrepository.addchangegroup()).t forcet unbundlehasht hashedt t unbundleRY s push failed:s" push failed (unexpected response):s remote: ( Rv R: R t sha1R9 t sortedt digestt _callpushR RX R RR RW R] Rz Rx R{ ( R t cgRY R� t retR| R6 ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� * s - c C sT i } | d k r | | d <n | d k r8 | | d <n | j d d | d | | �S( Nt threet fourt debugwireargst onet two( R RJ ( R R� R� R� R� t fiveR ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� D s N( R R RE R) R. R RM RY R\ Rb Rf Rl Rr R R� R� R� R R� R� R� ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRD � s" t streamresc B s e Z d � Z RS( c C s | | _ d S( N( t gen( R R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR P s ( R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� O s t pushresc B s e Z d � Z RS( c C s | | _ d S( N( t res( R R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR T s ( R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� S s t pusherrc B s e Z d � Z RS( c C s | | _ d S( N( R� ( R R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR X s ( R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� W s t ooberrorc B s e Z d � Z RS( c C s | | _ d S( N( t message( R R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR \ s ( R R R ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� [ s c C s> | j d � } t | \ } } | j | � } | | | | � S( Nt served( t filteredt commandst getargs( t repot protot commandt funct specR ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt dispatch_ s c C sk i } x2 | D]* } | | k r | | | | <| | =q q W| rg t j j d | d j | � f � n | S( Ns& abort: %s got unexpected arguments %s R< ( t syst stderrt writeR9 ( t cmdt keyst othersR R} ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt optionse s R� c s � � f d � } | S( s# decorator for wire protocol commandc s | � f t � <| S( N( R� ( R� ( R R ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt registerr s ( ( R R R� ( ( R R s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt wireprotocommandp s t pullRE c C s� | j d � } g } x�| j d � D]�} | j d d � \ } } i } xE | j d � D]4 } | rY | j d � \ } } t | � | | <qY qY Wt | \ } } t j | d � r� | j t j | d � � n | r�| j � } i } xo | D]g } | d k rGi } x1 | j � D]# } | | k r| | | | <qqW| | d <q� | | | | <q� W| | | g | D] } | | ^ qi� } n | | | � } t | t � r�| S| j t | � � q% Wd j | � S( NR� R= R3 i R< R> t checkpermt pusht *( R� R5 RB R� R R R� t permissionst getR� t isinstanceR� R R@ R9 ( R� R� RH R� R� t pairRK R t valst aRh R~ R� R� R� RV R} t starRN t result( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRE y s: ,Rl c C so g | j d � D] } t | d � ^ q } g } x. | j | � D] } | j t | � d � qA Wd j | � S( NR3 Rk s R� ( R5 R8 Rl R R: R9 ( R� R� Rm RG R- Ri ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRl � s +Rb c C sw | j � } g } xU | j � D]G \ } } t j t j | � � } t | � } | j d | | f � q Wd j | � S( Ns %s %ss ( Rb RI R_ t quoteRP RQ R: R R9 ( R� R� Rb RY t branchRZ Rd t branchnodes( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRb � s Rf c C sP t | � } g } x. | j | � D] } | j t | � d � q" Wd j | � S( Ns R� ( R8 Rf R R: R9 ( R� R� RZ R- Ri ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRf � s t capabilitiesc C s� d j � } t | j � r� | j j d d t � rC | j d � n | j | j @} | t d � ss | j d � q� | j d d j | � � n | j d d j t j � � | j d � d j | � S( NsM lookup changegroupsubset branchmap pushkey known getbundle unbundlehash batcht servert preferuncompresseds stream-preferredt revlogv1t streams streamreqs=%sR< s unbundle=%ss httpheader=1024R3 ( R� ( R5 t _allowstreamRx t configboolRw R t requirementst supportedformatsR R9 R� t bundlepriority( R� R� t capst requiredformats( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s R� c C s1 t | � } | j | d � } t | j | � � S( Nt serve( R8 R� R� t groupchunks( R� R� R� RZ R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s R� c C s@ t | � } t | � } | j | | d � } t | j | � � S( NR� ( R8 R� R� R� ( R� R� R� RY R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s R� c C s+ t d d d g | � } | j | | | � S( NR� R� R� ( R� R� ( R� R� R� R� R� R ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s R� c C sj t d d d g | � } x* | j � D] \ } } t | � | | <q% W| j d | � } t | j | � � S( NR� RY R� R� ( R� RI R8 R� R� R� ( R� R� R� R R} R~ R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s RY c C s | j � } t | � d S( Ns ( RY R: ( R� R� t h( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRY � s t helloc C s d t | | � S( s the hello command returns a set of lines describing various interesting things about the server, in an RFC822-like format. Currently the only one defined is "capabilities", which consists of a line in the form: capabilities: space separated list of tokens s capabilities: %s ( R� ( R� R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� � s R c C sf | j t j | � � j � } d j g | D]. \ } } d t j | � t j | � f ^ q+ � } | S( Ns s %s %s( R RP R^ t itemsR9 RQ ( R� R� Rs RT R} R~ t t( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR � s ;RM c C se y/ t j | � } | | } | j � } d } Wn% t k rV } t | � } d } n Xd | | f S( Ni i s %s %s ( RP R^ R t Exceptiont str( R� R� RN R} t cR- RU t inst( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRM s R\ c C s& d j d � | j t | � � D� � S( NR� c s s! | ] } | r d p d Vq d S( t 1t 0N( ( RF Ri ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pys <genexpr> s ( R9 R\ R8 ( R� R� RZ R� ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR\ s R� Rr c C sD t | � d k r^ | j d � | k r^ y | j d � t j | � } Wqm t k rZ qm Xn t j | � } t j | d � r| j � y= | j t j | � t j | � t j | � | � p� t } Wn t j k r� t } n X| j � } d t | � | f S| j t j | � t j | � t j | � | � } d t | � S( Ni s string-escapes utf-8t restores %s %ss %s ( Ro t encodet decodeRP R^ t UnicodeDecodeErrorR R t redirectRr Rw t AbortR� RR ( R� R� Rs RN Rt Ru R- R| ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyRr s& ' c C s | j d d t d t �S( NR� t uncompressedt untrusted( R� Rz ( Rx ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� 1 s R� c s� t | j � s d Sg } d � y{ | j � } z] | j j d � xF | j j � D]5 \ } } } | rQ | j | | f � � | 7� qQ qQ WWd | j � XWn t j k r� d SX� f d � } t | | | � � � S( s If the server supports streaming clone, it advertises the "stream" capability with a value representing the version and flags of the repo it is serving. Client checks to see if it understands the format. The format is simple: the server writes out a line with the amount of files, then the total amount of bytes to be transferred (separated by a space). Then, for each file, the server first writes the filename and filesize (separated by the null character), then the file contents. s 1 i s scanning Ns 2 c 3 sP d V| j j d t | � � f � d t | � � f V| j } | j } | j j } t | _ y� x� | D]� \ } } | r� | j j d | | f � n d t j | � | f V| d k r� | | � } z | j | � } Wd | j � X| Vqk x( t j | | � d | �D] } | VqWqk WWn t k rB| | _ � n X| | _ d S( s, stream out all metadata files in repository.s 0 s %d files, %d bytes to transfer s %d %d s sending %s (%d bytes) s %s %d i Nt limit( Rx Ry Ro t sopenert mustauditt debugflagRw t storet encodedirt readt closeR t filechunkiterR� ( R� t entriest totalR� t oldauditR� R t sizet fpRV t chunk( t total_bytes( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt streamerS s2 " ( R� Rx t lockRy R� t walkR t releaseR t LockErrorR� ( R� R� R� R� R t enameR� R� ( ( R� s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� 5 s" "R� c sA t | � � � � f d � } | j � | � s; t d � St j d d � \ } } t j | d � } d } z� | j | � � j � } z� | � s� t d � S| j d � t j | d � } y � j | d | j � � } Wn* t j k r} t j j d | � n XWd | j � Xt | � SWd | j � t j | � Xd S( Nc s[ � j � } t j d j t | � � � j � } � d g k pZ � | k pZ � d | g k S( NR� R� R� ( RY R R� R9 R� R� ( RY t heads_hash( R� t their_heads( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt check_heads{ s $s= repository changed while preparing changes - please try againt prefixs hg-unbundle-s wb+i s= repository changed while uploading changes - please try againR� s abort: %s ( R8 R� R� t tempfilet mkstempt ost fdopent getfileR� t seekR� t readbundleR t addchangegroupt _clientR R� R� R� R� R� R� R� t unlink( R� R� RY R t fdt tempnameR� R- R� R� R� ( ( R� R� s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyR� x s0 s cmds *Rm RZ R� s bases headss one two *R� s nodes *Rs RN s namespace key old new(7 R_ R R R� t i18nR t nodeR R R� R� t peerR RP R R� R� t objectR R R R R R8 R: R@ RB RC t peerrepositoryRD R� R� R� R� R� R� R� RE Rl Rb Rf R� R� R� R� RY R� R RM R\ Rr R� R� R� R� ( ( ( s9 /usr/lib64/python2.7/site-packages/mercurial/wireproto.pyt <module> s� 0 < " & � * B .