ž
¨ÿ f½& c @ s d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z d d l m
Z
m Z d d d d d d d
d d d
d d d d g Z d Z
d Z d Z d Z d Z d Z d Z d a d* a d d „ Z d d „ Z d d „ Z d d „ Z d d „ Z d d d „ Z d d
„ Z e j ƒ Z e j! ƒ Z" d d „ Z# d! d „ Z$ i Z% e j! ƒ Z& Gd" d
„ d
e' ƒ Z( d d# d$ „ Z) d% d „ Z* d* a+ e e e) e e
d& d' „ Z, e j- e, ƒ Gd( d „ d e' ƒ Z. Gd) d „ d e j/ ƒ Z0 d S(+ i N( u _args_from_interpreter_flags( u current_processu active_childrenu sub_debugu debugu infou sub_warningu
get_loggeru
log_to_stderru get_temp_diru register_after_forku
is_exitingu Finalizeu ForkAwareThreadLocku ForkAwareLocalu SUBDEBUGu
SUBWARNINGi i
i i u multiprocessingu+ [%(levelname)s/%(processName)s] %(message)sc G s t r t j t | | Πn d S( N( u _loggeru logu SUBDEBUG( u msgu args( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu sub_debug- s c G s t r t j t | | Πn d S( N( u _loggeru logu DEBUG( u msgu args( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu debug1 s c G s t r t j t | | Πn d S( N( u _loggeru logu INFO( u msgu args( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu info5 s c G s t r t j t | | Πn d S( N( u _loggeru logu
SUBWARNING( u msgu args( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu sub_warning9 s c
C sË d d l } | j ƒ z£ t s¸ | j t ƒ a d t _ | j t d ƒ | j t d ƒ t t
d ƒ rƒ t
j t ƒ t
j
t ƒ q¸ t
j j t f i f ƒ t
j j t f i f ƒ n Wd | j ƒ Xt S( u0
Returns logger used by multiprocessing
i Nu SUBDEBUGu
SUBWARNINGu
unregister( u loggingu _acquireLocku _loggeru getLoggeru LOGGER_NAMEu propagateu addLevelNameu SUBDEBUGu
SUBWARNINGu hasattru atexitu
unregisteru _exit_functionu registeru
_exithandlersu removeu appendu _releaseLock( u logging( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
get_logger= s
c C sj d d l } t ƒ } | j t ƒ } | j ƒ } | j | ƒ | j | ƒ | r` | j | ƒ n d a t
S( uB
Turn on logging and add a handler which prints to stderr
i NT( u loggingu
get_loggeru Formatteru DEFAULT_LOGGING_FORMATu
StreamHandleru setFormatteru
addHandleru setLevelu Trueu _log_to_stderru _logger( u levelu loggingu loggeru formatteru handler( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
log_to_stderrZ s
c C s t ƒ j d k rw d d l } d d l } | j d d ƒ } t d | ƒ t d | j d | g d d ƒ| t ƒ _ n t ƒ j S( Ni u prefixu pymp-u created temp directory %su argsu exitpriorityid iœÿÿÿ( u current_processu _tempdiru Noneu shutilu tempfileu mkdtempu infou Finalizeu rmtree( u shutilu tempfileu tempdir( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu get_temp_dirp s
c C sƒ t t j ƒ ƒ } | j ƒ x` | D]X \ \ } } } } y | | ƒ Wq# t k
rz } z t d | ƒ WYd d } ~ Xq# Xq# Wd S( Nu after forker raised exception %s( u listu _afterfork_registryu itemsu sortu Exceptionu info( u itemsu indexu identu funcu obju e( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu _run_after_forkers s
u _run_after_forkersc C s# | t t t ƒ t | ƒ | f u (
u _weakrefu AttributeErroru TypeErroru Noneu getattru _callbacku _argsu stru _kwargsu _key( u selfu obju x( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu __repr__Ó s u Finalize.__repr__N( u __name__u
__module__u __qualname__u __doc__u Noneu __init__u _finalizer_registryu sub_debugu osu getpidu __call__u cancelu still_activeu __repr__( u
__locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu Finalize• s c sé t d k r d Sˆ d k r+ d d „ ‰ n ‡ f d d † ‰ ‡ f d d † t t j ƒ ƒ Dƒ } | j d d
ƒ xW | D]O \ } } t d | ƒ y | ƒ Wqy t k
rÇ d d l } | j ƒ Yqy Xqy Wˆ d k rå t j
ƒ n d S( uà
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.
Nc S s | d d d k S( Ni ( u None( u p( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu õ s u! _run_finalizers..c s& | d d d k o% | d d ˆ k S( Ni ( u None( u p( u minpriority( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu ÷ s c s" g | ] } ˆ | ƒ r | ‘ q S( ( ( u .0u x( u f( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
ù s u# _run_finalizers..u reverseu
calling %si T( u _finalizer_registryu Noneu listu itemsu sortu Trueu sub_debugu Exceptionu tracebacku print_excu clear( u minpriorityu itemsu keyu finalizeru traceback( ( u fu minpriorityu9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu _run_finalizersç s %
u _run_finalizersc C s t p t d k S( u6
Returns true if the process is shutting down
N( u _exitingu None( ( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
is_exiting s c C s¿ t s» d a | d ƒ | d ƒ | d ƒ | ƒ d k r§ x: | ƒ D]/ } | j rC | d | j ƒ | j j ƒ qC qC Wx. | ƒ D] } | d | j ƒ | j ƒ q€ Wn | d ƒ | ƒ n d S( Nu process shutting downu2 running all "atexit" finalizers with priority >= 0i u! calling terminate() for daemon %su calling join() for process %su) running the remaining "atexit" finalizersT( u _exitingu Trueu Noneu _daemonicu nameu _popenu terminateu join( u infou debugu _run_finalizersu active_childrenu current_processu p( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu _exit_function s
u _exit_functionc B s, | Ee Z d Z d d „ Z d d „ Z d S( u ForkAwareThreadLockc C s | j ƒ t | t j ƒ d S( N( u _resetu register_after_forku ForkAwareThreadLock( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu __init__D s
u ForkAwareThreadLock.__init__c C s1 t j ƒ | _ | j j | _ | j j | _ d S( N( u threadingu Locku _locku acquireu release( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu _resetH s u ForkAwareThreadLock._resetN( u __name__u
__module__u __qualname__u __init__u _reset( u
__locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu ForkAwareThreadLockC s c B s, | Ee Z d Z d d „ Z d d „ Z d S( u ForkAwareLocalc C s t | d d „ ƒ d S( Nc S s
| j j ƒ S( N( u __dict__u clear( u obj( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu O s u) ForkAwareLocal.__init__..( u register_after_fork( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu __init__N s u ForkAwareLocal.__init__c C s t | ƒ f f S( N( u type( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
__reduce__P s u ForkAwareLocal.__reduce__N( u __name__u
__module__u __qualname__u __init__u
__reduce__( u
__locals__( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu ForkAwareLocalM s F(1 u sysu functoolsu osu itertoolsu weakrefu atexitu threadingu
subprocessu _args_from_interpreter_flagsu multiprocessing.processu current_processu active_childrenu __all__u NOTSETu SUBDEBUGu DEBUGu INFOu
SUBWARNINGu LOGGER_NAMEu DEFAULT_LOGGING_FORMATu Noneu _loggeru Falseu _log_to_stderru sub_debugu debugu infou sub_warningu
get_loggeru
log_to_stderru get_temp_diru WeakValueDictionaryu _afterfork_registryu countu _afterfork_counteru _run_after_forkersu register_after_forku _finalizer_registryu _finalizer_counteru objectu Finalizeu _run_finalizersu
is_exitingu _exitingu _exit_functionu registeru ForkAwareThreadLocku localu ForkAwareLocal( ( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu
sX R$ (