�
x7_c@@s�dd
lm
Z

ddlZddlmZ
ddlmZmZmZ
de	f
d��YZ
d�Zd	�Zd
e	f
d��YZ
dejf
d
��YZeZdS(i(
tabsolute_importNi
(
t
_(terrortutilt	wireprotot
remotelockc
B@s5eZ
d�Zd
�Zd�Zd�Zd�ZRS(cC@s
|
|_dS(
N(
trepo(tselfR((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt__init__s
c

C@s|jj
�
d|_dS(
N(RtunlocktNone(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pytreleases


c


C@s|S(
N((
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt	__enter__s
c
C@s|jr|j
�
ndS(
N(RR(Rtexc_typetexc_valtexc_tb((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt__exit__s
	
c


C@s|jr|j
�
ndS(
N(RR(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt__del__s
	
(t__name__t
__module__RRRRR(((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRs

				c

C@s4|s
|Stj
d
|�r |Sd|jdd�S(Ns[a-zA-Z0-9@%_+=:,./-]*$s'%s't
's'\''(tretmatchtreplace(
t
s((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_serverquote"s




cC@sLtj
|
�
}|rHx0|j�D]}|jtd
�
|d�
q"WndS(sYdisplay all data currently available on pipe as remote output.

    This is non blocking.sremote: s

N(Rtreadpipet
splitlineststatusR
(tuitpipeRt
l((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_forwardoutput*s


t
doublepipecB@sYeZ
dZd
�Zd�Zd�Zd�Zd�Zd	d�
Z	d�Z
d�ZRS(
s4Operate a side-channel pipe in addition of a main one

    The side-channel pipe contains server output to be forwarded to the user
    input. The double pipe will behave as the "main" pipe, but will ensure the
    content of the "side" pipe is properly processed while we wait for blocking
    call on the "main" pipe.

    If large amounts of data are read from "main", the forward will cease after
    the first bytes start to appear. This simplifies the implementation
    without affecting actual output of sshpeer too much as we rarely issue
    large read for data not yet emitted by the server.

    The main pipe is expected to be a 'bufferedinputpipe' from the util module
    that handle all the os specific bites. This class lives in this module
    because it focus on behavior specific to the ssh protocol.cC@s|
|_||_
||_dS(
N(t_uit_maint_side(RRtmaintside((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRDs
	
	
c
C@s�t|j
d
t�rttfS|j
j�|jj�g}
ytj|
�
}Wntk
ri


|
}n
X|j
j�|k|jj�|kfS(s�wait until some data are available on main or side

        return a pair of boolean (ismainready, issideready)

        (This will only wait for data if the setup is supported by `util.poll`)
        t	hasbuffer(	tgetattrR#tFalsetTruetfilenoR$RtpolltNotImplementedError(Rtfdstact((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_waitIs








cC@s|jd
|
�S(Ntwrite(
t_call(Rtdata((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR1Zs
cC@s|jd
|
�S(Ntread(
R2(Rtsize((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR4]s
c

C@s
|jd
�
S(Ntreadline(
R2(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR6`s
cC@s�|dk	r|s|j
jr6t|j|j�
d
Sxptr�|j�\}}|rmt|j|j�
n|r9t|j
|
�}|dkr�|�S||�
Sq9q9WdS(sKcall <methname> on "main", forward output of "side" while blocking
        tN(	R
R#tclosedR R"R$R*R0R((RtmethnameR3t	mainreadyt	sidereadytmeth((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR2cs


	






c


C@s
|jj
�S(
N(R#tclose(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR=us
c


C@s
|jj
�S(
N(R#tflush(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR>xs
N(RRt__doc__RR0R1R4R6R
R2R=R>(((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR!3s						tsshpeercB@s�eZ
ed�
Zd
�Zd�Zd�Zd�Zd�Zd�Z	e	Z
d�Zd�Zd	�Z
d
�Zd�Zd�Zd
�Zd�Zed�
Zd�Zd�Zdd�
ZRS(c
C@s�
||_|
|_
d|_|_|_tj|d
tdt�
}|j	dksl|j
sl|jdkr�|jt
jtd�
|�
�

ntj|�

|j|_|jdk	r�|jt
jtd�
�
�

n|j
|_
|j|_|jp�d|_|j
jddd�}|j
jddd	�}tj||j
|j|j�}|r�
d
||tjdt|�
t|j�
f�
f}|
jd|�

|
j|�
}	|	d
kr�
|jt
jtd�
�
�

q�
n|j|||�
dS(Nt
parsequeryt
parsefragmenttsshscouldn't parse location %sspassword in URL not supportedt
.Rt	remotecmdthgs%s %s %ss
%s init %ssrunning %s
iscould not create remote repo(t_urlRR
tpipeotpipeitpipeeRturlR)tschemethosttpatht_abortRt	RepoErrorR
tchecksafesshtusertpasswdtporttconfigtsshargst
shellquoteRtdebugtsystemt
_validaterepo(
RRRNtcreatet
utsshcmdREtargstcmdtres((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR|s2
	
	

(
#






!
	
	
#



"c


C@s|jS(
N(
RG(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRK�s
c
C@s)|j�
d
|
|t
jdt|�
t|j�
f�
f}|jjd|�

t
j|�
}t
j|dd�

}|\|_	|_
|_|_t
j
|j
�
|_
t|j|j
|j�|_
t|j|j	|j�|_	|jd�

|jddd	d
dd
df�

}dd
g}d}x�|dr�
|r�
|j�}	|j�
|ddkru
|	dkru
Pn|	r�
|jjd|	�
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
tbufsizeithellotbetweentpairss%s-%st
0i(R7tdummyi�
i����s1
s

sremote: i
s#no suitable response from remote hgs
capabilities:t
:(tcleanupRRWRRNRRXtquotecommandtpopen4RHRIRJt
subprocesstbufferedinputpipeR!t_callstreamR6treaderrtappendRORRPR
tsett_capstreversedt
startswithtupdatetsplit(
RR]R^RER_tsubt
rtlinest	max_noiseR((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRZ�s<
	
	
#






'















'
c


C@s|jS(
N(
Rq(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt
_capabilities�s
c

C@st|j
|j�
dS(
N(R RRJ(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRn�s
c
C@s|j�
|
�
dS(
N(
Rh(Rt	exception((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRO�s


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


n
X|jj�
dS(Nsremote: (
RHR
R=RIRJRRR
tIOErrort
ValueError(RR((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRh�s







!


cc@s�|jd
dt
j|
�
�

}|j�}t|d�}|j|�
}||8}|}xu|r�x6d|kr�|jdd�\}}t
j|�
V
qdWt|d�}|j|�
}||8}||7}q[Wt
j|�
V
dS(Ntbatchtcmdsit
;i
(RmRtencodebatchcmdst
_getamounttminR4Rutunescapearg(Rtreqtrspt	availablettoreadtworktchunktone((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_submitbatch�s






	








cK@sS
|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�Wq�|jj|�

q�W|jj�
|j
S(Nssending %s command
s%s
t
*s%s %d
(RRXRHR1RtcommandsRutsortedt	iteritemstlent
isinstancetdictR>RI(RR_R^t_functnamestkeystwireargst
kt
vtdktdv((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyRm�s(













 


 


cK@s|j|
|�
S(
N(
Rm(RR_R^((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_callcompressable
s
cK@s|j|
|�

|j
�S(
N(Rmt_recv(RR_R^((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR2
s

c@s�|j|
|�
}|r"d
|fSx-t
�f
d�d
�D]}|j|�

q;W|jd
dt�


|j�}|r�d
|fS|j�d
fS(NR7c@s
�jd
�
S(Ni(
R4((
tfp(s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt<lambda> 
sR>(R2titert_sendR*R�(RR_R�R^Rwt
d((
R�s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt	_callpush
s











c@s~|j|
|�
}|r4t
jtd
�
|�
�
nx-t�f
d�d�D]}|j|�

qMW|jddt�


|jS(Nsunexpected remote reply: %sc@s
�jd
�
S(Ni(
R4((
R�(s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�-
sR7R>(R2RtAbortR
R�R�R*RI(RR_R�R^RwR�((
R�s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt_calltwowaystream(
s





c
C@s�|jj
�}
|
d
krM|j�
td�
}|jtjd|�
�

n|j�
yt|
�
SWn0tk
r�


|jtj	td�
|
��

n
XdS(Ns

scheck previous remote outputthintsunexpected response:(
RIR6RnR
RORtOutOfBandErrortintR}t
ResponseError(RRtmsg((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�2
s












c

C@s|jj
|j��
S(
N(RIR4R�(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�>
s
cC@sW|jj
d
t|
�
�

|
r3|jj
|
�

n|rI|jj�
n|j�
dS(Ns%d
(RHR1R�R>Rn(RR3R>((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�A
s





c

C@s|jd
�

t
|�
S(Ntlock(R2R(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�I
s


c

C@s|jd
�

dS(NR	(
R2(
R((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR	M
s
c@s�|jd
�
}|r8|j
tjtd�
|�
�

nx:t�f
d�d�D] }|jj|�

|j�
qQW|jj	�
|j�
|j
�}|s�dSyt|�
SWn0tk
r�


|j
tj
td�
|��

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: %sc@s
�jd
�
S(Ni(
R4((
tcg(s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�W
sR7i
sunexpected response:N(R2RORRPR
R�RHR1RnR>R�R�R}R�(RR�tsourceRKR�R�Rw((
R�s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR�P
s

#












N(RRR)RRKRZRzRnRORhRR�RmR�R2R�R�R�R�R�R�R	R
R�(((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyR@{s(
"		/				
						
				(t
__future__RRti18nR
R7RRRtobjectRRR R!twirepeerR@tinstance(((s5/usr/lib/python2.7/dist-packages/mercurial/sshpeer.pyt<module>s
			H�