@,bi;"SSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKrSSK J r SSK J r /SQr \ "\S5r\R\R 4rSr\S S .r\R(S :XaPSSKrSSKr\ "\S 5(a\R/S \R005 \R/S\R205 "SS\5r"SS\5r\"5r\R>r\R@r \RBr!\RDr"Sr#Sr$g)N)deque)spawn)util)ensure_runningregister unregisterpthread_sigmaskc[S5e)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 GGcgNr s rr)s$r)noopdummyposix sem_unlink semaphore shared_memoryc\rSrSrSrg)ReentrantCallError>rN)__name__ __module__ __qualname____firstlineno____static_attributes__rrrrr>srrc\rSrSrSrSrSrSSjr\R\R\R4Sjr Sr SrS rS rS rSS jrSrSrSrSrSrSrg )ResourceTrackerBc[R"5UlSUlSUlSUl[ 5UlSUlg)NT) threadingRLock_lock_fd_pid _exitcoder_reentrant_messages_use_simple_formatselfs r__init__ResourceTracker.__init__Ds9__&  #(7 #'rc[S5e)Nz8Reentrant call into the multiprocessing resource tracker)rr0s r_reentrant_call_error%ResourceTracker._reentrant_call_errorRs ! FH Hrc"URSS9 g)NF)use_blocking_lock)_stopr0s r__del__ResourceTracker.__del__Zs U +rcfU(a&UR UR5 SSS5 gURRSS9nUR5 U(aURR5 gg!,(df  g=f!U(aURR5 ff=f)NF)blocking)r* _stop_lockedacquirerelease)r1r8acquireds rr9ResourceTracker._stop`s !!#zz))5)9H )!!#JJ&&(JJ&&(sA;B ; B  $B0cURR5S:aUR5eURcgURcgU"UR5 SUlU"URS5upESUlU"U5Ulg![ a SUlSUlgf=f![a SUlgf=f)Nrr)r*_recursion_countr5r+r,ChildProcessErrorr- ValueError)r1closewaitpidwaitstatus_to_exitcode_statuss rr>ResourceTracker._stop_lockedls :: & & (1 ,,,. . 88   99   dhh  1-IA   "3F;DN! DI!DN   "!DN "s$%B B.B+*B+.CCc:UR5 UR$r)rr+r0s rgetfdResourceTracker.getfds xxrc"UR5$)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_writer0s rrResourceTracker.ensure_runnings --//rc[R"UR5 URb![R"URS5 SUlSUlSUl[R"S5 g![ a N8f=f)NrzUresource_tracker: process died unexpectedly, relaunching. Some resources might leak.) osrGr+r,rHrEr-warningswarnr0s r_teardown_dead_process&ResourceTracker._teardown_dead_processss  yy$ 499a(  A B!   s.A<< B B c>/nUR[RR55 [ R "5up#URU5 [R"5nU/[R"5QSPSUS3PnSn[(a)[R"[R[5n[R "XEU5nUb%[R"[R"U5 X0lXpl[ R("U5 g![a GNf=f!Ub&[R"[R"U5 ff=f! [ R("U5 e=f![ R("U5 f=f)Nz-cz7from multiprocessing.resource_tracker import main;main())appendsysstderrfileno ExceptionrTpiperget_executabler_args_from_interpreter_flags _HAVE_SIGMASKsignalr SIG_BLOCK_IGNORED_SIGNALSspawnv_passfds SIG_SETMASKr+r,rG)r1 fds_to_passrwexeargs prev_sigmaskpids r_launchResourceTracker._launchs[     szz002 3wwy    q !&&(C224J!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((FFFc|UR(ag[R"SSS.SSS9S-RS 5$) zReturn a probe message.s PROBE:0:noop PROBEr)cmdrtypeT,: ensure_ascii separators ascii)r/jsondumpsencoder0s r_make_probe_message#ResourceTracker._make_probe_messagesB  " "$ JJ&1!%     &/ rNcUR URR5S:a7UcUR5eURR U5sSSS5 $UR b+UcUR 5nOUnURU5 SnOUR5 SSS5 URR5nURU5 M.![a# UR5 UR5 Nvf=f!,(df  Nm=f![a Of=fUbURU5 gg)Nr) r*rDr5r.r[r+r_writeOSErrorrWrppopleft IndexError)r1msgto_send reentrant_msgs rrQ)ResourceTracker._ensure_running_and_writes! ZZzz**,q0;4466//66s; Zxx#;"668G!G#KK(  +.  $ 8 8 @ @ B  KK & #//1LLN#Z4   ? KK  sHA D##DC"D5D#"*D DDD D # D0/D0c[R"URUR55 g![a gf=f)z;Check that the pipe has not been closed by sending a probe.TF)rTwriter+rrr0s r _check_aliveResourceTracker._check_alives=  HHTXXt779 :  s /2 ??c(URSX5 g)z0Register name of resource with resource tracker.REGISTERN_sendr1rrus rrResourceTracker.registers :t+rc(URSX5 g)z2Unregister name of resource with resource tracker. UNREGISTERNrrs rr ResourceTracker.unregisters <-rc[R"URU5nU[U5:XdSU<S[U5<35eg)Nznbytes=z != len(msg)=)rTrr+len)r1rnbytess rrResourceTracker._writes>$((C(S!>gfYn3s8+#>>!rcRUR(aLSU;aFUSUSUS3RS5n[U5S:a [S5eUR U5 gURSS5n[U5S:a [S 5e[ R "U5RS5nXUS .n[R"US S S 9S-RS5n[U5S::dS[U5S35eURS5(deUR U5 g)Nr|rxr}iz msg too longutf-8surrogateescapez+shared memory name too long (max 255 bytes))rtru base64_nameTrvryz"internal error: message too long (z bytes){) r/rrrFrQbase64urlsafe_b64encodedecoder~r startswith)r1rtrrurbb64payloads rrResourceTracker._sends  " "t4'7E4&%+227;C3x#~!00  * *3 /  KK!2 3 q6C<JK K&&q)009cBzz'LtS[[\cd3x3V"DSXJg VV~~d#### &&s+r)r-r+r*r,r.r/)Tr)rr r!r"r2r5r:r9rTrGrHrIr>rNrrWrprrQrrr rrr#rrrr%r%Bsp 'H, )hh !88 !"F0B&&P B ,.?,rr%cURS5(a[R"URS55nUSnUSnUR SS5n[U[5(a*[U[5(a[U[5(d[ SU<35e[R"U5RS S 5nOAUR5RS5RS S S9up7URS S S9updX4U4$![an[ SU<35UeSnAff=f![ an[ S U<35UeSnAff=f)Nrr}z$malformed resource_tracker message: rtrurz#malformed resource_tracker fields: rrz(malformed resource_tracker base64_name: rxr)maxsplit)rr~loadsrr_rFget isinstancestrrurlsafe_b64decodestripsplitrsplit)lineobjertrurrrests r_decode_messagerBs= t X**T[[12C%jG ww}b)#s##:eS+A+ATWY\I]I]MN N [++C077ARSDJJL''066sQ6G kk#k2  t # XOPVW W X [SRSYZ Z [s/%D(&D6 D3D..D36 EEEc j[R"[R[R5 [R"[R[R5 [(a)[R "[R [5 [R[R4HnUR5 M [R5Vs0sH o"[5_M nnSn[!US5nUHn[#U5upbn[R%US5nUc['SUSU35eUS:XaX2R)U5 MWUS:XaX2R+U5 MrUS:XaMz[-S U-5e SSS5 UR35HYup)U (a3S nUS :XaO)[4R6"S [9U 5SUSU 35 U Hn[U"U5 M M[ [R:"U5 g![a GMzf=fs snf![a8 S n[R."[R0"56 GMd! GMk=ff=f!,(df  N=f![a Nf=f![a*n Sn[4R6"SU<SU <35 Sn A NSn A ff=f!f=f!UR35Hup)U (aCS nUS :XaO9[4R6"S [9U 5SUSU 35 O![a Of=fU HQn[U"U5 O7![a*n Sn[4R6"SU<SU <35 Sn A OSn A ff=fMN!f=f M [R:"U5 f=f)zRun resource tracker.rrbNzCannot register z. for automatic cleanup: unknown resource type rrrszunrecognized command %rrrz%resource_tracker: There appear to be z leaked z" objects to clean up at shutdown: zresource_tracker: z: )rdSIGINTSIG_IGNSIGTERMrcr SIG_UNBLOCKrfr\stdinstdoutrGr__CLEANUP_FUNCSkeyssetopenrrrFaddremover excepthookexc_infoitemsrUrVrexit) fdfrucache exit_coderrtr cleanup_func rtype_cachers rmainrZsd MM&--0 MM&..&..1}v113CDii $  GGI% (6':':'< ='>j( ((. , ++D1*+Ds+JKK!4#(++- E  !I' C";/0@55@MC$N&u-d3 $!#0:     >.! !I 7 %^P!%N$%  D!&LMMN7#(++- E  !I' C";/0@55@MC !#N&u-d3$N$%  D!&LMMND$!#0: sK?H')H9 K JAH>&J(H>JH> J H>JK J (J9J$' H65H6> J &I51J5I< 7J8J<JJ J K  J! J!$ K. KKKKK N2>L0N2(L0/N20 L= :N2<L= =N2MN N ! N NN NN2N  N2)%rrTrdr\r(rU collectionsrr~rrr__all__hasattrrcrrrfrrr_multiprocessing _posixshmemupdater shm_unlinkr robjectr%_resource_trackerrrr rNrrrrrrs$   6 12 MM6>>2H   77g.. )44  //   w,fw,r$%"11  % %  ) ) 0Jr