�
{fc@s�dd
dgZddl
Z
ddlZddlZddlZddlZddlZddlZddlZddl	m
Z
mZ
ddlm
Z
mZmZmZ
ddlmZmZ
dZd	Zd
Zej�ZdZdg
Zeed�r
dZedg
7Znejd
kr4
dZedg
7Zned�
Zd�Zd�Zd�Z d
e!f
d��YZ"ddd�Z$ejd
kr�
e%d�
Z&nddlm'Z'
e%d�
Z&de!f
d��YZ(d�Z)ejd
kr
de!f
d��YZ*d�Z+ndZ,dZ-d Z.d!Z/d"�Z0d#�Z1d$�Z2d%e!f
d&��YZ3d'�Z4d(�Z5d)e"f
d*��YZ6d+�Z7dS(,tClienttListenertPipei����N(tcurrent_processtAuthenticationError(tget_temp_dirtFinalizet	sub_debugtdebug(t	duplicatetclosei g4@tsha256tAF_INETtAF_UNIXtwin32tAF_PIPEc

Cstj�|S(
N(
ttime(
ttimeout((s2/usr/lib64/python2.7/multiprocessing/connection.pyt
_init_timeoutMs
c

Cstj�|kS(
N(
R(
t
t((s2/usr/lib64/python2.7/multiprocessing/connection.pyt_check_timeoutPs
c

Cs}|d
krd
S|dkr5tj
dddt��S|dkrmtj
dd	tj�tj�fdd
�Std�
�
dS(s?
    Return an arbitrary free address for the given family
    Rt	localhostiR
tprefixs	listener-tdirRs\\.\pipe\pyc-%d-%d-tsunrecognized familyN(Ri(ttempfiletmktempRtostgetpidt
_mmap_countertnextt
ValueError(
tfamily((s2/usr/lib64/python2.7/multiprocessing/connection.pytarbitrary_addressWs





 c

Cset|�
t
krd
St|�
tkr;|jd�
r;dSt|�
tkrQdStd|�
�
dS(s]
    Return the types of the address

    This can be 'AF_INET', 'AF_UNIX', or 'AF_PIPE'
    Rs\\RR
saddress type of %r unrecognizedN(ttypettupletstrt
startswithR(
taddress((s2/usr/lib64/python2.7/multiprocessing/connection.pytaddress_typefs

!


cBsSeZ
dZddd
dd�Zd�Zd�Zed��
Zed��
Z	RS(s�
    Returns a listener object.

    This is a wrapper for a bound socket which is 'listening' for
    connections, or for a Windows named pipe.
    i
cCs�|p|
rt|
�
pt
}|
p-t|�
}
|d
krQt|
|�|_nt|
||�|_|dk	r�t|t�r�t	d�n||_
dS(NRsauthkey should be a byte string(R'tdefault_familyR!tPipeListenert	_listenertSocketListenertNonet
isinstancetbytest	TypeErrort_authkey(tselfR&R tbacklogtauthkey((s2/usr/lib64/python2.7/multiprocessing/connection.pyt__init__�s




c
Cs?|jj
�}
|jr;t|
|j�
t|
|j�
n|
S(
sz
        Accept a connection on the bound socket or named pipe of `self`.

        Returns a `Connection` object.
        (R*tacceptR0tdeliver_challengetanswer_challenge(R1t
c((s2/usr/lib64/python2.7/multiprocessing/connection.pyR5�s

	


c


Cs
|jj
�S(
sA
        Close the bound socket or named pipe of `self`.
        (R*R
(
R1((s2/usr/lib64/python2.7/multiprocessing/connection.pyR
�sc


Cs
|jj
S(
N(R*t_address(
R1((s2/usr/lib64/python2.7/multiprocessing/connection.pyt<lambda>�Rc


Cs
|jj
S(
N(R*t_last_accepted(
R1((s2/usr/lib64/python2.7/multiprocessing/connection.pyR:�RN(
t__name__t
__module__t__doc__R,R4R5R
tpropertyR&t
last_accepted(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR
ys
		
cCs�|
pt|�
}
|
d
kr-t
|�
}nt|�
}|dk	rat|t�ratd�n|dk	r�t||�
t||�
n|S(s=
    Returns a connection to the address of a `Listener`
    Rsauthkey should be a byte stringN(	R't
PipeClienttSocketClientR,R-R.R/R7R6(R&R R3R8((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s





c
Cs�|r�tj
�\}
}|
jt�

|jt�

tjtj|
j��
�
}tjtj|j��
�
}|
j	�
|j	�
n<tj
�\}}tj|d
t�

}tj|dt�

}||fS(sL
        Returns pair of connection objects at either end of a pipe
        twritabletreadable(tsockett
socketpairtsetblockingtTruet_multiprocessingt
ConnectionRtduptfilenoR
tpipetFalse(tduplexts1ts2tc1tc2tfd1tfd2((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s












(
Rc
	CsU
td
�
}
|r;t
j}t
jt
jB}tt}}nt
j}t
j}dt}}t
j|
|t
jt
j	Bt
j
Bd||t
jt
j�}t
j
|
|dt
jt
jdt
j�}t
j|t
j	dd�
yt
j|t
j�
Wn/tk
r 

}
|jdt
jkr!
�q!
n
Xtj|d|�

}	tj|d|�

}
|	|
fS(sL
        Returns pair of connection objects at either end of a pipe
        Rii
RCRDN(R!RtPIPE_ACCESS_DUPLEXtGENERIC_READt
GENERIC_WRITEtBUFSIZEtPIPE_ACCESS_INBOUNDtCreateNamedPipetPIPE_TYPE_MESSAGEtPIPE_READMODE_MESSAGEt	PIPE_WAITtNMPWAIT_WAIT_FOREVERtNULLt
CreateFilet
OPEN_EXISTINGtSetNamedPipeHandleStateR,tConnectNamedPipetWindowsErrortargstERROR_PIPE_CONNECTEDRItPipeConnection(ROR&topenmodetaccesstobsizetibsizeth1th2t
eRRRS((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�s2

	

	
	







$






R+cBs,eZ
dZd
d�
Zd�Zd�ZRS(sO
    Representation of a socket which is bound to an address and listening
    i
cCs�tjt
t|��
|_yb|jjtjtjd
�
|jjt�

|jj|
�

|jj	|�

|jj
�|_Wn$tjk
r�


|jj
�
�n
X||_d|_|dkr�t|tjd|
f
dd�|_n	d|_dS(Ni
R
Rftexitpriorityi(REtgetattrt_sockett
setsockoptt
SOL_SOCKETtSO_REUSEADDRRGRHtbindtlistentgetsocknameR9terrorR
t_familyR,R;RRtunlinkt_unlink(R1R&R R2((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4�s 











	
	

$c
Cs�x\tr^y|j
j�\}
|_Wn2tjk
rY
}
|jd
tjkr[�q[qXPqW|
j	t�

t
|
j��
}tj
|�
}|
j�
|S(Ni(RHRrR5R;RERyRfterrnotEINTRRGR	RLRIRJR
(R1t
sRotfdtconn((s2/usr/lib64/python2.7/multiprocessing/connection.pyR5
s
	












c
CsAz|jj
�
Wd|j}
|
dk	r<d|_|
�
nXdS(
N(RrR
R|R,(R1R{((s2/usr/lib64/python2.7/multiprocessing/connection.pyR
#
s

	

	
(R<R=R>R4R5R
(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR+�s
	c
Cs�tt
t|�
�}
t�}x�t
j
|
�
}|jt�

y|j|�

Wnbt
jk
r�
}
|j�
|j	d
t
jks�t|�
r�t
d|�
�ntjd�

q!XPq!W�t|j��
}tj|�
}|j�
|S(sO
    Return a connection object connected to the socket given by `address`
    isfailed to connect to address %sg{�G�z�?(RqRER'RRGRHtconnectRyR
RfR}tECONNREFUSEDRRRtsleepR	RLRIRJ(R&R RRRoR�R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyRB-
s&
	








"







R)cBs2eZ
dZdd
�
Zd�Zed��
ZRS(s0
        Representation of a named pipe
        c	Cs�|
|_t
j|
t
jt
jt
jBt
jBt
jttt
j	t
j
�}|g
|_d|_
td
|j�
t|tjd|j|jfdd�|_dS(Ns listener created with address=%rRfRpi(R9RR[RVR\R]R^tPIPE_UNLIMITED_INSTANCESRYR_R`t
_handle_queueR,R;RRR)t_finalize_pipe_listenerR
(R1R&R2thandle((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4S
s
	

	





	

c
	Cs�tj
|jtjtjtjBtjBtjtttj	tj
�}
|jj|
�

|jj
d
�
}ytj|tj
�
Wn8tk
r�
}
|jd
tjtjfkr��q�n
Xtj|�
S(Ni(RR[R9RVR\R]R^R�RYR_R`R�tappendtpopRdReRfRgt
ERROR_NO_DATARIRh(R1t	newhandleR�Ro((s2/usr/lib64/python2.7/multiprocessing/connection.pyR5f
s














cCs,td
|
�
x|D]}t
|�

qWdS(Ns closing listener with address=%r(RR
(tqueueR&R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR�z
s



N(R<R=R>R,R4R5tstaticmethodR�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR)O
s
	c
Cs�t�}
x�yHt
j|d
�
t
j|t
jt
jBdt
jt
jdt
j�}WnDtk
r�
}
|j	dt
j
t
jfks�t|
�
r��q�qXPqW�t
j
|t
jdd�
tj|�
S(sU
        Return a connection object connected to the pipe given by `address`
        i�iN(RRt
WaitNamedPipeRaRWRXR`RbReRftERROR_SEM_TIMEOUTtERROR_PIPE_BUSYRRcR]R,RIRh(R&Rt
hRo((s2/usr/lib64/python2.7/multiprocessing/connection.pyRA�
s 	





"




is#CHALLENGE#s	#WELCOME#s	#FAILURE#c
Csd
dl}t
|t�S(Ni����(thashlibRqtHMAC_DIGEST_NAME(
R�((s2/usr/lib64/python2.7/multiprocessing/connection.pytget_digestmod_for_hmac�
s

cCs�d
dl}t
jt�
}|jt|�

|j|
|t��j�}|j	d�
}||kru|jt
�

n|jt�

td�
�
dS(Ni����i
sdigest received was wrong(
thmacRturandomtMESSAGE_LENGTHt
send_bytest	CHALLENGEtnewR�tdigestt
recv_bytestWELCOMEtFAILURER(t
connectionR3R�tmessageR�tresponse((s2/usr/lib64/python2.7/multiprocessing/connection.pyR6�
s







cCs�d
dl}|j
d�
}|tt�
}|j|
|t��j�}|j|�

|j
d�
}|tkr�t	d�
�
ndS(Ni����i
sdigest sent was rejected(
R�R�tlenR�R�R�R�R�R�R(R�R3R�R�R�R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR7�
s






tConnectionWrapperc
Bs#eZ
d�Zd
�Zd�ZRS(cCsO|
|_||_
||_x-dD]%}t|
|�}t|||�
q"WdS(NRLR
tpollR�R�(RLR
R�R�R�(t_connt_dumpst_loadsRqtsetattr(R1R�tdumpstloadstattrtobj((s2/usr/lib64/python2.7/multiprocessing/connection.pyR4�
s
	
	
	



cCs#|j|
�
}|j
j|�

dS(
N(R�R�R�(R1R�R((s2/usr/lib64/python2.7/multiprocessing/connection.pytsend�
s

c
Cs|jj
�}
|j|
�
S(
N(R�R�R�(R1R((s2/usr/lib64/python2.7/multiprocessing/connection.pytrecv�
s

(R<R=R4R�R�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR��
s
		c

Cstj
|f
dddd
�S(Ni
(t	xmlrpclibR�R,(
R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyt
_xml_dumps�
s
c
Cstj
|�
\\
}
}|
S(
N(R�R�(RR�tmethod((s2/usr/lib64/python2.7/multiprocessing/connection.pyt
_xml_loads�
s

tXmlListenerc
BseZ
d�ZRS(
c
Cs+d
dlat
j|�
}
t|
tt�S(Ni����(R�R
R5R�R�R�(R1R�((s2/usr/lib64/python2.7/multiprocessing/connection.pyR5�
s

(R<R=R5(((s2/usr/lib64/python2.7/multiprocessing/connection.pyR��
s
cOs%d
dlat
t||
�tt�S(Ni����(R�R�RR�R�(Rftkwds((s2/usr/lib64/python2.7/multiprocessing/connection.pyt	XmlClient�
s
(8t__all__RtsysRER}RRt	itertoolsRItmultiprocessingRRtmultiprocessing.utilRRRRtmultiprocessing.forkingR	R
RYtCONNECTION_TIMEOUTR�tcountRR(tfamiliesthasattrtplatformRRR!R'tobjectR
R,RRHRRR+RBR)RAR�R�R�R�R�R6R7R�R�R�R�R�(((s2/usr/lib64/python2.7/multiprocessing/connection.pyt<module>#sd







"

	



			,*2	 1