�
�Xc@@s^dd
lm
Z

ddlZddlZddlZddlZddlmZ
ddlm	Z	m
Z
mZ
ddlm
Z
mZmZmZmZmZmZ
dZdZd	Zd
�Zd�Zd�Zd
�Zd�Zed�
Zdef
d��YZdef
d��YZ de f
d��YZ!def
d��YZ"def
d��YZ#de#f
d��YZ$de$f
d��YZ%ie#efd6e$e fd6e%e!fd 6Z&d!�Z'd"�Z(d#�Z)d$�Z*ed%�
Z+ed&�
Z,d'�Z-e.d(�
Z/e.d)�
Z0dd*�
Z1edd+�Z2edd,�Z3edd-�Z4d.�Z5d/�Z6dS(0i(
tabsolute_importNi
(
t
_(thextnullrevtshort(t	branchmaptdagutilt	discoveryterrortmdifftphasestutilt20s20s20s20st20s20s20s20s20ss>20s20s20s20s20sHcC@sM|j|
�
}t
|�
|
krItjtd
�
t
|�
|
f�
�
n|S(s=read n bytes from stream.read and abort if less was availables5stream ended unexpectedly (got %d bytes, expected %d)(treadtlenRtAbortR
(tstreamt
nt
s((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytreadexactly$s



c
C@sht|d
�}
t
jd|
�d}|d
k
rW|rStjtd�
|�
�
ndSt||d
�S(s-return the next chunk from stream as a stringis>lisinvalid chunk length %dt(RtstructtunpackRRR
(Rt
dt
l((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetchunk-s





c

C@stj
d
|d�S(s*return a changegroup chunk header (string)s>li(Rtpack(
tlength((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytchunkheader7scC@stj
d
d�S(sBreturn a changegroup chunk header (string) for a zero-length chunks>li(RR(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
closechunk;sc
C@s�d
}
d}x^|D]V}|d
kr/d
}Pn|dkrL|
|d7}
q|dkr|
|d7}
qqW|
d
kr�d|
}n|
d
kr�d|
}n|S(s:logic to combine 0 or more addchangegroup results into oneii
i����((tresultstchangedheadstresulttret((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytcombineresults?s















cC@s�d}d}z�|rE|r0|j
|d
�}qut
|d
d�}n0tjdddd�\}}tj|d
�}|}x|
D]}|j|�

q�Wd}|SWd|dk	r�|j�
n|dk	r�|r�|r�|j|�

q�tj|�

nXdS(s�Write chunks to a file and return its filename.

    The stream is assumed to be a bundle file.
    Existing files will not be overwritten.
    If no filename is specified, a temporary file is created.
    twbitprefixs
hg-bundle-tsuffixs.hgN(	tNonetopenttempfiletmkstemptostfdopentwritetclosetunlink(tuitchunkstfilenametvfstfhtcleanuptfdt
c((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytwritechunksRs(
















tcg1unpackercB@s�eZ
dZeZeje�
Zd
ZdZ	dd�
Zd�Zd�Z
d�Zd�Zd�Zd	�Zd
�Zd�Zd�Zd
�Zd�Zd�Zd�Zeejdd�ZRS(s�Unpacker for cg1 changegroup streams.

    A changegroup unpacker handles the framing of the revision data in
    the wire format. Most consumers will want to use the apply()
    method to add the changes from the changegroup to a repository.

    If you're forwarding a changegroup unmodified to another consumer,
    use getchunks(), which returns an iterator of changegroup
    chunks. This is mostly useful for cases where you need to know the
    data stream has ended by observing the end of the changegroup.

    deltachunk() is useful only if you're applying delta data. Most
    consumers should prefer apply() instead.

    A few other public methods exist. Those are used only for
    bundlerepo and some debug commands - their use is discouraged.
    t01i
cC@s�|d
krd}n|t
jkr@tjtd�
|�
�
n|dkrUd}nt
j||
�
|_||_|p}i|_d|_	dS(NtUNs#unknown stream compression type: %stBZt_truncatedBZ(
R'Rt
decompressorsRRR
t_streamt_typetextrastcallback(tselfR4talgRA((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt__init__�s

	





	

	

c

C@s
|jdk	S(
N(R@R'(
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
compressed�s
cC@s|jj
|
�
S(
N(R?R(RCR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR�s
cC@s|jj
|
�
S(
N(R?tseek(RCtpos((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRG�s
c


C@s
|jj
�S(
N(R?ttell(
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRI�s
c


C@s
|jj
�S(
N(R?R.(
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR.�s
c
C@sxt|j
d
�}
tjd|
�d}|d
k
rZ|rVtjtd�
|�
�
ndS|jrp|j�
n|d
S(Nis>lisinvalid chunk length %d(RR?RRRRR
RB(RCRR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_chunklength�s






	


c


C@siS(
s*v10 does not have a changelog header chunk((
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytchangelogheader�sc


C@siS(
s)v10 does not have a manifest header chunk((
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytmanifestheader�sc
C@s3|j�}
|
siSt
|j|
�}i
|d
6S(sBreturn the header of the filelogs chunk, v10 only has the filenameR2(RJRR?(RCRtfname((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
filelogheader�s




c	C@sI|
\}}}}|dkr'|}n|}d
}||||||fS(Ni(
R'(	RCtheadertupletprevnodetnodetp1tp2tcst	deltabasetflags((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_deltaheader�s


	

cC@s�|j�}|siSt
|j|j�}tj|j|�}t
|j||j�}|j||
�\}}}}	}
}i|d
6|d6|d6|
d6|	d6|d6|d6S(NRQRRRSRTRUtdeltaRV(RJRR?tdeltaheadersizeRRtdeltaheaderRW(RCRPRt
headerdatatheaderRXRQRRRSRURTRV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
deltachunk�s






$

c
c@s�d
}
d
}x�||jkr�t
}|
d7}
x�t
r�t|�
}|sl|rh|
dkrh|d7}nPnt}tt|�
�
V
d
}x2|t|�
kr�|d}|||!V
|}q�Wq1Wt�V
qWdS(s"
returns all the chunks contains in the bundle

        Used when you need to forward the binary stream to a file or another
        network API. To do so, it parse the changegroup data, otherwise it will
        block in case of sshrepo because it don't know the end of the stream.
        ii
iiNi(t_grouplistcounttTrueRtFalseRRR(RCtcountt
emptycounttemptytchunkRHtnext((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt	getchunks�s&





	














cC@s^|td
�
|�|_
|j�
|
jj|||�
|
jjtd
�
d�
d|_
dS(Nt	manifests(R
RBRLtmanifesttaddgroupR0tprogressR'(RCtrepotrevmapttrptprogt
numchanges((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_unpackmanifests�s




c @s��j���
�fd
�}�
f
d�}d}	}
}z��j
dj|tj|�
g�
�
�[}|jjd|�}|jjd|�}�jddt|j�


�j	�
�
j
|�

�
j��tj
|�
}
�jjtd	�
�

t�
�
�d
tf
�f
d��Y}|td�
|�|_t���f
d
�}|j�
�
j|||
d|�
}t��
�|p�
|s�
tjtd�
�
�
nt�
�
}|�}	�jjtd�
d$�
d$|_�jjtd�
�

|j�||
||	�
i}�jjdddt�
r�x�t�|�D]t}�j	j�j	j |�
�
d}�j!|j"�}x6|j#�D](\}}|j|t��j$|�

qWq7Wn�jjtd�
�

t%�|||
�|�\}}||7}|
|7}
d}�rh�
j�}t|�
t��
}x:|D]/}|�kr2�|j&�r2|d8}q2q2Wnd}|r�td�
|}n�jjtd�
|	||
|f�

�j'�
|	dkr~d|jkr t(�
j ��
�
|jd<t(�
j |d�
�
|jd<t)|j�
�nEt)|j�
�t(�
j ��
�
�d<t(�
j |d�
�
�d<�jddt��


ngt�|�D]}�
j |�
^q���j*�}|d%kr|r�t+j,�|t+j-|�
q=t+j,�|t+j.|�
t+j/�|t+j.��
n%|dkr=t+j/�||��
n|	dkr�|dkr~�jj0d�

t1j2�j3d �
�

n�����fd!��|j4d"���fd#��
nWd$QXWd$�jj5�
X|dkr�|dS|dSd$S(&s�
Add the changegroup returned by source.read() to this repo.
        srctype is a string like 'push', 'pull', or 'unbundle'.  url is
        the URL of the repo where this changegroup is coming from.

        Return an integer summarizing the change to this repo:
        - nothing changed or no source: 0
        - more heads than before: 1+added heads (2..n)
        - fewer heads than before: -1-removed heads (-2..-n)
        - number of heads stays the same: 1
        c

@s$�
jj
d
t|�
�

t��
S(Nsadd changeset %s
(R0tdebugRR(
t
x(tclRk(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytcsmap
s

c

@s
�j|�
S(
N(
trev(
Rr(
Rs(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRl
s
is

tsourceturltprechangegrouptthrowsadding changesets
Rnc@s eZ
d�Z�f
d
�ZRS(cS@s|
|_||_
d
|_dS(Ni
(t_stept_totalt_count(RCtstepttotal((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRE-
s
	
	
c

@sA�jj
|j|jd
td�
d|j�
|jd7_dS(NtunitR1R~i
(R0RjRzR|R
R{(
RC(
Rk(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt__call__1
s


(t__name__t
__module__RER�((
Rk(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRn,
s
	t
changesetsc@s�j|j
|
�
�

dS(
N(tupdatet	readfiles(RsRQ(
tefiles(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytonchangelog8
s
t
addrevisioncbs!received changelog group is emptysadding manifests
tservertvalidatetdefaultsadding file changes
i
Rs (%+d heads)s2added %d changesets with %d changes to %d files%s
RQt	node_lasttpretxnchangegrouptpushtservetstripsupdating the branch cache
tservedc
@s��
t��
krdS�j
d
��

xA�D]9}�j�}
t|�
|
d<|
d=�j
d|
�

q-Wg�j�D]}|�krw|^qw}�jjddt��
djg|D]}t|d �
^q��
�
dS(NtchangegroupRQR�tincomings$%s incoming changes - new heads: %s
s, i(RthooktcopyRtheadsR0tlogtjoin(Rtargst
htnewheadsR7(taddedtclstartthookargstoldheadsRk(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytrunhooks�
s









	
schangegroup-runhooks-%020ic

@s
�j�
�
S(
N(
t
_afterlock(
ttr(RkR�(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt<lambda>�
sN(R�R�(6t
unfilteredttransactionR�RthidepasswordR�t
setdefaultR�R_t	changelogtdelayupdateR�tweakreftproxyR0tstatusR
RtobjectRBtsetRKRiRRRjR'Rpt
configboolR`txrangeRRQtmanifestlogt	readdeltat	iteritemstaddt_addchangegroupfilestclosesbranchtinvalidatevolatilesetsRtdictt
publishingR
tadvanceboundarytpublictdrafttretractboundaryRqRtupdatecachetfilteredtaddpostclosetflush( RCRktsrctypeRwtemptyokttargetphaset
expectedtotalRtRlR�tfilest	revisionsR�RmRnR�t
srccontenttclendt	needfilestcsettmfnodetmfestt
fRtnewrevstnewfilestdhR�R�thtextt
rR�((R�RsR�R�R�R�RkR�s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytapply

s�




	




		



	






	


	


'




















 



+











 
N(R�R�t__doc__t_CHANGEGROUPV1_DELTA_HEADERRZRtcalcsizeRYtversionR^R'RERFRRGRIR.RJRKRLRNRWR]RfRpR`R
R�R�(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR9ts*



													 	

tcg2unpackercB@s2eZ
dZeZeje�
Zd
Zd�Z	RS(s�Unpacker for cg2 streams.

    cg2 streams add support for generaldelta, so the delta header
    format is slightly different. All other features about the data
    remain the same.
    t02c	C@s1|
\}}}}}d
}||||||fS(Ni((	RCRORPRQRRRSRURTRV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRW�
s


(
R�R�R�t_CHANGEGROUPV2_DELTA_HEADERRZRR�RYR�RW(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��
s



tcg3unpackercB@sAeZ
dZeZeje�
Zd
ZdZ	d�Z
d�ZRS(s�Unpacker for cg3 streams.

    cg3 streams add support for exchanging treemanifests and revlog
    flags. It adds the revlog flags to the delta header and an empty chunk
    separating manifests and files.
    t03ic	C@s.|
\}}}}}}||||||fS(
N((	RCRORPRQRRRSRURTRV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRW�
s

c	C@s�tt
|�j|
||||�
xwt|ji�D]c}|d
}|
jjd|�

|
jj|�
}|j	|||�s5t
jtd�
�
�
q5q5WdS(NR2sadding %s revisions
s"received dir revlog group is empty(
tsuperR�RptiterRNR0RqRhtdirlogRiRRR
(	RCRkRlRmRnRot	chunkdataRR�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRp�
s







(R�R�R�t_CHANGEGROUPV3_DELTA_HEADERRZRR�RYR�R^RWRp(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��
s



	theaderlessfixupc
B@seZ
d�Zd
�ZRS(cC@s||_|
|_
dS(
N(t_ht_fh(RCR4R�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRE�
s
	
cC@sp|jr`|j|
 |j|
}|_t
|�
|
kr\|t|j|
t
|�
�7}n|St|j|
�S(
N(R�RRR�(RCRR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR�
s
	


#

(R�R�RER(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��
s
	t	cg1packercB@s�eZ
eZdZdd
�
Zd�Zd�Zd�Z	dd�
Z
d�Zd�Zd�Z
d	�Zd
�Zd�Zd�Zd
�Zd�ZRS(R:cC@s�|dkrt
�}n||_|
jjd
dd�}|dkrNd}ntj|�
}|
|_||_|
jj	|_
|jjjr�|jjjr�|jjj
|_nd�|_dS(s�Given a source repo, construct a bundler.

        bundlecaps is optional and can be used to specify the set of
        capabilities which can be used to build the bundle.
        tbundletreordertautoc


S@sdS(
N(
R'(
R((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR�sN(R'R�t_bundlecapsR0tconfigRt	parseboolt_repot_reorderRjt	_progresstverboset	debugflagtnotet_verbosenote(RCRkt
bundlecapsR�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRE�
s

	

	
	
	


c


C@st�S(
N(
R(
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR.
s
cC@stt
|
�
�
|
S(
N(RR(RCRM((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
fileheaders
c@s}�jr|j
dks!|j
rStj��
}|jt�f
d
�|D�
�
�
Stg|D]}�j|�
^q]�
SdS(s7Sort nodes for change group and turn them into revnums.c
3@s|]}
�j|
�
V
qdS(
N(
Ru(t.0R(
trevlog(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pys	<genexpr>sN(	t
_generaldeltaR�R'Rt	revlogdagt	linearizeR�tsortedRu(RCR�tnodelisttlookuptdagR((
R�s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
_sortgroups!

#cc@sM
t|
�
d
kr!|j
�V
dS|j||
|�}|j|d
�
d
}|jd
|�
t|�
d}td�
}x�tt|�
d�
D]�}	|dk	r�|j||	dd|d|�
n||	||	d}
}||j	|�
�
}x%|j
|||
|�D]}
|
V
q
Wq�W|dk	r>
|j|d�
n|j
�V
dS(spCalculate a delta group, yielding a sequence of changegroup chunks
        (strings).

        Given a list of changeset revs, return a set of deltas and
        metadata corresponding to nodes. The first delta is
        first parent(nodelist[0]) -> nodelist[0], the receiver is
        guaranteed to have this parent as it has all history before
        these changesets. In the case firstparent is nullrev the
        changegroup starts with a full revision.

        If units is not None, progress detail will be generated, units specifies
        the type of revlog that is touched (changelog, manifest, etc.).
        iNi
tbundlingRR~(RR.R�t
parentrevstinsertR
R�R'R�RQtrevchunk(RCR�R�R�tunitstrevst
pR~tmsgbundlingR�tprevtcurrtlinknodeR7((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgroups$






#






cC@sB|
j|
j
}}g|D]$}|||�
�
|kr|^qS(
N(Rutlinkrev(RCR�tmissingt
commonrevstrrtrlR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytpruneGs

cc@sH|
s
t�
x4|j
||jj|d
td�
�
D]}|V
q5WdS(s.Pack flat manifests into a changegroup stream.R
RgN(tAssertionErrorR
R�RhR
(RCtdirtmfnodestlookuplinknodeRd((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_packmanifestsKs



c


C@sd
S(NR((
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_manifestsdoneRs
c
#@s�
|j}|j
�
i�i�i�t����
��fd
�}|jtd�
�

d}x>|j|�
|dtd�
�
D]}|t|�
7}|V
q�W|jtd�
|�

|o�|j}|o�d|jk}x(|j	|
�|���D]}|V
q�W�j
�
t�
f
d�|D�
�
�|sD
�f
d	�}	n�
j���fd
�}	x%|j�|	|
|�D]}|V
qx
W|j
�V
|r�
|jddt|d�
d
|�

ndS(s0yield a sequence of changegroup chunks (strings)c
@sN�
j|�
}
t
��
�|<|
d
}�j||�
�j|
d�

|S(Nii(RRR�R�(RrR7R(tchangedfilesRst
clrevordertmfs(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytlookupclbs




s%uncompressed size of bundle content:
iR
R�s%8.i (changelog)
ttreemanifestc
3@s|]}
�j|
�
V
qdS(
N(
Ru(R�Rr(
Rs(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pys	<genexpr>�sc@s�j|
i�S(
N(
tget(tunusedRM(
tfnodes(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt	linknodes�s
c@sH|j�
|j
��
f
d
�|D�
}t���fd�|D�
�
S(Nc
3@s!|]}
|
�|
�
fV
qdS(
N((R�R�(
tllr(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pys	<genexpr>�sc
3@s9|]/\}
}|�
kr�|
�
�|�
fV
qdS(
N((R�R�tlr(tclntclrevstfln(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pys	<genexpr>�s(R
RQR�(t
filerevlogRMR
(R#
R$
(R%
R!
s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR 
�s
	
	

toutgoingRQRvN(R�R�R�R�R
R
RR�trequirementstgeneratemanifeststclearRQt
generatefilesR.R�R(
RCR
tclnodestfastpathlinkrevRvRkR
tsizeRdR 
((R
RsR#
R
R$
R
R
s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgenerateUs>	
	


	

(

	



	



	



	
c
#@s�|j}|j
j�
i
�d
6���
����fd�}d}x��r�t��
}	�|	}
|j�
|	�
|
|
�}|	s�|r�x;|j|	|||	�
�D]}|t|�
7}|V
q�Wn�|	=qIW|jtd�
|�

|j	�V
dS(NRc
@s9�r�st�
�j
S�
����fd
�}
|
S(Nc
@s���
|}
��
�
j|�
}x�|j
�D]�\}}}|d
kr��
|d}�j|i�}|j||
�}�|
�|kr�|
||<q�q0�
|}	�j|	i�}
|
j||
�}�|
�|kr0|
|
|<q0q0W|
S(sPCallback for looking up the linknode for manifests.

                Returns the linkrev node for the specified manifest.

                SIDE EFFECT:

                1) fclnodes gets populated with the list of relevant
                   file nodes if we're not using fastpathlinkrev
                2) When treemanifests are in use, collects treemanifest nodes
                   to send

                Note that this means manifests must be completely sent to
                the client before you can trust the list of files and
                treemanifests to send.
                t
tt
/(treadshallowfasttiterentriesR�(RrtclnodetmdataR
Rtfltsubdirt
tmfclnodest	tmfclnodeR�tfclnodestfclnode(R
R
R�R
ttmfnodes(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytlookupmflinknode�s













(R
t__getitem__(R
R=
(R
R�R-
R
R
R<
(
R
s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytmakelookupmflinknode�s




 is%8.i (manifests)
(
R�RhR�tminR
R
RR�R
R
(
RCR
R
R-
R
R
RkR?
R.
R
tnodestprunednodesRr((R
R�R-
R
R
R<
s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR)
�s"	


'
	












c
#@sl
|j}|j
}td
�
}t|
�
}td�
}	x"
tt|
�
�
D]
\}
}|j|�
}|s�tjtd�
|�
�
n|||���f
d�}
|j	|�|�}|rI|||
dd|d|	d|�
|j
|�
}t|�
}|V
x2|j|||
�D]}|t|�
7}|V
q
W|jtd	�
||f�

qIqIW||d�
dS(
NR
R�sempty or missing revlog for %sc

@s�|S(
N((
Rr(
tlinkrevnodes(s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
lookupfilelog�s
i
titemRR~s	%8.i  %s
(R�R�R
Rt	enumerateR�tfileRRR
R�R
R�R'(RCR
R 
R
RvRkRjR
R~tmsgfilest
iRMR&
RD
t	filenodesR�R.
Rd((
RC
s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR+
�s.
	
	













	
$
c
C@s|S(
N((RCR�RuRRRSR
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytdeltaparents
cc@s�
|
j|�
}|
j
|�
\}}|j|
||||�}d
}	|
j|�
sc|
j|�
r�y|
j|�
}
Wntjk
r�
}
|j}
n
X|tkr�t	j
t|
�
�
}	q+
|
j|�
}t	j
|t|
�
�}	nE|tkr
|
j|�
}
t	j
t|
�
�
}	n|
j||�}
|
j|�
\}
}|
j|�
}|
j|�
}|j||
||||�}||	7}t|�
t|
�
}t|�
V
|V
|
V
dS(NR(RQR

RK
t
iscensoredtrevisionRtCensoredNodeErrort	tombstoneRR	ttrivialdiffheaderRtrawsizetreplacediffheadertrevdifftparentsRVtbuilddeltaheaderR(RCR�RuR
R

RQRRRStbaseR%RXt
etbaselentp1ntp2ntbasenodeRVtmetaR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR
s4
























cC@stj
|j|
|||�S(
N(RRRZ(RCRQRY
RZ
R[
R

RV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRU
$sN(R�R�R�RZR�R'RER.R�R�R
R
R
R
R/
R)
R+
RK
R
RU
(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��
s 


			
)				O	?	 		t	cg2packercB@s2eZ
dZeZdd
�
Zd�Zd�ZRS(R�cC@s8tt
|�j|
|�
|jdkr4t|_ndS(
N(R�R]
RER�R'R`(RCRkR�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRE-s

cC@sY|
j|�
}|t
kr(|
jr(|S|t
kr8t
S||||fkrQ|S|SdS(
N(RK
Rtstoredeltachains(RCR�RuRRRSR
tdp((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRK
5s



cC@stj
|j|
||||�S(
N(RRRZ(RCRQRY
RZ
R[
R

RV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRU
JsN(	R�R�R�R�RZR'RERK
RU
(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR]
)s


	t	cg3packerc
B@s/eZ
dZeZd
�Zd�Zd�ZRS(R�cc@s[|
r|j|
�
V
nx=|j
||jjj|
�
|d
td�
�
D]}|V
qHWdS(NR
Rg(R�R
R�RhR�R
(RCR
R
R
Rd((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR
Rs





c


C@s
|j�S(
N(
R.(
RC((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR
Ys
cC@s"tj
|j|
|||||�S(
N(RRRZ(RCRQRY
RZ
R[
R

RV((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyRU
\s

(R�R�R�R�RZR
R
RU
(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR`
Ns


		R:R�R�c
C@sWtt
j��
}
|
jd
�

|jdd�sC|jdd�rS|
jd
�

n|
S(NR�texperimentaltchangegroup3R
(R�t
_packermaptkeystdiscardR�R�(R0tversions((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytallsupportedversionsgs






c
C@s2t|j
�
}
d
|jkr.|
jd�

n|
S(NR
R�(Rg
R0R(
R�(RkRf
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytsupportedincomingversionsps



c
C@sLt|j
�
}
d
|jkrH|
jd�

|
jd�

|
jd�

n|
S(NR
R:R�R�(Rg
R0R(
Re
R�(RkRf
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytsupportedoutgoingversionsws






c
C@sAt|�
}
d
|j
kr+|
jd�

n|
s7t�
t|
�
S(NtgeneraldeltaR:(Ri
R(
Re
R
R@
(RkRf
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytsafeversion�s




cC@s-|t|
�
kst
�
t|d
|
|�S(Ni(Ri
R
Rc
(R�RkR�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt
getbundler�s

cC@st|d
|
|d|�
S(Ni
RA(
Rc
(R�R4RDRA((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetunbundler�s
cC@s�|jj
s|d
kr;|jjtd�
t|
�
�

n|jjr�|jjd�

x+|
D] }|jjdt|�
�

q^WndS(NR�s%d changesets found
slist of changesets:
s%s
(R0R�R�R
RR�RqR(RkRA
RvRQ((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt_changegroupinfo�s

#




c	C@s�|j�}|
j
}|
j}|
j}|j�
|p[|jdko[|t|j��
k}|j	d
dt
d|�

t|||�
|j||||�S(NtpreoutgoingRyRv(
R�tcommonR

tmissingheadstsortt
filternameR'R�R�R�R_Rn
R/
(	RkR'
tbundlerRvtfastpathR
tcsetsR�R-
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetsubsetraw�s

	
	
	


'

cC@sGt||
|||�}t
|jtj|�
di
t|
j�
d
6�S(Ntclcount(Rw
Rm
R�RtchunkbufferR'RR

(RkR'
Rt
RvRu
tgengroup((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt	getsubset�s


cC@s=tj
|d
|
d|�
}t||�}t||||�S(sCompute a changegroup consisting of all the nodes that are
    descendants of any of the roots and ancestors of any of the heads.
    Return a chunkbuffer object whose read() method will return
    successive changegroup chunks.

    It is fairly complex as determining which filenodes and which
    manifest nodes need to be included for the changeset to be complete
    is non-trivial.

    Another wrinkle is doing the reverse, figuring out which changeset in
    the changegroup a particular filenode or manifestnode belongs to.
    tmissingrootsRq
(RR'
Rl
R{
(RktrootsR�RvR�R'
Rt
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytchangegroupsubset�s


cC@s2|js
d
St|||�}t||||
�S(s�Like getbundle, but taking a discovery.outgoing as an argument.

    This is only implemented for local repos and reuses potentially
    precomputed sets in outgoing. Returns a raw changegroup generator.N(R

R'Rl
Rw
(RkRvR'
R�R�Rt
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetlocalchangegroupraw�s	


cC@s2|js
d
St|||�}t||||
�S(s�Like getbundle, but taking a discovery.outgoing as an argument.

    This is only implemented for local repos and reuses potentially
    precomputed sets in outgoing.N(R

R'Rl
R{
(RkRvR'
R�R�Rt
((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetlocalchangegroup�s	


cC@st||
|d
|d|�S(s6
Like changegroupsubset, but returns the set difference between the
    ancestors of heads and the ancestors common.

    If heads is None, use the local heads. If common is None, use [nullid].

    The nodes in common might not all be known locally due to the way the
    current discovery protocol works.
    R�R�(
R�
(RkRvR'
R�R�((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pytgetchangegroup�s

cC@st||
|j
�|�S(
N(R~
R�(Rkt	basenodesRv((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��scC@sDd
}d
}x�
t|
j
i�D]t
}|d7}|d}	|jjd|	�

|jjtd�
|dtd�
d|�
|j|	�
}
t|
�
}y1|
j|
||�s�t	j
td�
�
�
nWn/t	jk
r�
}
t	j
td	�
|�
�
n
X|t|
�
|7}|	|kr||	}
x]t|t|
�
�D]F}|
j
|�
}||
krg
|
j|�

q6
t	j
td
�
�
�
q6
W|
s�
||	=q�
qqW|jjtd�
d�
x�|j�D]y\}	}
|j|	�
}
x[|
D]S}y|
j|�

Wq�
t	jk
r1


t	j
td�
|	t|�
f�
�
q�
Xq�
Wq�
W||fS(Nii
R2sadding %s revisions
R�RR~s#received file revlog group is emptys#received delta base is censored: %ss#received spurious file revlog entrys+missing file data for %s:%s - run hg verify(R�RNR0RqRjR
RG
RRiRRtCensoredBaseErrorR�RQtremoveR'R�RutLookupErrorR(RkRvRlRmt
expectedfilesR�R�R�R�R�R6
t
oRW
tneedstnewR((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyR��sJ








$



























	
"(7t
__future__RR+RR)R�ti18nR
RQRRRRRRRRR	R
RR�R�R�RRRRR#R'R8R�R9R�R�R�R�R]
R`
Rc
Rg
Rh
Ri
Rk
Rl
Rm
Rn
R`Rw
R{
R~
R
R�
R�
R�R�(((s9/usr/lib/python2.7/dist-packages/mercurial/changegroup.pyt<module>s\



4


			
			"�H�8%