�t�c@sbdd
lZdd
l
Z
dd
lZdd
lZdd
lZdd
lZdef
d��YZd
S(i�Nt	sshservercBs�eZ
d�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
d	�Zd
�Zd�Z
iee6e	ej6e
ej6eej6eej6Zd�Zd
�Zd�Zd�Zd�ZRS(cCsz|
|_||_
d|_|
j|_|
j|_tjt�
|
j	|
_|j_t
j|j�
t
j|j�
dS(
N(tuitrepotNonetlocktfintfoutthooktredirecttTruetferrtutilt	setbinary(tselfR
R((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt__init__
s
	
	
	




cCs6
i}|
j�}x
t
t|��D]�|jj�d
 }|j�\}}||krrtjd|��n|dkr�}xat
t|��D]M}	|jj�d
 }|j�\}}|jjt|��}
|
||<q�W||d<q%|jjt|��}
|
||<q%Wg|D]}	||	^q"
S(Ni�sunexpected parameter %rt
*(	tsplittxrangetlenRtreadlineRtAborttinttread(R
targstdatatkeyst
ntarglinetargt
ltstart
ktval((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytgetargss$

















cCs|j|
�d
S(Ni(
R!(R
tname((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytgetarg0s
cCsa|jd
�
t
|jj��}x8|r\|
j|jj|��
t
|jj��}q%WdS(Nt(tsendresponseRRRtwriteR(R
tfpouttcount((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytgetfile3s




	

c


CsdS(
N((
R
((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyR:s
ccs/x(tr*|
j
d
�}|s"Pn|V
qWdS(Ni(R	R(R
tchangegroupt
d((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytgroupchunks=s

	



cCs;|jj
d
t|
��
|jj
|
�
|jj�
dS(Ns%d
(RR&Rtflush(R
t
v((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyR%Ds


cCs;|jj
}x|
jD]}||�
qW|jj�
dS(
N(RR&tgenR-(R
tsourceR&tchunk((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt
sendstreamIs



cCs'|jd
�
|jt
|
j��
dS(NR$(R%tstrtres(R
trsp((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytsendpushresponseOs


cCs|j|
j
�
dS(
N(R%R4(R
R5((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt
sendpusherrorSs
cCsK|jj
jd
|
j�
|jj
j�
|jjd�
|jj�
dS(Ns%s
-
s

(R
R
R&tmessageR-R(R
R5((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytsendooberrorVs



c

CsKzx|j�rqWWd|j
dk	r9|j
j�
nXtjd
�
dS(Ni(t	serve_oneRRtreleasetsystexit(
R
((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt
serve_forever\s




c
Cs�|jj
�d
 }
|
rZ|
tjkrZtj|j||
�}|j|j||�
nZ|
r�t|d|
d�}|r�|�}|dk	r�|j
|�
q�q�|j
d�
n|
dkS(Ni�tdo_R$(RRt	wireprototcommandstdispatchRthandlerst	__class__tgetattrRR%(R
tcmdR5timplt
r((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyR:ms







	



c

Cs|jj
�|_
d
S(s<DEPRECATED - allowing remote client to lock repo is not safeR$(RR(
R
((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytdo_lock{s
c

Cs&|jr|jj
�
nd|_d
S(t
DEPRECATEDR$N(RR;R(
R
((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt	do_unlock�s	

	
c
Csq|js|j
d
�
dS|j
d�
tj|jd�}
|jj|
d|j��}|jj�
t	|�S(RJs
not lockedNR$tUNtserve(
RR%R*t
unbundle10RRtaddchangegroupt_clientR;R3(R
tcgRH((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pytdo_addchangegroup�s	








c
Cs-tj
jd
d�jdd�d}
d|
S(Nt
SSH_CLIENTR$t
 i
isremote:ssh:(tostenvirontgetR(R
tclient((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyRP�s
%
(t__name__t
__module__RR!R#R)RR,R%R2R6R7R9R>R3R@t	streamrestpushrestpusherrtooberrorRCR:RIRKRRRP(((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyRs.
													








				
(RRR@R*RUR<tobjectR(((s7/sys/lib/python2.7/site-packages/mercurial/sshserver.pyt<module>	s0