⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3.12
/
test
/
support
/
__pycache__
/
View File Name :
threading_helper.cpython-312.pyc
CRhq d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlmZ d Z d Z d Z ej dd Z ddZej dd Z G d d Zd efd Z e Zd ddZy) N)supportc \ t j t t j fS N)_thread_countlen threading _dangling 4/usr/lib/python3.12/test/support/threading_helper.pythreading_setupr s >> S!4!4 5 55r c b | \ }}d}t j |d D ]6 }t t j }t j }||k s6 y dt _ t j d|dd| d| d dt |D ] }t j d | y ) Ng ?FerrorTz2threading_cleanup() failed to clean up threads in .1fz seconds before: thread count=z , dangling=z after: thread count=zDangling thread: ) r sleeping_retrylistr r r r environment_altered print_warningr )original_values orig_countorig_ndanglingtimeout_dangling_threadscountthreads r threading_cleanupr s !0 JG # #G5 9 3 34 J : #'G c] "", [ 8H I!!&{37G3H2I KL # 1& <= #r c B t j fd }|S )zUse this function when threads are being used. This will ensure that the threads are cleaned up even when the test fails. c N t } | t | S # t | w xY wr )r r )argskeyfuncs r decoratorz reap_threads.<locals>.decorator> s) $; s # s #s $) functoolswraps)r$ r% s ` r reap_threadsr( : s( __T$ $ r c # K | t j } t j } d t j }t j | d D ]1 }t j t j }||k s1 y t j |z }d|z d|dd| d| d }t | # t j }t j | d D ]1 }t j t j }||k s1 w t j |z }d|z d|dd| d| d }t | xY ww) aH 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. NFr z!wait_threads() failed to cleanup z threads after r z seconds (count: z , old count: )) r SHORT_TIMEOUTr r time monotonicr gc_collectAssertionError)r old_count start_timer r dtmsgs r wait_threads_exitr4 H sa '' I& ^^% ''u=A NN$E ! > !J.B6uy7H6I J$$&s8 , #WM)A?C !% % ^^% ''u=A NN$E ! > !J.B6uy7H6I J$$&s8 , #WM)A?C !% %s) 'EC AE 8EA E 8EEc |t j }| j | | j rd|dd}t | y)zcJoin a thread. Raise an AssertionError if the thread is still alive after timeout seconds. Nz failed to join the thread in r z seconds)r r+ joinis_aliver/ )r r r3 s r join_threadr8 k sJ '' KK -gc](C S!! r c # 8 K dd l }t | } g } | D ]# }|j |j | % d |r | t j }t dd D ] }|dz }|D ]2 }|j t |t j z d 4 |D cg c] }|j s| }}|s n,t j stt dt | |fz |D cg c] }|j s| }}|r8| |j t j" t% dt | z y # t $ r d }Y ^w xY w# t j r"t dt | t | fz xY wc c}w c c}w # |D cg c] }|j s| nc c}w }}|r8| |j t j" t% dt | z w xY w# |r | t j }t dd D ] }|dz }|D ]2 }|j t |t j z d 4 |D cg c] }|j s| nc c}w }}|s n,t j szt dt | |fz |D cg c] }|j s| nc c}w }}|r8| |j t j" t% dt | z w # |D cg c] }|j s| nc c}w }}|r8| |j t j" t% dt | z w xY wxY ww) Nr z/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 ImportErrorr startappendr verboseprintr r, r- ranger6 maxr7 dump_tracebacksysstdoutr/ )threadsunlockr= startedtendtimer s r start_threadsrM w s? 7mGG Q q! Qnn&G B<2 AFF3w )9 94@A !&->g 1g> ?? '*-g,)@A B ( #*:'QQZZ\q'G: + // ;$%@3w<%OPP C G7|S\23 4 ? ;':'QQZZ\q':G: + // ;$%@3w<%OPP ! Qnn&G B<2 AFF3w )9 94@A !&->g 1g>> ?? '*-g,)@A B ( #*:'QQZZ\q':G: + // ;$%@3w<%OPP #*:'QQZZ\q':G: + // ;$%@3w<%OPP s NE N(E* H A,F, 1F"F" F, "F, =NF'F'=N E'#N&E''N*5F H "F, 'N,H1G G AHNNA,L2?J J L26L2NK0+K0/AN2N7M M ANNNc ( e Zd ZdZd Zd Zd Zd Zy)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) c J d | _ d | _ d | _ d | _ d | _ y r )exc_type exc_value exc_tracebackr _old_hookselfs r __init__z"catch_threading_exception.__init__ s& ! r c |j | _ |j | _ |j | _ |j | _ y r )rQ rR rS r )rV r" s r _hookz catch_threading_exception._hook s1 ! / /kk r c Z t j | _ | j t _ | S r )r excepthookrT rY rU s r __enter__z#catch_threading_exception.__enter__ s "-- #zz r c > | j t _ | `| `| `| `y r )rT r r[ rQ rR rS r )rV exc_infos r __exit__z"catch_threading_exception.__exit__ s# #~~ M N Kr N)__name__ __module__ __qualname____doc__rW rY r\ r_ r r r rO rO s < " r rO returnc t j dk( rt j j S t j dk( ryy)ay 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)rF platform_emscripten_infopthreadsr r r _can_start_threadrk s6 |||###,,, r F)modulec v d}| r t st j | yt j t | S )zSkip 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)rl r3 s r requires_working_threadingrr s; 'C ##C( ( ""#3S99r r )r contextlibr& rF r r, ro testr r r r( contextmanagerr4 r8 rM rO boolrk rn rr r r r <module>rw s 6>< & &D " 'Q 'QT6 6r4 & %& ). :r