�
�Xc@@s�
dd
lm
Z

ddlZddlZddlZddlZddlZddlZddlZddl	Z	ddl
Z
ddlZddlm
Z

ddlmZmZmZ
dad�Zdef
d��YZd	ef
d
��YZdef
d��YZd
�Zd�Zdef
d��YZd�Zd�Zdef
d��YZdef
d��YZied6ed6Z d�Z!dS(i(
tabsolute_importNi
(
t
_(tencodingterrortutilcG@s<ts
dSx!|D]}
tj
t|
�
�

qWtj�
dS(
N(tlogfiletwritetstrtflush(targst
a((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytlogs




tchanneledoutputcB@s8eZ
dZd
�Zed��
Zd�Zd�ZRS(s^
    Write data to out in the following format:

    data length (unsigned int),
    data
    cC@s|
|_||_
dS(
N(touttchannel(tselfR
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__init__.s
	
c

C@sd
|jS(Ns<%c-channel>(
R(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytname2scC@sS|
s
dS|jj
tjd
|jt|
�
��

|jj
|
�

|jj�
dS(Ns>cI(R
RtstructtpackRtlenR(Rtdata((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR6s



(

cC@s+|
dkrt|
�
�
nt
|j|
�S(Ntisattytfilenottelltseek(RRRR(tAttributeErrortgetattrR
(Rtattr((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__getattr__=s


(t__name__t
__module__t__doc__RtpropertyRRR(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR's

		tchanneledinputcB@sheZ
dZdZd�Zed��
Zdd�
Zd�Zdd�
Z	d	�Z
d
�Zd�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
    iicC@s|
|_||_
||_dS(
N(tin_R
R(RR#R
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRQs
	
	
c

C@sd
|jS(Ns<%c-channel>(
R(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRVsi����cC@sw|
d
kr`|j}
|j
|
|j�}|}x)|r[|j
|
|j�}||7}q3W|S|j
|
|j�SdS(Ni(tmaxchunksizet_readR(Rtsizet
stbuf((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytreadZs
	


	

cC@s�|
s
d
S|
dkst�
|j
jtjd||
��

|j
j�
|jjd�
}tjd|�d}|szd
S|jj|�
SdS(Ntis>cIis>I(	tAssertionErrorR
RRRRR#R)tunpack(RR&Rtlength((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR%is







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

(R$R%(RR&R'R(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytreadlineys

	



c


C@s|S(
N((
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt__iter__�s
c

C@s|j�}
|
st
�
n|
S(
N(R/t
StopIteration(Rt
l((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytnext�s


	
cC@s+|
dkrt|
�
�
nt
|j|
�S(NRRRR(RRRR(RRR#(RR((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�s


i(
RRR R$RR!RR)R%R/R0R3R(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR"Bs				tservercB@sseZ
dZd
�Zd�Zd�Zd�Zd�Zd�Zd�Z	d�Z
ied	6e	d
6Zd�ZRS(sm
    Listens for commands on fin, runs them and writes the output on a channel
    based stream to fout.
    cC@s�tj
�|_|
jd
dd�}|rZ|dkrHt|d�aqZt|d�an|r�|j|_	||_
|j	|_n|
|_	d|_
|_t|d�|_t|d�|_
t||d�|_t|d	�|_||_dS(
Nt	cmdserverRt
-t
dR
t
et
ot
It
r(tostgetcwdtcwdtconfigtNoneRRtopentbaseuituitrepotrepouitcerrtcoutR"tcintcresulttclient(RRCRDtfintfouttlogpath((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�s"


	
	



c


C@sd
S(s9release and restore resources taken during server sessionN((
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytcleanup�scC@s/|
s
d
S|jj
|
�
}|s+t�
n|S(NR*(RJR)tEOFError(RR&R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR%�s


	c
C@s6tj
d
|jd�
�d}
|
s)dS|j|
�
S(s[read a string from the channel

        format:
        data length (uint32), data
        s>IiiR*(RR,R%(RR-((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_readstr�s


c
C@s'|j�}
|
r|
j
d
�
SgSdS(s6read a list of NULL separated strings from the channels
N(RPtsplit(RR'((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt	_readlist�s


c
	C@sr
d
dlm
}

|j�}|jj�}|g
}|jr�||j_|jj|j�
}|j|_|j	|�

||j_|jj
_|jj�
nxF|D]>}|j
�
tj|jd�s�|jdddd�
q�q�W|
j|||j|j|j|j�}|
j
|�
p&
dd	@}d
|krL
tj|j�

n|jjtjdt|�
��

dS(
sk reads a list of  terminated arguments, executes
        and writes the return code to the result channel i
(
tdispatchRRCtnonttyttruet
commandserverii�s--cwds>iN(R*RSRRRCtcopyRDRBREt	__class__tappendtdirstatet_uit
invalidateallt
resetstateRtsafehasattrRHt	setconfigtrequestRGRFR<tchdirR>RIRRRtint(	RRSR	tcopieduituisRERCtreqtret((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
runcommand�s*
	
	











c

C@s|jj
tj�

d
S(s3 writes the current encoding to the result channel N(RIRR(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytgetencoding
sc
C@sd|jj
�d
 }
|
rZ|jj|
�
}|r>||�

qZtjtd�
|
�
�
n|
dkS(Ni����sunknown command %sR*(RJR/tcapabilitiestgetRtAbortR
(Rtcmdthandler((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytserveone
s





RgRhc
C@s�d
djt
|j�
�
}
|
d7}
|
dtj7}
|
d7}
|
dtj�7}
tjtd�r�|
d7}
|
dtjd�
7}
n|j	j
|
�

yx|j�r�q�WWntk
r�


d	SXdS(
Nscapabilities: t
 s

s
encoding: spid: %dtgetpgidspgid: %dii
(
tjointsortedRiRRtgetpidR^R<RpRGRRnRO(Rthellomsg((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytserve
s














(
RRR RRNR%RPRRRgRhRnRiRu(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR4�s
						'		


c
C@s�|j�
g}
t
jt
jt
j�}x�|jtjd
f|jtj	dfgD]h\}}}||kr�t
j
|j��
}t
j||j��
t
j
||�}n|
j|�

qSWt
j|�

t|
�
S(sC duplicates streams and redirect original to null if ui uses stdio trbtwb(RR<RAtdevnulltO_RDWRRKtsyststdinRLtstdouttdupRtdup2tfdopenRYtclosettuple(RCtnewfilestnullfdt
ftsysftmodetnewfd((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_protectio.
s




%







cC@sr|j�
xa|
|j
f||jfgD]A\}}||k	r)tj|j�|j��
|j�
q)q)Wd
S(s' restores streams from duplicated ones N(RRKRLR<R~RR�(RCRKRLR�tuif((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_restoreio=
s


+


tpipeservicec
B@s#eZ
d�Zd
�Zd�ZRS(cC@s|
|_||_
dS(
N(RCRD(RRCRDtopts((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyRF
s
	
c


C@sdS(
N((
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytinitJ
s
c
C@sc|j}
t
|
�
\}}z&t|
|j||�}|j�SWd|j�
t|
||�
XdS(
N(RCR�R4RDRuRNR�(RRCRKRLtsv((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytrunM
s
	




(RRRR�R�(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�E
s
		cC@stj
d
d
�
tj�
dS(Ni(R<tsetpgidtrandomtseed(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_initworkerprocessY
sc	C@sW
|jd
�
}|jd�
}d}z�y�||
|||�}z|y|j�
Wngtjk
r
}
|jtd�
|�

n;tk
r�
}
|jtj	kr��q�nt
k
r�


n
XWd|j�
XWn;


|r�|j}nt
|d�}tjd|�

�n
XWd|j�
y|j�
Wn+tk
rQ

}
|jtj	krR
�qR
n
XXdS(NRvRws
abort: %s
R8tfile(tmakefileR@RuRRktwarnR
tIOErrorterrnotEPIPEtKeyboardInterruptRNRFRt	tracebackt	print_excR�(	RCRDtconntcreatecmdserverRKRLR�tinstRF((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
_serverequestj
s:










	












tunixservicehandlerc
B@sSeZ
dZdZd
�Zd�Zd�Zd�Zd�Z	d�Z
d�ZRS(	s�Set of pluggable operations for unix-mode services

    Almost all methods except for createcmdserver() are called in the main
    process. You can't pass mutable resource back from createcmdserver().
    cC@s
|
|_dS(
N(
RC(RRC((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�
s
cC@stj
|
|�
dS(
N(Rtbindunixsocket(Rtsocktaddress((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
bindsocket�
s
cC@stj
|
�

dS(
N(R<tunlink(RR�((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytunlinksocket�
s
cC@s+|jj
td
�
|
�

|jj�
dS(Nslistening at %s
(RCtstatusR
R(RR�((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pytprintbanner�
s

c


C@stS(
s9True if server should shut down; checked per pollinterval(
tFalse(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
shouldexit�
sc


C@sd
S(s/Called when main process notices new connectionN((
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
newconnection�
scC@st|j
|
||�S(
shCreate new command server instance; called in the process that
        serves for the current connection(R4RC(RRDR�RKRL((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
sN(RRR R@tpollintervalRR�R�R�R�R�R�(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s						tunixforkingservicecB@sYeZ
dZd	d
�
Zd�Zd�Zd�Zd�Zd�Z	d�Z
d�ZRS(
sG
    Listens on unix domain socket and forks server per connection
    cC@s�|
|_||_
|d
|_tjtd�sItjtd�
�
�
n|jsjtjtd�
�
�
n|pyt	|
�
|_
d|_d|_
t�|_dS(NR�tAF_UNIXsunsupported platforms'no socket path specified with --address(RCRDR�RR^tsocketRRkR
R�t_servicehandlerR@t_sockt_oldsigchldhandlertsett_workerpids(RRCRDR�Rm((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�
s
	
	




	


	
	
c
C@sytjtj
�
|_|jj|j|j�
|jjtj�

tjtj	|j
�}
|
|_|jj|j�

dS(
N(
R�R�R�R�R�R�tlistent	SOMAXCONNtsignaltSIGCHLDt_sigchldhandlerR�R�(RR9((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s




	
c

C@sGtjtj
|j�
|jj�
|jj|j�

|jd
�

dS(Ni(	R�R�R�R�R�R�R�R�t_reapworkers(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt_cleanup�
s



c

C@s z|j�
Wd|j
�
XdS(
N(t	_mainloopR�(
R((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s

c
C@sZ
|j}
xJ
|
j
�sU
yJtj|jg
gg|
j�d
}|sLwn|jj�\}}Wn>tjtjfk
r�
}
|jd
t	j
kr�qn�n
Xtj�}|r�z2|j
jd|�

|jj|�

|
j�
Wd|j�
Xqy(|j|�

|j�
tjd
�

Wq


z|j
jdt�

Wdtjd�

XqXqWdS(Nisforked worker process (pid=%d)
tforcei�(R�R�tselectR�R�tacceptRR�R	R�tEINTRR<tforkRCtdebugR�taddR�R�t
_runworkert_exitR�tTrue(Rt
htreadyR�t_addrR�tpid((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s4
	


%



















cC@s|jt
j�

dS(
N(R�R<tWNOHANG(RR�tframe((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s
cC@s�x�|jr�yt
jd
|
�\}}WnQtk
r{
}
|jtjkrRqn|jtjkrj�n|jj�
dSX|dkr�dS|jj	d|�

|jj
|�

qWdS(Ni����isworker process exited (pid=%d)
(R�R<twaitpidtOSErrorR�R�tECHILDtclearRCR�tdiscard(RtoptionsR�t_statusR�((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s












cC@sXtjtj
|j�
t�
|j}z t|j|j|
|j�
Wdt	j
�
XdS(
N(R�R�R�R�R�R�RCRDR�tgctcollect(RR�R�((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR�
s


	

 N(RRR R@RR�R�R�R�R�R�R�(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyR��
s
				 		tpipetunixcC@sS|d
}yt|||
|�SWn*t
k
rN


tjtd�
|�
�
n
XdS(NR5sunknown mode %s(t_servicemaptKeyErrorRRkR
(RCRDR�R�((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt
createservices







("t
__future__RR�R�R<R�R�R�R�RRzR�ti18nR
R*RRRR@RRtobjectRR"R4R�R�R�R�R�R�R�R�R�(((s;/usr/lib/python2.7/dist-packages/mercurial/commandserver.pyt<module>s8









		T�				$#e