��c@s�dd
lZddl
mZ
dd
lZdd
lZdd
lZdef
d��YZd�Zdej	f
d��YZ
e
Zd
S(i�N(
t
_t
remotelockc
Bs#eZ
d�Zd
�Zd�ZRS(cCs
|
|_dS(
N(
trepo(tselfR((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt__init__
s
c

Cs|jj
�
d|_dS(
N(RtunlocktNone(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pytreleases


c


Cs|jr|j
�
ndS(
N(RR(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt__del__s
	
(t__name__t
__module__RRR(((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR
s
		c

Cs*tj
d
|�r|Sd|jdd�S(s=quote a string for the remote shell ... which we assume is shs[a-zA-Z0-9@%_+=:,./-]*$s'%s't
's'\''(tretmatchtreplace(
t
s((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt_serverquotes

tsshpeercBs�eZ
ed�Zd
�Zd�Zd�Zd�Zd�Zd�Z	e	Z
d�Zd�Zd	�Z
d
�Zd�Zed�Zd
�Zd�Zdd�ZRS(c
Cs�||_|
|_
d|_|_|_tj|d
tdt�}|j	dksl|j
sl|jdkr�|jt
jtd�|��
n|j|_|jdk	r�|jt
jtd���
n|j
|_
|j|_|jp�|_|j
jddd�}|j
jddd	�}tj||j
|j|j�}|r�d
||tjdt|�t|j�f�f}|
jtd�|�
tj|�}	|	d
kr�|jt
jtd���
q�n|j|
|||�
dS(Nt
parsequeryt
parsefragmenttsshscouldn't parse location %sspassword in URL not supportedt
.tuit	remotecmdthgs%s %s %ss
%s init %ssrunning %s
iscould not create remote repo(t_urlRRtpipeotpipeitpipeetutilturltFalsetschemethosttpatht_abortterrort	RepoErrorRtusertpasswdtporttconfigtsshargst
shellquoteRtnotetsystemt
validate_repo(
RRR"tcreatet
utsshcmdRtargstcmdtres((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyRs0
	
	

(
#





!
	
	
#



"c


Cs|jS(
N(
R(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR=s
c
Cs�|j�
d
||t
jdt|�t|j�f�f}|
jtd�|�
t
j|�}t
j|�\|_	|_
|_|_|j
d�
|j
ddddd	dd	f�
}d
dg}d}x�|d
rN
|rN
|j�}	|j�
|d
dkr
|	dkr
Pn|	r4
|
jd|	�
n|j|	�
|d8}q�W|jtjtd���
t�|_xNt|�D]@}	|	jd�r�|jj|	d
 jd�dj��
Pq�q�WdS(Ns%s %s %ss%s -R %s serve --stdiosrunning %s
thellotbetweentpairss%s-%st
0i(ttdummyi�i�s1
s

sremote: i
s#no suitable response from remote hgs
capabilities:t
:(tcleanupRR+RR"R,Rtquotecommandtpopen4RRRt
subprocesst_callstreamtreadlinetreaderrtdebugtappendR#R$R%tsett_capstreversedt
startswithtupdatetsplit(
RRR1R2RR3t
rtlinest	max_noiset
l((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR.@s4
	
	
#

'

'















'
c


Cs|jS(
N(
RF(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt
_capabilitiesfs
c
Cs�x~tr�t
j|j�j}
|
d
kr.Pn|jj|
�}|sJPnx0|j�D]"}|jjt	d�|d�
qWWqWdS(Nisremote: s

(
tTrueRtfstatRtst_sizetreadt
splitlinesRtstatusR(RtsizeRRN((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyRBis
	







c
Cs|j�
|
�dS(
N(
R<(Rt	exception((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR#ts


c
Cs�|jdkrdS|jj�
|jj�
y1x*|jD]}
|jjtd
�|
�
q:WWntt	fk
rw


n
X|jj�
dS(Nsremote: (
RRtcloseRRRRURtIOErrort
ValueError(RRN((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR<xs







!


cKsS
|jj
d
|
�
|jjd|
�
tj|
\}}|j�}i}x=|D]5}|dkrt||d<PqT||||<||=qTWx�t|j��D]�\}}|jjd|t	|�f�
t
|t�r+
x]|j�D]<\}	}
|jjd|	t	|
�f�
|jj|
�
q�q�|jj|�
q�W|jj�
|j
S(Nssending %s command
s%s
t
*s%s %d
(RRCRtwritet	wireprototcommandsRJtsortedt	iteritemstlent
isinstancetdicttflushR(RR3R2t_functnamestkeystwireargst
kt
vtdktdv((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR@�s(













 


 


cKs|j|
|�
|j
�S(
N(R@t_recv(RR3R2((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt_call�s

cKs�|j|
|�}|r"d
|fSx0t
rT|jd�}|sDPn|j|�
q%W|jd
dt
�

|j�}|r�d
|fS|j�d
fS(NR9iRd(RnRPRSt_sendRm(RR3tfpR2RKt
d((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt	_callpush�s




	









c
Cs|
S(
N((Rtstream((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt_decompress�s
c
Cs�|jj
�}
|
d
kr�g}x9tr\|jj
�}|dkrIPn|j|g
�
q$Wt|�dkr�|dd |d<n|jtj|��
n|j	�
yt
|
�}
Wn0tk
r�

|jtjt
d�|
��
n
X|jj|
�S(Ns

s-
ii�sunexpected response:(RRARPRtextendRaR#R$tOutOfBandErrorRBtintRZt
ResponseErrorRRS(RRNterrtline((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyRm�s"



	












#
cCsW|jj
d
t|
��
|
r3|jj
|
�
n|rI|jj�
n|j�
dS(Ns%d
(RR\RaRdRB(RtdataRd((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyRo�s





c

Cs|jd
�
t
|�S(Ntlock(RnR
(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR|�s


c

Cs|jd
�
dS(NR(
Rn(
R((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR�s
cCs�|jd
�}|r8|j
tjtd�|��
nx=trw|
jd�}|sZPn|jj|�
|j	�
q;W|jj
�
|j	�
|j�}|s�dSyt|�SWn0t
k
r�

|j
tjtd�|��
n
XdS(s�Send a changegroup to the remote server.  Return an integer
        similar to unbundle(). DEPRECATED, since it requires locking the
        remote.taddchangegroupspush refused: %sii
sunexpected response:N(RnR#R$R%RRPRSRR\RBRdRmRwRZRx(RtcgtsourceRR|RqRK((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyR}�s$

#
	














N(R	R
RRRR.RORBR#R<RR@RnRrRtRmRoR|RRR}(((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyRs"
 		&				
							(Rti18nRRR$R]tobjectR
RtwirepeerRtinstance(((s5/sys/lib/python2.7/site-packages/mercurial/sshpeer.pyt<module>s

$