�
�c@s�dd
kl
Z

ddklZlZ
ddkZddkZddkZddkZddk	Z	ddk
Z
ddkZdef
d��YZ
dS(i�(
t
_(tbinthexNt	sshserverc
Bs�eZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
d�Zd
�Zd�Zd�Zd�Zd�Zd�ZRS(cCsp|
|_||_
d|_ti|_ti|_t	i
t�
tit_t
i|i�
t
i|i�
dS(
N(tuitrepotNonetlocktsyststdintfintstdouttfoutthooktredirecttTruetstderrtutilt
set_binary(tselfRR((s&/sys/lib/python/mercurial/sshserver.pyt__init__s
	
	
	




c
CsG|ii
�d
 }
|
i�\}}|iit|��}||fS(Ni�(R
treadlinetsplittreadtint(Rtarglinetargt
ltval((s&/sys/lib/python/mercurial/sshserver.pytgetargs



cCs;|ii
d
t|
��
|ii
|
�
|ii�
dS(Ns%d
(Rtwritetlentflush(Rt
v((s&/sys/lib/python/mercurial/sshserver.pytrespond#s


c

CsOzx|i�o
q
WWd|i
dj	o
|i
i�
n

Xtid
�
dS(Ni(t	serve_oneRRtreleaseRtexit(
R((s&/sys/lib/python/mercurial/sshserver.pyt
serve_forever(s




c
Cs]|ii
�d
 }
|
o9
t|d|
d�}|o
|�
qS
|id�
n

|
djS(Ni�tdo_t(R
RtgetattrRR"(Rtcmdtimpl((s&/sys/lib/python/mercurial/sshserver.pyR#0s





c
Cs�|i�\}
}|
d
jp
t
�
y"t|ii|��}d}Wn'tj
o

}
t|�}d}n
X|id||f�
dS(Ntkeyi
is%s %s
(RtAssertionErrorRRtlookupt	ExceptiontstrR"(RRR,t
rtsuccesstinst((s&/sys/lib/python/mercurial/sshserver.pyt	do_lookup8s









c
	Cs�|ii
�}
g}xp|
i�D]b\}}ti|�}g}|D]}|t|�qH~}|id
|di|�f�
q"W|idi|��
dS(Ns%s %st
 s

(	Rt	branchmapt	iteritemsturllibtquoteRtappendtjoinR"(	RR6theadstbranchtnodest
branchnamet_[1]tnodetbranchnodes((s&/sys/lib/python/mercurial/sshserver.pytdo_branchmapCs





'
$
c
Cs6|ii
�}
|id
itt|
��d�
dS(NR5s

(RR<R"R;tmapR(Rt
h((s&/sys/lib/python/mercurial/sshserver.pytdo_headsLs

c
Csgd
dddg}
|ii
dd�o
|
id|iii�
n

|idd	i|
�f
�
d
S(s)
the hello command returns a set of lines describing various
        interesting things about the server, in an RFC822-like format.
        Currently the only one defined is "capabilities", which
        consists of a line in the form:

        capabilities: space separated list of tokens
        tunbundleR.tchangegroupsubsetR6tservertuncompresseds	stream=%dscapabilities: %s
R5N(Rt
configboolR:Rt	changelogtversionR"R;(Rtcaps((s&/sys/lib/python/mercurial/sshserver.pytdo_helloPs	


c

Cs#|ii
�|_
|id
�
dS(s<DEPRECATED - allowing remote client to lock repo is not safeR(N(RRR"(
R((s&/sys/lib/python/mercurial/sshserver.pytdo_lock^s
c

Cs5|io
|ii
�
n

d|_|id
�
dS(t
DEPRECATEDR(N(RR$RR"(
R((s&/sys/lib/python/mercurial/sshserver.pyt	do_unlockds


	
c
Cs�|i�\}
}t
t|id
��}g}x=|ii|�D])}|id
it
t|��d�
qCW|i	di|��
dS(NR5s

R((
RRDR
RRtbranchesR:R;RR"(RRR>R1t
b((s&/sys/lib/python/mercurial/sshserver.pytdo_branchesls




'
c
Cs�|i�\}
}g}|i
d
�D]}|tt|i
d��q&~}g}x=|ii|�D])}|id
itt|��d�
qgW|i	di|��
dS(NR5t
-s

R((
RRRDR
RtbetweenR:R;RR"(RRtpairsR@t
pR1RT((s&/sys/lib/python/mercurial/sshserver.pyt
do_betweents

<


'
c
Cs�g}
|i�\}}t
t|id
��}
|ii|
d�}x7to/
|id�}|p
Pn

|ii	|�
qH
W|ii
�
dS(NR5tservei(RRDR
RRtchangegroupRRRRR (RR>Rtrootstcgt
d((s&/sys/lib/python/mercurial/sshserver.pytdo_changegroup|s








c
	Cs�t|i
�|i
�g�}
g}|
d
id�D]}|t|�q6~}g}|
did�D]}|t|�qj~}|ii||d�}x7to/
|id�}|p
Pn

|ii	|�
q�
W|ii
�
dS(NtbasesR5R<R[i(tdictRRR
RRHRRRRR (	RtargmapR@t
nRat_[2]R<R^R_((s&/sys/lib/python/mercurial/sshserver.pytdo_changegroupsubset�s

4
4





c
Csd|ip
|i
d
�
dSn

|i
d�
|ii|id|i��}
|i
t|
��
dS(RQs
not lockedNR(R[(RR"RtaddchangegroupR
t
client_urlR0(RR1((s&/sys/lib/python/mercurial/sshserver.pytdo_addchangegroup�s





!
c
Cs-ti
id
d�idd�d}
d|
S(Nt
SSH_CLIENTR(R5i
isremote:ssh:(tostenvirontgetR(Rtclient((s&/sys/lib/python/mercurial/sshserver.pyRh�s
%
c
s��i�d
i
����fd�}
|
�p
�itd��
dSn

�id�
d}}zE
tidd�
\}}ti|d�}t	�i
i��}x:|o2
|i�i
i
|��
t	�i
i��}q�
W�idj	}|p
�ii��_n

zt|
�p
�itd��
dSn

�id�
|id�
�ii|d	�i��}�it|��
Wd|p
�ii�
d�_n

XWd|dj	o
|i�
n

|dj	o
ti|�
n

XdS(
Ni
c
s8tt
�ii��}�t
d
�g
jp

�|jS(Ntforce(RDRRR<(
R<(Rttheir_heads(s&/sys/lib/python/mercurial/sshserver.pytcheck_heads�s

sunsynced changesR(tprefixshg-unbundle-swb+iR[(RRR"RRttempfiletmkstempRktfdopenRR
RRRRRtseekRgRhR0R$tclosetunlink(RRqttempnametfptfdtcountt
was_lockedR1((RRps&/sys/lib/python/mercurial/sshserver.pytdo_unbundle�s@































c
Cs�y>x*ti
|i�D]}
|ii|
�
qW|ii�
Wn;tij
o,

}
|iit|��
|ii�
n
XdS(
N(tstreamclonet
stream_outRRRR tStreamExceptionR0(RtchunkR3((s&/sys/lib/python/mercurial/sshserver.pyt
do_stream_out�s






(t__name__t
__module__RRR"R&R#R4RCRFRORPRRRURZR`RfRiRhR~R�(((s&/sys/lib/python/mercurial/sshserver.pyRs&
																			3(ti18nRRAR
RRRR
RkRRsR8tobjectR(((s&/sys/lib/python/mercurial/sshserver.pys<module>	s

$
0