FM / multiprocessing

/usr/lib64/python2.7/multiprocessing

Name	Size	Mode	Actions
dummy/	-	0755	rm
connection.py	15007	0644	edit dl rm
connection.pyc	14666	0644	edit dl rm
connection.pyo	14519	0644	edit dl rm
forking.py	17157	0644	edit dl rm
forking.pyc	14474	0644	edit dl rm
forking.pyo	14315	0644	edit dl rm
heap.py	8581	0644	edit dl rm
heap.pyc	6909	0644	edit dl rm
heap.pyo	6539	0644	edit dl rm
managers.py	36715	0644	edit dl rm
managers.pyc	38373	0644	edit dl rm
managers.pyo	37772	0644	edit dl rm
pool.py	24201	0644	edit dl rm
pool.pyc	22592	0644	edit dl rm
pool.pyo	22076	0644	edit dl rm
process.py	9684	0644	edit dl rm
process.pyc	9604	0644	edit dl rm
process.pyo	8851	0644	edit dl rm
queues.py	12296	0644	edit dl rm
queues.pyc	11499	0644	edit dl rm
queues.pyo	11402	0644	edit dl rm
reduction.py	6582	0644	edit dl rm
reduction.pyc	6014	0644	edit dl rm
reduction.pyo	6014	0644	edit dl rm
sharedctypes.py	7756	0644	edit dl rm
sharedctypes.pyc	8632	0644	edit dl rm
sharedctypes.pyo	8551	0644	edit dl rm
synchronize.py	10654	0644	edit dl rm
synchronize.pyc	11025	0644	edit dl rm
synchronize.pyo	10692	0644	edit dl rm
util.py	11006	0644	edit dl rm
util.pyc	10145	0644	edit dl rm
util.pyo	10040	0644	edit dl rm
__init__.py	7805	0644	edit dl rm
__init__.pyc	8465	0644	edit dl rm
__init__.pyo	8465	0644	edit dl rm

Edit: /usr/lib64/python2.7/multiprocessing/util.pyc (10145B)

� {fc@s�ddlZddlZddlZddlZddlZddlmZddlmZm Z dddddd d ddd ddddgZ dZdZdZ dZdZdZdZdaead�Zd�Zd�Zd�Zd�Zdd�Zd�Zej�Zej�Z d �Z!d!�Z"iZ#ej�Z$d e%fd"��YZ&dd#�Z'd$�Z(ea)eee'e ed%�Z*ej+e*�de%fd&��YZ,dej-fd'��YZ.dS((i��N(t_args_from_interpreter_flags(tcurrent_processtactive_childrent sub_debugtdebugtinfotsub_warningt get_loggert log_to_stderrtget_temp_dirtregister_after_forkt is_exitingtFinalizetForkAwareThreadLocktForkAwareLocaltSUBDEBUGt SUBWARNINGiii iitmultiprocessings+[%(levelname)s/%(processName)s] %(message)scGs trtjt||�ndS(N(t_loggertlogR(tmsgtargs((s,/usr/lib64/python2.7/multiprocessing/util.pyRDscGs trtjt||�ndS(N(RRtDEBUG(RR((s,/usr/lib64/python2.7/multiprocessing/util.pyRHscGs trtjt||�ndS(N(RRtINFO(RR((s,/usr/lib64/python2.7/multiprocessing/util.pyRLscGs trtjt||�ndS(N(RRR(RR((s,/usr/lib64/python2.7/multiprocessing/util.pyRPscCs�ddl}ddl}|j�z�ts�|jt�adt_|jtd�|jt d�t |d�r�|jt�|j t�q�|jjtdif�|jjtdif�nWd|j�XtS( s0 Returns logger used by multiprocessing i��NiRRt unregister(((tloggingtatexitt_acquireLockRt getLoggertLOGGER_NAMEt propagatetaddLevelNameRRthasattrRt_exit_functiontregistert _exithandlerstremovetappendt_releaseLock(RR((s,/usr/lib64/python2.7/multiprocessing/util.pyRTs cCsjddl}t�}|jt�}|j�}|j|�|j|�|r`|j|�nta t S(sB Turn on logging and add a handler which prints to stderr i��N(RRt FormattertDEFAULT_LOGGING_FORMATt StreamHandlertsetFormattert addHandlertsetLeveltTruet_log_to_stderrR(tlevelRtloggert formatterthandler((s,/usr/lib64/python2.7/multiprocessing/util.pyRqs cCs�t�jdkrwddl}ddl}|jdd�}td|�td|jd|gdd�|t�_nt�jS(Ni��tprefixspymp-screated temp directory %sRtexitpriorityi��( Rt_tempdirtNonetshutilttempfiletmkdtempRRtrmtree(R7R8ttempdir((s,/usr/lib64/python2.7/multiprocessing/util.pyR �s cCsqttj��}|j�xN|D]F\\}}}}y||�Wq#tk rh}td|�q#Xq#WdS(Ns after forker raised exception %s(tlistt_afterfork_registrytitemstsortt ExceptionR(R>tindextidenttfunctobjte((s,/usr/lib64/python2.7/multiprocessing/util.pyt_run_after_forkers�s cCs#|ttj�t|�|fs( RPtAttributeErrort TypeErrorR6tgetattrRQRRtstrRSRU(RZRDtx((s,/usr/lib64/python2.7/multiprocessing/util.pyt__repr__�s (N( Rdt __module__t__doc__R6R]RaRbRcRk(((s,/usr/lib64/python2.7/multiprocessing/util.pyR�s cs�tdkrdS�dkr(d�}n�fd�}gtj�D]}||�rD|^qD}|jdt�xV|D]N\}}td|�y|�Wqytk r�ddl}|j�qyXqyW�dkr�tj �ndS(s� Run all finalizers whose exit priority is not None and at least minpriority Finalizers with highest priority are called first; finalizers with the same priority will be called in reverse order of creation. NcSs|dddk S(Ni(R6(tp((s,/usr/lib64/python2.7/multiprocessing/util.pyttcs&|dddk o%|dd�kS(Ni(R6(Rn(tminpriority(s,/usr/lib64/python2.7/multiprocessing/util.pyRo Rptreverses calling %si��( RYR6R>R?R-RR@t tracebackt print_exctclear(RqtfRjR>tkeyt finalizerRs((Rqs,/usr/lib64/python2.7/multiprocessing/util.pyt_run_finalizers�s + cCstptdkS(s6 Returns true if the process is shutting down N(t_exitingR6(((s,/usr/lib64/python2.7/multiprocessing/util.pyR!scCs�|d�|d�|d�|�dk r�x:|�D]/}|jr7|d|j�|jj�q7q7Wx.|�D] }|d|j�|j�qtWn|d�|�dS(Nsprocess shutting downs2running all "atexit" finalizers with priority >= 0is!calling terminate() for daemon %sscalling join() for process %ss)running the remaining "atexit" finalizers(R6t _daemonictnamet_popent terminatetjoin(RRRyRRRn((s,/usr/lib64/python2.7/multiprocessing/util.pyR!)s cBseZd�Zd�ZRS(cCs|j�t|tj�dS(N(t_resetR R (RZ((s,/usr/lib64/python2.7/multiprocessing/util.pyR]Ts cCs1tj�|_|jj|_|jj|_dS(N(t threadingtLockt_locktacquiretrelease(RZ((s,/usr/lib64/python2.7/multiprocessing/util.pyR�Xs(RdRlR]R�(((s,/usr/lib64/python2.7/multiprocessing/util.pyR Ss cBseZd�Zd�ZRS(cCst|d��dS(NcSs |jj�S(N(t__dict__Ru(RD((s,/usr/lib64/python2.7/multiprocessing/util.pyRo_Rp(R (RZ((s,/usr/lib64/python2.7/multiprocessing/util.pyR]^scCst|�dfS(N((RJ(RZ((s,/usr/lib64/python2.7/multiprocessing/util.pyt __reduce__`s(RdRlR]R�(((s,/usr/lib64/python2.7/multiprocessing/util.pyR]s (/RVt itertoolsRNRR�t subprocessRtmultiprocessing.processRRt__all__tNOTSETRRRRRR(R6RtFalseR.RRRRRRR tWeakValueDictionaryR=tcountRGRFR RYRTtobjectRRyRRzR!R"R tlocalR(((s,/usr/lib64/python2.7/multiprocessing/util.pyt#sT N' "