<|h[ddlmZddlmZdZeedjdejdDZ djdejdDZ ddlm Z e jZ ddl Z ddlZddlZddlZddlZddlZddlZddlZddlmZd Z dd lmZd ZGd d eZGddej<ZeGddej@Z!eGddej@Z"eGddej@Z#eGddejHZ$eGddejJZ%eGddejJZ&eGddejNZ'eGddejJZ(eGd d!ejRZ)eGd"d#ejTZ*eGd$d%ejVZ+e,d&k(rejZyy)')xrangeNafrom gevent import monkey; monkey.patch_all() from gevent.event import Event from gevent.lock import RLock, Semaphore, BoundedSemaphore from gevent.thread import allocate_lock as Lock import threading threading.Event = Event threading.Lock = Lock # NOTE: We're completely patching around the allocate_lock # patch we try to do with RLock; our monkey patch doesn't # behave this way, but we do it in tests to make sure that # our RLock implementation behaves correctly by itself. # However, we must test the patched version too, so make it # available. threading.NativeRLock = threading.RLock threading.RLock = RLock threading.Semaphore = Semaphore threading.BoundedSemaphore = BoundedSemaphore  c#&K|] }d|z yw)z %sN.0lines ]/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__threading_2.py r sK$t+Kc#&K|] }d|z yw)z %sNrrs r r r sOD(4/Or )support) lock_testsF)patchcztjtjxrtjd|S)Nz#SKIPPED: Timeout on PyPy3 on Travis)unittestskipIf greentestPYPY3 RUNNING_ON_CI)clss r skipDueToHangr3s6 8??3I33-    c$eZdZdZdZdZdZy)Countercd|_y)Nrvalueselfs r __init__zCounter.__init__;s  rc.|xjdz c_yNrrs r incz Counter.inc> a rc.|xjdzc_yr#rrs r decz Counter.decAr&rc|jSNrrs r getz Counter.getDs zzrN)__name__ __module__ __qualname__r!r%r(r+rrr rr9srrceZdZdZdZy) TestThreadc~tjj||||_||_||_||_y)N)name) threadingThreadr!testcasesemamutexnrunning)r r2r5r6r7r8s r r!zTestThread.__init__Is7!!$T!2      rctjdz }trtd|j|dzfz|j5|j 5|j jtr$t|j jd|jj|j jddddtj|trtd|jd|j 5|j j|jj|j jdtr2td |j|j jfzddddddy#1swYxYw#1swYxYw#1swYyxYw) Ng@ztask %s will run for %.1f usecg.Aztasks are runningtaskdonerz$%s is finished. %d tasks are running)randomverboseprintr2r6r7r8r%r+r5assertLessEqualtimesleepr(assertGreaterEqual)r delays r runzTestThread.runQsc ')  2 53;6(( )YY 9 F !!#$--++-/BC --dmm.?.?.A1E  F JJu fdii0 9 !!# 001B1B1DaH@ 4==#4#4#6D889  9 9 9 F F 9 9 9 9s? GA9F+ AGBF7G+F4 0G7G <GG N)r,r-r.r!rErrr r0r0Hs !9rr0ceZdZdZdZdZdZdZdZdZ dZ d Z e jd d Ze jeed  d dZeedsdZyy) ThreadTestsNc d}tjd}tj}t}g}d}tj dddkrd}t |D]}td|z||||}|j|d |_ |j|j|j|j|jtj|t!|t!||j#t$r t'd |D]}|j)||j|j+|j,t/|d sK|j1|jd |j|jdu|jtjd t!|t$r t'd|j3|j5d y)N r:rz)r: zz Fz!waiting for all tasks to completeidentrzzall tasks done)r3BoundedSemaphoreRLockrsys version_inforanger0appenddaemon assertIsNonerL assertFalse assertTruerematchreprstartr>r?joinis_alive__dict__hasattrassertNotEqual assertEqualr+) r NUMTASKSr6r7 numrunningthreads initial_regexits r test_various_opszThreadTests.test_various_opsos))2!Y 6   BQ ' );Mx A=1,dD%LA NN1 AH   agg &   QXX & OOBHH]DG< G % GGI   5 6 UA FF8    QZZ\1:: 6q'"##AGGQ/  D1)I4PQ7 ST  U  " # )1-rcntj}|j|jdut |t |fd}tj gtj|dj|jddutjd=y)Nctj}j|jt |t |j yr*)r3current_threadrRrLstrrYset)rfr<rLs r fz9ThreadTests.test_ident_of_no_threading_threads..fs8((*A LL ! F G HHJrrr) r3rjrUrLrkrYEventthreadstart_new_threadwait_active)r rfrmr<rLs @@r "test_ident_of_no_threading_threadsz.ThreadTests.test_ident_of_no_threading_threadss  $ $ & D) A Q  2&  qT)*   eAh 'rctr td tjd|j tjdy#tj $rtr tdYywxYw)Nzwith 256kB thread stack size...i4platform does not support changing thread stack sizerr>r?r3 stack_sizeroerrorrgrs r test_various_ops_small_stackz(ThreadTests.test_various_ops_small_stacksa  3 4    ( Q || LM  A$A54A5ctr td tjd|j tjdy#tj $rtr tdYywxYw)Nzwith 1MB thread stack size...irurrvrs r test_various_ops_large_stackz(ThreadTests.test_various_ops_large_stacksa  1 2    * Q || LM  rzcdd}tj}|jtj||f}|j|j |tj |jtj |tjtj |=y)NcLtj|jyr*)r3rjrelease)r7s r rmz*ThreadTests.test_foreign_thread..fs  $ $ & MMOr) r3LockacquirerorpassertInrrassertIsInstance _DummyThread)r rmr7tids r test_foreign_threadzThreadTests.test_foreign_threads    %%a%2  c9,,- i//4'44 6   c "rc ddl}|jj }Gddt |j}tj tjG fddtj}|}d|_ |jtr tdtr td ||jd |}|j|dtr td  jtr td |j!|j"tr td ||j|j$|}|j|dtr tdjd|j'|j"tr td|j"r|j)yy#t$rtr tdYywxYw)Nrz2test_PyThreadState_SetAsyncExc can't import ctypesc eZdZy)AThreadTests.SKIP_test_PyThreadState_SetAsyncExc..AsyncExcN)r,r-r.rrr AsyncExcrs rrc$eZdZdZdZfdZy)?ThreadTests.SKIP_test_PyThreadState_SetAsyncExc..WorkerNFctj|_d|_ j t j d&#$rd|_j YywxYw)NFTg?)ro get_identidfinishedrlrArB)r rworker_saw_exceptionworker_starteds r rEzCThreadTests.SKIP_test_PyThreadState_SetAsyncExc..Worker.runsb **, % /&**, 3 /$(DM(,,./s'A A)(A))r,r-r.rrrE)rrrsr WorkerrsBH /rrTz started worker threadz trying nonsensical thread idz, waiting for worker thread to get startedz" verifying worker hasn't exitedz2 attempting to raise asynch exception in workerr$z5 waiting for worker to say it caught the exceptionrI)timeoutz all OK -- joining worker)ctypes ImportErrorr>r? pythonapiPyThreadState_SetAsyncExc Exception py_objectr3rnr4rSrZc_longr`rqrUrrrVr[) r r set_async_exc exceptionrrfresultrrrs @@@r #SKIP_test_PyThreadState_SetAsyncExcz/ThreadTests.SKIP_test_PyThreadState_SetAsyncExcs   ((BB  y $$X. #*(0 / /Y%% / H   - .  4 5v}}R0)< #  @ A  6 7 $  F Gv}}QTT2I> #  I J!!"!-  #  0 1 :: FFH C JK  sG--H  H cd}ttdrtjtd|}ntjtd|}|j |j |j tjd}|jtj|j |j|tjvdy)Nc*tjr*)rorx)_args_kws r fail_new_threadz7ThreadTests.test_limbo_cleanup..fail_new_thread*s,,. r_start_new_thread)new_start_joinable_threadcyr*rrrr z0ThreadTests.test_limbo_cleanup..5rtargetz:Failed to cleanup _limbo map on failure of Thread.start().) r^r3Patchobject addCleanupstoprZr4 assertRaisesrorxrU_limbo)r rpatcherrfs r test_limbo_cleanupzThreadTests.test_limbo_cleanup(s ! 91 2ll9.AWGll9.FO\G  %    L 1 &,,0  !! ! H Jrc" ddl}t|dt|jd~ddl}|jtjddddtzg}|j|d y#ttf$rt r t dYywxYw) NrrPyGILState_Ensurez6test_finalize_with_runnning_thread can't import ctypes-Wignore-caif 1: %s import ctypes, sys, time try: import thread except ImportError: import _thread as thread # Py3 # This lock is used as a simple event variable. ready = thread.allocate_lock() ready.acquire() # Module globals are cleared before __del__ is run # So we save the functions in class dict class C: ensure = ctypes.pythonapi.PyGILState_Ensure release = ctypes.pythonapi.PyGILState_Release def __del__(self): state = self.ensure() self.release(state) def waitingThread(): x = C() ready.release() time.sleep(100) thread.start_new_thread(waitingThread, ()) ready.acquire() # Be sure the other thread is waiting. sys.exit(42) *) rgetattrrrAttributeErrorr>r? subprocesscallrO executablesetup_3r`)r rrrcs r test_finalize_runnning_threadz)ThreadTests.test_finalize_runnning_thread;s   FK ( F$$&9 :  __cnndHdE:;E< R M^, NO  s&A++ B BhangscBddl}dtz}|jtjddd|g|j |j }|j \}}|j}|jd}|jd}|jd|y) Nraif 1: %s import threading from time import sleep def child(): sleep(0.3) # As a non-daemon thread we SHOULD wake up and nothing # should be torn down yet print("Woke up, sleep function is: %%s.%%s" %% (sleep.__module__, sleep.__name__)) threading.Thread(target=child).start() raise SystemExit rrr)stdoutstderrutf-8z,Woke up, sleep function is: gevent.hub.sleep) rsetup_4PopenrOrPIPE communicatestripdecoder`)r rscriptprrs r test_join_nondaemon_on_shutdownz+ThreadTests.test_join_nondaemon_on_shutdownks       cnndHdFK$.OO$.OO  5w'w'  :  rgetcheckintervalzNeeds sys.getcheckintervalc.tj}ddl}|j5|j dt t j} tddD]q}t j|dztjd}|j|j|}|j||vd||fzs t j| dddy#t j|wxYw#1swYyxYw) Nrrr$dcyr*rrrr rz7ThreadTests.test_enumerate_after_join..rrrz� triggered after %d trials: %s)r3 enumeratewarningscatch_warnings simplefilterDeprecationWarningrOrrsetcheckintervalr4rZr[rU)r enumr old_intervalrerfls r test_enumerate_after_joinz%ThreadTests.test_enumerate_after_joins""  $ $ & 3  ! !(,> ?//1L 33 XA((a0!(( =AGGIFFHA$$Q!V%MQRTUPV%VX X$$\2# 3 3"$$\2# 3 3s$+D BC1D 1DD  Dpypy_version_infocGddt}|d}tj|}|jj ~|j |dt j|z|d}tj|}|jj ~|j |dt j|zy)NceZdZdZdZy)DThreadTests.test_no_refcycle_through_target..RunSelfFunctionc||_tj|j|fd|i|_|jj y)N _yet_another)rargskwargs) should_raiser3r4_runrorZ)r rs r r!zMThreadTests.test_no_refcycle_through_target..RunSelfFunction.__init__sD)5D%"+"2"2$))9=;I4:P#RDKKK%%'rc(|jrtyr*)r SystemExit)r _other_refrs r rzIThreadTests.test_no_refcycle_through_target..RunSelfFunction._runs(((()rN)r,r-r.r!rrrr RunSelfFunctionrs ()rrF)rz%d references still around)msgT)rweakrefrefror[rTrO getrefcount)r r cyclic_objectweak_cyclic_objectraising_cyclic_objectweak_raising_cyclic_objects r test_no_refcycle_through_targetz+ThreadTests.test_no_refcycle_through_targets )& ),?M!(]!;   % % '   02#?#&??3E3G#H$I  K%4$F !)05J)K & ! ( ( - - /%   8:#?#&??3M3O#P$Q  Sr)r,r-r.maxDiffrgrsryr|rrrrrskipOnLibuvOnPyPyOnWinrrr^rOrrrrr rGrGisG(.T(2    #*EPJ&.!`&Y%%g./HY C+ ,-$3 30 3+ , S -rrGc|eZdZdZdZej ddZejddZ dZ y)ThreadJoinOnShutdownNcdtz|z}ddl}|jtjddd|g|j }|j }|jjjdd}|jj|jd }|j|d |j|d d |j|dd y)Nzif 1: %s import sys, os, time, threading # a thread, which waits for the main program to terminate def joiningfunc(mainthread): mainthread.join() print('end of thread') rrrr)r rrzend of main end of thread rJzinterpreter was blockedzUnexpected error)rrrrOrrrqrreadreplacecloserr`r_)r rrrrdatas r _run_and_joinz"ThreadJoinOnShutdown._run_and_joins!!    cnndHdFKT^TcTc  d VVXxx}}&&uc2 {{7# => B#<= Q 23rrc*d}|j|y)Nzif 1: import os t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() time.sleep(0.2) print('end of main') )r)r rs r test_1_join_on_shutdownz,ThreadJoinOnShutdown.test_1_join_on_shutdowns 6"rzSometimes randomly times outcLddl}t|dsyd}|j|y)NrforkaGif 1: childpid = os.fork() if childpid != 0: os.waitpid(childpid, 0) sys.exit(0) t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() print('end of main') osr^rr rrs r test_2_join_in_forked_processz2ThreadJoinOnShutdown.test_2_join_in_forked_processs+ r6"   6"rcLddl}t|dsyd}|j|y)Nrraif 1: main_thread = threading.current_thread() def worker(): childpid = os.fork() if childpid != 0: os.waitpid(childpid, 0) sys.exit(0) t = threading.Thread(target=joiningfunc, args=(main_thread,)) print('end of main') t.start() t.join() # Should not block: main_thread is already stopped w = threading.Thread(target=worker) w.start() import sys if sys.version_info[:2] >= (3, 7) or (sys.version_info[:2] >= (3, 5) and hasattr(sys, 'pypy_version_info') and sys.platform != 'darwin'): w.join() rr s r !test_3_join_in_forked_from_threadz6ThreadJoinOnShutdown.test_3_join_in_forked_from_threads+ r6" *: 6"r) r,r-r.rrrrrskipOnPyPy3OnCIr r rrr rrsVG4(&Y%%g. #/ #Y=>#?#$7#rrc$eZdZdZdZdZdZy)ThreadingExceptionTestsctj}|j|jt|jyr*)r3r4rZr RuntimeErrorr thread_s r test_start_thread_againz/ThreadingExceptionTests.test_start_thread_againDs-""$  , 6rcltj}|jt|jyr*)r3rjrrr[)r rjs r test_joining_current_threadz3ThreadingExceptionTests.test_joining_current_threadIs&"113 ,(;(;r=rWrOr3_threadrorArr gevent.testsr unittest.mockrrrrrr4r0TestCaserGrrrr!r#r&r)r,r/r3r,mainrrr r@sB&" &V ))K T8JK K ))OFLL