F ux2 N d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZ ddlm Z g dZ
d Z dZ dZ
dZd Zd
Zd Zdad ad
Zd Zd Zd Zd Zd*dZd Zd Z e Z d Z d Z ej Z ej! Z"d Z#d Z$i Z% ej! Z& G d de' Z(d*dZ)d Z*d a+eee)e j, e j- fd Z. ej/ e. G d d e' Z0 G d d!ej1 Z2 e j3 d" Z4n
# e5$ r d#Z4Y nw xY wd$ Z6d% Z7d& Z8d' Z9d( Z: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 N t r t j t | g|R ddi d S d S N
stacklevel )_loggerlogr msgargss ;/opt/alt/python311/lib64/python3.11/multiprocessing/util.pyr r , s< 8 Hc7D777Q777778 8 c N t r t j t | g|R ddi d S d S r )r r DEBUGr s r# r r 0 s< 5 E34444!444445 5r$ c N t r t j t | g|R ddi d S d S r )r r INFOr s r# r r 4 s< 4 D#3333333334 4r$ c N t r t j t | g|R ddi d S d S r )r r r r s r# r r 8 s< : J9d999q99999: :r$ c $ ddl } | t s| t adt _ t
t d r3t j t t j
t nNt j t di f t j
t di f | n# | w xY wt S )z0
Returns logger used by multiprocessing
r N
unregister )logging _acquireLockr getLogger LOGGER_NAME propagatehasattratexitr+ _exit_functionregister
_exithandlersremoveappend _releaseLock)r- s r# r
r
< s
NNN F '' 44G !G v|,,
F!.111////$++^R,DEEE$++^R,DEEE Ns CC2 2Dc ddl }t }| t }| }| | | | | r| | dat S )zB
Turn on logging and add a handler which prints to stderr
r NT)
r- r
FormatterDEFAULT_LOGGING_FORMAT
StreamHandler setFormatter
addHandlersetLevel_log_to_stderrr )levelr- logger formatterhandlers r# r r W s
NNN
\\F!!"899I##%%G ###
g N Nr$ c X t j dk rdS t t d rdS dS )NlinuxTgetandroidapilevelF)sysplatformr2 r, r$ r# #_platform_supports_abstract_socketsrK l s1
|w ts()) t 5r$ c | sdS t | t r | d dk S t | t r | d dk S t d| d )NFr zaddress type of z
unrecognized)
isinstancebytesstr TypeError)addresss r# is_abstract_socket_namespacerS t sj u'5!! "qzQ GS ! ! "qzT!!
?w???
@
@@r$ c h d } | || t j }| d |j d< d S d S )Nc > t |d t s d S Nr )
issubclassFileNotFoundError)funcpatherr_infos r# onerrorz!_remove_temp_dir..onerror s& (1+'899 r$ )r\ tempdir)r current_process_config)rmtreer] r\ r^ s r# _remove_temp_dirra sY F7G$$$$ -//O "-1 *** #"r$ c 0 t j j d } | hdd l}dd l}| d } t d| t d t |j
| fd | t j j d< | S )Nr] r zpymp-)prefixzcreated temp directory %si)r" exitpriority) r r^ r_ getshutiltempfilemkdtempr r ra r` )r] rf rg s r# r r s %''/33I>>G ""'"22
('222 'v}g.F " $ $ $ $7> !!))4 Nr$ c t t } | | D ]<\ \ }}}} || # t $ r}t d| Y d }~5d }~ww xY wd S )Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )rl indexidentrY objes r# _run_after_forkersrs s $**,, - -E JJLLL%* 8 8! tc 8 DIIII 8 8 8 3Q 7 7 7 7 7 7 7 7 88 8s A
A7 A22A7c ^ | t t t t | |f< d S N)rk next_afterfork_counterid)rq rY s r# r
r
s) EH 0112c77DABBBr$ c F e Zd ZdZd dZdeeej fdZ d Z
d Z d Z dS )
r zA
Class which supports object finalization using weakrefs
r, Nc |Et |t s0t d |t | |t j || | _ n|t d || _ || _
|pi | _ |t t f| _ t j | _ | t$ | j < d S )Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rN intrQ formattypeweakrefref_weakref
ValueError _callback_args_kwargsrv _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfrq callbackr" kwargsrd s r# __init__zFinalize.__init__ s $j c.J.J $ELL $|"4"46 67 7
7 ? #KT 2 2DMM
! JKK K!
| !4(:#;#;< IKK )-DI&&&r$ c @ || j = | j | k r |d d}n4 |d| j | j | j | j | j i | j }dx| _ x| _ x| _ x| _ | _ |S # t $ r |d Y dS w xY w)zQ
Run the callback unless it has already been called or cancelled
z+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %sz finalizer no longer registered)r r r r r r KeyError)r wrr r r ress r# __call__zFinalize.__call__ s #DI. yFFHH$$ GHHH K .$*dlD D D$dndjADLAA7;
) r AttributeErrorrQ __class__r getattrr r rP r r )r rq xs r# __repr__zFinalize.__repr__ s --//CC * CCC ;& )@@ @ '''
DNCCC
E : -
S__, ,A < 1
s4< 0 00 0A 9Q< #
"S1 %6%66 6A3ws --)r, NN)
r
__module__ __qualname____doc__r r r r r r r r r r, r$ r# r r s . . . .& &9$RY 0
<
<
<0 0 0 r$ r c t dS d n fdfdt t D }| d |D ]b}t | }|Dt d| | :# t
$ r ddl}| Y ^w xY wc t dS 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 | d d uS rV r, )ps r# z!_run_finalizers.. s qt4' r$ c 0 | d d uo | d k S rV r, )r minprioritys r# r z!_run_finalizers.. s qt4'?AaDK,? r$ c * g | ]} |
|S r, r, ).0keyfs r#
z#_run_finalizers..& s& ? ? ?C# ?C ? ? ?r$ T)reversez
calling %sr ) r rj rm re r rn traceback print_excclear)r keysr finalizerr r s ` @r# _run_finalizersr s " ' ' ? ? ? ? @ ? ? ?4 344 ? ? ?DIIdI & &'++C00 lI . . .
&
&
&
& ##%%%%%
& ! !!##### s >
B "B.-B.c " t pt du S )z6
Returns true if the process is shutting down
N)_exitingr, r$ r# r r ; s 'x4''r$ c | t sda | d |d |d | p | D ]3}|j r* | d|j |j 4 | D ]'} | d|j | ( |d | d S 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^ r s r# r4 r4 C s
$%%%
BCCC ? ( %_&&
)
)8 )D. s s|/A/A/C/C r$ )r
r s r# r zForkAwareLocal.__init__ s D"C"CDDDDDr$ c $ t | dfS )Nr, )r} r s r#
__reduce__zForkAwareLocal.__reduce__ s Dzz2~ r$ N)r r r r r r, r$ r# r r s5 E E E r$ r SC_OPEN_MAX c t | dt gz } | t t | dz
D ])}t j | | dz | |dz *d S )Nr )rj MAXFDrm rangelenr
closerange)fdsis r# r r ss
s))r5k
!CHHJJJ
3s88a<
* *
c!fQhAaC))))* *r$ c t j d S t j n# t t f$ r Y nw xY w t j t
j t
j } t
| dd t _ d S # t j | xY w# t t f$ r Y d S w xY w)Nzutf-8F)encodingclosefd) rI stdincloseOSErrorr r opendevnullO_RDONLY)fds r# _close_stdinr s
y
Z
WRZ
-
- R'5AAACIII HRLLL Z
s3 / AA)B) 1 B B&&B) )B>=B>c t j n# t t f$ r Y nw xY w t j d S # t t f$ r Y d S w xY wru )rI stdoutflushr r stderrr, r$ r# _flush_std_streamsr s
J '
J '
s ! 55 A A.-A.c dd l }dd l}t t t t
| }t
j \ }} | || gd|d d dddddd||dddd d d dd |j t
j
| t
j
| S # t
j
| t
j
| w xY w)Nr Tr F) _posixsubprocess
subprocesstuplesortedmapr{ r pipe fork_exec
_USE_VFORKr )rZ r" passfdsr r errpipe_read
errpipe_writes r# spawnv_passfdsr s F3sG,,--..G"$')) L- )) 4&$t BBL- 5"dD$D ! # #
s 0B( (*Cc 8 | D ]}t j | dS )z/Close each file descriptor given as an argumentN)r r )r r s r# close_fdsr s*
r$ c ddl m} t j ddlm} |j ddlm} |j t | | dS )zKCleanup multiprocessing resources when multiprocessing tests
completed.r )support)
forkserver)resource_trackerN)
testr r _cleanupr r _forkserver_stopr _resource_trackerr
gc_collect
reap_children)r r r s r# _cleanup_testsr s +***** """ 100000&,,... r$ ru )r sD
3 3 3 3 3 3
F
8 8 85 5 54 4 4: : : 6 * A A A A @ B B
2
2
2 $ 2g133 $Y_&& 8 8 8I I I $Y_&& S S S S Sv S S Sl&$ &$ &$ &$X( ( ( E?#*#:#*#:( ( ( (T * * * * *& * * *" Y_ BJ} % %EE EEE* * *
.
s 5D DD