File: //usr/lib/python2.7/dist-packages/mercurial/wireproto.pyc
x7 _c @@ 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
m Z d d l m
Z
m Z m Z m Z m Z m Z m Z m Z m Z e j Z e j Z e d Z d e f d YZ d
e j f d YZ d e j f d
YZ e j! Z! e j" Z" d d Z# d d Z$ d Z% d Z& d Z' i d d 6d d 6d d 6d d 6d d 6d d 6d d 6Z( 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* Z0 d+ Z1 d, Z2 i Z3 i Z4 d- d. Z5 d/ e4 d0 <e5 d0 d1 d2 Z6 d/ e4 d3 <e5 d3 d4 d5 Z7 d/ e4 d6 <e5 d6 d7 Z8 d/ e4 d8 <e5 d8 d d9 Z9 e5 d: d- d; Z: d< d= d6 d> d? d@ dA d0 g Z; dB Z< d/ e4 dC <e5 dC dD Z= d/ e4 dE <e5 dE dF dG Z d/ e4 d= <e5 d= dH dI Z> d/ e4 dJ <e5 dJ dK dL Z? d/ e4 d@ <e5 d@ dM dN Z@ d/ e4 d <e5 d dO ZA d/ e4 dP <e5 dP dQ ZB d/ e4 d <e5 d dR dS ZC d/ e4 d< <e5 d< dT dU ZD d/ e4 d? <e5 d? dV dW ZE dX e4 d> <e5 d> dY dZ Z d/ e4 d[ <e5 d[ d\ ZF dX e4 d] <e5 d] d d^ ZG d S(_ i ( t absolute_importNi ( t _( t bint hex( t bundle2t changegroupt encodingt errort exchanget peert pushkeyt streamclonet utilsl incompatible Mercurial client; bundle2 required
(see https://www.mercurial-scm.org/wiki/IncompatibleClient)
t abstractserverprotoc B@ s; e Z d Z d Z d Z d Z d Z d Z RS( s^ abstract class that summarizes the protocol API
Used as reference and documentation.
c C@ s
t d S( sa return the value for arguments in <args>
returns a list of values (same order as <args>)N( t NotImplementedError( t selft args( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt getargs/ s c C@ s
t d S( s write the whole content of a file into a file like object
The file is in the form::
(<chunk-size>
<chunk>)+0
chunk size is the ascii version of the int.
N( R ( R t fp( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt getfile5 s c C@ s
t d S( sT may setup interception for stdout and stderr
See also the `restore` method.N( R ( R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt redirect@ s c C@ s
t d S( sm Generator of chunks to send to the client.
Some protocols may have compressed the contents.
N( R ( R t fh( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt groupchunksQ s c C@ s
t d S( s Generator of possible compressed chunks to send to the client.
This is like ``groupchunks()`` except it accepts a generator as
its argument.
N( R ( R t chunks( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt compresschunksX s ( t __name__t
__module__t __doc__R R R R R ( ( ( s7 /usr/lib/python2.7/dist-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 j | | | _ d S( sN remote must support _submitbatch(encbatch) and
_submitone(op, encargs)N( R t batchert __init__t remote( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR b s c C@ s g g } } x | j D] \ } } } } t | j | } t | d d } | d k r | | j | | } t | \ }
} | r | j | |
f | j | | | f q | j |
q | r | j | | g g } } n | j | | | q W| r| j | | n d S( Nt batchable( t callst getattrR t Nonet im_selft nextt appendt sett
_submitreq( R t reqt rspt nameR t optst resreft mtdt batchablefnR t encargsorrest encresref( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt submitg s"
c C@ se | j j | } xL t | | D]; \ } } | \ } } } | j | | j t | q" Wd S( N( R t _submitbatcht zipR' R% ( R R) R* t
encresultst encrest rR R1 R- ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR( { s
( R R R R R2 R( ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR ` s t remoteiterbatcherc B@ s, e Z d Z d Z d Z d Z RS( c C@ s t t | j | | _ d S( N( t superR8 R t _remote( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s c C@ s> t | j | t s( t d | n t t | j | S( Ns/ Attempted to iterbatch non-batchable call to %r( R" R: t Falset AttributeErrorR9 R8 t __getattr__( R R+ ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR= s c C@ s g g } } x | j D] \ } } } } t | j | } | j | j | | } t | \ } }
|
sq t | j | | f | j | |
f q W| r | j j | | _ n | | _
d S( s Break the batch request into many patch calls and pipeline them.
This is mostly valuable over http where request sizes can be
limited, but can be used in other places as well.
N( R! R" R: R R$ R% t AssertionErrorR& R3 t _resultitert _rsp( R R) R* R+ R R, R- R. R R0 R1 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR2 s
c c@ sK xD t j | j | j D]* \ \ } } } | j | t | Vq Wd S( N( t itertoolst izipR@ R? R' R% ( R R R1 R6 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt results s "
( R R R R= R2 RC ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR8 s t c C@ s | r t t | j | Sg S( N( t mapR t split( t lt sep( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt
decodelist s c C@ s5 y | j t t | SWn t k
r0 n Xd S( N( t joinRE R t TypeError( RG RH ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt
encodelist s
c C@ s4 | j d d j d d j d d j d d S( Nt :s :ct ,s :ot ;s :st =s :e( t replace( t plain( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt escapearg s
c C@ s4 | j d d j d d j d d j d d S( Ns :eRP s :sRO s :oRN s :cRM ( RQ ( t escaped( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt unescapearg s
c C@ s| g } xf | D]^ \ } } t d | D s5 t d j d | j D } | j d | | f q
Wd j | S( s; Return a ``cmds`` argument value for the ``batch`` command.c s@ s! | ] } t | | k Vq d S( N( RS ( t .0t k( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pys <genexpr> s RN c s@ s1 | ]' \ } } d t | t | f Vq d S( s %s=%sN( RS ( RV RW t v( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pys <genexpr> s s %s %sRO ( t allR> RJ t iteritemsR& ( R) t cmdst opt argsdictR ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt encodebatchcmds s t nodest headst commont booleant
obsmarkerst scsvt
bundlecapst csvt listkeyst cgt cbattemptedt wirepeerc B@ s e Z d Z d 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 Z d Z d d d d Z d Z d Z d Z d Z d Z d Z RS( s Client-side interface for communicating with a peer repository.
Methods commonly call wire protocol commands of the same name.
See also httppeer.py and sshpeer.py for protocol-specific
implementations of this interface.
c C@ s* | j d r t | St j | Sd S( Nt batch( t capableR R t
localbatch( R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRk s
c c@ s | j d d t | } | j d } | g } x | r x2 d | k rp | rp | j d } | j | q? Wd j | } x3 d | k r | j d d \ } } t | Vq W| j d } | | g } q6 Wt d j | Vd S( sq run batch request <req> on the server
Returns an iterator of the raw responses from the server.
Rk R[ i RO t i N( t _callstreamR^ t readR& RJ RF RU ( R R) R* t chunkt workt mergedt one( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR3 s c C@ s | j | | S( N( t _call( R R\ R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt
_submitone s c C@ s
t | S( N( R8 ( R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt iterbatch s c c@ s | j d t d t } i t j | d 6| f V| j } | d j d d \ } } t | ry t | Vn | j t
j | d S( Nt lookups look up remote revisiont keyiRD i ( t
requirecapR t futureR t fromlocalt valueRF t intR t _abortR t RepoError( R Ry t ft dt successt data( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRx s c c@ sg t } i | f V| j } y t | d VWn0 t k
rb | j t j t d | n Xd S( Nis unexpected response:( R{ R} RI t
ValueErrorR R t
ResponseErrorR ( R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR` s
c c@ s t } i t | d 6| f V| j } y( g | D] } t t | ^ q4 VWn0 t k
r | j t j t d | n Xd S( NR_ s unexpected response:(
R{ RL R} t boolR~ R R R R R ( R R_ R R t b( ( s7 /usr/lib/python2.7/dist-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( NRD i s unexpected response:( R{ R} t
splitlinesRF R t tolocalt urlreqt unquoteRI RK R R R R ( R R R t branchmapt
branchpartt
branchnamet branchheads( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR 1 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 branchesR_ s unexpected response:(
RL Ru R t tupleRI R R R R R ( R R_ t nR R t br( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR A 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 RD t -t betweent pairsc s@ s' | ] } | r t | p g Vq d S( N( RI ( RV RG ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pys <genexpr>Q s s unexpected response:( t xranget lenRJ RL Ru t extendR R R R R R ( R R Rk R7 t it pR R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR J s 6!
'c c@ s* | j d s t d f Vn t } | j j d | | f i t j | d 6t j | d 6t j | d 6t j | d 6| 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( NR
s preparing pushkey for "%s:%s"
t namespaceRy t oldt news
i s" push failed (unexpected response):s remote: ( Rl R; R# R{ t uit debugR R| R} RF R R~ R R R R R t Truet status( R R Ry R R R R t outputRG ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR
V s$
c c@ s | j d s i d f Vn t } | j j d | i t j | d 6| f V| j } | j j d | t | f t j
| Vd S( NR
s preparing listkeys for "%s"
R s$ received listkey for "%s": %i bytes
( Rl R# R{ R R R R| R} R t
pushkeymodt
decodekeys( R R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRg k s c C@ s
| j d S( Nt
stream_out( Ro ( R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR w s c C@ s1 t | } | j d d | } t j | d S( NR t rootst UN( RL t _callcompressablet changegroupmodt cg1unpacker( R R_ t kindR R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR z s c C@ sY | j d t d t | } t | } | j d d | d | } t j | d S( Nt changegroupsubsets look up remote changest basesR` R ( Rz R RL R R R ( R R R` R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s c K@ s | j d t d i } | j d } | d k rJ t | | d <n d } x | j D] \ } } | d k r{ q] n t j | } | d k r t s"t d nw | d k r t | } n\ | d k r d j
| } n> | d k rd
t | } n | d k r"t d | n | | | <q] W| j
d | } t d
| D rkt j | j | St j | d Sd S( Nt getbundles look up remote changesRe t
unexpectedR_ Rf Rd RN Rb s %iRR s unknown getbundle option type %sc s@ s | ] } | j d Vq d S( t HG2N( t
startswith( RV t cap( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pys <genexpr> s R ( ( Rf Rd ( Rz R t getR# t sortedRZ t gboptsmapR; R> RL RJ R t KeyErrorR t anyR t getunbundlerR R R ( R t sourcet kwargsR, Re Ry R} t keytypeR ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s4
c C@ sW | d g k rQ | j d rQ t d t j d j t | j g } n t | } t j | d r&| j d | d | \ } } | d k r t
j t d | n y t
| } Wn) t k
r t
j t d | n Xx` | j t D] } | j j t d
| q Wn- | j d | d | } t j | j | } | 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.
When pushing a bundle10 stream, return an integer indicating the
result of the push (see localrepository.addchangegroup()).
When pushing a bundle20 stream, return a bundle20 stream.
`url` is the url the client thinks it's pushing to, which is
visible to hooks.
t forcet unbundlehasht hashedRn t deltaheadert unbundleR` s push failed:s" push failed (unexpected response):s remote: ( Rl RL t hashlibt sha1RJ R t digestR t safehasattrt _callpushR R R R~ R R R R R t _calltwowaystreamR R ( R Rh R` t urlt retR RG t stream( ( s7 /usr/lib/python2.7/dist-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
debugwireargsRt t two( R# Ru ( R Rt R R R t fiveR, ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s
c K@ s
t d S( s execute <cmd> on the server
The command is expected to return a simple string.
returns the server reply as a string.N( R ( R t cmdR ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRu s c K@ s
t d S( s execute <cmd> on the server
The command is expected to return a stream. Note that if the
command doesn't return a stream, _callstream behaves
differently for ssh and http peers.
returns the server reply as a file like object.
N( R ( R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRo s c K@ s
t d S( sE execute <cmd> on the server
The command is expected to return a stream.
The stream may have been compressed in some implementations. This
function takes care of the decompression. This is the only difference
with _callstream.
returns the server reply as a file like object.
N( R ( R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s c K@ s
t d S( s execute a <cmd> on server
The command is expected to be related to a push. Push has a special
return method.
returns the server reply as a (ret, output) tuple. ret is either
empty (error) or a stringified int.
N( R ( R R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s c K@ s
t d S( sq execute <cmd> on server
The command will send a stream to the server and get a stream in reply.
N( R ( R R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s c C@ s
t d S( sK clearly abort the wire protocol connection and raise the exception
N( R ( R t exception( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s N( R R R Rk R3 Rv Rw R Rx R` R R R R R
Rg R R R R R R# R Ru Ro R R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRj s2
(
t streamresc B@ s e Z d Z d Z RS( s wireproto reply: binary stream
The call was successful and the result is a stream.
Iterate on the `self.gen` attribute to retrieve chunks.
c C@ s
| | _ d S( N( t gen( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s ( R R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s t pushresc B@ s e Z d Z d Z RS( s wireproto reply: success with simple integer return
The call was successful and returned an integer contained in `self.res`.
c C@ s
| | _ d S( N( t res( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s ( R R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s t pusherrc B@ s e Z d Z d Z RS( sh wireproto reply: failure
The call failed. The `self.res` attribute contains the error message.
c C@ s
| | _ d S( N( R ( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR & s ( R R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR ! s t ooberrorc B@ s e Z d Z d Z RS( s wireproto reply: failure of a batch of operation
Something failed during a batch call. The error message is stored in
`self.message`.
c C@ s
| | _ d S( N( t message( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR / s ( R R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR ) s c C@ s
| j d S( s Obtain the repo used for processing wire protocol commands.
The intent of this function is to serve as a monkeypatch point for
extensions that need commands to operate on different repo views under
specialized circumstances.
t served( t filtered( t repot protot command( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt getdispatchrepo2 s c C@ sA t | | | } t | \ } } | j | } | | | | S( N( R t commandsR ( R R R t funct specR ( ( s7 /usr/lib/python2.7/dist-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, warning: %s ignored unexpected arguments %s
RN ( t syst stderrt writeRJ ( R t keyst othersR, RW ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt optionsA s
c C@ s | j } d | j k } | rJ | j d d | d } | d k rJ | Sn | j d d | d } | d k rs | S| r | j d d d } | d k r | Sn | j d d t S( s Whether a bundle1 operation is allowed from the server.
Priority is:
1. server.bundle1gd.<action> (if generaldelta active)
2. server.bundle1.<action>
3. server.bundle1gd (if generaldelta active)
4. server.bundle1
t generaldeltat servers bundle1gd.%ss
bundle1.%st bundle1gdt bundle1N( R t requirementst
configboolR# R ( R t actionR t gdRX ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt bundle1allowedL s
Rn c @ s f d } | S( s# decorator for wire protocol commandc @ s | f t <| S( N( R ( R ( R R+ ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt registers s ( ( R+ R R ( ( R R+ s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt wireprotocommandq s t pullRk s cmds *c C@ s | j d } g } x| j d D]} | j d d \ } } i } xK | j d D]: } | rY | j d \ }
} t | | t |
<qY qY Wt | \ } }
t j | d r | j t j | d n |
r|
j } i } xo | D]g } | d k rMi } x1 | j D]# } | | k r| | | | <qqW| | d <q | | | | <q W| | | g | D] } | | ^ qo } n | | | } t
| t r| S| j t
| q% Wd j | S(
NR RO RD i RN RP t checkpermt pusht *( R RF RU R R R R t permissionsR R t
isinstanceR R& RS RJ ( R R R[ R R t pairR\ R t valst aR RX R R R R RW t starRy t result( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRk z s:
,R R c C@ so g | j d D] } t | d ^ q } g } x. | j | D] } | j t | d qA Wd j | S( NRD R s
Rn ( RF RI R R& RL RJ ( R R R R R7 R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s
+R c C@ sw | j } g } xU | j D]G \ } } t j t j | } t | } | j d | | f q Wd j | S( Ns %s %ss
( R RZ R t quoteR R| RL R& RJ ( R R R R` t branchR_ R t branchnodes( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s R c C@ sP t | } g } x. | j | D] } | j t | d q" Wd j | S( Ns
Rn ( RI R R& RL RJ ( R R R_ R7 R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s
t clonebundlesc C@ s | j j d S( sZ Server command for returning info for available bundles to seed clones.
Clients will parse this response and determine what bundle to fetch.
Extensions may wrap this command to filter or dynamically emit data
depending on the request. e.g. you could advertise URLs for the closest
data center given the client's IP address.
s clonebundles.manifest( t openert tryread( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s
Rx R R
R R R c C@ sR t t } t j | j r | j j d d t rF | j d n | j | j @} | t
d sv | j d q | j d d j t | n | j j d d t
r t j t j | } | j d
t j | n | j d d j t j | j d | j j d d
d | j j d d t rN| j d n | S( s) return a list of capabilities for a repo
This function exists to allow extensions to easily wrap capabilities
computation
- returns a lists: easy to alter
- change done here will be propagated to both `capabilities` and `hello`
command without any other action needed.
R t preferuncompresseds stream-preferredt revlogv1R s
streamreqs=%sRN t experimentals bundle2-advertises bundle2=s unbundle=%ss
httpheader=%dt maxhttpheaderleni t httppostargs( R ( t listt
wireprotocapsR t allowservergenerationR R R; R& R t supportedformatsR' RJ R R R t
encodecapst getrepocapsR R t bundlepriorityt configint( R R t capst requiredformatst capsblob( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt
_capabilities s" # t capabilitiesc C@ s d j t | | S( NRD ( RJ R ( R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s R R c C@ s4 t | } t j | | d } t | j | S( Nt serve( RI R R R R ( R R R R_ Rh ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s s bases headsc C@ sC t | } t | } t j | | | d } t | j | S( NR ( RI R R R R ( R R R R` Rh ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s R s one two *c C@ s+ t d d d g | } | j | | | S( NR R R ( R R ( R R Rt R R R, ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s R c C@ sa t d t j | } x | j D] \ } } t | } | d k rZ t | | | <q% | d k r t | j d | | <q% | d k r t | j d | | <q% | d k r | d k r t | | <qt | | | <q% | d k r% t
d | q% q% Wt | d
s9t j
| j d s9t t Sn t j | d | } t | j | S(
NR R_ Rf RN Rd Rb t 0RR s unknown getbundle option type %sR Re R ( R R R RZ RI R RF R' R; R R R R t bundle2requestedR R t bundle2requiredt getbundlechunksR R ( R R R R, RW RX R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s*
c C@ s | j } t | d S( Ns
( R` RL ( R R t h( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR` - 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 ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR 3 s R c C@ s1 | j t j | j } t j t | S( N( Rg R R t itemsR t
encodekeysR ( R R R R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRg ? s Ry c C@ se y/ t j | } | | } | j } d } Wn% t k
rV } t | } d } n Xd | | f S( Ni i s %s %s
( R R R t Exceptiont str( R R Ry RW t cR7 R t inst( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyRx E s
s nodes *c C@ s& d j d | j t | D S( NRn c s@ s! | ] } | r d p d Vq d S( t 1R N( ( RV R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pys <genexpr>T s ( RJ R RI ( R R R_ R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR R s R s namespace key old newc 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
( R t encodet decodeR R t UnicodeDecodeErrorR R R R
R; R t AbortR' R~ ( R R R Ry R R R7 R ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR
W s& '
R c C@ s^ t j | j s d Sd } y# t j | } t | | SWn t j k
rY d SXd 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.
s 1
c s@ s d Vx | D] } | Vq Wd S( Ns 0
( ( t itRq ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt getstream s
s 2
N( R R R t generatev1wireprotoR R t LockError( R R R- R, ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR x s R c C@ s t | } y| j t j | | d t j d d \ } } t j | d } d } z | j | | j d t j
| j | d } t
| t j r t | d r t t St j | | | d | j } t j | d r t | j St | SWd | j t j | XWnRt j t j t j f k
r{} t | d t! sy Wqt j k
rt" j# j$ d
| t d St j k
rt% t& | SXn t' j( | j }
x' t | d d D] } |
j) | qWyYy WnKt j* k
rL} t | d d } | d k rPd
| j+ d d k rP n |
j, d }
|
j- d | j. | j/ d k r|
j- d | j/ d t! n | j0 d k r|
j- d | j0 d t! n | j1 d k r|
j- d | j1 d t! n | j2 d k r |
j- d | j2 d t! n | j3 d k rM|
j- d | j3 d t! qMn XWnt j k
r} |
j, d } | j4 d k r| j- d | j4 n | j5 rk| j- d d j6 | j5 qkn t j k
r6} d t& | f g } g } | j7 d k r| j8 d | j7 f n |
j) t' j9 d | | n5 t j k
rj} |
j, d d t& | f g n Xt |
j SXd S(! Ns preparing changest prefixs hg-unbundle-s wb+i R R t addpartt duringunbundle2s
abort: %s
t _bundle2salvagedoutputt
_replycapsR
R s
error:pushkeys in-reply-toR t mandatoryRy R R R s error:unsupportedcontentt parttypet paramss R t hints error:aborts error:pushraced( ( (: RI R R t check_headst tempfilet mkstempt ost fdopenR t seekt
readbundleR R# R R R R R R R t _clientR R R t getchunksR t closet unlinkR t BundleValueErrorR+ t PushRacedR" R; R R R R R# R t bundle20R1 t
PushkeyFailedR t newpartt addparamt partidR Ry R R R R6 R7 RJ R8 R& t
bundlepart( R R R` t their_headst fdt tempnameR R7 R t exct bundlert outt
remotecapst partt errpartt manargst advargs( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyR s
!
$ "#(H t
__future__R R RA R< R R: t i18nR t nodeR R Rn R R R R R R R R
R R R t urlerrR R t objectR
R R t iterbatcherR8 R R{ RI RL RS RU R^ R t peerrepositoryRj R R R R R R R R R R R Rk R R R R R
R R R R R R` R Rg Rx R R R ( ( ( s7 /usr/lib/python2.7/dist-packages/mercurial/wireproto.pyt <module> s @ 7"%
&
+
"