]y- @ 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
multiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc G s t r t j t | | d S)N)_loggerlogr )msgargs r )/opt/alt/python35/lib64/python3.5/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)Nr
unregister)logging _acquireLockr getLogger LOGGER_NAME propagatehasattratexitr! _exit_functionregister
_exithandlersremoveappend _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)Nr T)
r" r FormatterDEFAULT_LOGGING_FORMAT
StreamHandler setFormatter
addHandlersetLevel_log_to_stderrr )levelr" logger formatterhandlerr 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_process_configgetshutiltempfilemkdtempr r rmtree)r: rA rB 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 )rG indexidentfuncobjer r r _run_after_forkers s
rO c C s# | t t t t | | f z<%s object, callback=%s__name__z, args=z , kwargs=r z, exitprority=>) rU AttributeError TypeError __class__ri getattrrV rW strrX rZ )r_ rM xr r r __repr__ s zFinalize.__repr__) ri
__module__ __qualname__rb r^ r r[ r\ rf rg rh rq 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)
Nc S s | d d k S)Nr r )pr r r s z!_run_finalizers..c s | d d k o | d k S)Nr r )rt ) minpriorityr r ru s c s" g | ] } | r | q Sr r ).0key)fr r
s z#_run_finalizers..reverseTz
calling %sr ) r^ rE rH r@ r rI traceback print_excclear)rv keysrx finalizerr| r )ry rv r _run_finalizers s$
r c C s t p t d k S)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)r daemonname_popen terminatejoin)r r r active_childrenr> rt 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 )r_ r r r rb K s
z ForkAwareThreadLock.__init__c C s1 t j | _ | j j | _ | j j | _ d S)N) threadingLock_lockacquirerelease)r_ r r r r O s zForkAwareThreadLock._resetc C s
| j j S)N)r __enter__)r_ r r r r T s z ForkAwareThreadLock.__enter__c G s | j j | S)N)r __exit__)r_ r r r r r W s z ForkAwareThreadLock.__exit__N)ri rr rs rb r 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__r~ )rM r r r ru ] s z)ForkAwareLocal.__init__..)r )r_ r r r rb \ s zForkAwareLocal.__init__c C s t | f f S)N)type)r_ r r r
__reduce__^ s zForkAwareLocal.__reduce__N)ri rr rs rb r r r r r r [ s SC_OPEN_MAX c C se t | d t g } | j x> t t | d D]& } t j | | d | | d q7 Wd S)Nr )rE MAXFDrH rangelenr[
closerange)fdsir 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
ValueErrorr[ 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 )
_posixsubprocesstuplesortedmapintr[ pipe fork_execfsencoder )pathr passfdsr errpipe_read
errpipe_writer r r spawnv_passfds s
r )5r[ itertoolsr rS r( r
subprocessr r __all__NOTSETr r r r r% r0 r r5 r r r r r r
r WeakValueDictionaryrF countrQ rO r r^ rY objectr r r
r r r> r) r* r localr sysconfr rI r r r r r r r
sd S, (