ó
{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




"