+
    Biu                        ^ RI t ^ 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IHt ^ RIHt ^RIHtHtHt RsR tR	 tRR
 lt ! R R]4      t ! R R]4      t]! ]! 4       ]4       ]! ]! 4       ]4       ]P4                  ! ]P6                  R8H  R4       ! R R]P8                  4      4       tR t]R8X  d   ]P@                  ! 4        R# R# )    N)BrokenExecutor)_check_system_limits)QueueHandler)support)ExecutorMixincreate_executor_testssetup_moduleuninitializedc                     V s \          R # NINITIALIZER_STATUS)xs   &=/usr/lib/python3.14/test/test_concurrent_futures/test_init.pyinitr      s         c                      \         # r   r    r   r   get_init_statusr      s    r   c                     V eI   \         P                  ! R4      pVP                  \        V 4      4       VP	                  R4       RVn        \        P                  ! R4       \        R4      h)Nconcurrent.futuresCRITICALFg?zerror in initializer)	logging	getLogger
addHandlerr   setLevel	propagatetimesleep
ValueError)	log_queueloggers   & r   	init_failr#      sW    ""#78,y12
# JJsO
+
,,r   c                   <   a a ] tR t^)t o^tV 3R ltR tRtVtV ;t	# )InitializerMixinc                T   < R s \        \        RR7      V n        \        SV `  4        R# )r
   initializerinitargsN)initialized)r   dictr   executor_kwargssupersetUpself	__class__s   &r   r.   InitializerMixin.setUp,   s$    ,#-= ?r   c                    \        V P                  4       Uu. uF"  pV P                  P                  \        4      NK$  	  ppV F#  pV P                  VP                  4       R 4       K%  	  R# u upi )r*   N)rangeworker_countexecutorsubmitr   assertEqualresult)r0   _futuresfs   &   r   test_initializer!InitializerMixin.test_initializer3   sc    !$"3"3464q ==''84 	 6 AQXXZ7 6s   (A-)r,   )
__name__
__module____qualname____firstlineno__r5   r.   r=   __static_attributes____classdictcell____classcell__r1   __classdict__s   @@r   r%   r%   )   s     L8 8r   r%   c                   `   a a ] tR t^;t o^tV 3R ltR t]P                  R 4       t	Rt
VtV ;t# )FailingInitializerMixinc                :  < \        V R 4      '       dW   V P                  4       V n        V P                  P                  4       V n        \        \        V P                  3R7      V n        M#RV n        RV n        \        \        R7      V n        \        SV `%  4        R# )ctxr'   N)r(   )
hasattrget_context
mp_contextQueuer!   r+   r#   r,   r-   r.   r/   s   &r   r.   FailingInitializerMixin.setUp>   st    4"..0DO!__224DN#'I26..1B$DD 
 #DO!DN#'I#>D r   c           	        V P                  R 4      ;_uu_ 4         V P                  P                  \        4      pV P	                  \
        4      ;_uu_ 4        VP                  4        RRR4       \        P                  ! \        P                  R4       F!  pT P                  P                  '       g   K!   M	  T P	                  \
        4      ;_uu_ 4        T P                  P                  \        4       RRR4       RRR4       R#   + '       g   i     L; i  \
         d     Li ; i  + '       g   i     L>; i  + '       g   i     R# ; i)z ValueError: error in initializerNzexecutor not broken)_assert_loggedr6   r7   r   assertRaisesr   r9   r   sleeping_retrySHORT_TIMEOUT_broken)r0   futurer:   s   &  r   r=   (FailingInitializerMixin.test_initializerM   s      !CDD$--o>
 &&~66MMO 7 ++G,A,A,AC==(((C "">22$$_5 3# ED 76	 "  32# EDDsd   EDED
	)A	E7!E D.	8E
DED+(E*D++E.D>9EE	c              #    a"   V P                   eB   R x  . p  VP                  V P                   P                  4       P                  4       4       K:  V P                  RR4      ;_uu_ 4       pR x  R R R 4       XP                  pT P                  \        ;QJ d    V3R lV 4       F  '       g   K   RM	  RM! V3R lV 4       4      V4       R #   \        P
                   d     Lci ; i  + '       g   i     L; i5i)NTr   r   c              3   .   <"   T F
  pSV9   x  K  	  R # 5ir   r   ).0linemsgs   & r   	<genexpr>9FailingInitializerMixin._assert_logged.<locals>.<genexpr>p   s     ;FDC4KFs   F)
r!   append
get_nowait
getMessagequeueEmpty
assertLogsoutput
assertTrueany)r0   r]   rf   cms   &f  r   rR   &FailingInitializerMixin._assert_loggedb   s     >>%FMM$..";";"="H"H"JK !5zBBb CYYF;F;;F;;	  ;;  CBsL   D :C D -C-2)D D 3D C*'D )C**D -C=	8D )r,   r!   rN   )r?   r@   rA   rB   r5   r.   r=   
contextlibcontextmanagerrR   rC   rD   rE   rF   s   @@r   rI   rI   ;   s3     L6*      r   rI   win32z'Resource Tracker doesn't run on Windowsc                   d   a  ] tR t^xt o RtR tR t]P                  ! RRR7      R 4       t	Rt
V tR	# )
FailingInitializerResourcesTestz9
Source: https://github.com/python/cpython/issues/104090
c                F    \        4        \        P                  ! \
        P                  ! 4       R7      pVP                  V! R4      4       ^ RIH	p VP                  4        V P                  VP                  ^ 4       R#   \         d    T P                  R 4        Li ; i)z.ProcessPoolExecutor unavailable on this system)streamr=   )_resource_trackerN)r   NotImplementedErrorskipTestunittestTextTestRunnerioStringIOrun multiprocessing.resource_trackerrr   _stopr8   	_exitcode)r0   
test_classrunnerrr   s   &&  r   _test%FailingInitializerResourcesTest._test~   s    	L " ((>

:012
 	G!*44a8 # 	LMMJK	Ls   
B B B c                0    V P                  \        4       R # r   )r   &ProcessPoolSpawnFailingInitializerTestr0   s   &r   
test_spawn*FailingInitializerResourcesTest.test_spawn   s    

9:r   z'TSAN doesn't support threads after forkT)threadc                0    V P                  \        4       R # r   )r   +ProcessPoolForkserverFailingInitializerTestr   s   &r   test_forkserver/FailingInitializerResourcesTest.test_forkserver   s    

>?r   r   N)r?   r@   rA   rB   __doc__r   r   r   skip_if_sanitizerr   rC   rD   )rG   s   @r   ro   ro   x   s:     9"; HQUV@ W@r   ro   c                      \        4        R # r   )r	   r   r   r   setUpModuler      s    Nr   __main__r   )!rk   r   rc   r   ru   sysrw   concurrent.futures._baser   concurrent.futures.processr   logging.handlersr   testr   utilr   r   r	   r   r   r   r#   r%   rI   globalsskipIfplatformTestCasero   r   r?   mainr   r   r   <module>r      s         
 	 3 ; )  D D % -8} 8$6 m 6 r gi!1 2 gi!8 9 
(*ST@h&7&7 @ U@< zMMO r   