�
�c@s
dd
kl
Z

ddkZddkZddkZddkZddkZddkZd�Zd�Z	d�Z
d�Zdef
d��YZ
hd	e
fd	<d
e
fd
<dd�fd
<dd�fd<Zdd
d
gZd�Zd�Zd�ZdS(i�(
t
_Nc
Cs�|id
�}
|
p
dSn

t
id|
�d}|d
j
o
dSn

|i|d
�}
t|
�|d
jo-
titd�t|
�|d
f��n

|
S(sget a chunk from a changegroupits>lis7premature EOF reading chunk (got %d bytes, expected %d)(treadtstructtunpacktlentutiltAbortR(tsourcet
dt
l((s(/sys/lib/python/mercurial/changegroup.pytgetchunks









c
cs'x t|�}
|
p
Pn

|
V
qd
S(s$iterate through the chunks in sourceN(
R(Rt
c((s(/sys/lib/python/mercurial/changegroup.pyt	chunkiters




c

Csti
d
|d�S(s build a changegroup chunk headers>li(Rtpack(
tlength((s(/sys/lib/python/mercurial/changegroup.pytchunkheader#scCsti
d
d�S(Ns>li(RR(((s(/sys/lib/python/mercurial/changegroup.pyt
closechunk's
t
nocompressc
BseZ
d�Zd
�ZRS(c
Cs|
S(
N((tselft
x((s(/sys/lib/python/mercurial/changegroup.pytcompress+s
c


Csd
S(NR
((
R((s(/sys/lib/python/mercurial/changegroup.pytflush-s
(t__name__t
__module__RR(((s(/sys/lib/python/mercurial/changegroup.pyR*s
	R
tHG10UNtHG10c
Cs
ti
�S((tbz2t
BZ2Compressor(((s(/sys/lib/python/mercurial/changegroup.pyt<lambda>3stHG10BZtHG10GZc
Cs
ti
�S((tzlibtcompressobj(((s(/sys/lib/python/mercurial/changegroup.pyR4sc	Cs�d
}d
}zv
|
o
t
|
d
�}n1
tidddd�\}}
ti|d
�}|
}t|\}}|i|�
|�}t}	d}
x�|	p

|
dj
o�
t	}	|
d7}
x�t
|�D]|}t}	|i|itt
|����
d}xE|t
|�jo1
|d}
|i|i|||
!��
|
}q�q�W|i|it���
q�
W|i|i��
d
}|
SWd
|d
j	o
|i�
n

|d
j	o
ti|�
n

Xd
S(s�Write a bundle file and return its filename.

    Existing files will not be overwritten.
    If no filename is specified, a temporary file is created.
    bz2 compression can be turned off.
    The bundle file will be deleted in case of errors.
    twbtprefixs
hg-bundle-tsuffixs.hgiii
iNi(tNonetopenttempfiletmkstemptostfdopentbundletypestwritetFalsetTrueR
RRRRRtclosetunlink(tcgtfilenamet
bundletypetfhtcleanuptfdtheadert
compressort
ztemptytcounttchunktpostnext((s(/sys/lib/python/mercurial/changegroup.pytwritebundle:sB	








	








"














cs�d
jo
|
SnX
�id�p
�f
d�}n5
�djo

d�}n
�djo

d�}n

t
i||
��S(NRtHGc
3s�V
x|D]}
|
V
qWdS(
N((t
fR<(
R7(s(/sys/lib/python/mercurial/changegroup.pyt	generatorss


Rc
ss/ti
�}
x|D]}|
i|�V
qWdS(
N(R t
decompressobjt
decompress(RAtzdR<((s(/sys/lib/python/mercurial/changegroup.pyRBxs


Rc
ssHti
�}
|
id
�
x(ti|d�D]}|
i|�V
q,WdS(NtBZi(RtBZ2DecompressorRDRt
filechunkiter(RARER<((s(/sys/lib/python/mercurial/changegroup.pyRB}s





(t
startswithRtchunkbuffer(R7R4RB((
R7s(/sys/lib/python/mercurial/changegroup.pytunbundlens









cCs�|id
�}|i
d�p
titd�|
��n

|i
d�p
titd�|
��n+
|tjo
titd�|
��n

t||�S(NiR@s%s: not a Mercurial bundle fileRs%s: unknown bundle versions#%s: unknown bundle compression type(RRIRRRR+RK(R4tfnameR7((s(/sys/lib/python/mercurial/changegroup.pyt
readbundle�s








(ti18nRRRR)RR R'RR
RRtobjectRR+tbundlepriorityR?RKRM(((s(/sys/lib/python/mercurial/changegroup.pys<module>s 

<				



	4