+ iDcs^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RIH t .R(Ot ^t ^t ^ t ^t^t^tRtRtRsR sR tR tR tR tRtRtR)RltRtRt]!4t]P>R8Xd^lt M9]P>PCR*4'd^ht M]PDR8XdRM^\t Rt#Rt$Rt%]PL!4t']PP!4t)Rt*Rt+/t,]PP!4t-!RR].4t/R)Rlt0Rt1R s2]]]0] Pf] Ph3Rlt5]Pl!]54!RR].4t7!RR]Pp4t9]Pt!R 4t;R"t=R#t>R$t?R%t@R&tAR'tBR# ]<dR!t;Li;i)+N)_args_from_interpreter_flags)processFinalizeForkAwareThreadLockForkAwareLocalmultiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc`\'d"\P!\V.VO5R^/R#R#Z stacklevelN)_loggerlogSUBDEBUGZmsgargs&*-/usr/lib64/python3.14/multiprocessing/util.py sub_debugr-s$w Hc7D7Q7crr)r r DEBUGr rrdebugr1s$w E344!4rcrr)r r INFOr rrinfor5s$w D#333rcrr)r r WARNINGr rrwarnr9s$w GS646A6rcrr)r r SUBWARNINGr rr sub_warningr=s$w J9d9q9rcs^RIpVP;_uu_4\'gVP\4s^\n\ \R4'd6\P!\4\P!\4ML\PP\R/34\PP\R/34RRR4\# +'gi\#;i)z( Returns logger used by multiprocessing N unregister)logging_lockr Z getLogger LOGGER_NAMEZ propagateZhasattratexitr_exit_functionregisterZ _exithandlersZremoveZappend)r r get_loggerr#As  w'' 4G !G v|,,!!.1/$$++^R,DE$$++^R,DE  N  Ns CC++ D cs^RIp\4pVP\4pVP 4pVP V4VP V4V'dVPV4Rs\#)z: Turn on logging and add a handler which prints to stderr NT) rr#Z FormatterDEFAULT_LOGGING_FORMATZ StreamHandlerZ setFormatterZ addHandlerZsetLevel_log_to_stderrr )ZlevelrZloggerZ formatterZhandler& r log_to_stderrr'Xsb  \F!!"89I##%G # g N Nrcs(\PR9#)linux)r(Zandroid)sysplatformrrr#_platform_supports_abstract_socketsr+ms <</ //rcsV'gR#\V\4'd V^,^8H#\V\4'd V^,R8H#\RV: R24h)FZzaddress type of z unrecognized) isinstanceZbytesstr TypeError)Zaddress&ris_abstract_socket_namespacer0qsT '5!!qzQ GS ! !qzT!! &wk? @@rr(ntcsjV!V4\P!4pVeRVPR&R#R#)Ntempdir)rcurrent_process_config)rmtreer2r3s&& r_remove_temp_dirr6s4 7O--/O"-1 *#rcs"\PR8XdR#VP4p\V4^,^,pV\8dV#.ROpVP V4p\RT4T# \ d\RY4Tu#i;i)zGet a temporary directory where socket files will be created. To prevent additional imports, pass a pre-imported 'tempfile' module. r1NzProcess-wide temporary directory %s will not be usable for creating socket files and no usable system-wide temporary directory was found in %sz-Ignoring user-defined temporary directory: %s)z/tmpz/var/tmpz/usr/tmp)osnameZ gettempdirlen _SUN_PATH_MAXZ_get_default_tempdirZFileNotFoundErrorr)tempfile base_tempdirZ sun_path_lenZdirlistZbase_system_tempdirr&r_get_base_temp_dirr=s  ww$&&(L|$r)B.Lm#/G &;;GD 8,G   )*6 A sA22B BcsP\P!4PPR4pVft^RIp^RIp\ V4pVPRVR7p\RV4\R\VPV3RR7V\P!4PR&V#)r2Nzpymp-)ZprefixZdirzcreated temp directory %s)r exitpriorityi) rr3r4getshutilr;r=Zmkdtemprrr6r5)r2r@r;r<s r get_temp_dirrAs%%'//33I>G)(3 ""'|"D ('2 'v}}g.F" $7>!)))4 Nrcs\\P44pVP4VFwwrr4V!V4K R# \dp\ RT4Rp?K4Rp?ii;i)z after forker raised exception %sN)list_afterfork_registryitemssort Exceptionr)rDZindexZidentfuncobjZes r_run_after_forkersrIs] $**, -E JJL%*!t 8 I&+ 8 3Q 7 7 8sA A) A$$A)csJV\\\4\V4V3&R#N)rCnext_afterfork_counterZid)rHrGs&&rregister_after_forkrMsEH012c7DABrcsfa]tRt^toRtR RltR]]]P3Rlt Rt Rt Rt RtVtR#) rz9 Class which supports object finalization using weakrefs NcsVe;\V\4'g%\RPV\ V444hVe\ P !W4VnMVf \R4hW n W0n T;'g/Vn V\\43Vn\P !4VnV\$VP&R#)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)r,intr.ZformattypeweakrefZref_weakref ValueError _callback_args_kwargsrK_finalizer_counter_keyr7getpid_pid_finalizer_registry)selfrHZcallbackr Zkwargsr>s&&&&&&r__init__ZFinalize.__init__s  $jc.J.JELL $|"467 7 ?#KK2DM  !JK K! || !4(:#;< IIK )-DII&rc szW PVPV!48wd V!R4RpMOV!RVPVPVP4VP!VP/VPBpR;Vn;Vn;Vn;VnVnV# \ d T!R4R#i;i)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)rWrYrSrTrUrQKeyError)r[ZwrrZrrXZres&&&&& r__call__ZFinalize.__call__s #II.yyFH$GHK..$**dllDnndjjADLLA7; Z) rQAttributeErrorr.Z __class__rcZgetattrrSrTr-rUrW)r[rHZxs& r__repr__ZFinalize.__repr__>s --/C ;&)@)@@ @ '' DNNC E ::: S_, ,A <<< s4<<00 0A 99Q< # "S1%66 6A3w * C sD""D98D9)rTrSrWrUrYrQ)rNN)rc __module__ __qualname____firstlineno__Z__doc__r\rZrr7rXr_rarbre__static_attributes____classdictcell__Z __classdict__@rrrs;.&&9$RYY 0 <0 rcsa\fR#SfRpMV3Rlp\\4Uu.uFq!!V4'gKVNK ppVPRR7VF2p\PV4pVfK\ RV4V!4K4 Sf\P4R#R#uupi \ d^RIpTP4Kyi;i)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. NcsV^,RJ#rNr)pr/r!_run_finalizers..as qt4'rcsB<V^,RJ;'d V^,S8#rmr)rn minprioritys&rrorpcs"qt4'??AaDK,??rT)Zreversez calling %s) rZrBrEr?rrF tracebackZ print_excclear)rqZfZkeyZkeysZ finalizerrrsf r_run_finalizersrtSs"  ' ? 34 ?4C#CC4D ?IIdI'++C0  lI . & !!# @ & ##% &sB-B-B22CCcs.\;'g \RJ#)z. Returns true if the process is shutting down N)_exitingrrr is_exitingrvs  ' 'x4''rcs\'gRsV!R4V!R4V!^4V!4eV!4FDpVP'gKV!RVP4VPP 4KF V!4F&pV!RVP4VP 4K( V!R4V!4R#R#)Tzprocess shutting downz2running all "atexit" finalizers with priority >= 0Nz!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)ruZdaemonr8Z_popenZ terminateZjoin)rrrtactive_childrenr3rnr^rr r s 8 $% BC   (%&888.ss||/A/A/CrN)rMr`r/rr\ZForkAwareLocal.__init__s D"CDrcs\V4R3#)Nr)rOr`r/r __reduce__ZForkAwareLocal.__reduce__sDz2~rrN)rcrfrgrhr\rrirjrkrlrrrsErZ SC_OPEN_MAXics\V4R\.,pVP4\\ V4^, 4F4p\ P !W,^,W^,,4K6 R#)iN)rBMAXFDrEZranger9r7Z closerange)fdsZis& rclose_all_fds_exceptrsN s)r5k !CHHJ 3s8a<  cfQhaC)!rcs\PfR#\PP4\ P !\ P\ P4p\ VRRR7\nR# \\3dLai;i \ P!T4h;i \\3dR#i;i)Nzutf-8F)ZencodingZclosefd) r)ZstdincloseZOSErrorrRr7ZopenZdevnullZO_RDONLY)fdr"r _close_stdinrs yy   WWRZZ - R'5ACI Z      HHRL  Z    s4B3B5)BBBB22B55C  C cs\PP4\P P4R# \\3dL4i;i \\3dR#i;irJ)r)ZstdoutZflushrdrRZstderrrrr_flush_std_streamsrs]     J '    J '   s"AAAAA-,A-cs^RIp\\\\V444p\ P !4wrEVPW.RVRRRRRRRRWERRRRRRRR4\ P!V4\ P!V4# \ P!T4\ P!T4i;i)rNTFr) _posixsubprocessZtupleZsortedZmaprNr7ZpipeZ fork_execr)Zpathr ZpassfdsrZ errpipe_readZ errpipe_writes&&& rspawnv_passfdsrsF3sG,-.G"$'')L )) &$t BBL 5"dD$D:    s $B.B>csDVFp\P!V4K R#)z/Close each file descriptor given as an argumentN)r7r)rrs* r close_fdsrs  rcs^RIHp\P!4^RIHpVP P4^RIHpVPP4\4VP4VP4R#)zGCleanup multiprocessing resources when multiprocessing tests completed.)support) forkserver)resource_trackerN) ZtestrrZ_cleanuprrZ _forkserverZ_stoprZ_resource_trackerrtZ gc_collectZ reap_children)rrrs r_cleanup_testsrsc +  "1&&,,.  r)rrrrrr#r'rArMrvrrrrr rrJ)ZopenbsdZfreebsd)Cr7Z itertoolsr)rPrrxZ subprocessrZrZ__all__ZNOTSETr rrrrrr$r r%rrrrrr#r'r+r0Zabstract_sockets_supportedr*r:Z startswithr8r6r=rAZWeakValueDictionaryrCZcountrLrIrMrZrVZobjectrrtrvrurwr3r r!rZlocalrZsysconfrrFrrrrrrrrrrs   3        F 8547:.*0AAB<<7M\\344MGGtODM26p &113__&8I__&SvSl&$X( E?#*#:#:#*#:#:(T *&*"Y__ JJ} %E* .    M EsE>> F  F