File "util.cpython-39.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python39/lib64/python3.9/multiprocessing/__pycache__/util.cpython-39.pyc
File size: 11.25 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
a
XC?h6 @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z g dZ
d Z dZ dZ
dZd Zd
Zd Zdad ad
d Zdd Zdd Zdd Zdd Zd?ddZdd Zdd 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& d&e'Z(d@d'd(Z)d)d* Z*d a+eee)e j,e j-fd+d,Z.e/e. G d-d. d.e'Z0G d/d0 d0ej1Z2ze 3d1Z4W n e5y d2Z4Y n0 d3d4 Z6d5d6 Z7d7d8 Z8d9d: Z9d;d< Z:d=d> Z;dS )A 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| g|R d S N)_loggerlogr msgargs r 9/opt/alt/python39/lib64/python3.9/multiprocessing/util.pyr , s r c G s t rt jt| g|R d S r )r r DEBUGr r r r r 0 s r c G s t rt jt| g|R d S r )r r INFOr r r r r 4 s r c G s t rt jt| g|R d S r )r r r r r r r r 8 s r c C s ddl } | zdtsj| tadt_ttdrFtt t
t n$tj t di f tj
t di f W | n
| 0 tS )z0
Returns logger used by multiprocessing
r N
unregisterr )loggingZ _acquireLockr Z getLogger LOGGER_NAMEZ propagatehasattratexitr# _exit_functionregisterZ
_exithandlersremoveappendZ _releaseLock)r$ r r r r < s
r c C sJ ddl }t }|t}| }|| || | rB|| dat 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
r
c C s t jdkrdS tt dr dS dS )NZlinuxTZgetandroidapilevelF)sysplatformr& r r r r #_platform_supports_abstract_socketsl s
r1 c C sH | sdS t | tr | d dkS t | tr4| d dkS td| dd S )NFr zaddress type of z
unrecognized)
isinstancebytesstr TypeError)Zaddressr r r is_abstract_socket_namespacet s
r7 c C s& | | t }|d ur"d |jd< d S )Ntempdir)r current_process_config)rmtreer8 r9 r r r _remove_temp_dir s r< c C sf t jd} | d u rbdd l}dd l}|jdd} td| td t |j
| fdd | t jd< | S )Nr8 r zpymp-)prefixzcreated temp directory %si)r exitpriority) r r9 r: getshutiltempfileZmkdtempr r r< r; )r8 r@ rA r r r r s
r c C sh t t } | | D ]J\\}}}}z || W q ty` } ztd| W Y d }~qd }~0 0 qd S )Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )rD indexZidentfuncobjer r r _run_after_forkers s rK c C s | t ttt| |f< d S r )rC next_afterfork_counterid)rI rH r r r r s r c @ sF e Zd ZdZdddZdeeejfddZ dd Z
d
d Z d d
Z dS )r zA
Class which supports object finalization using weakrefs
r Nc C s |d ur&t |ts&td|t||d ur>t|| | _n|d u rNtd|| _ || _
|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)r3 intr6 formattypeweakrefref_weakref
ValueError _callback_args_kwargsrL _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfrI callbackr kwargsr> r r r __init__ s
zFinalize.__init__c C s z || j = W n ty& |d Y nf0 | j| krB|d d}n(|d| j| j| j | j| ji | j}d | _ | _ | _ | _| _ |S dS )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)rZ KeyErrorr] rV rW rX rT )r_ Zwrr^ r r\ resr r r __call__ s zFinalize.__call__c C sB z t | j= W n ty Y n 0 d | _ | _ | _ | _| _dS )z3
Cancel finalization of the object
N)r^ rZ rc rT rV rW rX r_ r r r cancel s zFinalize.cancelc C s
| j tv S )zS
Return whether this finalizer is still waiting to invoke callback
)rZ r^ rf r r r still_active s zFinalize.still_activec C s z | }W n ttfy& d }Y n0 |d u r<d| jj S d| jjt| jd| jf }| jrp|dt| j 7 }| j r|dt| j 7 }| j
d d ur|dt| j
d 7 }|d S ) Nz<%s object, dead>z<%s object, callback=%s__name__z, args=z , kwargs=r z, exitpriority=>) rT AttributeErrorr6 __class__ri getattrrV rW r5 rX rZ )r_ rI xr r r __repr__ s"
zFinalize.__repr__)r NN)
ri
__module__ __qualname____doc__rb r^ r r[ r\ re rg rh ro r r r r r s
r c s t du r dS du r dd n fdd fddtt D }|jdd |D ]N}t |}|durPtd | z
| W qP ty d
dl}| Y qP0 qPdu rt dS ) 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 uS Nr r pr r r <lambda> z!_run_finalizers.<locals>.<lambda>c s | d d uo| d kS rs r rt ) minpriorityr r rv rw c s g | ]} |r|qS r r ).0key)fr r
<listcomp># rw z#_run_finalizers.<locals>.<listcomp>T)reversez
calling %sr ) r^ rB rE r? r rF traceback print_excclear)rx keysrz finalizerr~ r )r{ rx r _run_finalizers s$
r c C s t p
t du S )z6
Returns true if the process is shutting down
N)_exitingr r r r r
8 s r
c C s t sda | d |d |d | d urr| D ] }|jr0| d|j |j q0| D ]}| d|j | qX|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_childrenr9 ru r r r r( @ s
r( c @ s, e Zd Zdd Zdd Zdd Zdd Zd S )
r c C s. t | _| jj| _| jj| _t| tj d S r ) threadingZLock_lockacquirereleaser r _at_fork_reinitrf r r r rb q s
z ForkAwareThreadLock.__init__c C s | j d S r )r r rf r r r r w s z#ForkAwareThreadLock._at_fork_reinitc C s
| j S r )r __enter__rf r r r r z s z ForkAwareThreadLock.__enter__c G s | j j| S r )r __exit__)r_ r r r r r } s z ForkAwareThreadLock.__exit__N)ri rp rq rb r r r r r r r r p s r c @ s e Zd Zdd Zdd ZdS )r c C s t | dd d S )Nc S s
| j S r )__dict__r )rI r r r rv rw z)ForkAwareLocal.__init__.<locals>.<lambda>)r rf r r r rb s zForkAwareLocal.__init__c C s t | dfS )Nr )rQ rf r r r
__reduce__ s zForkAwareLocal.__reduce__N)ri rp rq rb r r r r r r s r SC_OPEN_MAX c C sb t | dtg } | | d tks,J dtt| d D ] }t| | d | |d q<d S )Nz fd too larger )rB MAXFDrE rangelenr[
closerange)fdsir r r r s
r c C s t jd u rd S zt j W n ttfy2 Y n0 z@ttjtj} zt| ddt _W n t| Y n0 W n ttfy Y n0 d S )NF)closefd) r/ stdincloseOSErrorrU r[ opendevnullO_RDONLY)fdr r r _close_stdin s
r c C sP zt j W n ttfy$ Y n0 zt j W n ttfyJ Y n0 d S r )r/ stdoutflushrk rU stderrr r r r _flush_std_streams s r c C s dd l }tttt|}t \}}zP||t| gd|d d dddddd||ddd d d dd W t | t | S t | t | 0 d S )Nr Tr F)
_posixsubprocesstuplesortedmaprO r[ pipeZ fork_execfsencoder )pathr Zpassfdsr Z errpipe_readZ
errpipe_writer r r spawnv_passfds s
r c G s | D ]}t | qdS )z/Close each file descriptor given as an argumentN)r[ r )r r r r r close_fds s r c C sZ ddl m} t ddlm} |j ddlm} |j t
| | dS )zKCleanup multiprocessing resources when multiprocessing tests
completed.r )support)
forkserver)resource_trackerN)
testr r Z_cleanupr r Z _forkserverZ_stopr Z_resource_trackerr Z
gc_collectZ
reap_children)r r r r r r _cleanup_tests s
r )N)N)<r[ itertoolsr/ rR r' r
subprocessr r __all__ZNOTSETr r! r" r r% r, r r- r r r r r r
r1 r7 Zabstract_sockets_supportedr< r ZWeakValueDictionaryrC countrM rK r r^ rY objectr r r
r r r9 r( r) r Zlocalr sysconfr rF r r r r r r r r r r <module>
sn
V
,
*