F\h6lSSKrSSKrSSKrSSKrSSKrSSKrSSKJr SSKJ r /SQr Sr Sr Sr SrS rS rS rSqS qS rSrSrSrSrS*SjrSrSr\"5rSrSr\R>"5r \RB"5r"Sr#Sr$0r%\RB"5r&"SS\'5r(S*Sjr)Sr*S q+\\\)\ RX\ RZ4Sjr.\R^"\.5 "SS\'5r0"S S!\Rb5r2\Rf"S"5r4S$r6S%r7S&r8S'r9S(r:S)r;g!\5a S#r4Nf=f)+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)sFcZ[(a [R"[U/UQ7SS06 ggN stacklevel)_loggerlogrmsgargss +/usr/lib/python3.13/multiprocessing/util.pyrr,s$w Hc7D7Q7cZ[(a [R"[U/UQ7SS06 ggr)rrDEBUGr s r#rr0s$w E344!4r$cZ[(a [R"[U/UQ7SS06 ggr)rrINFOr s r#rr4s$w D#333r$cZ[(a [R"[U/UQ7SS06 ggr)rrrr s r#r r 8s$w J9d9q9r$cSSKnUR [(dUR[5qS[l[ [S5(a5[R"[5 [R"[5 OL[RR[S045 [RR[S045 SSS5 [$!,(df  [$=f)z( Returns logger used by multiprocessing rN unregister)logging_lockr getLogger LOGGER_NAME propagatehasattratexitr+_exit_functionregister _exithandlersremoveappend)r-s r#r r <s  w'' 4G !G v|,,!!.1/$$++^R,DE$$++^R,DE  N  Ns CC!! C4cSSKn[5nUR[5nUR 5nUR U5 UR U5 U(aURU5 Sq[$)z: Turn on logging and add a handler which prints to stderr rNT) r-r FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrr)levelr-logger formatterhandlers r#r r Ssb  \F!!"89I##%G # g N Nr$c([RS;$)N)linuxandroid)sysplatformr,r$r##_platform_supports_abstract_socketsrJhs <</ //r$cU(dg[U[5(aUSS:H$[U[5(aUSS:H$[SU<S35e)NFrzaddress type of z unrecognized) isinstancebytesstr TypeError)addresss r#is_abstract_socket_namespacerRlsT '5!!qzQ GS ! !qzT!! &wk? @@r$cdU"U5 [R"5nUbSURS'gg)Ntempdir)rcurrent_process_config)rmtreerTrUs r#_remove_temp_dirrX|s4 7O--/O"-1 *#r$c*[R"5RRS5nUcaSSKnSSKnUR SS9n[SU5 [S[URU4SS9 U[R"5RS'U$)NrTrzpymp-)prefixzcreated temp directory %si)r" exitpriority) rrUrVgetshutiltempfilemkdtemprrrXrW)rTr]r^s r#r r s%%'//33I>G""'"2 ('2 'v}}g.F" $7>!)))4 Nr$c[[R55nUR5 UHuupp4U"U5 M g![an[ SU5 SnAM2SnAff=f)Nz after forker raised exception %s)list_afterfork_registryitemssort Exceptionr)rcindexidentfuncobjes r#_run_after_forkersrks] $**, -E JJL%*!t 8 I&+ 8 3Q 7 7 8sA A' A""A'cHU[[[5[U5U4'gN)rbnext_afterfork_counterid)rirhs r#r r sEH012c7DABr$cZ\rSrSrSrS SjrS\\\R4Sjr Sr Sr Sr S rg) rz9 Class which supports object finalization using weakrefs NcUb9[U[5(d$[SRU[ U555eUb[ R "X5UlOUc [S5eX l X0l U=(d 0Ul U[[54Ul[R "5UlU[$UR'g)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rMintrPformattypeweakrefref_weakref ValueError _callback_args_kwargsrn_finalizer_counter_keyosgetpid_pid_finalizer_registry)selfricallbackr"kwargsr[s r#__init__Finalize.__init__s  $jc.J.JELL $|"467 7 ?#KK2DM  !JK K! | !4(:#;< IIK )-DII&r$ctX R URU"5:wa U"S5 SnOOU"SURURUR5 UR"UR0URD6nS=Ul=Ul=Ul=UlUlU$![ a U"S5 gf=f)zA 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 %szfinalizer no longer registered)rrr{r|r}ryKeyError)rwrrrrress r#__call__Finalize.__call__s #II.yyFH$GHK..$**dllDnndjjADLLA7; ) ryAttributeErrorrP __class__rgetattrr{r|rOr}r)rrixs r#__repr__Finalize.__repr__s --/C ;&)@)@@ @ '' DNNC E :: S_, ,A << s4<<00 0A 99Q< # "S1%66 6A3w * C sC66D  D )r|r{rr}rry)r,NN)r __module__ __qualname____firstlineno____doc__rrrrrrrrr__static_attributes__r,r$r#rrs3.&&9$RYY 0 <0 r$rc^[cgTcSnOU4Sjn[[5Vs/sHo!"U5(dMUPM nnURSS9 UH1n[RU5nUcM[ SU5 U"5 M3 Tc[R5 ggs snf![ a SSKnUR5 Mtf=f)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. NcUSSL$Nrr,)ps r#!_run_finalizers..s qt4'r$c0>USSL=(a UST:$rr,)r minprioritys r#rrsqt4'?AaDK,??r$T)reversez calling %sr) rrardr\rre traceback print_excclear)rfkeykeys finalizerrs` r#_run_finalizersrs"  ' ? 34 ?4C#C4D ?IIdI'++C0  lI . & !!# @ & ##% &sB#B#?B((C  C c,[=(d [SL$)z. Returns true if the process is shutting down N)_exitingr,r$r#rr0s  'x4''r$c|[(dSqU"S5 U"S5 U"S5 U"5bU"5HCnUR(dMU"SUR5 URR 5 ME U"5H&nU"SUR5 UR 5 M( U"S5 U"5 gg)NTzprocess shutting downz2running all "atexit" finalizers with priority >= 0rz!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)rdaemonname_popen terminatejoin)rrractive_childrenrUrs r#r4r48s 8 $% BC   (%&888.{ss||/A/A/Cr$)r rs r#rForkAwareLocal.__init__zs D"CDr$c[U5S4$)Nr,)rvrs r# __reduce__ForkAwareLocal.__reduce__|sDz2~r$r,N)rrrrrrrr,r$r#rrys Er$r SC_OPEN_MAXc[U5S[/-nUR5 US[:XdS5e[[ U5S- 5H$n[ R "XS-XS-5 M& g)Nz fd too larger)raMAXFDrdrangelenr closerange)fdsis r#rrse s)r5k !CHHJ r7e +^+  3s8a<  cfQhaC)!r$c[Rcg[RR5 [ R "[ R[ R5n[ USSS9[lg![[4a N\f=f! [ R"U5 e=f![[4a gf=f)Nzutf-8F)encodingclosefd) rHstdincloseOSErrorrzropendevnullO_RDONLY)fds r# _close_stdinrs yy   WWRZZ - R'5ACI Z      HHRL  Z    s4A<3B.'B<BBB++B..CCc[RR5 [R R5 g![[4a N2f=f![[4a gf=frm)rHstdoutflushrrzstderrr,r$r#_flush_std_streamsrs]     J '    J '   s"AAAAA)(A)cSSKnSSKn[[[ [ U555n[ R"5upVURX/SUSSSSSSSSXVSSSSSSSSUR5[ R"U5 [ R"U5 $![ R"U5 [ R"U5 f=f)NrTrF) _posixsubprocess subprocesstuplesortedmaprtrpipe fork_exec _USE_VFORKr)pathr"passfdsrr errpipe_read errpipe_writes r#spawnv_passfdsrsF3sG,-.G"$'')L )) &$t BBL 5"dD$D  ! ! #    s /B.C cBUHn[R"U5 M g)z/Close each file descriptor given as an argumentN)rr)rrs r# close_fdsrs  r$cSSKJn [R"5 SSKJn UR R5 SSKJn URR5 [5 UR5 UR5 g)zGCleanup multiprocessing resources when multiprocessing tests completed.r)support) forkserver)resource_trackerN) testrr_cleanuprr _forkserver_stopr_resource_trackerr gc_collect reap_children)rrrs r#_cleanup_testsr sc +  "1&&,,.  r$rm)rs   3        F 854:.*0AAB 2 $113__&8I__&SvSl&$X( E?#*#:#:#*#:#:(T *&*"Y__ JJ} %E* .    Q EsD((D32D3