�
{fc@sgZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlm	Z	m
Z
mZmZ
ddl
mZmZmZ
ddlmZmZ
ejdkp�eed�s�ed�
�
nejdkr
dd
lZdd	lmZ
d
�Zd�Znd�Zd
�Ze�ad�Zed
�

eee�
d�Zd�Z d�Z!d�Z"d�Z#d�Z$ej%ej&e#�
dd�
Z'd�Z(d�Z)ej%eje(�
ejdkr�
d�Z*d�Z+ej%ej,e*�
nd
S(i����N(
tcurrent_process(tPopent	duplicatetclosetForkingPickler(tregister_after_forktdebugt	sub_debug(tClienttListenertwin32trecvfds%pickling of connections not supported(
R
cCsJtj
tjt|�}z t|
|�}|j|�

Wdt|�

XdS(
N(R
tOpenProcesstPROCESS_ALL_ACCESStFalseRtsendR(tconnthandletdestination_pidtprocess_handlet
new_handle((s1/usr/lib64/python2.7/multiprocessing/reduction.pytsend_handleAs



c


Cs
|j�S(
N(
trecv(
R((s1/usr/lib64/python2.7/multiprocessing/reduction.pytrecv_handleKs
cCstj
|j�|
�
dS(
N(t_multiprocessingtsendfdtfileno(RRR((s1/usr/lib64/python2.7/multiprocessing/reduction.pyROs
c

Cstj
|j��
S(
N(RRR(
R((s1/usr/lib64/python2.7/multiprocessing/reduction.pyRRs
c
Cs;xtD]}
t
|
�

qWtj�
tj�adadS(
N(t_cacheRtcleart	threadingtLockt_locktNonet	_listener(tobjt
h((s1/usr/lib64/python2.7/multiprocessing/reduction.pyt_reset[s






c
Cs�tdkr~tj�
zWtdkrltd
�

tdt�j�
atj	dt
�
}t|_|j
�
nWdtj�
XntS(Ns0starting listener and thread for sending handlestauthkeyttarget(R!R RtacquireRR	RR%RtThreadt_servetTruetdaemontstarttrelease(
t
t((s1/usr/lib64/python2.7/multiprocessing/reduction.pyt
_get_listenerfs








	
cCs�d
dlm
}m}

x�yStj�}|j�\}}tj|�

t|||�
t	|�

|j	�
Wq


|�s�ddl
}|
dddd|j�dd�

q�qXqWdS(Ni
(t
is_exitingtsub_warningi����s.thread for sharing handles raised exception :
t
-iOs

(tutilR0R1R!tacceptRRtremoveRRt	tracebackt
format_exc(R0R1Rt
handle_wantedRR6((s1/usr/lib64/python2.7/multiprocessing/reduction.pyR)ws











	

c
Cs[tj
�r"dtj|�
tfSt|�
}
tj|
�

td
|�
t	�j
|
tfS(Nsreducing handle %d(R
tthread_is_spawningR tduplicate_for_childR*RRtaddRR/taddressR(Rt
dup_handle((s1/usr/lib64/python2.7/multiprocessing/reduction.pyt
reduce_handle�s







c
Csq|\}
}}|r|Std
|�
t
|
dt�j�

}|j|tj�f�

t|�
}|j�
|S(Nsrebuilding handle %dR%(	RRRR%RtostgetpidRR(tpickled_dataR<Rt	inheritedRR((s1/usr/lib64/python2.7/multiprocessing/reduction.pytrebuild_handle�s










c
Cs+t|j
��
}
t|
|j|jffS(
N(R>Rtrebuild_connectiontreadabletwritable(Rtrh((s1/usr/lib64/python2.7/multiprocessing/reduction.pytreduce_connection�s

cCs%t|�
}t
j|d
|
d|�
S(NRERF(RCRt
Connection(treduced_handleRERFR((s1/usr/lib64/python2.7/multiprocessing/reduction.pyRD�s


icCsCtj
||
||�}|jtjk	r?tjd
|�
}n|S(Nt_sock(tsockettfromfdt	__class__(tfdtfamilyttype_tprotot
s((s1/usr/lib64/python2.7/multiprocessing/reduction.pyRM�s



c
Cs1t|j
��
}
t|
|j|j|jffS(
N(R>Rtrebuild_socketRPttypeRR(RSRJ((s1/usr/lib64/python2.7/multiprocessing/reduction.pyt
reduce_socket�s

cCs/t|�
}t
||
||�}t|�

|S(
N(RCRMR(RJRPRQRRRORK((s1/usr/lib64/python2.7/multiprocessing/reduction.pyRT�s




c
Cs+t|j
��
}
t|
|j|jffS(
N(R>Rtrebuild_pipe_connectionRERF(RRG((s1/usr/lib64/python2.7/multiprocessing/reduction.pytreduce_pipe_connection�s

cCs%t|�
}t
j|d
|
d|�
S(NRERF(RCRtPipeConnection(RJRERFR((s1/usr/lib64/python2.7/multiprocessing/reduction.pyRW�s


(-t__all__R?tsysRLRRtmultiprocessingRtmultiprocessing.forkingR
RRRtmultiprocessing.utilRRRtmultiprocessing.connectionRR	tplatformthasattrtImportErrort_subprocessR
RRtsetRR$R R/R)R>RCRHRDtregisterRIRMRVRTRXRWRY(((s1/usr/lib64/python2.7/multiprocessing/reduction.pyt<module>$sJ




"