��Qc@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��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((s//sys/lib/python2.7/multiprocessing/reduction.pytsend_handleAs



c


Cs
|j�S(
N(
trecv(
R((s//sys/lib/python2.7/multiprocessing/reduction.pytrecv_handleKs
cCstj
|j�|
�
dS(
N(t_multiprocessingtsendfdtfileno(RRR((s//sys/lib/python2.7/multiprocessing/reduction.pyROs
c

Cstj
|j��S(
N(RRR(
R((s//sys/lib/python2.7/multiprocessing/reduction.pyRRs
c
Cs;xtD]}
t
|
�
qWtj�
tj�adadS(
N(t_cacheRtcleart	threadingtLockt_locktNonet	_listener(tobjt
h((s//sys/lib/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((s//sys/lib/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�qXqdS(Ni
(t
is_exitingtsub_warningi�s.thread for sharing handles raised exception :
t
-iOs

(tutilR0R1R!tacceptRRtremoveRRt	tracebackt
format_exc(R0R1Rt
handle_wantedRR6((s//sys/lib/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((s//sys/lib/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((s//sys/lib/python2.7/multiprocessing/reduction.pytrebuild_handle�s










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

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

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



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

cCs/t|�}t
||
||�}t|�
|S(
N(RCRMR(RJRPRQRRRORK((s//sys/lib/python2.7/multiprocessing/reduction.pyRT�s




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

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

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

"