← Back
Editing: util.cpython-33.pyc
� �� 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 <d S( N( u _afterfork_registryu nextu _afterfork_counteru id( u obju func( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu register_after_fork� s c B sn | Ee Z d Z d Z f d d d d � Z d e e e j d d � Z d d � Z d d � Z d d � Z d S( u FinalizeuA Class which supports object finalization using weakrefs c C s� | d k s$ t | � t k s$ t � | d k rH t j | | � | _ n | d k sZ t � | | _ | | _ | pu i | _ | t t � f | _ t j � | _ | t | j <d S( N( u Noneu typeu intu AssertionErroru weakrefu refu _weakrefu _callbacku _argsu _kwargsu nextu _finalizer_counteru _keyu osu getpidu _pidu _finalizer_registry( u selfu obju callbacku argsu kwargsu exitpriority( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu __init__� s $ u Finalize.__init__c C s� y | | j =Wn t k r, | d � Yn� X| j | � k rR | d � d } n4 | d | j | j | j � | j | j | j � } d | _ | _ | _ | _ | _ | Sd S( uQ Run the callback unless it has already been called or cancelled u finalizer no longer registeredu+ finalizer ignored because different processu/ finalizer calling %s with args %s and kwargs %sN( u _keyu KeyErroru _pidu Noneu _callbacku _argsu _kwargsu _weakref( u selfu wru _finalizer_registryu sub_debugu getpidu res( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu __call__� s %u Finalize.__call__c C sL y t | j =Wn t k r" Yn& Xd | _ | _ | _ | _ | _ d S( u3 Cancel finalization of the object N( u _finalizer_registryu _keyu KeyErroru Noneu _weakrefu _callbacku _argsu _kwargs( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu cancel� s u Finalize.cancelc C s | j t k S( uS Return whether this finalizer is still waiting to invoke callback ( u _keyu _finalizer_registry( u self( ( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu still_active� s u Finalize.still_activec C s� y | j � } Wn t t f k r0 d } Yn X| d k rA d Sd t | j d | j � } | j r� | d t | j � 7} n | j r� | d t | j � 7} n | j d d k r� | d t | j d � 7} n | d S( Nu <Finalize object, dead>u <Finalize object, callback=%su __name__u , args=u , kwargs=i u , exitprority=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 <lambda>� s u! _run_finalizers.<locals>.<lambda>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 <lambda>� s c s" g | ] } � | � r | � q S( ( ( u .0u x( u f( u9 /opt/alt/python33/lib64/python3.3/multiprocessing/util.pyu <listcomp>� s u# _run_finalizers.<locals>.<listcomp>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 <lambda>O s u) ForkAwareLocal.__init__.<locals>.<lambda>( 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 <module> sX R$ (
Save File
Cancel