�
�c@sm
dZd
dk
lZ
d
dklZ
d
dkZd
dkZd
dkZd
dkZd
dk	Z	d
dk
Z
d
dkZd
dkZd
dk
Z
d
dkZd
dkZd
dkZd
dkZd
dkZd
dkZdeif
d��YZdeeifd��YZd	eeifd
��YZdeeifd��YZd
eif
d��YZd�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bundlerevlogcBsteZ
dd�Zd
�Zd�Zddd�Zd�Zd�Zdddd�Z	d�Z
d	�Zd
�ZRS(c
s�tii
||
|�
�|_h|_�f
d
�}t|�}d}x�|�D]�\}}	t|�}
|
djo
titd���n

|	d7}	|
d8}
t	i
d|d �\}}}
}||ijo

|}qSn

xF||
fD]8}||ijo"
ti
||itd���q��djo

|}n

||�}|p

|}n

ti|	d�|
dd||i|�|i|
�|f}||i|<|iid|�
||i|<|}|d7}qSWdS(	Nc3s?x8ti
��D]'}�i�}
||
t|�fV
qWdS(
N(tchangegroupt	chunkiterttelltlen(tchunktpos(
t
bundlefile(s'/sys/lib/python/mercurial/bundlerepo.pytchunkpositer#s


iPsinvalid changegroupt20s20s20s20ssunknown parentii�i
(trevlogt__init__R	tbasemapRtNonetutiltAbortR
tstructtunpacktnodemapterrortLookupErrort	indexfiletoffset_typetrevtindextinsert(tselftopenerRR	t
linkmapperR
t
ntprevRtstarttsizetnodetp1tp2tcst
ptlinkt
e((
R	s'/sys/lib/python/mercurial/bundlerepo.pyR
sD
	
	












"














!






cCs"|
d
jo
tSn

|
|i
jS(sis rev from the bundlei(tFalseR(RR((s'/sys/lib/python/mercurial/bundlerepo.pytbundleGs


cCs|i|
S(
N(
R(RR((s'/sys/lib/python/mercurial/bundlerepo.pyt
bundlebaseLsicCs\|i|
�p
t
i
i||
|�Sn

|ii|i|
��
|ii|i|
��S(
N(R+RRR	tseekR!treadtlength(RRtdftcachelen((s'/sys/lib/python/mercurial/bundlerepo.pyRMs


cCs�|i|
�oJ
|i|�o:
|i
|i|��}||
jo
|i|�Sq�
n=
|i|
�o+
|i|�o
tii||
|�Sn

ti|i|i	|
��|i|i	|���S(
s1return or calculate a delta between two revisions(
R+RR,RRtrevdifftmdiffttextdifftrevisionR#(Rtrev1trev2trevb((s'/sys/lib/python/mercurial/bundlerepo.pyR2Vs 



"

c	Cs�|
tjo
d
Sn

d}g}|
}|i|�}xp|i|�o_
|io&
|id|jo
|id}Pn

|i|�
|i|�}|i|�}q9
W|djo
tii||�}n

x6|o.
|i	|i
��}ti||g
�}q�
W|i
|
�\}}|
ti|||�jo/
titd�|i|i|
�f��n

|
|i|
�|f|_|S(s*return an uncompressed revision of a giventiisintegrity check failed on %s:%dN(RRRR+t_cachetappendR,RR5RtpopR3tpatchestparentsthashRtRevlogErrorR
tdatafile(	RR#ttexttchaint	iter_nodeRtdeltaR$R%((s'/sys/lib/python/mercurial/bundlerepo.pyR5cs.



















 
c
Cs
t�dS(
N(
tNotImplementedError(RRBttransactionR(R$R%t
d((s'/sys/lib/python/mercurial/bundlerepo.pytaddrevision�s
c
Cs
t�dS(
N(
RF(RtrevsRRG((s'/sys/lib/python/mercurial/bundlerepo.pytaddgroup�s
c
Cs
t�dS(
N(
RF(RRtminlink((s'/sys/lib/python/mercurial/bundlerepo.pytstrip�s
c


Cs
t�dS(
N(
RF(
R((s'/sys/lib/python/mercurial/bundlerepo.pyt	checksize�s
N(
t__name__t
__module__RR
R+R,RR2R5RIRKRMRN(((s'/sys/lib/python/mercurial/bundlerepo.pyRs1		
		
			tbundlechangelogc
BseZ
d�ZRS(
cCs0tii
||
�
ti
||
|i|�
dS(
N(t	changelogR
RR(RRR	((s'/sys/lib/python/mercurial/bundlerepo.pyR
�s

(RORPR
(((s'/sys/lib/python/mercurial/bundlerepo.pyRQ�s
tbundlemanifestc
BseZ
d�ZRS(
cCs3tii
||
�
ti
||
|i||�
dS(
N(tmanifestR
RR(RRR	R((s'/sys/lib/python/mercurial/bundlerepo.pyR
�s


(RORPR
(((s'/sys/lib/python/mercurial/bundlerepo.pyRS�s
t
bundlefilelogc
BseZ
d�ZRS(
cCs6tii
||
|�
ti
||
|i||�
dS(
N(tfilelogR
RR(RRtpathR	R((s'/sys/lib/python/mercurial/bundlerepo.pyR
�s


(RORPR
(((s'/sys/lib/python/mercurial/bundlerepo.pyRU�s
tbundlerepositorycBs�eZ
d�Zeid
��Zeid��Zeid��Zeid��Zd�Z	d�Z
d�Zd�Zd	�Z
d
�ZRS(c
s^d|_
ytii||
|�
WnTtij
oE



ti�|_
ti	|
|i
d
�
tii||
|i
�
n
X|o
d|d||_
n
d||_
d|_t|d�|_|ii
d���id�p
titd�|��nQ

�id�p
titd	�|��n$

�d
jp

�djo�
tidd
ddd|i�\}}||_ti|d�}�f
d�}|ti|id��}z/|id�
x|D]}	|i|	�
q�WWd|i�
|ii�
Xt|id�|_|iid�
n+
�djo
n
titd�|��h|_dS(Ni
sbundle:t
+trbitHGs%s: not a Mercurial bundle filetHG10s%s: unknown bundle versiontHG10BZtHG10GZtprefixs
hg-bundle-tsuffixs.hg10untdirtwbc
3sj�d
jo
ti
�}
|
id�
n
�djo
ti�}
n

x|D]}|
i|�V
qNWdS(NR]tBZR^(tbz2tBZ2Decompressort
decompresstzlibt
decompressobj(t
ftzdR(
theader(s'/sys/lib/python/mercurial/bundlerepo.pyt	generator�s








itHG10UNs#%s: unknown bundle compression type(Rt_tempparentt	localrepotlocalrepositoryR
Rt	RepoErrorttempfiletmkdtemptinstancet_urltopenR	R.t
startswithRRR
tmkstempRWtostfdopent
filechunkitertwritetcloseR-tbundlefilespos(
RtuiRWt
bundlenametfdtempttemptfptempRltgenR((
Rks'/sys/lib/python/mercurial/bundlerepo.pyR
�sL
	







	









	











c
Cs+t|i
|i�}
|ii�|_|
S(
N(RQtsopenerR	Rtmanstart(Rt
c((s'/sys/lib/python/mercurial/bundlerepo.pyRR�s

c
CsG|ii
|i�
t|i|i|ii�}
|ii�|_|
S(
N(	R	R-R�RSR�RRRRt	filestart(Rt
m((s'/sys/lib/python/mercurial/bundlerepo.pyRT�s


c


Cs|i
|i
S(
N(RRR�(
R((s'/sys/lib/python/mercurial/bundlerepo.pyR��s
c


Cs|i
|i
S(
N(RTR�(
R((s'/sys/lib/python/mercurial/bundlerepo.pyR��s
c


Cs|iS(
N(
Ru(
R((s'/sys/lib/python/mercurial/bundlerepo.pyturl�s
cCs�|ipn
|i
i|i�
xXti|i
�}|p
Pn

|i
i�|i|<xti|i
�D]}qgWq n

|
d
djo
|
d}
n

|
|ijo:
|i
i|i|
�
t|i	|
|i
|i
i�Sn
ti|i	|
�SdS(Nit
/i
(
R~R	R-R�RtgetchunkRRRUR�RRRRV(RRiRR�((s'/sys/lib/python/mercurial/bundlerepo.pytfile�s"














c


Cs|ii
�
d
S(s'Close assigned bundle file immediately.N(R	R}(
R((s'/sys/lib/python/mercurial/bundlerepo.pyR}
sc
Cs�t|d
d�}
|
o
|
io
|
i�
n

t|dd�}|dj	o
ti|�
n

|io
ti|it	�
n

dS(NR	Rr(
tgetattrRtclosedR}RytunlinkRntshutiltrmtreetTrue(RR	Rr((s'/sys/lib/python/mercurial/bundlerepo.pyt__del__
s









c


CstS(
N(
R*(
R((s'/sys/lib/python/mercurial/bundlerepo.pytcancopy
s
c


Cs
ti
�S(
N(Rytgetcwd(
R((s'/sys/lib/python/mercurial/bundlerepo.pyR�
s
(RORPR
Rt
propertycacheRRRTR�R�R�R�R}R�R�R�(((s'/sys/lib/python/mercurial/bundlerepo.pyRX�s
	8				
	cCs7
|o
ti
td
���n

|iddd�}|o`
ti�}||jo

d}q�
tii|d�}|i|�o
|t	|�}q�
n

ti
d|
�}
|
id�o\
ti
d|
�}
|
idd�}t	|�djo
||d	}}q'

|\}}n
||
}}t|||�S(
Ns#cannot create new bundle repositoryR+tmainreporootR9R�sbundle:RYi
i(
RRR
tconfigRyR�RWtjoinRwRtdrop_schemetsplitRX(RRWtcreatet
parentpathtcwdt
strepopathR�((s'/sys/lib/python/mercurial/bundlerepo.pyRt
s&

















(t__doc__R#Rti18nR
RyRRdRgRrR�RRR3RoRRRTRVRRRRQRSRURpRXRt(((s'/sys/lib/python/mercurial/bundlerepo.pys<module>s

H
$
Hw{