֦i7 d 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 ejB Z"d Z#d Z$i Z% ejB Z& G d de' Z(d*dZ)d Z*d a+eee)e jX e jZ fd Z. ej^ e. G d d e' Z0 G d d!ejb Z2 e jf d" Z4d$ Z6d% Z7d& Z8d' Z9d( Z:d) Z;y# e5$ r d#Z4Y w xY w)+ 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|ddi y y N
stacklevel )_loggerlogr msgargss -/usr/lib64/python3.12/multiprocessing/util.pyr r , s" Hc7D7Q7 c N t r t j t | g|ddi y y r )r r DEBUGr s r# r r 0 s" E344!4 r$ c N t r t j t | g|ddi y y r )r r INFOr s r# r r 4 s" D#333 r$ c N t r t j t | g|ddi y y r )r r r r s r# r r 8 s" J9d9q9 r$ c dd l } | j t s| j t adt _ t
t d r3t j t t j t nLt j j t di f t j j t di f | j t S # | j w xY w)Nr
unregister )logging _acquireLockr getLogger LOGGER_NAME propagatehasattratexitr+ _exit_functionregister
_exithandlersremoveappend _releaseLock)r- s r# r
r
< s '' 4G !G v|,!!.1/$$++^R,DE$$++^R,DE N s B5C" "C4c dd l }t }|j t }|j }|j | |j
| | r|j | dat S )Nr T)
r- r
FormatterDEFAULT_LOGGING_FORMAT
StreamHandler setFormatter
addHandlersetLevel_log_to_stderrr )levelr- logger formatterhandlers r# r r W sg
\F!!"89I##%G #
g N Nr$ c N t j dk( ryt t d ryy)NlinuxTgetandroidapilevelF)sysplatformr2 r, r$ r# #_platform_supports_abstract_socketsrK l s"
||w s() r$ c | syt | 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 sN '5!qzQ GS !qzT!!
&wk ?
@@r$ c j d } | || t j }|d |j d< y y )Nc , t |d t s y Nr )
issubclassFileNotFoundError)funcpatherr_infos r# onerrorz!_remove_temp_dir..onerror s (1+'89 :r$ )r\ tempdir)r current_process_config)rmtreer] r\ r^ s r# _remove_temp_dirra s> 7G$ --/O "-1 * #r$ c 0 t j j j d } | fdd l}dd l}|j
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 ""'"2
('2 'v}}g.F " $7> !)))4 Nr$ c t t j } | j | D ] \ \ }}}} || y # t $ r}t d| Y d }~0d }~ww xY w)Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr )rl indexidentrY objes r# _run_after_forkersrs sa $**, -E JJL%*! tc 8 I &+ 8 3Q 7 7 8s A A% A A%c H | t t t t | |f< y N)rk next_afterfork_counterid)rq rY s r# r
r
s EH 012c7DABr$ c L e Zd Z ddZdeeej fdZd Z d Z
d Z y)r Nc | |4t |t s$t dj |t | | t j || | _ n
| t d || _ || _
|xs i | _ |t t f| _ t j | _ | t$ | j < y )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.JELL $|"467
7 ? #KKT 2DM
! JK K!
| !4(:#;< IIK )-DII&r$ c t || j = | j | k7 r |d d }nO |d| j | j | j | j | j i | j }d x| _ x| _ x| _ x| _ | _ |S # t $ r |d Y y w xY w)Nz+finalizer ignored because different processz/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
#DII. yyFH$GHK ..$**dllD$dnndjjADLLA7;
) r AttributeErrorrQ __class__r getattrr r rP r r )r rq xs r# __repr__zFinalize.__repr__ s --/C ;& )@)@@ @ ''
DNNC
E ::
S_, ,A <<
s4<< 00 0A 99Q< #
"S1 %66 6A3w * C s C( (C<;C<)r, NN) r
__module__ __qualname__r r r r r r r r r r, r$ r# r r s3 .& &9$RYY 0
<0 r$ r c ~ t y d }n fd}t t D cg c]
} || s | }}|j d |D ]. }t j | }|t d| | 0 t j y y c c}w # t
$ r dd l}|j Y mw xY w)Nc | d d uS rV r, )ps r# z!_run_finalizers.. s
qt4'r$ c & | d d uxr | d k\ S rV r, )r minprioritys r# r z!_run_finalizers.. s qt4'?AaDK,??r$ T)reversez
calling %sr ) r rj rm re r rn traceback print_excclear)r fkeykeys finalizerr s ` r# _run_finalizersr s " ' ? 34 ?4C#C4D ?IIdI'++C0 lI .
&
!!# @
& ##%
&s
BB6B B<;B<c $ t xs t d u S ru )_exitingr, r$ r# r r ; s 'x4''r$ c \ t sda | d |d |d | u | D ]< }|j s | d|j |j j > | D ]% } | d|j |j ' |d | y y )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
$%
BC ( %&88B?c t j j t j
j y # t t f$ r Y 1w xY w# t t f$ r Y y w xY wru )rI stdoutflushr r stderrr, r$ r# _flush_std_streamsr s]
J '
J '
s" A A AAA'&A'c dd l }dd l}t t t t
| }t
j \ }} |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 1B ,C c > | D ] }t j | y ru )r r )r r s r# close_fdsr s 9
r$ c ddl m} t j ddlm} |j j ddlm} |j j t | j | j y )Nr )support)
forkserver)resource_tracker)
testr r _cleanupr r _forkserver_stopr _resource_trackerr
gc_collect
reap_children)r r r s r# _cleanup_testsr sh + " 1&&,,. r$ ru )r s
3
F
854:6*A A B
2 $ 2g113 $Y__& 8I $Y__& Sv Sl&$X( E?#*#:#:#*#:#:(T *& *" Y__ BJJ} %E*
.
Q Es D% %D/.D/