Ñò §ÚêLc@s gZddkZddkZddkZddkZddkZddklZddkl Z l Z l Z l Z ddk lZlZlZddklZlZeidjp eedƒpedƒ‚neidjo2ddkZdd klZd „Zd „Znd „Zd „Zeƒad„Zedƒeeeƒd„Zd„Z d„Z!d„Z"d„Z#d„Z$e i%ei&e#ƒdd„Z'd„Z(d„Z)e i%eie(ƒeidjo)d„Z*d„Z+e i%ei,e*ƒndS(iÿÿÿÿN(tcurrent_process(tPopent duplicatetclosetForkingPickler(tregister_after_forktdebugt sub_debug(tClienttListenertwin32trecvfds%pickling of connections not supported(R cCsJtitit|ƒ}z t||ƒ}|i|ƒWdt|ƒXdS(N(R t OpenProcesstPROCESS_ALL_ACCESStFalseRtsendR(tconnthandletdestination_pidtprocess_handlet new_handle((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt send_handle's cCs |iƒS(N(trecv(R((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt recv_handle1scCsti|iƒ|ƒdS(N(t_multiprocessingtsendfdtfileno(RRR((s1/usr/lib64/python2.6/multiprocessing/reduction.pyR5scCsti|iƒƒS(N(RR R(R((s1/usr/lib64/python2.6/multiprocessing/reduction.pyR8scCs;xtD]}t|ƒqWtiƒtiƒadadS(N(t_cacheRtcleart threadingtLockt_locktNonet _listener(tobjth((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt_resetAs   cCs†tdjoutiƒzYtdjoHtdƒtdtƒiƒati dt ƒ}t |_ |i ƒnWdtiƒXntS(Ns0starting listener and thread for sending handlestauthkeyttarget(R!R RtacquireRR RR%RtThreadt_servetTruetdaemontstarttrelease(tt((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt _get_listenerLs     cCs¿ddkl}l}x¢yStiƒ}|iƒ\}}ti|ƒt|||ƒt |ƒ|i ƒWq|ƒp8ddk }|dddd|i ƒddƒq¸qXqdS(Ni(t is_exitingt sub_warningiÿÿÿÿs.thread for sharing handles raised exception : t-iOs ( tutilR0R1R!tacceptRRtremoveRRt tracebackt format_exc(R0R1Rt handle_wantedRR6((s1/usr/lib64/python2.6/multiprocessing/reduction.pyR)]s     cCs]tiƒodti|ƒtfSt|ƒ}ti|ƒtd|ƒt ƒi |t fS(Nsreducing handle %d( Rtthread_is_spawningR tduplicate_for_childR*RRtaddRR/taddressR(Rt dup_handle((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt reduce_handlets     cCss|\}}}|o|Std|ƒt|dtƒiƒ}|i|tiƒfƒt|ƒ}|iƒ|S(Nsrebuilding handle %dR%( RRRR%RtostgetpidRR(t pickled_dataR<Rt inheritedRR((s1/usr/lib64/python2.6/multiprocessing/reduction.pytrebuild_handle|s   cCs+t|iƒƒ}t||i|iffS(N(R>Rtrebuild_connectiontreadabletwritable(Rtrh((s1/usr/lib64/python2.6/multiprocessing/reduction.pytreduce_connection‹scCs%t|ƒ}ti|d|d|ƒS(NRERF(RCRt Connection(treduced_handleRERFR((s1/usr/lib64/python2.6/multiprocessing/reduction.pyRDs icCsEti||||ƒ}|itij otid|ƒ}n|S(Nt_sock(tsockettfromfdt __class__(tfdtfamilyttype_tprotots((s1/usr/lib64/python2.6/multiprocessing/reduction.pyRM›scCs1t|iƒƒ}t||i|i|iffS(N(R>Rtrebuild_socketRPttypeRR(RSRJ((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt reduce_socket¡scCs/t|ƒ}t||||ƒ}t|ƒ|S(N(RCRMR(RJRPRQRRRORK((s1/usr/lib64/python2.6/multiprocessing/reduction.pyRT¥s  cCs+t|iƒƒ}t||i|iffS(N(R>Rtrebuild_pipe_connectionRERF(RRG((s1/usr/lib64/python2.6/multiprocessing/reduction.pytreduce_pipe_connection³scCs%t|ƒ}ti|d|d|ƒS(NRERF(RCRtPipeConnection(RJRERFR((s1/usr/lib64/python2.6/multiprocessing/reduction.pyRW·s (-t__all__R?tsysRLRRtmultiprocessingRtmultiprocessing.forkingRRRRtmultiprocessing.utilRRRtmultiprocessing.connectionRR tplatformthasattrt ImportErrort _subprocessR RRtsetRR$R R/R)R>RCRHRDtregisterRIRMRVRTRXRWRY(((s1/usr/lib64/python2.6/multiprocessing/reduction.pyt sJ     "