�
�Xc@@s�
dZd
dl
mZ
d
dlZd
dlZd
dlZddlmZ
ddlm	Z	
ddl
mZmZm
Z
mZmZmZmZmZmZmZmZmZmZmZmZmZmZ
dejf
d	��YZd
ee
j
fd��YZdeejfd
��YZdeejfd��YZdej f
d��YZ!dej"f
d��YZ#d�Z$dej%f
d��YZ&d�Z'de(f
d��YZ)dde+d�Z,dS(s�Repository class for viewing uncompressed bundles.

This provides a read-only repository interface to bundles as if they
were part of the actual repository.
i(
tabsolute_importNi
(
t
_(
tnullid(tbundle2tchangegroupt	changelogtcmdutilt	discoveryterrortexchangetfilelogt	localrepotmanifesttmdifftnodetpathutiltphasestrevlogtscmutiltutiltbundlerevlogcB@sbeZ
d�Zd
�Zd�Zd�Zd�Zd	d	d	d�Zd�Z	d�Z
d�ZRS(
c	@stj
|
�
}
tjj||
|�
�|_t|�
}|d
|_d�
t�|_	��
fd�}x�
t
|i�D]�
}|d}|d}	|d}
|d}|d}|d}
t|
�
}�j�|}||�
}||jkr
|�
|j	j
|j|�

q{nxD|	|
fD]6}||jkr$
tj||jtd	�
��
q$
q$
W||jkr�
t||jtd
�
��
n|j|�
}tj|d�|d|||j|	�
|j|
�
|f}|jjd|�
||j|<|j	j
|�

|�
|d
7}q{WdS(
Ni
c@s
�j�
�
S(
N(
t
deltachunk((tbundletchain(s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt<lambda>;sRtp1tp2tcst	deltabasetdeltasunknown parentsunknown delta baseii����(RtreadonlyvfsRt__init__Rtlent
repotiprevtNonetsett
bundlerevstiterttelltnodemaptaddRtLookupErrort	indexfileR
trevtoffset_typetindextinsert(tselftopenerR*Rt
linkmappert
ntgetchunkt	chunkdataRRRRRRtsizetstarttlinkt
ptbaserevt
e((RRs8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR,sJ

	




























!





cC@sT|
|jk
r"t
j
j||
�S|jj|j|
�
�

|jj|j|
�
�
S(
N(R!Rt_chunkRtseekR6treadtlength(R/R+((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR;as


cC@s�|
|jkrK||jkrK|j
|d
}||
kr|j|�
Sn4|
|jk
r||jk
rtjj||
|�Stj|j|j|
�
�
|j|j|�
�
�S(s1return or calculate a delta between two revisionsi(	R!R-R;RtrevdiffR
ttextdifftrevisionR(R/trev1trev2trevb((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR?js




cC@s=
t|
t
�r'|
}|j|�
}n|
}|j|�
}|tkrLd
Sd}g}|}x^||jkr�|jr�|jd|kr�|jd}Pn|j|�

|j	|d}qaW|dkr�|j
|�
}nx4|r
|j|j��
}t
j||g
�}q�W|j|||�
|||f|_|S(sTreturn an uncompressed revision of a given node or revision
        number.
        ti
iiN(t
isinstancetintRR+RR"R!t_cachetappendR-tbaserevisionR;tpopR
tpatchest
_checkhash(R/t	nodeorrevR+RttextRtiterrevR((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRAws0














	



cC@stjj
||
�S(
N(RRA(R/RN((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRJ�sc
C@s
t�
dS(
N(
tNotImplementedError(R/ROttransactionR7RRt
d((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytaddrevision�s
c
C@s
t�
dS(
N(
RQ(R/trevsR1RR((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytaddgroup�s
c
C@s
t�
dS(
N(
RQ(R/R+tminlink((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytstrip�s
c


C@s
t�
dS(
N(
RQ(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt	checksize�s
N(t__name__t
__module__RR;R?RARJR"RTRVRXRY(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR+s
	5			
	#			tbundlechangelogc
B@seZ
d�Zd
�ZRS(cC@s<tjj
||
�
d
�}tj
||
|j||�
dS(Nc


S@s|S(
N((
t
x((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�s(RRRR*(R/R0RR1((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�s

	

cC@s:|j}z d
|_t
j
j||
�SWd||_XdS(N((tfilteredrevsRRA(R/RNt	oldfilter((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRJ�s
	

	
(RZR[RRJ(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR\�s
	tbundlemanifestcB@s)eZ
ddd
�Zd�Zd�ZRS(REcC@s�tjj
||
d
|�

tj
||
|j||�
|dkrni}|jjdkrnt|j�
}qnn||_||_	dS(Ntdirt03(
RRRR*R"Rtversiont_getfilestartst
_dirlogstartst_linkmapper(R/R0RR1tdirlogstartsRa((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�s







	
cC@se|
}t|t
�r'|j|�
}n||jkrL|j|j�}ntjj||
�}|S(
N(RFRGRt
fulltextcachettostringRRA(R/RNRtresult((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRJ�s




cC@sa|
|jkrK|j
j|j|
�

t|j|j
|j|jd
|
�
Stt|�j|
�
S(NRa(ReRR<R`R0Rftsupertdirlog(R/RS((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRl�s





N(RZR[R"RRJRl(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR`�s
	t
bundlefilelogc
B@seZ
d�Zd
�ZRS(cC@s6tjj
||
|�
tj
||
|j||�
dS(
N(R
RRR*(R/R0tpathRR1((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�s


cC@stjj
||
�S(
N(R
RA(R/RN((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRJ�s
(RZR[RRJ(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRm�s
	t
bundlepeerc
B@seZ
d�ZRS(
c


C@stS(
N(
tFalse(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytcanpush�s
(RZR[Rq(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRo�s
tbundlephasecachec
B@s,eZ
d�Zd
�Zd�Zd�ZRS(c
O@sGtt
|�j|
|�
tj|d
�rCtj|j�
|_ndS(NR0(RkRrRRtsafehasattrRRR0(R/targstkwargs((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�s


c


C@s
t�
dS(
N(
RQ(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytwrite�s
c
C@s
t�
dS(
N(
RQ(R/tfp((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt_write�s
cC@s$||j|
<|j
�
t|_dS(
N(t
phaserootst
invalidatetTruetdirty(R/tphasetnewrootsttr((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt_updateroots�s




(RZR[RRvRxR�(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRr�s
			c
@sdi}
xWt�j
i�D]C}|d
}�j�|
|<x t�f
d�i�D]}qRWqW|
S(Ntfilenamec@s
�jd�
S(
N(RR"((
R(s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR
s(R%t
filelogheaderR&(RtbundlefilesposR4tfnametchunk((
Rs8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRd�s







tbundlerepositorycB@s�eZ
d�Zejd
��
Zejd��
Zd�Zejd��
Zejd��
Z	d�Z
d�Zd�Zd	�Z
d
�Zd�Zed�
ZRS(
c@s�d
�f
d�
}d�_
ytjj�|
|�
WnRtjk
r�


tj��_
tj	|
�j
d�
tjj�|
�j
�
n
X�j
jddtd�
|r�dt
j|�
d|�_n
d|�_d�_t
j|d	�}tj|
||��_�_t�jtj�r?d}x��jj�D]�}|jd
kr<
|dk	rl
td�
�
n|}|jjdd
�}tj��
}	||	kr�
td�
}
tj |
|�
�
n�jj!�r�
||j"d|�}q�
q<
q<
W|dkrtj td�
�
�
n|j#d�

tj$||d��_nR�jj!�r�|�jj"ddd�
}tj|
||�j%��_�_ni�_&�j'j(d�_)t*j+�dt*j,g��j)D]}|j-�^q��
dS(NREc@s��jj
d
ddd�\}}|�_tj|d��D}|j|�

x-tr{|d�
}|skPn|j|�

qOWWdQX�jj�jd	d
�

S(s�Write a temporary file to disk

            This is closure because we need to make sure this tracked by
            self.tempfile for cleanup purposes.tprefixs
hg-bundle-tsuffixs.hg10untwbiiNtmodetrbi(tvfstmkstempttempfiletostfdopenRvR{topen(R=R�theadertfdtempttemptfptempR�(
R/(s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt_writetempbundle
s

	


	



i
Rtpublisht
bundlereposbundle:t
+R�Rs#can't process multiple changegroupsRct01s#Unsupported changegroup version: %ss.cg%sunsNo changegroups founditUNs.hg10unR�tHG10UN(.R"t_tempparentRtlocalrepositoryRRt	RepoErrorR�tmkdtemptinstancetuit	setconfigRpRt
expandpatht_urlt	posixfileR	t
readbundlet
bundlefileRRFRt
unbundle20t	iterpartsttypeRQtparamstgetRtsupportedincomingversionsR
tAbortt
compressedR=R<tgetunbundlerR�R�RR!tfirstnewrevRtretractboundarytdraftR(R/R�Rnt
bundlenameR�t
ftcgstreamtpartRctlegalcgverstmsgtctx((
R/s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR
sV
	







!
	













	







	

c

C@st||j
�S(
N(Rrt_phasedefaults(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt_phasecacheN
sc
C@s8|jj
�
t|j|j�}
|jj�|_|
S(
N(RtchangelogheaderR\tsvfsR&tmanstart(R/t
c((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRR
s



c
C@s`|jj
|j�

|jj�
|j�jj}
t|j|j|
�}|jj	�|_
|S(
N(RR<R�tmanifestheadert
unfilteredRR+R`R�R&t	filestart(R/R1t
m((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt_constructmanifestZ
s





c


C@s|j
|j
S(
N(RR�(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�c
s
c


C@s|j
|j
S(
N(RR�(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�h
s
c


C@s|jS(
N(
R�(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyturlm
s
cC@s�|js1|j
j|j�

t|j
�
|_n|
|jkr�|j
j|j|
�

|j�jj}t|j	|
|j
|�St
j
|j	|
�SdS(
N(R�RR<R�RdR�RR+RmR�R
(R/R�R1((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytfilep
s
	




c

C@sU|jj
�
|jd
k	r2|jj|j�

n|jrQtj|jt	�
nd
S(s'Close assigned bundle file immediately.N(
R�tcloseR�R"R�tunlinkR�tshutiltrmtreeR{(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�|
s




	
c


C@stS(
N(
Rp(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytcancopy�
s
c

C@s
t|�
S(
N(
Ro(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytpeer�
s
c


C@s
tj
�S(
N(R�tgetcwd(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR��
s
cC@s�|jj
|
�
}|jj
|�
}td
�
}|jj|krb|jj|tj|
�
�

n|jj|kr�|jj|tj|�
�

ntt	|�j
|
|�S(Ns9setting parent to node %s that only exists in the bundle
(RR+R
R!R�twarntnodemodthexRkR�t
setparents(R/RRtp1revtp2revR�((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR��
s




 

 
(RZR[RRtunfilteredpropertycacheR�RR�R�R�R�R�R�R�R�R�RR�(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR�
s
	I								c	C@sO
|rtj
td
�
�
�
n|jddd�}|sftjtj��
}|dkrfd}qfn|r�tj�}||kr�d}q�t	j
|�
}|j|�
r�|t|�
}q�nt
j|
�
}|j�}
|jdkr2
|
jdd�}t|�
dkr#
||d}}q?
|\}}n
||
}}t|||�S(Ns#cannot create new bundle repositoryRtmainreporootRER�i
i(RR�R
tconfigRtfindrepoR�R�R"Rtnormasprefixt
startswithR RR�t	localpathtschemetsplitR�(	R�Rntcreatet
parentpathtcwdt
ut
strepopathR�((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR��
s.







	









tbundletransactionmanagerc
B@s#eZ
d�Zd
�Zd�ZRS(c


C@sdS(
N(
R"(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyRR�
s
c


C@s
t�
dS(
N(
RQ(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR��
s
c


C@s
t�
dS(
N(
RQ(
R/((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytrelease�
s
(RZR[RRR�R�(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyR��
s
		c@s2tj
|
�d
|d|�}|\}}}	|sqy|rLtj|�

nWntk
r`


n
X|
g�jfSt|�
}
g|	D]}||
kr�|^q�}	d�d�
�j�}|s�|rt|j	dd�}
d|
ko�d|
k}|o
�j
d�
o
�j
d�
}|r�
i}||d<|	|d
<tj|
�
|d	<t
|d
<�jd|�
}tj||j�|�}�n��j
d�
r�
�jdd|d
|	�
}nL|dkr�
�j
d�
r�
�j|d�}d}	n�j||	d�}|rd
}nd}tj||||�}�|r@d�n|stt|
j|
j|�}�
|
j�}qtn|r�|j�}n|jj||	�}�
rg�
�
jD]}|j�^q�}�jd�
}tj�
�d
|�
}t �|_!tj"||�
n��
�fd�}|||fS(sGobtains a bundle of changes incoming from other

    "onlyheads" restricts the returned changes to those reachable from the
      specified heads.
    "bundlename", if given, stores the bundle to this file path permanently;
      otherwise it's stored to a temp file and gets deleted again when you call
      the returned "cleanupfn".
    "force" indicates whether to proceed on unrelated repos.

    Returns a tuple (local, csets, cleanupfn):

    "local" is a local repo from which to obtain the actual incoming
      changesets; it is a bundlerepo for the obtained bundle when the
      original "other" is remote.
    "csets" lists the incoming changeset node ids.
    "cleanupfn" must be called without arguments when you're done processing
      the changes; it closes both the original "other" and the one returned
      here.
    theadstforcetdevelslegacy.exchangeRtbundle1t	getbundletcommont
bundlecapstcgtincomingtchangegroupsubsettHG10BZR�Rc@s7�
r�
j�
n�r)t
j��

n�j�
dS(
N(R�R�R�((RR�tother(s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytcleanup"s






N(#RtfindcommonincomingR�R�tOSErrorR�R#R"tlocalt
configlisttcapableR	t
caps20to10R{R�Rtwritechunkst_forwardchunksR�RtwritebundleR�tbaseuitrootR�R�RtfindmissingR�Rtlistkeyst
pulloperationR�t	trmanagert_pullapplyphases(R�trepoR�t	onlyheadsR�R�ttmpR�R�trheadst	commonsetR]Rtlegexctforcebundle1t
canbundle2Rutb2R�R�t
bundletypetcsetsR�t	reponodestremotephasestpullopR�((RR�R�s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pytgetremotechanges�
st
	









%






















	

	



	




&


(-t__doc__t
__future__RR�R�R�ti18nR
RRRERRRRRRR	R
RRR
R�RRRRRRR\R`Rmt	localpeerRot
phasecacheRrRdR�R�R�tobjectR�R"RpR
(((s8/usr/lib/python2.7/dist-packages/mercurial/bundlerepo.pyt<module>s&


p~			�