File "reduction.pyc"

Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyc
File size: 6.09 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit


V~gc@sgZdd
l
Z
dd
lZdd
lZdd
lZdd
lZddlmZ
ddlm	Z	m
Z
mZmZ
ddl
mZmZmZ
ddlmZmZ
ejdkpeedsed

nejdkr
dd
lZdd	lmZ
d
ZdZndZd
ZeadZed


eee
dZdZ dZ!dZ"dZ#dZ$ej%ej&e#
dd
Z'dZ(dZ)ej%eje(
ejdkr
dZ*dZ+ej%ej,e*
nd
S(iN(
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>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pytsend_handleAs



c


Cs
|jS(
N(
trecv(
R((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pytrecv_handleKs
cCstj
|j|

dS(
N(t_multiprocessingtsendfdtfileno(RRR((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyROs
c

Cstj
|j
S(
N(RRR(
R((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyRRs
c
Cs;xtD]}
t
|


qWtj
tjadadS(
N(t_cacheRtcleart	threadingtLockt_locktNonet	_listener(tobjt
h((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyt_reset[s






c
Cstdkr~tj
zWtdkrltd


tdtj
atj	dt

}t|_|j

nWdtj
XntS(Ns0starting listener and thread for sending handlestauthkeyttarget(R!R RtacquireRR	RR%RtThreadt_servetTruetdaemontstarttrelease(
t
t((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyt
_get_listenerfs








	
cCsd
dlm
}m}

xyStj}|j\}}tj|

t|||
t	|

|j	
Wq


|sddl
}|
dddd|jdd

qqXqWdS(Ni
(t
is_exitingtsub_warningis.thread for sharing handles raised exception :
t
-iOs

(tutilR0R1R!tacceptRRtremoveRRt	tracebackt
format_exc(R0R1Rt
handle_wantedRR6((s>/opt/alt/python27/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((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyt
reduce_handles







c
Csq|\}
}}|r|Std
|
t
|
dtj

}|j|tjf

t|
}|j
|S(Nsrebuilding handle %dR%(	RRRR%RtostgetpidRR(tpickled_dataR<Rt	inheritedRR((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pytrebuild_handles










c
Cs+t|j

}
t|
|j|jffS(
N(R>Rtrebuild_connectiontreadabletwritable(Rtrh((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pytreduce_connections

cCs%t|
}t
j|d
|
d|
S(NRERF(RCRt
Connection(treduced_handleRERFR((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyRDs


icCsCtj
||
||}|jtjk	r?tjd
|
}n|S(Nt_sock(tsockettfromfdt	__class__(tfdtfamilyttype_tprotot
s((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyRMs



c
Cs1t|j

}
t|
|j|j|jffS(
N(R>Rtrebuild_socketRPttypeRR(RSRJ((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyt
reduce_sockets

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

|S(
N(RCRMR(RJRPRQRRRORK((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyRTs




c
Cs+t|j

}
t|
|j|jffS(
N(R>Rtrebuild_pipe_connectionRERF(RRG((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pytreduce_pipe_connections

cCs%t|
}t
j|d
|
d|
S(NRERF(RCRtPipeConnection(RJRERFR((s>/opt/alt/python27/lib64/python2.7/multiprocessing/reduction.pyRWs


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

"