��c@s�dZd
dl
mZ
d
dlmZ
d
dlZd
dlZd
dlZd
dlZd
dl	Z	d
dl
Z
d
dlZd
dlZd
dl
Z
d
dlZd
dlZd
dlZd
dlZd
dlZd
dlZdejf
d��YZdeejfd��YZd	eejfd
��YZdeejfd��YZd
ejf
d��YZdejf
d��YZd�Zdded�ZdS(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�(
tnullid(
t
_NtbundlerevlogcBsYeZ
d�Zd
�Zd�Zd�Zdddd�Zd�Zd�Z	d�Z
RS(	cCstj
|
�}
tjj||
|�
||_t|�}|d
|_d}t�|_	x�t
r|j|�}|s{Pn|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
tnodetp1tp2tcst	deltabasetdeltasunknown parentsunknown delta baseii�(tscmutiltreadonlyvfstrevlogt__init__tbundletlent
repotiprevtNonetsett
bundlerevstTruet
deltachunkttelltnodemaptaddterrortLookupErrort	indexfileR
trevtoffset_typetindextinsert(tselftopenerRR
t
linkmappert
ntchaint	chunkdataRRRRRRtsizetstarttlinkt
ptbaserevt
e((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRsN

	





	
























!





cCsT|
|jk
r"t
j
j||
�S|jj|j|
��
|jj|j|
��S(
N(RRt_chunkR
tseekR&treadtlength(RR((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR+Ls


cCs�|
|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(	RRR+RtrevdifftmdiffttextdifftrevisionR(Rtrev1trev2trevb((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR/Us




cCsC
t|
t
�r'|
}|j|�}n|
}|j|�}|tkrLd
Sd}g}|}x^||jkr�|jr�|jd|kr�|jd}Pn|j|�
|j	|d}qaW|dkr�
j
j||�}nx4|r
|j|j
��}tj||g
�}q�|j|||�
|||f|_|S(sTreturn an uncompressed revision of a given node or revision
        number.
        ti
iiN(t
isinstancetintRRRRRt_cachetappendRRR2R+tpopR0tpatchest
_checkhash(Rt	nodeorrevRRttextR#titerrevR((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR2bs0














	



c
Cs
t�dS(
N(
tNotImplementedError(RR?ttransactionR'RRt
d((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytaddrevision�s
c
Cs
t�dS(
N(
RA(RtrevsR!RB((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytaddgroup�s
c
Cs
t�dS(
N(
RA(RRtminlink((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytstrip�s
c


Cs
t�dS(
N(
RA(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyt	checksize�s
N(t__name__t
__module__RR+R/R2RRDRFRHRI(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRs
	7			
	#		tbundlechangelogc
BseZ
d�ZRS(
cCs<tjj
||
�
d
�}tj
||
|j||�
dS(Nc


Ss|S(
N((
t
x((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyt<lambda>�s(t	changelogRRR(RR R
R!((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR�s

	

(RJRKR(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRL�s
tbundlemanifestc
BseZ
d�ZRS(
cCs3tjj
||
�
tj
||
|j||�
dS(
N(tmanifestRRR(RR R
R!((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR�s


(RJRKR(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRP�s
t
bundlefilelogc
BseZ
d�Zd
�ZRS(cCs?tjj
||
|�
tj
||
|j||�
||_dS(
N(tfilelogRRRt_repo(RR tpathR
R!trepo((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR�s



cCs|jj
|
�
dS(
N(RTtfile(Rt
f((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyt_file�s
(RJRKRRY(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRR�s
	t
bundlepeerc
BseZ
d�ZRS(
c


CstS(
N(
tFalse(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytcanpush�s
(RJRKR\(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRZ�s
tbundlerepositorycBs�eZ
d�Zejd
��Zejd��Zejd��Zejd��Zd�Z	d�Z
d�Zd�Zd	�Z
d
�ZRS(c	Cs�d|_
ytjj||
|�
WnRtjk
rw


tj�|_
tj	|
|j
d
�
tjj||
|j
�
n
X|j
jddt�
|r�dt
j|�d||_n
d||_d|_t
j|d�}tj||�|_|jj�r�tjddd	d
d|j�\}}||_tj|d�}zG|jd
�
x3tr�|jjd�}|sx
Pn|j|�
qV
WWd|j�
Xt
j|jd�}tj||�|_ni|_dS(Ni
tphasestpublishsbundle:t
+trbtprefixs
hg-bundle-tsuffixs.hg10untdirtwbtHG10UNiii(Rt_tempparentt	localrepotlocalrepositoryRRt	RepoErrorttempfiletmkdtemptinstancetuit	setconfigR[tutilt
expandpatht_urlt	posixfiletchangegroupt
readbundleR
t
compressedtmkstempRUtostfdopentwriteRR-tclosetbundlefilespos(	RRnRUt
bundlenameRXtfdtempttemptfptemptchunk((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR�s<
	







!
	





	



	




c
Cs8|jj
�
t|j|j�}
|jj�|_|
S(
N(R
tchangelogheaderRLtsopenerRtmanstart(Rt
c((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRO�s



c
CsT|jj
|j�
|jj�
t|j|j|jj�}
|jj�|_	|
S(
N(
R
R,R�tmanifestheaderRPR�RORRt	filestart(Rt
m((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRQ�s




c


Cs|j
|j
S(
N(ROR�(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR��s
c


Cs|j
|j
S(
N(RQR�(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR��s
c


Cs|jS(
N(
Rr(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyturl�s
cCs�|js�|j
j|j�
xotr�|j
j�}|s>Pn|d
}|j
j�|j|<x&tr�|j
jd�}|saPqaqaWqWn|
|jkr�|j
j|j|
�
t	|j
|
|j
|jj|�St
j
|j
|
�SdS(Ntfilename(R|R
R,R�Rt
filelogheaderRRRRRR�RORRS(RRXR$tfnameR�((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRW�s"
	

	






	





c

CsR|jj
�
|jd
k	r/tj|j�
n|jrNtj|jt	�
nd
S(s'Close assigned bundle file immediately.N(
R
R{RkRRxtunlinkRgtshutiltrmtreeR(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR{
s




	
c


CstS(
N(
R[(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytcancopy

s
c

Cs
t|�S(
N(
RZ(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytpeer
s
c


Cs
tj
�S(
N(Rxtgetcwd(
R((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR�
s
(RJRKRRhtunfilteredpropertycacheRORQR�R�R�RWR{R�R�R�(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyR]�s
	(						c	CsU
|rtj
td
���n|jddd�}|sftjtj��}|dkrfd}qfn|r�tj�}||kr�d}q�tj	j
|d�}|j|�r�|t|�}q�ntj
|
�}|j�}
|jdkr8
|
jdd�}t|�dkr)
||d}}qE
|\}}n
||
}}t|||�S(Ns#cannot create new bundle repositoryR
tmainreporootR6R`i
i(RptAbortR
tconfigtcmdutiltfindrepoRxR�RRUtjoint
startswithRR�t	localpathtschemetsplitR](	RnRUtcreatet
parentpathtcwdt
ut
strepopathR}((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyRm
s.








	









cs�tj
|
�d
|d|�}|\}}}	|sqy|rLtj|�
nWntk
r`


n
X|
g�jfSd
�d
��j�}
|s�|
r}
�jd�r��j	dd|d
|	�}nL|d
kr�jd�r�j
|d�}d
}	n�j||	d�}|
r
dp
d}t
j|||�}
�|rI
d
�n|
s}
t
|
j|
j|
�}
�|
j�}q}
n|
r�|
j�}
n|
jj||	�}���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.
    theadstforcet	getbundletincomingtcommontchangegroupsubsettHG10BZRfcs7�r�j�
n�r)t
j��
n�j�
dS(
N(R{RxR�((R
t
bundlerepotother(s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytcleanupw
s






N(t	discoverytfindcommonincomingRxR�tOSErrorR{RtlocaltcapableR�RtR�twritebundleR]tbaseuitrootR�t
unfilteredROtfindmissing(RnRVR�t	onlyheadsR}R�ttmpR�R�trheadsRhtcgt
bundletypeR�tcsetsR�((R
R�R�s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pytgetremotechanges6
sB
	















	


	



( t__doc__RRti18nR
RxRkR�RtRpR0R�R�R	RhRORQRSRRRRLRPRRt	localpeerRZRiR]RmRR[R�(((s8/sys/lib/python2.7/site-packages/mercurial/bundlerepo.pyt<module>s

$
H
Hz
n