File "util.cpython-35.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python35/lib64/python3.5/multiprocessing/__pycache__/util.cpython-35.pyc
File size: 10.14 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
Yfy- @ sT 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 d 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 j( e j) d) d* Z* e j+ e* Gd+ d d e# Z, Gd, d d e j- Z. y e j/ d- Z0 Wn e1 k
r+d. Z0 Yn Xd/ d Z2 d0 d1 Z3 d2 d3 Z4 d S)4 N) _args_from_interpreter_flags )process sub_debugdebuginfo sub_warning
get_logger
log_to_stderr get_temp_dirregister_after_fork
is_exitingFinalizeForkAwareThreadLockForkAwareLocalclose_all_fds_exceptSUBDEBUG
SUBWARNING
Zmultiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc G s t r t j t | | d S)N)_loggerlogr )msgargs r 9/opt/alt/python35/lib64/python3.5/multiprocessing/util.pyr , s c G s t r t j t | | d S)N)r r DEBUG)r r r r r r 0 s c G s t r t j t | | d S)N)r r INFO)r r r r r r 4 s c G s t r t j t | | d S)N)r r r )r r r r r r 8 s c
C s d d l } | j z t s | j t a d t _ t t d rc t j t t j
t n2 t j j t f i f t j j
t f i f Wd | j Xt S)z0
Returns logger used by multiprocessing
r N
unregister)loggingZ _acquireLockr Z getLogger LOGGER_NAMEZ propagatehasattratexitr _exit_functionregisterZ
_exithandlersremoveappendZ _releaseLock)r! r r r r < s
c C sg d d l } t } | j t } | j } | j | | j | | r] | j | d a t S)zB
Turn on logging and add a handler which prints to stderr
r NT)
r! r Z FormatterDEFAULT_LOGGING_FORMATZ
StreamHandlerZ setFormatterZ
addHandlerZsetLevel_log_to_stderrr )levelr! ZloggerZ formatterZhandlerr r r r
W s
c C s t j j j d } | d k r d d l } d d l } | j d d } t d | t d | j d | g d d | t j j d <| S)
Ntempdirr prefixzpymp-zcreated temp directory %sr exitpriorityd i)
r current_processZ_configgetshutiltempfileZmkdtempr r Zrmtree)r, r2 r3 r r r r m 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)Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )r6 indexZidentfuncobjer r r _run_after_forkers s
r= c C s# | t t t t | | f <d S)N)r5 next_afterfork_counterid)r; r: r r r r s c @ sj e 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)
r zA
Class which supports object finalization using weakrefs
Nc 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)typeintAssertionErrorweakrefref_weakref _callback_args_kwargsr> _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfr; callbackr kwargsr. r r r __init__ s $ zFinalize.__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)zQ
Run the callback unless it has already been called or cancelled
z finalizer no longer registeredz+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %s)rK KeyErrorrN rG rH rI rF )rP wrrO r rM resr r r __call__ s
%zFinalize.__call__c C sL y t | j =Wn t k
r" Yn& Xd | _ | _ | _ | _ | _ d S)z3
Cancel finalization of the object
N)rO rK rT rF rG rH rI )rP r r r cancel s
zFinalize.cancelc C s
| j t k S)zS
Return whether this finalizer is still waiting to invoke callback
)rK rO )rP r r r still_active s zFinalize.still_activec C s y | j } Wn t t f k
r0 d } Yn X| d k rK d | j j Sd | j j t | j d | j f } | j r | d t | j 7} | j r | d t | j 7} | j
d d k r | d t | j
d 7} | d S) Nz<%s object, dead>z<%s object, callback=%s__name__z, args=z , kwargs=r z, exitprority=>) rF AttributeError TypeError __class__rZ getattrrG rH strrI rK )rP r; xr r r __repr__ s zFinalize.__repr__)
rZ
__module__ __qualname____doc__rS rO r rL rM rW rX rY rb r r r r r s c s t d k r d S d k r+ d d n f d d f d d t t D } | j d d xl | D]d } t j | } | d k rs t d | y | Wqs t k
r d
d l } | j Yqs Xqs W d k r t j d S) z
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 k S)Nr r )pr r r <lambda> s z!_run_finalizers.<locals>.<lambda>c s | d d k o | d k S)Nr r )rf ) minpriorityr r rg s c s" g | ] } | r | q Sr r ).0key)fr r
<listcomp> s z#_run_finalizers.<locals>.<listcomp>reverseTz
calling %sr ) rO r4 r7 r1 r r8 traceback print_excclear)rh keysrj Z finalizerrn r )rk rh r _run_finalizers s$
rr c C s t p t d k S)z6
Returns true if the process is shutting down
N)_exitingr r r r r
s c C s t s d a | d | d | d | d k r x7 | D], } | j rC | d | j | j j qC Wx+ | D] } | d | j | j q} W| d | d S)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0r z!calling terminate() for daemon %sz calling join() for process %sz)running the remaining "atexit" finalizers)rs ZdaemonnameZ_popenZ terminatejoin)r r rr active_childrenr0 rf r r r r% s
r% c @ s@ e Z d Z d d Z d d Z d d Z d d Z d S)
r c C s | j t | t j d S)N)_resetr r )rP r r r rS K s
z ForkAwareThreadLock.__init__c C s1 t j | _ | j j | _ | j j | _ d S)N) threadingZLock_lockacquirerelease)rP r r r rw O s zForkAwareThreadLock._resetc C s
| j j S)N)ry __enter__)rP r r r r| T s z ForkAwareThreadLock.__enter__c G s | j j | S)N)ry __exit__)rP r r r r r} W s z ForkAwareThreadLock.__exit__N)rZ rc rd rS rw r| r} r r r r r J s c @ s( e Z d Z d d Z d d Z d S)r c C s t | d d d S)Nc S s
| j j S)N)__dict__rp )r; r r r rg ] s z)ForkAwareLocal.__init__.<locals>.<lambda>)r )rP r r r rS \ s zForkAwareLocal.__init__c C s t | f f S)N)rA )rP r r r
__reduce__^ s zForkAwareLocal.__reduce__N)rZ rc rd rS r r r r r r [ s SC_OPEN_MAX c C s t | d t g } | j | d t k s< t d x> t t | d D]& } t j | | d | | d qS Wd S)Nr z fd too larger )r4 MAXFDr7 rC rangelenrL
closerange)Zfdsir r r r j s
c C s t j d k r d Sy t j j Wn t t f k
r> Yn XyP t j t j t j } y t | d d t _ Wn t j | Yn XWn t t f k
r Yn Xd S)NclosefdF) sysstdincloseOSError
ValueErrorrL opendevnullO_RDONLY)fdr r r _close_stdint s
r c C s d d l } t t t t | } t j \ } } zM | j | t j | g d | d d d d d d d d
| | d d d SWd t j | t j | Xd S) Nr Tr Fr r r r r r )
_posixsubprocesstuplesortedmaprB rL pipeZ fork_execfsencoder )pathr Zpassfdsr Z errpipe_readZ
errpipe_writer r r spawnv_passfds s
r )5rL itertoolsr rD r$ rx
subprocessr r __all__ZNOTSETr r r r r" r) r r* r r r r r r
r WeakValueDictionaryr5 countr? r= r rO rJ objectr rr r
rs rv r0 r% r& r Zlocalr sysconfr r8 r r r r r r r <module>
sd S, (