+
     Bi;C                        ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIt^ RIHt ^RIH	t	 . R(Ot
^ t^t^
t^t^t^tRtRtRsR	sR
 tR tR tR tR tR tR)R ltR tR t]! 4       t]P>                  R8X  d   ^lt M9]P>                  PC                  R*4      '       d   ^ht M] PD                  R8X  d   RM^\t R t#R t$R t%]PL                  ! 4       t']PP                  ! 4       t)R t*R t+/ t,]PP                  ! 4       t- ! R R].4      t/R)R lt0R t1R	s2]]]0]	Pf                  ]	Ph                  3R lt5]Pl                  ! ]54        ! R R].4      t7 ! R R]Pp                  4      t9 ] Pt                  ! R 4      t;R" t=R# t>R$ t?R% t@R& tAR' tBR#   ]< d    R!t; Li ; i)+    N)_args_from_interpreter_flags)processFinalizeForkAwareThreadLockForkAwareLocalmultiprocessingz+[%(levelname)s/%(processName)s] %(message)sFc                 `    \         '       d"   \         P                  ! \        V .VO5R ^/  R# R# 
stacklevelN)_loggerlogSUBDEBUGmsgargss   &*+/usr/lib/python3.14/multiprocessing/util.py	sub_debugr   -   s$    wHc7D7Q7     c                 `    \         '       d"   \         P                  ! \        V .VO5R ^/  R# R# r
   )r   r   DEBUGr   s   &*r   debugr   1   s$    wE344!4 r   c                 `    \         '       d"   \         P                  ! \        V .VO5R ^/  R# R# r
   )r   r   INFOr   s   &*r   infor   5   s$    wD#333 r   c                 `    \         '       d"   \         P                  ! \        V .VO5R ^/  R# R# r
   )r   r   WARNINGr   s   &*r   warnr   9   s$    wGS646A6 r   c                 `    \         '       d"   \         P                  ! \        V .VO5R ^/  R# R# r
   )r   r   
SUBWARNINGr   s   &*r   sub_warningr    =   s$    wJ9d9q9 r   c                     ^ RI p V P                  ;_uu_ 4        \        '       g   V P                  \        4      s^ \        n        \        \        R4      '       d6   \        P                  ! \        4       \        P                  ! \        4       ML\        P                  P                  \        R/ 34       \        P                  P                  \        R/ 34       RRR4       \        #   + '       g   i     \        # ; i)r   N
unregister )logging_lockr   	getLoggerLOGGER_NAME	propagatehasattratexitr"   _exit_functionregister_exithandlersremoveappend)r$   s    r   
get_loggerr0   A   s    
 	w''4G !G v|,,!!.1/$$++^R,DE$$++^R,DE 
 N 
 Ns   CC++D 	c                     ^ RI p\        4       pVP                  \        4      pVP	                  4       pVP                  V4       VP                  V4       V '       d   VP                  V 4       Rs\        # )r   NT)
r$   r0   	FormatterDEFAULT_LOGGING_FORMATStreamHandlersetFormatter
addHandlersetLevel_log_to_stderrr   )levelr$   logger	formatterhandlers   &    r   log_to_stderrr=   X   sb    
 \F!!"89I##%G#
gNNr   c                  (    \         P                  R9   # )linux)r?   android)sysplatformr#   r   r   #_platform_supports_abstract_socketsrC   m   s    <<///r   c                     V '       g   R # \        V \        4      '       d   V ^ ,          ^ 8H  # \        V \        4      '       d   V ^ ,          R8H  # \        RV : R24      h)F zaddress type of z unrecognized)
isinstancebytesstr	TypeError)addresss   &r   is_abstract_socket_namespacerK   q   sT    '5!!qzQ	GS	!	!qzT!!
&wk?
@@r   r?   ntc                 j    V ! V4       \         P                  ! 4       pVe   R VP                  R&   R # R # )Ntempdir)r   current_process_config)rmtreerN   rO   s   && r   _remove_temp_dirrR      s4    
7O--/O "-1	* #r   c                 "   \         P                  R 8X  d   R# V P                  4       p\        V4      ^,           ^,           pV\        8:  d   V# . ROp V P                  V4      p\        RT4       T#   \         d    \        RY4       Tu # i ; i)rL   NzProcess-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)osname
gettempdirlen_SUN_PATH_MAX_get_default_tempdirFileNotFoundErrorr   )tempfilebase_tempdirsun_path_lendirlistbase_system_tempdirs   &    r   _get_base_temp_dirr`      s    
 
ww$ &&(L |$r)B.L}$ /G	&;;GD 		8,G    )*6	A s   A2 2BBc                  P   \         P                  ! 4       P                  P                  R 4      p V ft   ^ RIp^ RIp\        V4      pVP                  RVR7      p \        RV 4       \        R\        VP                  V 3RR7       V \         P                  ! 4       P                  R &   V # )rN   Nzpymp-)prefixdirzcreated temp directory %s)r   exitpriorityi)r   rO   rP   getshutilr[   r`   mkdtempr   r   rR   rQ   )rN   rf   r[   r\   s       r   get_temp_dirrh      s    %%'//33I>G)(3""'|"D('2 	'v}}g.F"	$7>!)))4Nr   c                      \        \        P                  4       4      p V P                  4        V  F  w  w  rr4 V! V4       K  	  R#   \         d   p\        R T4        Rp?K4  Rp?ii ; i)z after forker raised exception %sN)list_afterfork_registryitemssort	Exceptionr   )rl   indexidentfuncobjes         r   _run_after_forkersrt      s]    $**,-E	JJL%*!t	8I &+  	83Q77	8s   AA)A$$A)c                 J    V \         \        \        4      \        V 4      V3&   R # N)rk   next_afterfork_counterid)rr   rq   s   &&r   register_after_forkrz      s    EH012c7DABr   c                   b   a  ] tR t^t o RR ltR]]]P                  3R lt	R t
R tR tRtV tR# )	r   Nc                   Ve;   \        V\        4      '       g%   \        RP                  V\	        V4      4      4      hVe   \
        P                  ! W4      V n        MVf   \        R4      hW n	        W0n
        T;'       g    / V n        V\        \        4      3V n        \        P                   ! 4       V n        V \$        V P                  &   R # )Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rF   intrI   formattypeweakrefref_weakref
ValueError	_callback_args_kwargsrw   _finalizer_counter_keyrT   getpid_pid_finalizer_registry)selfrr   callbackr   kwargsrd   s   &&&&&&r   __init__Finalize.__init__   s    $jc.J.JELL $|"467 7 ?#KK2DM!JKK!
||!4(:#;<	IIK	)-DII&r   c                z    W P                    V P                  V! 4       8w  d   V! R 4       RpMOV! RV P                  V P                  V P                  4       V P                  ! V P                  / V P                  B pR;V n        ;V n        ;V n        ;V n        V n         V#   \         d    T! R4        R# i ; i)z+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %szfinalizer no longer registered)r   r   r   r   r   r   KeyError)r   wrr   r   r   ress   &&&&& r   __call__Finalize.__call__  s    	#II. yyFH$GHK..$**dllDnndjjADLLA7;<DM <DN <TZ < L49J  	867	8s   B# #B:9B:c                     \         V P                   R ;V n        ;V n        ;V n        ;V n        V n        R #   \         d     R # i ; irv   )r   r   r   r   r   r   r   r   s   &r   cancelFinalize.cancel(  sU    	<#DII.
 8<<DM <DN <TZ < L49	  		s   8 AAc                (    V P                   \        9   # rv   )r   r   r   s   &r   still_activeFinalize.still_active4  s     yy///r   c                x    V P                  4       pVf   RV P                  P                  ,          # RV P                  P                  : R\        V P                  RV P                  4      : 2pV P                  '       d$   VR\        V P                  4      ,           ,          pV P                  '       d$   VR\        V P                  4      ,           ,          pV P                  ^ ,          e+   VR\        V P                  ^ ,          4      ,           ,          pVR,           #   \        \        3 d    R p EL&i ; i)	Nz<%s object, dead><z object, callback=__name__z, args=z	, kwargs=z, exitpriority=>)r   AttributeErrorrI   	__class__r   getattrr   r   rH   r   r   )r   rr   xs   &  r   __repr__Finalize.__repr__:  s    	--/C ;&)@)@@@  ''
DNNCE :::S_,,A<<<s4<<000A99Q<#"S1%666A3w 	* 	C	s   D" "D98D9)r   r   r   r   r   r   )r#   NN)r   
__module____qualname____firstlineno__r   r   r   rT   r   r   r   r   r   __static_attributes____classdictcell____classdict__s   @r   r   r      s6     .&  &9$RYY	0
<0 r   c                   a  \         f   R # S f   R pMV 3R lp\        \         4       Uu. uF  q!! V4      '       g   K  VNK  	  ppVP                  RR7       V F2  p\         P                  V4      pVf   K  \	        RV4        V! 4        K4  	  S f   \         P                  4        R # R # u upi   \
         d    ^ R IpTP                  4         Ky  i ; i)Nc                     V ^ ,          RJ# r   Nr#   )ps   &r   <lambda>!_run_finalizers.<locals>.<lambda>]  s    qt4'r   c                 B   < V ^ ,          RJ;'       d    V ^ ,          S8  # r   r#   )r   minprioritys   &r   r   r   _  s"    qt4'??AaDK,??r   T)reversez
calling %s)	r   rj   rm   re   r   rn   	traceback	print_excclear)r   fkeykeys	finalizerr   s   f     r   _run_finalizersr   O  s     " 	'?   34?4C#CC4D?IIdI'++C0	 lI.&  !!#  @  & ##%&s   B-B-B22CCc                  .    \         ;'       g	    \         R J # rv   )_exitingr#   r   r   
is_exitingr   {  s     ''x4''r   c                    \         '       g   R s V ! R4       V! R4       V! ^ 4       V! 4       e   V! 4        FD  pVP                  '       g   K  V ! RVP                  4       VP                  P	                  4        KF  	  V! 4        F&  pV ! RVP                  4       VP                  4        K(  	  V! R4       V! 4        R# R# )Tzprocess shutting downz2running all "atexit" finalizers with priority >= 0Nz!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)r   daemonrU   _popen	terminatejoin)r   r   r   active_childrenrO   r   s   &&&&& r   r+   r+     s     8$%BC( %&888<affEHH&&( '
 %&4aff= ' 	9:? r   c                   8   a  ] tR tRt o R tR tR tR tRtV t	R# )r   i  c                    \         P                  ! 4       V n        V P                  P                  V n        V P                  P                  V n        \        V \        P                  4       R # rv   )	threadingLockr%   acquirereleaserz   r   _at_fork_reinitr   s   &r   r   ForkAwareThreadLock.__init__  sC    ^^%
zz))zz))D"5"E"EFr   c                :    V P                   P                  4        R # rv   )r%   r   r   s   &r   r   #ForkAwareThreadLock._at_fork_reinit  s    

""$r   c                6    V P                   P                  4       # rv   )r%   	__enter__r   s   &r   r   ForkAwareThreadLock.__enter__  s    zz##%%r   c                6    V P                   P                  ! V!  # rv   )r%   __exit__)r   r   s   &*r   r   ForkAwareThreadLock.__exit__  s    zz""D))r   )r%   r   r   N)
r   r   r   r   r   r   r   r   r   r   r   s   @r   r   r     s     G%&* *r   c                   ,   a  ] tR tRt o R tR tRtV tR# )r   i  c                     \        V R  4       R# )c                 6    V P                   P                  4       # rv   )__dict__r   )rr   s   &r   r   )ForkAwareLocal.__init__.<locals>.<lambda>  s    s||/A/A/Cr   N)rz   r   s   &r   r   ForkAwareLocal.__init__  s    D"CDr   c                    \        V 4      R3# )Nr#   )r   r   s   &r   
__reduce__ForkAwareLocal.__reduce__  s    Dz2~r   r#   N)r   r   r   r   r   r   r   r   r   s   @r   r   r     s     E r   SC_OPEN_MAX   c                     \        V 4      R\        .,           p V P                  4        \        \	        V 4      ^,
          4       F4  p\
        P                  ! W,          ^,           W^,           ,          4       K6  	  R# )   N)rj   MAXFDrm   rangerW   rT   
closerange)fdsis   & r   close_all_fds_exceptr     sN    
s)r5k
!CHHJ3s8a< 
cfQhaC) !r   c                     \         P                  f   R #  \         P                  P                  4         \
        P                  ! \
        P                  \
        P                  4      p  \        V RRR7      \         n        R #   \        \        3 d     Lai ; i   \
        P                  ! T 4       h ; i  \        \        3 d     R # i ; i)Nzutf-8F)encodingclosefd)	rA   stdincloseOSErrorr   rT   opendevnullO_RDONLY)fds    r   _close_stdinr     s    
yy		WWRZZ-	R'5ACI Z  	HHRLZ  s4   B 3B5 )B BBB22B5 5C
	C
c                       \         P                  P                  4         \         P
                  P                  4        R #   \        \        3 d     L4i ; i  \        \        3 d     R # i ; irv   )rA   stdoutflushr   r   stderrr#   r   r   _flush_std_streamsr     s]    



 J'  J' s"   A A AAA-,A-c                    ^ RI p\        \        \        \        V4      4      4      p\
        P                  ! 4       w  rE VP                  W.RVRRRRRRRRWERRRRRRRR4      \
        P                  ! V4       \
        P                  ! V4       #   \
        P                  ! T4       \
        P                  ! T4       i ; i)r   NTFr   )	_posixsubprocesstuplesortedmapr}   rT   pipe	fork_execr   )pathr   passfdsr   errpipe_readerrpipe_writes   &&&   r   spawnv_passfdsr    s    F3sG,-.G"$'')L ))&$tBBL5"dD$D:
 	
 	
s   $B .B>c                  D    V  F  p\         P                  ! V4       K  	  R # rv   )rT   r   )r   r   s   * r   	close_fdsr
    s    
 r   c                     ^ RI Hp  \        P                  ! 4        ^ RIHp VP                  P                  4        ^ RIHp VP                  P                  4        \        4        V P                  4        V P                  4        R# )r   )support)
forkserver)resource_trackerN)testr  r   _cleanupr   r  _forkserver_stopr  _resource_trackerr   
gc_collectreap_children)r  r  r  s      r   _cleanup_testsr    sc       +  " 1&&,,. r   )r   r   r   r    r   r0   r=   rh   rz   r   r   r   r   r   r   r   rv   )openbsdfreebsd)CrT   	itertoolsrA   r   r*   r   
subprocessr    r   __all__NOTSETr   r   r   r   r   r'   r3   r   r8   r   r   r   r   r    r0   r=   rC   rK   abstract_sockets_supportedrB   rX   
startswithrU   rR   r`   rh   WeakValueDictionaryrk   countrx   rt   rz   r   r   objectr   r   r   r   r   rO   r+   r,   r   localr   sysconfr   rn   r   r   r   r  r
  r  r#   r   r   <module>r%     s   
  
    3  

	

F 
8547:.*0A AB  <<7M\\344M GGtODM24l& 113 __& 8I  __& Sv Sl&$X( E?#*#:#:#*#:#:(T  *& *"Y__ JJ}%E*. M  Es   E> >	F
	F
