F\hqSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJr Sr Sr Sr \RSSj5r SSjr\RSSj5r"S S 5rS \4S jr\"5rS S.Sjrg)N)supportc^[R"5[[R54$N)_thread_countlen threading _dangling4/usr/lib/python3.13/test/support/threading_helper.pythreading_setuprs >> S!4!45 55r clUupSn[R"USS9H8n[[R5n[ R "5nXa::dM8 g S[l[R"SUSSUSUS WS[W53 5 UHn[R"S U<35 M g) Ng?FerrorTz2threading_cleanup() failed to clean up threads in .1fz seconds before: thread count=z , dangling=z after: thread count=zDangling thread: ) rsleeping_retrylistr r rrenvironment_altered print_warningr)original_values orig_countorig_ndanglingtimeout_dangling_threadscountthreads r threading_cleanuprs!0JG  # #G5 9 3 34    :#'G  c]"",[8HI!!&{37G3H2I KL # 1&<=#r cF^[R"T5U4Sj5nU$)z{Use this function when threads are being used. This will ensure that the threads are cleaned up even when the test fails. cN>[5nT"U6[U6 $![U6 f=fr)rr)argskeyfuncs r decoratorreap_threads..decorator>s) $; s # s #s $) functoolswraps)r$r%s` r reap_threadsr):s(__T$$ r c ## Uc[Rn[R"5nSv [R "5n[R "USS9H4n[R"5 [R"5nXA::dM4 g [R "5U- nSWU- SUSSUSUS 3 n[U5e![R "5n[R "USS9H4n[R"5 [R"5nXA::dM4 f [R "5U- nSWU- SUSSUSUS 3 n[U5e=f7f) a  bpo-31234: Context manager to wait until all threads created in the with statement exit. Use _thread.count() to check if threads exited. Indirectly, wait until threads exit the internal t_bootstrap() C function of the _thread module. threading_setup() and threading_cleanup() are designed to emit a warning if a test leaves running threads in the background. This context manager is designed to cleanup threads started by the _thread.start_new_thread() which doesn't allow to wait for thread exit, whereas thread.Thread has a join() method. NFrz!wait_threads() failed to cleanup z threads after rz seconds (count: z , old count: )) r SHORT_TIMEOUTrrtime monotonicr gc_collectAssertionError)r old_count start_timerrdtmsgs r wait_threads_exitr5Hs\'' I& ^^% ''u=A    NN$E! > !J.B6uy7H6IJ$$&s8,#WM)A?C!% %^^% ''u=A    NN$E! > !J.B6uy7H6IJ$$&s8,#WM)A?C!% %s))E$CAE$:E$AE!':E!!E$cUc[RnURU5 UR5(aSUSS3n[ U5eg)z[Join a thread. Raise an AssertionError if the thread is still alive after timeout seconds. Nzfailed to join the thread in rz seconds)rr,joinis_aliver0)rrr4s r join_threadr9ksM'' KK -gc](CS!!r c #.# SSKn[U5n/nUH$nUR5 UR U5 M& Sv U(aU"5 [R"5n[SS5HnUS- nUH4nUR[U[R"5- S55 M6 UVs/sHoDR5(dMUPM nnU(d O4[ R (dM[S[U5U4-5 M UVs/sHoDR5(dMUPM nnU(a9UbUR[ R"5 [%S[U5-5eg![a SnGNf=f! [ R (a"[S[U5[U54-5 e=fs snfs snf!UVs/sHoDR5(dMUPM Os snfnnU(a9UbUR[ R"5 [%S[U5-5ef=f!U(aU"5 [R"5n[SS5HnUS- nUH4nUR[U[R"5- S55 M6 UVs/sHoDR5(dMUPM Os snfnnU(d O4[ R (dM[S[U5U4-5 M UVs/sHoDR5(dMUPM Os snfnnU(a9UbUR[ R"5 [%S[U5-5ef!UVs/sHoDR5(dMUPM Os snfnnU(a9UbUR[ R"5 [%S[U5-5ef=f=f7f) Nrz/Can't start %d threads, only %d threads started<g{Gz?z7Unable to join %d threads during a period of %d minuteszUnable to join %d threads) faulthandler ImportErrorrstartappendrverboseprintrr-r.ranger7maxr8dump_tracebacksysstdoutr0)threadsunlockr>startedtendtimers r start_threadsrNws67mGGQ  q!  Qnn&G B<2  AFF3w)994@A!&->g1g>???'*-g,)@AB(#*:'QZZ\q'G:+ // ;$%@3w<%OPPC   G7|S\234 ?;':'QZZ\q':G:+ // ;$%@3w<%OPP! Qnn&G B<2  AFF3w)994@A!&->g1g>>???'*-g,)@AB(#*:'QZZ\q':G:+ // ;$%@3w<%OPP#*:'QZZ\q':G:+ // ;$%@3w<%OPPsPF P*FIA5G;GGG?GP G<GAP FPFP:GIGPI$HHA IPPA5N K, %K, +$NN0P4MMA PP$O O A PPPc0\rSrSrSrSrSrSrSrSr g) catch_threading_exceptiona Context manager catching threading.Thread exception using threading.excepthook. Attributes set when an exception is caught: * exc_type * exc_value * exc_traceback * thread See threading.excepthook() documentation for these attributes. These attributes are deleted at the context manager exit. Usage: with threading_helper.catch_threading_exception() as cm: # code spawning a thread which raises an exception ... # check the thread exception, use cm attributes: # exc_type, exc_value, exc_traceback, thread ... # exc_type, exc_value, exc_traceback, thread attributes of cm no longer # exists at this point # (to avoid reference cycles) cJSUlSUlSUlSUlSUlgr)exc_type exc_value exc_tracebackr _old_hookselfs r __init__"catch_threading_exception.__init__s& ! r cURUlURUlURUlURUlgr)rSrTrUr)rXr"s r _hookcatch_threading_exception._hooks1  !//kk r cZ[RUlUR[lU$r)r excepthookrVr\rWs r __enter__#catch_threading_exception.__enter__s "--#zz  r c>UR[lU?U?U?U?gr)rVr r_rSrTrUr)rXexc_infos r __exit__"catch_threading_exception.__exit__s##~~  M N   Kr )rVrUrSrTrN) __name__ __module__ __qualname____firstlineno____doc__rYr\r`rd__static_attributes__r r r rPrPs<"  r rPreturnc[RS:Xa[RR$[RS:Xagg)a]Detect whether Python can start new threads. Some WebAssembly platforms do not provide a working pthread implementation. Thread support is stubbed and any attempt to create a new thread fails. - wasm32-wasi does not have threading. - wasm32-emscripten can be compiled with or without pthread support (-s USE_PTHREADS / __EMSCRIPTEN_PTHREADS__). emscriptenwasiFT)rGplatform_emscripten_infopthreadsr r r _can_start_threadrss6 |||###,,,  r F)modulecSnU(a"[(d[R"U5eg[R"[U5$)z~Skip tests or modules that require working threading. Can be used as a function/class decorator or to skip an entire module. zrequires threading supportN)can_start_threadunittestSkipTest skipUnless)rtr4s r requires_working_threadingrzs> 'C ##C( ( ""#3S99r r)r contextlibr'rGr r-rwtestrrrr)contextmanagerr5r9rNrPboolrsrvrzr r r rs  6><  &&D " 'Q'QT66r4&%&). :r