��Qc@s�dd
lm
Z

ddlZddlZddlZddlZddlZddlZda	d�Z
def
d��YZdef
d��YZ
def
d	��YZdS(
i�(
t
_NcGs<ts
dSx!|D]}
tj
t|
��
qWtj�
dS(
N(tlogfiletwritetstrtflush(targst
a((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytlogs




tchanneledoutputc
Bs)eZ
dZd
�Zd�Zd�ZRS(sg
    Write data from in_ to out in the following format:

    data length (unsigned int),
    data
    cCs|
|_||_
||_dS(
N(tin_touttchannel(tselfR	R
R((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyt__init__s
	
	
cCsS|
s
dS|jj
tjd
|jt|
���
|jj
|
�
|jj�
dS(Ns>cI(R
RtstructtpackRtlenR(Rtdata((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR$s



(

cCs+|
dkrt|
��nt
|j|
�S(Ntisattytfileno(sisattysfileno(tAttributeErrortgetattrR	(Rtattr((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyt__getattr__+s


(t__name__t
__module__t__doc__R
RR(((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyRs
		tchanneledinputcBsYeZ
dZdZd�Zdd�Zd�Zdd�Zd�Zd	�Z	d
�Z
RS(s/

    Read data from in_.

    Requests for input are written to out in the following format:
    channel identifier - 'I' for plain input, 'L' line based (1 byte)
    how many bytes to send at most (unsigned int),

    The client replies with:
    data length (unsigned int), 0 meaning EOF
    data
    iicCs|
|_||_
||_dS(
N(R	R
R(RR	R
R((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR
?s
	
	
i�cCsw|
d
kr`|j}
|j
|
|j�}|}x)|r[|j
|
|j�}||7}q3W|S|j
|
|j�SdS(Ni(tmaxchunksizet_readR(Rtsizet
stbuf((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytreadDs
	


	

cCs�|
s
d
S|
dkst�|j
jtjd||
��
|j
j�
|jjd�}tjd|�d}|szd
S|jj|�SdS(Ntis>cIis>I(	tAssertionErrorR
RRRRR	R!tunpack(RRRtlength((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyRSs







cCs~|
d
krj|j}
|j
|
d�}|}x6|re|ddkre|j
|
d�}||7}q0W|S|j
|
d�SdS(Nit
Li�s

(RR(RRRR ((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytreadlinecs

	



c


Cs|S(
N((
R((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyt__iter__rs
c

Cs|j�}
|
st
�n|
S(
N(R't
StopIteration(Rt
l((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytnextus


	
cCs+|
dkrt|
��nt
|j|
�S(NRR(sisattysfileno(RRR	(RR((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR{s


i(RRRRR
R!RR'R(R+R(((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR0s				tservercBsXeZ
dZd
�Zd�Zd�Zd�Zd�Zied6ed6Zd�Z	RS(	sq
    Listens for commands on stdin, runs them and writes the output on a channel
    based stream to stdout.
    cCs(
tj
�|_|
jd
dd�}|rc|dkrQttjtjd�aqct	|d�an|j
|_||_|j|_
|dkr
ttjtjd�|_ttjtjd�|_ttjtjd	�|_ttjtjd
�|_tj|_ntjtd�|��dS(Nt	cmdserverRt
-t
dRtpipet
et
ot
It
rsunknown mode %s(tostgetcwdtcwdtconfigtNoneRtsyststdoutR
topentbaseuituitrepotrepouitstderrtcerrtcoutRtstdintcintcresulttclienttutiltAbortR(RR>R?tmodetlogpath((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR
�s 


	




cCs/|
s
d
S|jj
|
�}|s+t�n|S(NR"(RGR!tEOFError(RRR((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR�s


	c
Cs"
tj
d
|jd��d}
|
s.g}n|j|
�jd�}|jj�}||j_|jj�|j_|jj	_
|jj�
|jj�
t
j|||j|j|j|j�}t
j
|�p�d}d|kr�j|j�
n|jjtjdt|���
dS(sk reads a list of  terminated arguments, executes
        and writes the return code to the result channel s>Iiit
s--cwds>iN(RR$RtsplitR>tcopyR?R=R@tdirstatet_uit
invalidatetinvalidatedirstatetdispatchtrequestRERCRBR5tchdirR7RFRRtint(RR%Rtcopieduitreqtret((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyt
runcommand�s

	

"





c

Cs|jj
tj�
d
S(s3 writes the current encoding to the result channel N(RFRtencoding(
R((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytgetencoding�sc
Csd|jj
�d
 }
|
rZ|jj|
�}|r>||�
qZtjtd�|
��n|
dkS(Ni�sunknown command %sR"(RGR'tcapabilitiestgetRHRIR(Rtcmdthandler((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytserveone�s





R[R]c
Cswd
djt
|j��}
|
d7}
|
dtj7}
|jj|
�
yx|j�r\qMWWntk
rr


dSXdS(Nscapabilities: t
 s

s
encoding: i
i(tjointsortedR^R\RCRRbRL(Rthellomsg((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pytserve�s







(
RRRR
RR[R]RbR^Rg(((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyR,�s
					


(ti18nRRR:R5RTR\RHR9R
RtobjectRRR,(((s;/sys/lib/python2.7/site-packages/mercurial/commandserver.pyt<module>s


$		P