python (3.11.7)
e6 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 H t rt j t | g|R d S d S N)_loggerlogr msgargss H/BuggyBox/python/3.11.7/bootstrap/lib/python3.11/multiprocessing/util.pyr r , s4 * Hc)D))))))* * c H t rt j t | g|R d S d S r )r r DEBUGr s r! r r 0 s4 ' E3&&&&&&&' 'r" c H t rt j t | g|R d S d S r )r r INFOr s r! r r 4 s4 & D#%%%%%%%& &r" c H t rt j t | g|R d S d S r )r r r r s r! r r 8 s4 , J+d++++++, ,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)sysplatformr0 r* r" r! #_platform_supports_abstract_socketsrI 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_namespacerQ t sj u'5!! "qzQ GS ! ! "qzT!!
?w???
@
@@r" c ^ | | t j }| d |j d< d S d S )Ntempdir)r current_process_config)rmtreerS rT s r! _remove_temp_dirrW s@
F7OOO -//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 )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 ""'"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 )rb indexidentfuncobjes r! _run_after_forkersrj 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 r )ra next_afterfork_counterid)rh rg 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)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.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 rx ry rz rv KeyError)r wrr r r~ ress r! __call__zFinalize.__call__ s #DI. yFFHH$$ GHHH K .$*dlD D D$dndjADLAA7;
<DM
<DN
<TZ
< L49J 8 8 8 I6 7 7 7 7 7 7 8s B B B c t | j = dx| _ x| _ x| _ x| _ | _ dS # t $ r Y dS w xY w)z3
Cancel finalization of the object
N)r r| rv rx ry rz r r s r! cancelzFinalize.cancel sg <#DI.
8<
<DM
<DN
<TZ
< L4999 DD s
4
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 y ///r" c | }n# t t f$ r d }Y nw xY w|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 )
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 --//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 Nr r* )ps r! <lambda>z!_run_finalizers.<locals>.<lambda> s qt4' r" c 0 | d d uo | d k S r r* )r minprioritys r! r z!_run_finalizers.<locals>.<lambda> s qt4'?AaDK,? r" c * g | ]} |
|S r* r* ).0keyfs r!
<listcomp>z#_run_finalizers.<locals>.<listcomp># s& ? ? ?C# ?C ? ? ?r" T)reversez
calling %sr ) r r` rc r[ r rd 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 8 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_childrenrT r s r! r2 r2 @ s
$%%%
BCCC ? ( %_&&
)
)8 )D<afEEEH&&((($_&&
4af===
9:::? r" c & e Zd Zd Zd Zd Zd ZdS )r c t j | _ | j j | _ | j j | _ t | t j d S r ) threadingLock_lockacquirereleaser
r _at_fork_reinitr s r! r z ForkAwareThreadLock.__init__q sC ^%%
z) z) D"5"EFFFFFr" c 8 | j d S r )r r r s r! r z#ForkAwareThreadLock._at_fork_reinitw s
""$$$$$r" c 4 | j S r )r __enter__r s r! r z ForkAwareThreadLock.__enter__z s z##%%%r" c | j j | S r )r __exit__)r r s r! r z ForkAwareThreadLock.__exit__} s "tz"D))r" N)r r r r r r r r* r" r! r r p sS G G G % % %& & &* * * * *r" r c e Zd Zd Zd ZdS )r c ( t | d d S )Nc 4 | j S r )__dict__r )rh s r! r z)ForkAwareLocal.__init__.<locals>.<lambda> s s|/A/A/C/C r" )r
r s r! r zForkAwareLocal.__init__ s D"C"CDDDDDr" c $ t | dfS )Nr* )rs 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 )r` MAXFDrc 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) rG stdincloseOSErrorrw 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 wr )rG stdoutflushr rw 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
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 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" 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
sD
3 3 3 3 3 3
F
* * *' ' '& & &, , , 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
Browse
Usage
Versions