�
Hq�Qc@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((s:/usr/lib64/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((s:/usr/lib64/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((s:/usr/lib64/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�t
j
j||�}nx4|r
|j|j
��
}tj||g
�}q�W|j|||�
|||f|_|S(sTreturn an uncompressed revision of a given node or revision
        number.
        ti
iiN(t
isinstancetintRRRRRt_cachetappendRRR2R+tpopR0tpatchest
_checkhash(Rt	nodeorrevRRttextR#titerrevR((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR2bs0














	



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


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


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

	

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


(RJRKR(((s:/usr/lib64/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((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR�s



cCs|jj
|
�

dS(
N(RTtfile(Rt
f((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyt_file�s
(RJRKRRY(((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRR�s
	t
bundlepeerc
BseZ
d�ZRS(
c


CstS(
N(
tFalse(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pytcanpush�s
(RJRKR\(((s:/usr/lib64/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((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR�s<
	







!
	





	



	




c
Cs8|jj
�
t|j|j�}
|jj�|_|
S(
N(R
tchangelogheaderRLtsopenerRtmanstart(Rt
c((s:/usr/lib64/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((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyRQ�s




c


Cs|j
|j
S(
N(ROR�(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR��s
c


Cs|j
|j
S(
N(RQR�(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR��s
c


Cs|jS(
N(
Rr(
R((s:/usr/lib64/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�((s:/usr/lib64/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((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR{
s




	
c


CstS(
N(
R[(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pytcancopy

s
c

Cs
t|�
S(
N(
RZ(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pytpeer
s
c


Cs
tj
�S(
N(Rxtgetcwd(
R((s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pyR�
s
(RJRKRRhtunfilteredpropertycacheRORQR�R�R�RWR{R�R�R�(((s:/usr/lib64/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}((s:/usr/lib64/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(s:/usr/lib64/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�s:/usr/lib64/python2.7/site-packages/mercurial/bundlerepo.pytgetremotechanges6
sB
	















	


	



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

$
H
Hz
n