H/\c@sddlmZddlmZddljZdZedUdjdej dDZ djdej dDZ yddl m Z Wn!ek rddlm Z nXddlZddlZddlZddlZyddlZWnek rddlZnXddlZddlZddlZdd lmZd Zd efd YZd ejfdYZedej fdYZ!edej fdYZ"edej fdYZ#edej$fdYZ$edej%fdYZ%edej%fdYZ&edej'fdYZ'edej%fdYZ(edej)fd YZ)ed!ej*fd"YZ*ed#ej+fd$YZ+e,d%krej-ndS(&i(tprint_function(txrangeNsfrom 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 s ccs|]}d|VqdS(s %sN((t.0tline((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pys sccs|]}d|VqdS(s %sN((RR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pys s(tverbose(t lock_testscCs"tjtjotjd|S(Ns#SKIPPED: Timeout on PyPy3 on Travis(tunittesttskipIft greentesttPYPY3t RUNNING_ON_CI(tcls((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt skipDueToHang4stCountercBs,eZdZdZdZdZRS(cCs d|_dS(Ni(tvalue(tself((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt__init__;scCs|jd7_dS(Ni(R(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytinc>scCs|jd8_dS(Ni(R(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytdecAscCs|jS(N(R(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytgetDs(t__name__t __module__RRRR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR :s   t TestThreadcBseZdZdZRS(cCs>tjj|d|||_||_||_||_dS(Ntname(t threadingtThreadRttestcasetsematmutextnrunning(RRRRRR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRIs    c Cs+tjd}tr4td|j|dfn|j|jM|jjtrtt|jjdn|j j |jjdWdQXt j |trtd|jdn|jW|jj |j j|jjdtrtd |j|jjfnWdQXWdQXdS( Ng@stask %s will run for %.1f usecg.Astasks are runningittasktdoneis$%s is finished. %d tasks are running(trandomRtprintRRRRRRRtassertLessEqualttimetsleepRtassertGreaterEqual(Rtdelay((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytrunPs&   "   (RRRR'(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRHs t ThreadTestscBseZdZdZdZdZdZdZdZdZ e j dd Z d Z eed sd ZnRS( cCsd}tjdd}tj}t}g}xt|D]}td|||||}|j|t|_t |dr|j |j |j |j|j tjdt|n|jq@Wtrtdnx|D]}|j||j |jt |dr|j|j d|j |j dk|j tjd t|qqWtrtd n|j|jddS( Ni Ris tidentss!waiting for all tasks to completeissall tasks done(RtBoundedSemaphoretRLockR trangeRtappendtFalsetdaemonthasattrt assertIsNoneR)t assertFalset assertTruetretmatchtreprtstartRR!tjointis_alivetassertNotEqualtNonet assertEqualR(RtNUMTASKSRRt numrunningtthreadstitt((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_various_opsms4    "   & cstj}|j|jdkt|t|fd}tjgtj |dj |jddktj d=dS(Ncs>tj}j|jt|t|jdS(N(Rt currentThreadR-R)tstrR6tset(RA(RR)(s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytfs    i(( RRCR2R)R;RDR6tEventtthreadtstart_new_threadtwaitt_active(RRARF((RR)s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt"test_ident_of_no_threading_threadss     cCsjtrtdnytjdWn(tjk rNtrJtdndSX|jtjddS(Nswith 256kB thread stack size...is4platform does not support changing thread stack sizei(RR!Rt stack_sizeRHterrorRB(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_various_ops_small_stacks   cCsjtrtdnytjdWn(tjk rNtrJtdndSX|jtjddS(Nswith 1MB thread stack size...is4platform does not support changing thread stack sizei(RR!RRMRHRNRB(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_various_ops_large_stacks   cCsyd}tj}|jtj||f}|j|j|tj|jtj|tjtj|=dS(NcSstj|jdS(N(Rtcurrent_threadtrelease(R((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRFs ( RtLocktacquireRHRItassertInRKtassertIsInstancet _DummyThread(RRFRttid((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_foreign_threads     csyddl}Wn%tk r7tr3tdndSX|jj}dtfdY|j}tj tj dtj ffdY}|}t |_ |j trtdntrtdn||jd|}|j|d tr#td njtr@td n|j|jtrctd n||j|j|}|j|d trtdnjdd|j|jtrtdn|jr|jndS(Nis2test_PyThreadState_SetAsyncExc can't import ctypestAsyncExccBseZRS((RR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRZstWorkercs)eZdZeZfdZRS(csktj|_t|_y(x!tr>jtjdqWWn$k rft|_jnXdS(Ng?( RHt get_identtidR.tfinishedtTrueRER#R$(R(RZtworker_saw_exceptiontworker_started(s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR's     N(RRR;R]R.R^R'((RZR`Ra(s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR[ss started worker threads trying nonsensical thread idis, waiting for worker thread to get starteds" verifying worker hasn't exiteds2 attempting to raise asynch exception in workeris5 waiting for worker to say it caught the exceptionttimeouti s all OK -- joining worker(tctypest ImportErrorRR!t pythonapitPyThreadState_SetAsyncExct Exceptiont py_objectRRGRR_R/R7tc_longR<RJR2R^R]R3R8(RRct set_async_exct exceptionR[RAtresult((RZR`Ras=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt#SKIP_test_PyThreadState_SetAsyncExcsN     %            cCstd}tj}|t_zHtjdd}|jtj|j|j|tjkdWd|t_XdS(NcWstjdS(N(RHRN(t_args((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytfail_new_thread sttargetcSsdS(N(R;(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt%ss:Failed to cleanup _limbo map on failure of Thread.start().( Rt_start_new_threadRt assertRaisesRHRNR7R2t_limbo(RRoRrRA((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_limbo_cleanups     cCsy-ddl}t|dt|jdWn+ttfk rZtrVtdndSX~ddl}|jt j ddddt g}|j |d dS( NiRetPyGILState_Ensures6test_finalize_with_runnning_thread can't import ctypess-Wtignores-csif 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) i*( RctgetattrReRdtAttributeErrorRR!t subprocesstcalltsyst executabletsetup_3R<(RRcRztrc((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_finalize_runnning_thread-s    thangscCsddl}|jtjddddtgd|jd|j}|j\}}|j}|jd}|jd}t j d |st t |t j d d |t jj}dS( Nis-WRws-csif 1: %s import threading from time import sleep def child(): sleep(1) # As a non-daemon thread we SHOULD wake up and nothing # should be torn down yet print("Woke up, sleep function is: %%r" %% sleep) threading.Thread(target=child).start() raise SystemExit tstdouttstderrsutf-8s+^Woke up, sleep function is: <.*?sleep.*?>$s ^\[\d+ refs\]t(RztPopenR|R}tsetup_4tPIPEt communicatetstriptdecodeR4R5tAssertionErrorR6tsubt MULTILINE(RRztpRR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_join_nondaemon_on_shutdown]s     $c Cstj}ddl}|j|jdttj}zxztddD]i}tj |dtj dd}|j |j |}|j ||kd||fqQWWdtj |XWdQXdS( NiRwiidiRpcSsdS(N(R;(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRqss&#1703448 triggered after %d trials: %s(Rt enumeratetwarningstcatch_warningst simplefiltertDeprecationWarningR|tgetcheckintervalRtsetcheckintervalRR7R8R2(RtenumRt old_intervalR@RAtl((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_enumerate_after_join}s       tpypy_version_infocCsdtfdY}|dt}tj|}|jj~|j|ddtj||dt }tj|}|jj~|j|ddtj|dS(NtRunSelfFunctioncBseZdZdZRS(c SsH||_tjd|jd|fdi|d6|_|jjdS(NRptargstkwargst yet_another(t should_raiseRRt_runRHR7(RR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRs   cSs|jrtndS(N(Rt SystemExit(Rt _other_reft _yet_another((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRs (RRRR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRs Rtmsgs%d references still around( tobjectR.tweakreftrefRHR8R1R|t getrefcountR_(RRt cyclic_objecttweak_cyclic_objecttraising_cyclic_objecttweak_raising_cyclic_object((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_no_refcycle_through_targets  (RRRBRLRORPRYRmRuRRtskipOnLibuvOnPyPyOnWinRRR0R|R(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR(hs #   G  0 tThreadJoinOnShutdowncBsJeZdZejddZejddZdZRS(cCsdt|}ddl}|jtjddd|gd|j}|j}|jjj dd}|jj |j |d |j |d d |j |d d dS(Nsif 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') is-WRws-cRs Rsend of main end of thread isinterpreter was blockedisUnexpected error( R~RzRR|R}RRJRtreadtreplacetcloseR<R:(RtscriptRzRRtdata((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt _run_and_joins *  RcCsd}|j|dS(Nsif 1: import os t = threading.Thread(target=joiningfunc, args=(threading.current_thread(),)) t.start() time.sleep(0.1) print('end of main') (R(RR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_1_join_on_shutdowns sSometimes randomly times outcCs6ddl}t|dsdSd}|j|dS(NitforksGif 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') (tosR0R(RRR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_2_join_in_forked_processs   cCs6ddl}t|dsdSd}|j|dS(NiRs5if 1: main_thread = threading.current_thread() def worker(): threading._after_fork = lambda: None 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() (RR0R(RRR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyt!test_3_join_in_forked_from_threads  ) ( RRRRRRtskipOnPyPy3OnCIRR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRs  tThreadingExceptionTestscBs,eZdZdZdZdZRS(cCs-tj}|j|jt|jdS(N(RRR7Rst RuntimeError(Rtthread_((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_start_thread_again*s  cCs#tj}|jt|jdS(N(RRQRsRR8(RRQ((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_joining_current_thread/s cCs#tj}|jt|jdS(N(RRRsRR8(RR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_joining_inactive_thread3s cCs3tj}|j|jtt|dtdS(NR/(RRR7RsRtsetattrR_(RR((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyttest_daemonize_active_thread7s  (RRRRRR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR%s   t LockTestscBseZeejZRS((RRt staticmethodRRStlocktype(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR=st RLockTestscBseZeejZRS((RRRRR+R(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRAstNativeRLockTestscBseZeejZRS((RRRRt NativeRLockR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyREst EventTestscBseZeejZRS((RRRRRGt eventtype(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRKstConditionAsRLockTestscBseZeejZRS((RRRRt ConditionR(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyROstConditionTestscBseZeejZRS((RRRRRtcondtype(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRTstSemaphoreTestscBseZeejZRS((RRRRt Semaphoretsemtype(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyRXstBoundedSemaphoreTestscBseZeejZRS((RRRRR*R(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pyR\st__main__(.t __future__Rtgevent.testing.sixRtgevent.testingttestingRtsetup_R8tsplitR~Rt test.supportRRdttest.test_supportR R4R|RRHt_threadR#RRt gevent.testsRR RR RRtTestCaseR(RRRRRRRRRRRtmain(((s=lib/python2.7/site-packages/gevent/tests/test__threading_2.pytsd""           Lp