*jJ S SK r S SKrS SKrS SKrS SKrS SKrS SKrS SKJr S SK r SSK
J r SSK
J r / SQr
\" \S5 r\R \R" 4rS r\S S
.r\R* S :X aP S SKrS SKr\" \S 5 ( a \R1 S
\R2 05 \R1 S\R4 05 " S S\5 r " S S\ 5 r \R> " 5 r \ " 5 r!\!RD r"\!RF r#\!RH r$\!RJ r%\" \S5 ( a \RL " \!RN S9 S r(S r)g) N)deque )spawn)util)ensure_runningregister
unregisterpthread_sigmaskc [ S5 e)Nz-noop should never be registered or cleaned up) RuntimeErrornames G/opt/alt/python313/lib64/python3.13/multiprocessing/resource_tracker.py cleanup_noopr % s
F
GG c g N r
s r r * s $r )noopdummyposix
sem_unlink semaphore
shared_memoryc \ rS rSrSrg)ReentrantCallError? r N)__name__
__module__ __qualname____firstlineno____static_attributes__r r r r r ? s r r c
\ rS rSrS rS rS rS rSS jr\ R \ R \ R \
R \
R \" \ SS5 S4S jrS
rS rS rS
rS rSS jrS rS rS rS rS r Sr g)ResourceTrackerC c [ R " 5 U l S U l S U l S U l [
5 U l SU l SU l g NTF)
threadingRLock_lock_fd_pid _exitcoder _reentrant_messages_use_simple_format_waitpid_timed_outselfs r __init__ResourceTracker.__init__E sC __&
#(7 #' #( r c [ S5 e)Nz8Reentrant call into the multiprocessing resource tracker)r r2 s r _reentrant_call_error%ResourceTracker._reentrant_call_errorW s
! FH Hr c $ U R SSS9 g )NFg ?)use_blocking_lock wait_timeout)_stopr2 s r __del__ResourceTracker.__del___ s
U
=r c F U R R 5 U R R 5 S U l S U l U R bB [ [ SS5 ( d+ U R nS U l [ R " U5 g g g ! [ a g f = f)N preserve_fdF) r+ _at_fork_reinitr/ clearr- r. r, getattr _fork_intentoscloseOSError)r3 fds r _after_fork_in_child$ResourceTracker._after_fork_in_childg s (
""$ &&( HH mU;;BDH
<
!
s :B
B B Nc b U( a% U R U R US9 S S S 5 g U R R SS9n U R US9 U( a U R R 5 g g ! , ( d f g = f! U( a U R R 5 f f = f)N)r; F)blocking)r+ _stop_lockedacquirerelease)r3 r: r; acquireds r r< ResourceTracker._stop s !!|!< zz))5)9H
)!!|!<JJ&&( JJ&&( s A9B
9
B
$B.WNOHANGc b U R R 5 S: a U R 5 eU R c g U R c g U" U R 5 S U l Uc U" U R S5 u pOhU" 5 U- n
Sn U" U R U5 u pU S:w a O?X" 5 -
n
U
S:: a S U l S U l SU l g [ U S- U
S5 n U" U 5 M[ S U l U" U 5 U l g ! [ a S U l S U l g f = f! [ a
S U l g f = f)Nr r gMbP?T g?)
r+ _recursion_countr7 r, r- r. r1 minChildProcessError
ValueError)r3 rF waitpidwaitstatus_to_exitcode monotonicsleeprR r; _statusdeadlinedelay
result_pid remainings r rM ResourceTracker._stop_locked sG :: & & (1 ,,,. . 88 99 dhh # #DIIq 1 6
%; 5 )0G)D&J!Q (9; 6I A~
%) )-26/ 9c :E%L * " 3F ;DN ! DI !DN " !DN "s6 %C< >(C< '$C< C< .
D <DDD.-D.c : U R 5 U R $ r )r r, r2 s r getfdResourceTracker.getfd s xxr c " U R 5 $ r )_ensure_running_and_writer2 s r r ResourceTracker.ensure_running s
--//r c [ R " U R 5 U R b! [ R " U R S5 S U l S U l S U l [ R " S5 g ! [
a N8f = f)Nr zUresource_tracker: process died unexpectedly, relaunching. Some resources might leak.) rE rF r, r- rY rW r. warningswarnr2 s r _teardown_dead_process&ResourceTracker._teardown_dead_process ss
yy$
499a(
A B ! s .A< <
B B c > / n UR [ R R 5 5 [
R " 5 u p# UR U5 [ R " 5 nU/[ R " 5 QSPSU S3PnS n [ ( a) [ R " [ R [ 5 n[ R " XEU5 nUb% [ R " [ R" U5 X0l Xpl [
R( " U5 g ! [ a GNf = f! Ub& [ R " [ R" U5 f f = f! [
R( " U5 e = f! [
R( " U5 f = f)Nz-cz7from multiprocessing.resource_tracker import main;main())appendsysstderrfileno ExceptionrE piper get_executabler _args_from_interpreter_flags
_HAVE_SIGMASKsignalr
SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_SETMASKr, r- rF )r3 fds_to_passrwexeargs prev_sigmaskpids r _launchResourceTracker._launch s[ szz 0 0 2 3 wwy q !&&(C224 J!AN D L
M =#)#9#9&:J:JL\#]L))#[A +**6+=+=|L
HI HHQKE 2 +**6+=+=|L , HHQK
HHQKsI -D) AE( A D: (E( F )
D76D7:+E%%E( (FF F c | U R ( a g[ R " SSS.SSS9S- R S 5 $ )
Ns
PROBE:0:noop
PROBEr )cmdrtypeT,: ensure_ascii
separators
ascii)r0 jsondumpsencoder2 s r _make_probe_message#ResourceTracker._make_probe_message sB " "$ JJ &1 !%
&/ r c U R U R R 5 S: a7 Uc U R 5 eU R R U5 sS S S 5 $ U R
b+ Uc U R
5 nOUn U R U5 S nOU R 5 S S S 5 U R R 5 nU R U5 M. ! [ a# U R 5 U R 5 Nvf = f! , ( d f Nm= f! [ a Of = fUb U R U5 g g )Nr )
r+ rU r7 r/ rq r, r _writerG rm r popleft
IndexError)r3 msgto_send
reentrant_msgs r rh )ResourceTracker._ensure_running_and_write% s!
ZZzz**,q0; 4466//66s; Z xx#; " 6 6 8G !G#KK(
+ .
$ 8 8 @ @ B
KK
& #//1LLN# Z4
? KK sH A D##DC"D5D# "*D DDD
D #
D0/D0c [ R " U R U R 5 5 g! [ a gf = fr( )rE writer, r rG r2 s r _check_alive ResourceTracker._check_aliveF s=
HHTXXt 7 7 9 : s /2
??c ( U R SX5 g )NREGISTER_sendr3 r r s r r ResourceTracker.registerQ s
:t+r c ( U R SX5 g )N
UNREGISTERr r s r r ResourceTracker.unregisterU s
<-r c F [ R " U R U5 ng r )rE r r, )r3 r nbytess r r ResourceTracker._writeY s $((C(r c U R ( aL SU; aF U SU SU S3R S5 n[ U5 S: a [ S5 eU R U5 g UR SS5 n[ U5 S: a [ S 5 e[
R " U5 R S5 nXUS
.n[ R " US S S
9S- R S5 nU R U5 g )Nr r r i z msg too longutf-8surrogateescape z+shared memory name too long (max 255 bytes))r r base64_nameTr r )
r0 r lenrX rh base64urlsafe_b64encodedecoder r )r3 r r r r bb64payloads r r ResourceTracker._send] s " "t4'7E4&%+227;C3x#~ ! 00 * *3 /
KK!2 3 q6C< JK K&&q)009 cBzz'LtS[[\cd
&&s+r )r. r, r+ r- r/ r0 r1 )TNr ) r r r! r" r4 r7 r= rI r< rE rF rY rZ timer[ r\ rC rM re r rm r r rh r r r r r r# r r r r% r% C s ($H> B
) hh
! 8 8..jjIt,<"|0B&&P B ,.? ,r r% register_at_fork)after_in_childc U R S5 ( a [ R " U R S5 5 nUS nUS nUR
SS5 n[ U[ 5 ( a* [ U[ 5 ( a [ U[ 5 ( d [ SU< 35 e [ R " U5 R S S
5 nOAU R 5 R S5 R S S
S9u p7UR S S
S9u pdX4U4$ ! [ a n[ SU < 35 UeS nAff = f! [
a n[ S U< 35 UeS nAff = f)N {r z$malformed resource_tracker message: r r r z#malformed resource_tracker fields: r r z(malformed resource_tracker base64_name: r r )maxsplit)
startswithr loadsr ru rX get
isinstancestrr urlsafe_b64decodestripsplitrsplit)lineobjer r r r rests r _decode_messager s= t X**T[[ 12C %jG ww}b)#s##:eS+A+ATWY\I]I] MN N [++C077ARSD JJL''066sQ6G kk#k2 t # X OPVW W X [ S RSYZ Z [s/ %D (&D6
D3 D..D36
E EEc j [ R " [ R [ R 5 [ R " [ R [ R 5 [ ( a) [ R
" [ R [ 5 [ R [ R 4 H n UR 5 M [ R 5 Vs0 s H
o"[ 5 _M nnSn [! U S5 nU H n [# U5 u pbn[ R% US 5 nUc [' SU SU 35 eUS:X a X2 R) U5 MW US:X a X2 R+ U5 Mr US:X a Mz [- SU- 5 e S S S 5 UR3 5 HY u p)U ( a3 S
nUS :X a O)[4 R6 " S [9 U 5 S
U SU 35 U H n [ U " U5 M M[ [ R: " U5 g ! [ a GMz f = fs snf ! [ a8 S n [ R. " [ R0 " 5 6 GMd ! GMk = ff = f! , ( d f N= f! [ a Nf = f! [ a* n
Sn[4 R6 " SU< SU
< 35 S n
A
NS n
A
ff = f! f = f! UR3 5 H u p)U ( aC S
nUS :X a O9[4 R6 " S [9 U 5 S
U SU 35 O! [ a Of = fU HQ n [ U " U5 O7! [ a* n
Sn[4 R6 " SU< SU
< 35 S n
A
OS n
A
ff = fMN ! f = f M [ R: " U5 f = f)Nr rbzCannot register z. for automatic cleanup: unknown resource type r r r zunrecognized command %r r r z%resource_tracker: There appear to be z leaked z" objects to clean up at shutdown: rT zresource_tracker: z: ) rz SIGINTSIG_IGNSIGTERMry r
SIG_UNBLOCKr| rr stdinstdoutrF ru _CLEANUP_FUNCSkeyssetopenr r rX addremover
excepthookexc_infoitemsrk rl r exit) rH fr cache exit_coder r r cleanup_func rtype_cacher s r mainr sd MM&-- 0
MM&..&..1} v 1 13CDii
$
GGI % (6':':'< =' > j( ((. , ++D1 *+Ds+J KK! 4 #(++- E
!I '
C "; / 0 @55@M C $N&u-d3
$! #0:
>. ! !I 7 % ^P ! % N$%
D!&LMMN 7 #(++- E
!I '
C "; / 0 @55@M C
! #N&u-d3$ N$%
D!&LMMN D $! #0: sK ?H')H9 K JAH>&J(H>JH> J H>JK J (J9J$'
H65H6> J &I51J5I< 7J 8J<J J
J
K
J! J!$
K. KKKKK N2>L0N2(L0/N20
L= :N2<L= =N2MN
N ! N NN NN2N N2)*r rE rz rr r) r rk collectionsr r r r r __all__hasattrry r r r| r r r _multiprocessing _posixshmemupdater
shm_unlinkr r objectr% localrD _resource_trackerr r r re r rI r r r r r r sS $
6 12
MM6>>2 H
77g .. )44
//
y,f y,B
#% "11 % %
)
)
2!""'8'M'MN 0J r