�
�c@s:
dd
kZdd
k
Z
dd
kZdd
kZdd
kZdd
kZdd
kZddklZl	Z	
ddk
lZlZ
ddkl
Z
ddklZlZlZlZ
dddd	d
ddd
ddg
ZdZd�Zd�Zd�Zd�Zd�Zd�Z
d�Zd�Zd�Zd�Zd
S(i�N(tutiltstreamclone(tbinthex(
tchangegroup(t
ErrorResponsetHTTP_OKtHTTP_NOT_FOUNDtHTTP_SERVER_ERRORtlookuptheadstbranchestbetweenRtchangegroupsubsettcapabilitiestunbundlet
stream_outt	branchmapsapplication/mercurial-0.1c	cs�y*t|i
|
id
d��}d}Wn'tj
o

}
t|�}d}n
Xd||f}|
ittdt|��

|V
dS(Ntkeyii
s%s %s
tlength(	RR	tformt	ExceptiontstrtrespondRtHGTYPEtlen(trepotreqt
rtsuccesstinsttresp((s+/sys/lib/python/mercurial/hgweb/protocol.pyR	s

 







ccsGd
it
t|i���d}|
ittdt|��

|V
dS(Nt
 s

R(tjointmapRR
RRRR(RRR((s+/sys/lib/python/mercurial/hgweb/protocol.pyR
$s
"

ccs�|i�}g}xp|i
�D]b\}}ti|�}g}|D]}|t|�qE~}	|id
|di|	�f�
qWdi|�}
|
itt	dt
|
��

|
V
dS(Ns%s %sR s

R(Rt	iteritemsturllibtquoteRtappendR!RRRR(RRRR
tbranchtnodest
branchnamet_[1]tnodetbranchnodesR((s+/sys/lib/python/mercurial/hgweb/protocol.pyR)s





'
$


ccs�g}d
|
ijo'
t
t|
id
did��}n

ti�}x:|i|�D])}|idit
t	|��d�
qYW|i
�}|
itt
dt|��

|V
dS(NR(iR s

R(RR"Rtsplitt	cStringIOtStringIORtwriteR!RtgetvalueRRRR(RRR(Rt
b((s+/sys/lib/python/mercurial/hgweb/protocol.pyR4s


'


'


c
cs�d
|
ijoK
g}|
id
di
d�D]}|tt|i
d��q/~}n

ti�}x:|i|�D])}|iditt	|��d�
qwW|i
�}|
itt
dt|��

|V
dS(NtpairsiR t
-s

R(RR-R"RR.R/RR0R!RR1RRRR(RRR*t
pR3RR2((s+/sys/lib/python/mercurial/hgweb/protocol.pyR?s


D


'


ccs�|
it
t�
g}d
|
ijo'
tt|
id
did��}n

ti�}|i	|d�}x,|i
d�}|p
Pn

|i|�V
qn|i�V
dS(NtrootsiR tservei(
RRRRR"RR-tzlibtcompressobjRtreadtcompresstflush(RRR(t
zt
ftchunk((s+/sys/lib/python/mercurial/hgweb/protocol.pyRJs


'





c
cs
|
it
t�
g}g}d
|
ijo?
g}|
id
did�D]}|t|�qK~}n

d|
ijo?
g}|
iddid�D]}|t|�q�~}n

ti�}|i||d�}x,|i	d�}	|	p
Pn

|i
|	�V
q�|i�V
dS(NtbasesiR R
R7i(RRRRR-RR8R9R
R:R;R<(
RRR@R
R*t
xt_[2]R=R>R?((s+/sys/lib/python/mercurial/hgweb/protocol.pyR
[s



?

?





ccs�d
ddg}|ii
dddt�
o
|id|ii�
n

tio!
|idd	iti��
n

d
i|�}|
i	t
tdt|��

|V
dS(NR	R
Rtservertuncompressedt	untrusteds	stream=%dsunbundle=%st
,R R(
tuit
configbooltTrueR&t	changelogtversiontchangegroupmodtbundlepriorityR!RRRR(RRtcapstrsp((s+/sys/lib/python/mercurial/hgweb/protocol.pyRos





!


cs�|
ii
d
�p
d}|
iddid����fd�}|�p
|
i�
ttd��n

tidd	�
\}}t	i
|d
�}z�t|
id�}x*ti
|
d|�
D]}|i|�
q�Wy��i�}	z�|�p
ttd��n

|id�
|id
�}
|
id�o!
|
id�o
td��n!
|
tijo
td��n

ti|
|�}titif}ti�t_t_z�d|ti|
ii
dd��ti|
ii
dd��f}
y�i|d|
�}Wn2tij
o#

}
tiid|�
d}n
XWdtii �}|\t_t_X|
i!tt"�
d||ff
SWd|	i#�
XWn�tj
o

}
tt|��n�
t$t%fj
o�

}
t&|dd�}|i�i'�o
|t(�i'�d}n
d}t&|dd�}|i)t)i*jo

t+}n
t,}t|d||f��n
XWd|i-�
t	i.|�
XdS(Nswsgi.url_schemethttpR
iR c
s5tt
�i��}�t
d
�g
jp

�|jS(Ntforce(R"RR
(
R
(Rttheir_heads(s+/sys/lib/python/mercurial/hgweb/protocol.pytcheck_heads~s

sunsynced changestprefixshg-unbundle-swb+tCONTENT_LENGTHtlimititHGtHG10sunknown bundle versionsunknown bundle compression typesremote:%s:%s:%stREMOTE_HOSTttREMOTE_USERR7s
abort: %s
s%d
%stfilenamei
tstrerrors
Unknown errors%s: %s(/tenvtgetRR-tdrainRRttempfiletmkstemptostfdopentintRt
filechunkiterR0tlocktseekR:t
startswitht
ValueErrorRLtbundletypesRtsyststdouttstderrR.R/R$R%taddchangegrouptAbortR1RRtreleasetOSErrortIOErrortgetattrtrootRterrnotENOENTRRtclosetunlink(RRtprotoRStfdttempnametfpRt
sRgtheadertgentoldioturltretRtvalR\terrortcode((RRRs+/sys/lib/python/mercurial/hgweb/protocol.pyRysp

















!








"

















"

ccsc|
it
t�
y)x"ti|d
t�
D]}|V
q)WWn#tij
o

}
t|�V
n
XdS(NRE(RRRR
RRItStreamExceptionR(RRR?R((s+/sys/lib/python/mercurial/hgweb/protocol.pyR�s






(R.R8RaRvRcRlR$t	mercurialRR
tmercurial.nodeRRRRLtcommonRRRRt__all__RR	R
RRRR
RRR(((s+/sys/lib/python/mercurial/hgweb/protocol.pys<module>s$T



"

									
	O