*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 r1 s r _reentrant_call_error%ResourceTracker._reentrant_call_errorW s
! FH Hr c $ U R SSS9 g )NFg ?)use_blocking_lock wait_timeout)_stopr1 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)r2 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)r2 r9 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_countr6 r+ r, r- r0 minChildProcessError
ValueError)r2 rE waitpidwaitstatus_to_exitcode monotonicsleeprQ r: _statusdeadlinedelay
result_pid remainings r rL 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+ r1 s r getfdResourceTracker.getfd s xxr c " U R 5 $ )zMake sure that resource tracker process is running.
This can be run from any process. Usually a child process will use
the resource created by its parent.)_ensure_running_and_writer1 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.) rD rE r+ r, rX rV r- warningswarnr1 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 ExceptionrD piper get_executabler _args_from_interpreter_flags
_HAVE_SIGMASKsignalr
SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_SETMASKr+ r, rE )r2 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 $ )
zReturn a probe message.s
PROBE:0:noop
PROBEr )cmdrtypeT,: ensure_ascii
separators
ascii)r/ jsondumpsencoder1 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* rT r6 r. rp r+ r _writerF rl r popleft
IndexError)r2 msgto_send
reentrant_msgs r rg )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 = f)z;Check that the pipe has not been closed by sending a probe.TF)rD writer+ r rF r1 s r _check_alive ResourceTracker._check_aliveF s=
HHTXXt 7 7 9 : s /2
??c ( U R SX5 g)z0Register name of resource with resource tracker.REGISTERN_sendr2 r r s r r ResourceTracker.registerQ s
:t+r c ( U R SX5 g)z2Unregister name of resource with resource tracker.
UNREGISTERNr r s r r ResourceTracker.unregisterU s
<-r c [ R " U R U5 nU[ U5 :X d SU< S[ U5 < 35 eg )Nznbytes=z
!= len(msg)=)rD r r+ len)r2 r nbytess r r ResourceTracker._writeY s> $((C(S!>gfYn3s8+#>>!r c R 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 n[ U5 S:: d S[ U5 S35 eUR S5 ( d eU 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 z"internal error: message too long (z bytes) {) r/ r r rW rg base64urlsafe_b64encodedecoder r
startswith)r2 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 3x3V"DSXJg VV~~d#### &&s+r )r- r+ r* r, r. r/ r0 )TNr ) r r r! r" r3 r6 r< rH r; rD rE rX rY timerZ r[ rB rL rd r rl r r rg 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)Nr 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)r r loadsr rt rW 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% US5 nUc [' SU SU 35 eUS:X a X2 R) U5 MW US:X a X2 R+ U5 Mr US:X a Mz [- S U- 5 e SSS5 UR3 5 HY u p)U ( a3 S nUS :X a O)[4 R6 " S
[9 U 5 SU 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 Sn
A
NSn
A
ff = f! f = f! UR3 5 H u p)U ( aC S nUS :X a O9[4 R6 " S
[9 U 5 SU SU 35 O! [ a Of = fU HQ n [ U " U5 O7! [ a* n
Sn[4 R6 " SU< SU
< 35 Sn
A
OSn
A
ff = fMN ! f = f M [ R: " U5 f = f)zRun resource tracker.r rbNzCannot 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: rS zresource_tracker: z: ) ry SIGINTSIG_IGNSIGTERMrx r
SIG_UNBLOCKr{ rq stdinstdoutrE rt _CLEANUP_FUNCSkeyssetopenr r rW addremover
excepthookexc_infoitemsrj rk r exit) rG 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 rD ry rq r( r rj collectionsr r r r r __all__hasattrrx r r r{ r r r _multiprocessing _posixshmemupdater
shm_unlinkr r objectr% localrC _resource_trackerr r r rd r rH 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