python (3.12.0)
̑e6 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 H t r t j t | g| y y N)_loggerlogr msgargss H/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/multiprocessing/util.pyr r , s Hc)D) c H t r t j t | g| y y r )r r DEBUGr s r! r r 0 s E3&& r" c H t r t j t | g| y y r )r r INFOr s r! r r 4 s D#%% r" c H t r t j t | g| y y r )r r r r s r! r r 8 s J+d+ r" c ddl } | 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)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
'' 4G !G v|,!!.1/$$++^R,DE$$++^R,DE N s B5C! !C3c ddl }t }|j t }|j }|j | |j
| | r|j | 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 sb
\F!!"89I##%G #
g N Nr" c N t j dk( ryt t d ryy)NlinuxTgetandroidapilevelF)sysplatformr0 r* r" r! #_platform_supports_abstract_socketsrI 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_namespacerQ t sN '5!qzQ GS !qzT!!
&wk ?
@@r" c ` | | t j }|d |j d< y y )Ntempdir)r current_process_config)rmtreerS rT s r! _remove_temp_dirrW s4
7O --/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 )NrS r zpymp-)prefixzcreated temp directory %si)r exitpriority) r rT rU getshutiltempfilemkdtempr r rW rV )rS r\ r] 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 )rb indexidentfuncobjes r! _run_after_forkersrj sf $**, -E JJL%* 8! tc 8 I8 8 3Q 7 7 8s A A% A A%c H | t t t t | |f< y r )ra next_afterfork_counterid)rh rg s r! r
r
s EH 012c7DABr" c N e Zd ZdZddZdeeej fdZ d Z
d Z d Z y) r zA
Class which supports object finalization using weakrefs
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)rL intrO formattypeweakrefref_weakref
ValueError _callback_args_kwargsrl _finalizer_counter_keyosgetpid_pid_finalizer_registry)selfrh callbackr kwargsrZ s r! __init__zFinalize.__init__ s $j c.JELL $|"467
7 ? #KKT 2DM
! JK K!
| !4(:#;< IIK )-DII&r" c r || j = | j | k7 r |d d}nO |d| j | j | j | j | j i | j }dx| _ x| _ x| _ x| _ | _ |S # t $ r |d Y yw 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 rx ry rz rv KeyError)r wrr r r~ ress r! __call__zFinalize.__call__ s #DII. yyFH$GHK ..$**dllD$dnndjjADLLA7;
<DM
<DN
<TZ
< L49J 8 6 7 8s
B" "B65B6c t | j = dx| _ x| _ x| _ x| _ | _ y# t $ r Y yw xY w)z3
Cancel finalization of the object
N)r r| rv rx ry rz r r s r! cancelzFinalize.cancel sU <#DII.
8<
<DM
<DN
<TZ
< L49 s 7 AAc & | j t v S )zS
Return whether this finalizer is still waiting to invoke callback
)r| r r s r! still_activezFinalize.still_active s yy ///r" c | j }|d| j j z S d| j j dt | j d| j }| j r|dt | j z z
}| j r|dt | j z z
}| j d |dt | j d z z
}|d z S # t t f$ r d }Y w xY w)
Nz<%s object, dead><z object, callback=__name__z, args=z , kwargs=r z, exitpriority=>) rv AttributeErrorrO __class__r getattrrx ry rN rz r| )r rh 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____doc__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 yyc c}w # t
$ r ddl}|j Y mw xY w)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 Nr r* )ps r! <lambda>z!_run_finalizers.<locals>.<lambda> s qt4' r" c & | d d uxr | d k\ S r r* )r minprioritys r! r z!_run_finalizers.<locals>.<lambda> s qt4'?AaDK,? r" T)reversez
calling %sr ) r r` rc r[ r rd traceback print_excclear)r fkeykeys finalizerr s ` r! _run_finalizersr s " ' ? 34 ?C#C ?D ?IIdI &'++C0 lI .
&
& !!# @
& ##%
&s
BB5B B;:B;c " t xs t du S )z6
Returns true if the process is shutting down
N)_exitingr* r" r! r r 8 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_childrenrT r s r! r2 r2 @ s
$%
BC ( %&
)88<affEHH&&(
)
%&
4aff=
9:? r" c $ e Zd Zd Zd Zd Zd Zy)r c t j | _ | j j | _ | j j | _ t | t j y r ) threadingLock_lockacquirereleaser
r _at_fork_reinitr s r! r z ForkAwareThreadLock.__init__q sC ^^%
zz)) zz)) D"5"E"EFr" c 8 | j j y r )r r r s r! r z#ForkAwareThreadLock._at_fork_reinitw s
""$r" c 6 | j j S r )r __enter__r s r! r z ForkAwareThreadLock.__enter__z s zz##%%r" c 4 | j j | S r )r __exit__)r r s r! r z ForkAwareThreadLock.__exit__} s "tzz""D))r" N)r r r r r r r r* r" r! r r p s G %&*r" r c e Zd Zd Zd Zy)r c t | d y )Nc 6 | j j S r )__dict__r )rh s r! r z)ForkAwareLocal.__init__.<locals>.<lambda> s s||/A/A/C r" )r
r s r! r zForkAwareLocal.__init__ s
D"CDr" c t | dfS )Nr* )rs r s r!
__reduce__zForkAwareLocal.__reduce__ s Dz2~ r" N)r r r r r r* r" r! r r s
E r" r SC_OPEN_MAX c t | dt gz } | j | d t k( sJ d t t | dz
D ]$ }t j | | dz | |dz & y )Nz fd too larger )r` MAXFDrc rangelenr}
closerange)fdsis r! r r sk
s)r5k
!CHHJ r7e +^+
3s8a<
*
c!fQhAaC)*r" c t j y t j j t j t
j t
j } t
| dd t _ y # t t f$ r Y ]w xY w# t j | xY w# t t f$ r Y y w xY w)Nzutf-8F)encodingclosefd) rG stdincloseOSErrorrw r} opendevnullO_RDONLY)fds r! _close_stdinr s
yy
WWRZZ
- R'5ACI
Z
HHRL Z
s4 A= 2B- %B =BBB**B- -B?>B?c t j j t j
j y # t t f$ r Y 1w xY w# t t f$ r Y y w xY wr )rG stdoutflushr rw 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
subprocesstuplesortedmaprq r} pipe fork_exec
_USE_VFORKr )pathr 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)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 j ddlm} |j j t | j | j y)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 sc + " 1&&,,. r" r )<r} itertoolsrG rt r1 r r r r __all__NOTSETr r$ r& r r. r: r r? r r r r r
r rI rQ abstract_sockets_supportedrW r WeakValueDictionaryra countrm rj r
r r{ objectr r r r r rT r2 r3 r localr sysconfr rd r r r r r r r* r" r! <module>r s
3
F
*'&,6*A A B 2 $ 2g113 $Y__& 8I $Y__& Sv Sl&$X( E?#*#:#:#*#:#:(T *& *" Y__ BJJ} %E*
.
Q Es D% %D/.D/
Browse
Usage
Versions