File "util.cpython-37.opt-2.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python37/lib64/python3.7/multiprocessing/__pycache__/util.cpython-37.opt-2.pyc
File size: 9.95 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
B
YI~dl5 @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z ddddd d
d d d
ddddddgZ
d Z dZ dZ
dZdZdZdZdadadd Zd d Zd d Zd d Zd d Zd>d d
Zd!d" Zd#d$ Ze Z d%d& Z d'd Z e Z e! Z"d(d) Z#d*d Z$i Z%e! Z&G d+d de'Z(d?d,d-Z)d.d
Z*da+eee)e j,e j-fd/d0Z.e/e. G d1d de'Z0G d2d dej1Z2ye 3d3Z4W n e5k
r d4Z4Y nX d5d Z6d6d7 Z7d8d9 Z8d:d; Z9d<d= Z:dS )@ 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 rt jt| f| d S )N)_loggerlogr )msgargs r 9/opt/alt/python37/lib64/python3.7/multiprocessing/util.pyr , s c G s t rt jt| f| d S )N)r r DEBUG)r r r r r r 0 s c G s t rt jt| f| d S )N)r r INFO)r r r r r r 4 s c G s t rt jt| f| d S )N)r r r )r r r r r r 8 s c C s| dd l } | z\tsj| tadt_ttdrFtt t
t n$tj t di f tj
t di f W d | X tS )Nr
unregisterr )loggingZ _acquireLockr Z getLogger LOGGER_NAMEZ propagatehasattratexitr! _exit_functionregisterZ
_exithandlersremoveappendZ _releaseLock)r" r r r r < s
c C sJ dd l }t }|t}| }|| || | rB|| dat S )Nr T)
r" r Z FormatterDEFAULT_LOGGING_FORMATZ
StreamHandlerZ setFormatterZ
addHandlerZsetLevel_log_to_stderrr )levelr" Zlogger formatterZhandlerr r r r
W s
c C s t jdkrdS tt dr dS dS )NZlinuxTZgetandroidapilevelF)sysplatformr$ r r r r #_platform_supports_abstract_socketsl s
r0 c C s@ | sdS t | tr | d dkS t | tr4| d dkS tdd S )NFr z(address type of {address!r} unrecognized)
isinstancebytesstr TypeError)Zaddressr r r is_abstract_socket_namespacet s
r6 c C s& | | t }|d k r"d |jd< d S )Ntempdir)r current_process_config)rmtreer7 r8 r r r _remove_temp_dir s r; c C sf t jd} | d krbdd l}dd l}|jdd} td| td t |j
| fdd | t jd< | S )Nr7 r zpymp-)prefixzcreated temp directory %si)r exitpriority) r r8 r9 getshutiltempfileZmkdtempr r r; r: )r7 r? r@ r r r r s
c C sj t t } | xP| D ]H\\}}}}y || W q tk
r` } ztd| W d d }~X Y qX qW d S )Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )rC indexZidentfuncobjer r r _run_after_forkers s rJ c C s | t ttt| |f< d S )N)rB next_afterfork_counterid)rH rG r r r r s c @ sB e Zd Zd
ddZdeeejfddZdd Z d d
Z
d d Z dS )r r Nc C s |d k r&t |ts&td|t||d k r>t|| | _n|d krNtd|| _ || _
|p`i | _ |t t
f| _t | _| t| j< d S )Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)r2 intr5 formattypeweakrefref_weakref
ValueError _callback_args_kwargsrK _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfrH callbackr kwargsr= r r r __init__ s
zFinalize.__init__c C s y || j = W n tk
r( |d Y nbX | j| krD|d d }n$|d| j| j| j | j| j| j}d | _ | _ | _ | _| _ |S d S )Nz finalizer no longer registeredz+finalizer ignored because different processz/finalizer calling %s with args %s and kwargs %s)rY KeyErrorr\ rU rV rW rS )r^ Zwrr] r r[ Zresr r r __call__ s zFinalize.__call__c C sD y t | j= W n tk
r Y n X d | _ | _ | _ | _| _d S )N)r] rY rb rS rU rV rW )r^ r r r cancel s
zFinalize.cancelc C s
| j tkS )N)rY r] )r^ r r r still_active s zFinalize.still_activec C s y | }W n ttfk
r( d }Y nX |d kr>d| jj S d| jjt| jd| jf }| jrr|dt| j 7 }| j r|dt| j 7 }| j
d d k r|dt| j
d 7 }|d S ) Nz<%s object, dead>z<%s object, callback=%s__name__z, args=z , kwargs=r z, exitprority=>) rS AttributeErrorr5 __class__rf getattrrU rV r4 rW rY )r^ rH xr r r __repr__ s
zFinalize.__repr__)r NN) rf
__module__ __qualname__ra r] r rZ r[ rc rd re rl r r r r r s
c s t d kr d S d kr dd n fdd fddtt D }|jdd xX|D ]P}t |}|d k rRtd| y
| W qR tk
r d d l}| Y qRX qRW d krt d S )
Nc S s | d d k S )Nr r )pr r r <lambda> z!_run_finalizers.<locals>.<lambda>c s | d d k o| d kS )Nr r )ro ) minpriorityr r rp rq c s g | ]} |r|qS r r ).0key)fr r
<listcomp># s z#_run_finalizers.<locals>.<listcomp>T)reversez
calling %sr ) r] rA rD r> r rE traceback print_excclear)rr keysrt finalizerrx r )ru rr r _run_finalizers s$
r} c C s t p
t d kS )N)_exitingr r r r r
8 s c C s t sda | d |d |d | d k rzx*| D ] }|jr2| d|j |j q2W x"| D ]}| d|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~ ZdaemonnameZ_popenZ terminatejoin)r r r} active_childrenr8 ro r r r r& @ s
r& c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r c C s | t| tj d S )N)_resetr r )r^ r r r ra q s z ForkAwareThreadLock.__init__c C s" t | _| jj| _| jj| _d S )N) threadingZLock_lockacquirerelease)r^ r r r r u s
zForkAwareThreadLock._resetc C s
| j S )N)r __enter__)r^ r r r r z s z ForkAwareThreadLock.__enter__c G s | j j| S )N)r __exit__)r^ r r r r r } s z ForkAwareThreadLock.__exit__N)rf rm rn ra r r r r r r r r p s c @ s e Zd Zdd Zdd ZdS )r c C s t | dd d S )Nc S s
| j S )N)__dict__rz )rH r r r rp rq z)ForkAwareLocal.__init__.<locals>.<lambda>)r )r^ r r r ra s zForkAwareLocal.__init__c C s t | dfS )Nr )rP )r^ r r r
__reduce__ s zForkAwareLocal.__reduce__N)rf rm rn ra r r r r r r s SC_OPEN_MAX c C sR t | dtg } | x4tt| d D ] }t| | d | |d q*W d S )Nr )rA MAXFDrD rangelenrZ
closerange)Zfdsir r r r s c C s t jd krd S yt j W n ttfk
r4 Y nX y@ttjtj} yt| ddt _W n t| Y nX W n ttfk
r Y nX d S )NF)closefd) r. stdincloseOSErrorrT rZ opendevnullO_RDONLY)fdr r r _close_stdin s
r c C sT yt j W n ttfk
r& Y nX yt j W n ttfk
rN Y nX d S )N)r. stdoutflushrh rT stderrr r r r _flush_std_streams s r c C st dd l }tttt|}t \}}z2||t| gd|d d dddddd||ddd S t | t | X d S )Nr Tr F)
_posixsubprocesstuplesortedmaprN rZ pipeZ fork_execfsencoder )pathr Zpassfdsr Z errpipe_readZ
errpipe_writer r r spawnv_passfds s
r c C sD ddl m} t ddlm} |j t | |
d S )Nr )support)
forkserver) Ztestr r Z_cleanupr r Z _forkserverZ_stopr} Z
gc_collectZ
reap_children)r r r r r _cleanup_tests s
r )N)N);rZ itertoolsr. rQ r% r
subprocessr r __all__ZNOTSETr r r r r# r* r r+ r r r r r r
r0 r6 Zabstract_sockets_supportedr; r ZWeakValueDictionaryrB countrL rJ r r] rX objectr r} r
r~ r r8 r& r' r Zlocalr sysconfr rE r r r r r r r r r <module>
sp
V
,(