�
�c
@s�dd
kl
Z
lZ
ddklZ
ddkZddkZddkZddkZddk	Z	de
f
d��YZdeif
d��YZ
e
ZdS(i�(tbinthex(
t
_Nt
remotelockc
Bs#eZ
d�Zd
�Zd�ZRS(cCs
|
|_dS(
N(
trepo(tselfR((s$/sys/lib/python/mercurial/sshrepo.pyt__init__s
c

Cs|ii
�
d|_dS(
N(RtunlocktNone(
R((s$/sys/lib/python/mercurial/sshrepo.pytreleases


c


Cs|io
|i
�
n

dS(
N(RR	(
R((s$/sys/lib/python/mercurial/sshrepo.pyt__del__s


(t__name__t
__module__RR	R
(((s$/sys/lib/python/mercurial/sshrepo.pyR
s
		t
sshrepositorycBs�eZ
dd
�Zd�Zd�Zd�Zd�Zd�ZeZd�Z	d�Z
d	�Zed
�Z
d�Zd�Zd
�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�Zd�ZRS(ic
Cs�||_|
|_
tid
|�}|p$
|ititd�|��
n

|id�|_	|id�|_
|id�|_|id�p
d|_|i
i
dd	d	�}|i
i
dd
d�}ti||i
|i	|i�}|ov
d}|||||if}|
itd
�|�
ti|�}	|	djo 
|ititd���
ql

n

|i|
|||�
dS(Ns,^ssh://(([^@]+)@)?([^:/]+)(:(\d+))?(/(.*))?$scouldn't parse location %siiiit
.tuitssht	remotecmdthgs%s %s "%s init %s"srunning %s
iscould not create remote repo(t_urlRtretmatchtabortterrort	RepoErrorRtgrouptuserthosttporttpathtconfigtutiltsshargstnotetsystemt
validate_repo(
RRRtcreatet
mtsshcmdRtargstcmdtres((s$/sys/lib/python/mercurial/sshrepo.pyRs(
	
	

$



!





$c


Cs|iS(
N(
R(
R((s$/sys/lib/python/mercurial/sshrepo.pyturl5s
c
Cs�|i�
d
}|||||i
f}ti|�}|
itd�|�
ti|�\|_|_|_	|i
d�
|i
dddddddf�
}d	d
g}d}x�|do|
|ou
|i�}	|i�
|dd
jo
|	djo
Pn

|	o
|
i
td�|	�
n

|i|	�
|d8}q�
W|ititd���
t�|_xPt|�D]B}	|	id�o,
|ii|	d id�di��
Pqv

qv
WdS(Ns%s %s "%s -R %s serve --stdio"srunning %s
thellotbetweentpairss%s-%st
0i(ttdummyi�i�s1
s

sremote: i
s#no suitable response from remote hgs
capabilities:t
:(tcleanupRRtquotecommandR!Rtpopen3tpipeotpipeitpipeetdo_cmdtreadlinetreaderrtdebugtappendRRRtsettcapabilitiestreversedt
startswithtupdatetsplit(
RRR&R'RR(t
rtlinest	max_noiset
l((s$/sys/lib/python/mercurial/sshrepo.pyR#8s4



!

'
















'
c
Csex^ti
|i�i}
|
d
jo
Pn

|ii�}|p
Pn

|iitd�|�
qdS(Nisremote: (RtfstatR7tst_sizeR9RtstatusR(RtsizeRF((s$/sys/lib/python/mercurial/sshrepo.pyR:Zs





c
Cs|i�
|
�dS(
N(
R2(Rt	exception((s$/sys/lib/python/mercurial/sshrepo.pyRbs


c
CsfyX|ii
�
|ii
�
x*|iD]}
|iitd
�|
�
q'W|ii
�
Wn


n
XdS(Nsremote: (R5tcloseR6R7RRIR(RRF((s$/sys/lib/python/mercurial/sshrepo.pyR2fs









cKs�|ii
td
�|
�
|iid|
�
xJ|i�D]<\}}|iid|t|�f�
|ii|�
q;W|ii�
|iS(Nssending %s command
s%s
s%s %d
(	RR;RR5twritet	iteritemstlentflushR6(RR(R't
kt
v((s$/sys/lib/python/mercurial/sshrepo.pyR8ss




 


cKs|i|
|�
|i
�S(
N(R8t_recv(RR(R'((s$/sys/lib/python/mercurial/sshrepo.pytcall}s

c
Csb|ii
�}
|i�
yt|
�}
Wn&


|ititd
�|
��
n
X|ii|
�S(Nsunexpected response:(	R6R9R:tintRRt
ResponseErrorRtread(RRF((s$/sys/lib/python/mercurial/sshrepo.pyRS�s






#
cCs[|ii
d
t|
��
|
o
|ii
|
�
n

|o
|ii�
n

|i�
dS(Ns%d
(R5RMRORPR:(RtdataRP((s$/sys/lib/python/mercurial/sshrepo.pyt_send�s





c

Cs|id
�
t
|�S(Ntlock(RTR(
R((s$/sys/lib/python/mercurial/sshrepo.pyRZ�s


c

Cs|id
�
dS(NR(
RT(
R((s$/sys/lib/python/mercurial/sshrepo.pyR�s
cCs||id
t
d��
|id
d|
�
}|d idd�\}}t|�o
t|�Sn
|iti|��
dS(Ntlookupslook up remote revisiontkeyi�t
 i
(	t
requirecapRRTRBRURRRR(RR\t
dtsuccessRX((s$/sys/lib/python/mercurial/sshrepo.pyR[�s





c
CsZ|id
�}
yt
t|
d id��SWn&


|ititd�|
��
n
XdS(Ntheadsi�R]sunexpected response:(RTtmapRRBRRRVR(RR_((s$/sys/lib/python/mercurial/sshrepo.pyRa�s





c

Cs�|id
�}
y|h}xk|
i
�D]]}|id�}ti|d�}g}|dD]}|t|�q\~}|||<q%W|SWn


titd�|
��n
XdS(Nt	branchmapR]ii
sunexpected response:(	RTt
splitlinesRBturllibtunquoteRRRVR(RR_Rct
branchparttbranchheadst
branchnamet_[1]t
x((s$/sys/lib/python/mercurial/sshrepo.pyRc�s







+



cCs�d
it
t|
��}|idd|�
}yGg}|i�D]%}|tt
t|id
���qA~}|SWn&


|it	i
td�|��
n
XdS(NR]tbranchestnodessunexpected response:(tjoinRbR
RTRdttupleRRBRRRVR(RRmt
nR_Rjt
btbr((s$/sys/lib/python/mercurial/sshrepo.pyRl�s



?


cCs�d
ig}|
D]}|dit
t|��q~�}|idd|�
}yOg}|i�D]-}||o
t
t|id
��p
gqe~}|SWn&


|iti	t
d�|��
n
XdS(NR]t
-R,R-sunexpected response:(RnRbR
RTRdRRBRRRVR(RR-Rjt
pRpR_t_[2]RF((s$/sys/lib/python/mercurial/sshrepo.pyR,�s
<


G


cCs+d
it
t|
��}|idd|�
S(NR]tchangegrouptroots(RnRbR
R8(RRmtkindRp((s$/sys/lib/python/mercurial/sshrepo.pyRv�s

cCs_|id
t
d��
ditt|
��}
ditt|��}|id
d|
d|�S(Ntchangegroupsubsetslook up remote changesR]tbasesRa(R^RRnRbR
R8(RRzRaRx((s$/sys/lib/python/mercurial/sshrepo.pyRy�s



cCs
|id
ddi
tt|���
}|o$
|ititd�|��
n

x+|
id�}|p
Pn

|i	|�
qU|i	ddt
�

|i�}|o$
|ititd�|��
n

|i�}yt|�SWn&


|iti
td	�|��
n
XdS(
NtunbundleRaR]spush refused: %siR/RPspush failed: %ssunexpected response:(RTRnRbR
RRRRRWRYtTrueRSRURV(RtcgRatsourceR_RC((s$/sys/lib/python/mercurial/sshrepo.pyR{�s"
'
$




$



cCs�|id
�}|o$
|i
titd�|��
n

x8|
id�}|p
Pn

|ii|�
|i�
q=|ii	�
|i�
|i
�}|p
dSn

yt|�SWn&


|i
titd�|��
n
XdS(Ntaddchangegroupspush refused: %sii
sunexpected response:(
RTRRRRRWR5RMR:RPRSRURV(RR}R~R*R_RC((s$/sys/lib/python/mercurial/sshrepo.pyR�s$


$















c

Cs
|id
�S(Nt
stream_out(
R8(
R((s$/sys/lib/python/mercurial/sshrepo.pyR�

s
(RRRR*R#R:RR2R
R8RTRStFalseRYRZRR[RaRcRlR,RvRyR{RR�(((s$/sys/lib/python/mercurial/sshrepo.pyR
s.
		"				
									
								(tnodeRR
ti18nRRRRRRetobjectRt
repositoryR
tinstance(((s$/sys/lib/python/mercurial/sshrepo.pys<module>s

$