git: 9front

ref: 4bb9e229bcb23826a0fde907667c8fd6565d98d2
dir: /sys/lib/python/mercurial/hgweb/protocol.pyc/

��
�$�Jc@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