<|h`7ddlmZddlmZddlmZddlZddlZddlmZmZddl m Z ddl m Z ddlmZddlmZdd lmZdd lmZeezZGd d eZGd deZGddeZGddeZGddeZGddeZGdde j6ZGdde j6ZGddeZGdde j6ZGdd e j6Z Gd!d"e Z!Gd#d$e Z"Gd%d&e j6Z#Gd'd(e#Z$Gd)d*e#Z%Gd+d,e#Z&Gd-d.e j6Z'[[e(d/k(re jRyy)0)absolute_import)print_function)divisionN)Event AsyncResult)xrange)AbstractGenericGetTestCase)AbstractGenericWaitTestCase) SMALL_TICK)SMALL_TICK_MAX_ADJceZdZdZdZy) TestEventWaitc8tj|yNtimeout)rwaitselfrs W/var/www/html/test/engine/venv/lib/python3.12/site-packages/gevent/tests/test__event.pyrzTestEventWait.waits  W %c*ttyN)strrrs r test_coverzTestEventWait.test_covers  EG rN)__name__ __module__ __qualname__rrrrrrs &rrceZdZdZdZy)TestGeventWaitOnEventcDtjtg|yr)geventrrrs rrzTestGeventWaitOnEvent.wait s UWIw/rc|tfdfd}tj|jy)Nc&jyrset)eventsrsetterz:TestGeventWaitOnEvent.test_set_during_wait..setter*s IIKrctj}j}j|jj |j j jj tjfd}jj j|y)Ng{Gz?r) r$spawnr assertTruereadyjoinclear assertFalse assertNotIn)sresor)rr*s rwaiterz:TestGeventWaitOnEvent.test_set_during_wait..waiter-s V$A**,C OOC OOEKKM * FFH KKM   U[[] +  UHd3A   U[[] +   UA &r)rr$r,r/)rr6r)r*s` @@rtest_set_during_waitz*TestGeventWaitOnEvent.test_set_during_wait#s-   '*  V!!#rN)rrrrr7r rrr"r"s 0$rr"ceZdZdZy)TestAsyncResultWaitc8tj|yr)rrrs rrzTestAsyncResultWait.waitGs 7+rNrrrrr rrr9r9Es,rr9ceZdZdZy)TestWaitAsyncResultcDtjtg|yr)r$rrrs rrzTestWaitAsyncResult.waitMs []OW5rNr;r rrr=r=Ks6rr=ceZdZdZy)TestAsyncResultGetc8tj|yr)rgetrs rrzTestAsyncResultGet.waitSs '*rNr;r rrr@r@Qs+rr@c eZdZy) MyExceptionN)rrrr rrrDrDVsrrDc*eZdZdZdZdZdZdZy)TestAsyncResultct}|jt|jd|j d|j dt |yr)r assertRaises TypeErrorrawlinkunlinkrrars r test_linkzTestAsyncResult.test_link[s< ] )RZZ6 $ $ BrcTgtjjdjjdfd}t j |t }j|t jdjd|fgy)Nr cjt5}jdddjdjfy#1swY'xYw)Ncaught)rHrDrBappend exception)excelogrs rr6z,TestAsyncResult.test_set_exc..waiterhsF"";/ 3  JJ#--0 1  s AArrQ) r assertEqualexc_inforSr$r,rD set_exceptionsleep)rr6objrUrVs` @@r test_set_exczTestAsyncResult.test_set_excbs M R( d+ 2  Vm  Q #/0rct}td}tjt|j d}|j |jtjjd|5|jt5}|jddd|j|jdddy#1swY.xYw#1swYyxYw)N interruptedz hello event1r)rrDr$ spawn_laterDELAYr(_close_on_teardownkillTimeout start_newrHrBassertIsrS)revent1 timer_excgrTs rtest_setzTestAsyncResult.test_setrs .   ufjj. A ' ^^ % %a 3 4"";/ 3   MM)S]] 3 4 4   4 4s$6C C $C C CCct}t}tjt|j |}|j ||d|y)N timeout_valuez/Nobody sent anything to event2 yet it received )robjectr$ with_timeoutr`rBre)revent2Xresults rtest_set_with_timeoutz%TestAsyncResult.test_set_with_timeouts@ H$$UFJJaH ACI L Nrct}|jtj|jd|jtj|j y)NF)block)rrHr$rcrB get_nowaitrLs rtest_nonblocking_getz$TestAsyncResult.test_nonblocking_gets> ] &.."&&> &.."--8rN)rrrrNr\rirrrvr rrrFrFYs1 4N9rrFceZdZdZdZdZdZejd dZ dZ dZ dZ d Z ejd Zejd Zy )TestAsyncResultCrossThreadctSr)rrs r_makeOnez#TestAsyncResultCrossThread._makeOnes }rc&|jdyNz from mainr'rones r_setOnez"TestAsyncResultCrossThread._setOnes  r<cvtjr)ddl}|jdddkr|j dyyy)Nr)rrz;PyPy bug: https://foss.heptapod.net/pypy/pypy/-/issues/3381) greentestPYPYsyspypy_version_infoskipTest)rrs r_check_pypy_switchz-TestAsyncResultCrossThread._check_pypy_switchs: >> $$Ra(I5 [\6 rc|jddlmddlms|j |Gfdd}|}|j  |j j|j|j|jjtdz|jtdz|j|jy#|jtdzwxYw)NrThreadrc*eZdZfdZfdZy)@TestAsyncResultCrossThread.test_cross_thread_use..Threadcj|d|_|_|_j |_d|_yNTz __init__daemon running_eventfinished_eventrz async_resultrqr NativeEvent NativeThreadtests rrzITestAsyncResultCrossThread.test_cross_thread_use..Thread.__init__A%%d+" %0]"&1m#$(MMO!+ rc~tfd}tj|}fd}r'tj|}|j~n|j |j~j j tj jdy)Nczjs*jtdzjs)yy)N)is_setrr`)g_eventsrspinzRTestAsyncResultCrossThread.test_cross_thread_use..Thread.run..spins)%nn. UQY/&nn.rcjjr+jjj_yjj_yr)rr(rr BG_WAIT_DELAYrq)rr timed_waitsrworkzRTestAsyncResultCrossThread.test_cross_thread_use..Thread.run..worksN&&**, "&*&7&7&<& rT destroy_loop)rr$r,r/r(rget_hubdestroy) rrgletrworkerrrr wait_in_bgs ` @rrunzDTestAsyncResultCrossThread.test_cross_thread_use..Thread.runs'0||D) ?#\\$/FKKMF  ##'') ((d(;rNrrrrr)rrrrrsrrrs  , .Threadcj|d|_|_|_j |_d|_yrrrs rrzSTestAsyncResultCrossThread.test_cross_thread_use_set_in_bg..Thread.__init__rrc|jjj|j|jjt j jdy)NTr)rr(rrrr$rr)rrs rrzNTestAsyncResultCrossThread.test_cross_thread_use_set_in_bg..Thread.runsQ""&&( T../##'') ((d(;rNr)rrrsrrrs  , z6TestAsyncResultAsLinkTarget.test_set../srrrk) r$r,rlink link_valuelink_exceptionrWrBrmrnr`re)rrhs1s2s3rprqs rriz$TestAsyncResultAsLinkTarget.test_set.s LL # ]KM;=B r  R  1% 1% H$$UBFF!D fa rcd}tj|}ttt}}}|j||j ||j ||j tj|jt}tjt|j|}|j|||j tj|jy)Nc,tjd)Nz.TestAsyncResultAsLinkTarget.test_set_exception)rExpectedExceptionr rrfuncz.func;s--.^_ _rrk)r$r,rrrrrHrrrBrmrnr`re)rrrhrrrrprqs rtest_set_exceptionz.TestAsyncResultAsLinkTarget.test_set_exception:s ` LL  ]KM;=B r  R  )55rvv> H$$UBFF!D fa  )55rvv>rN)rrr error_fatalrirr rrrr+sK ! ?rrceZdZdZdZy)TestEvent_SetThenClearrc8t}t|jDcgc]!}tj|j #}}tj d|j|j|D]}|jycc}w)NgMbP?) rrangeNr$r,rrZr(r0r/)rrUiwaitersgreenlets rrzTestEvent_SetThenClear.testLsm G16tvv?A6<<'?? U    H MMO  @s&BN)rrrrrr rrrrIs  ArrceZdZdZy)TestEvent_SetThenClear100dNrrrrr rrrrVs ArrceZdZdZy)TestEvent_SetThenClear1000iNrr rrrrZs ArrcXeZdZdZdZdZedz ZdZejddZ y)TestWaitrNrgY@c|s|rtj|j|r|jj tj|j|r|jj |r|ryyr)r$rZperiodpopr()reventsasyncss r_senderzTestWait._senderdsX LL %   " LL %   " rz:Not all results have arrived sometimes due to timer issuesc(t|jDcgc] }t}}t|jDcgc] }t}}t |t |z}t j |j||}t j||z|j|j}|j|}n#t||j|jz }|j!|j|j|nFt|j|}|j|j||j!|j#|t ||t ||fycc}wcc}w)N)countr)rrrrlenr$r,rrrrminrr-r.r1rbrW)r_rrmax_lensenderresults expected_lens rrz TestWait.testms!#)$&&>2a%'22)/8A+-88f+F +dllFF;++fvoTZZV << "Lw t{{(BCL ::  OOFLLNF 3tzz<8L   V\\^V 4 KKM s7|lCLRY5Z[38s F F) rrrrrrrrrskipOnAppVeyorrr rrrr^sD A EG u_F#YZ[\\\rrceZdZdZy)TestWait_notimeoutN)rrrrr rrrrsGrrceZdZdZy)TestWait_count1rNrrrrr rrrr ErrceZdZdZy)TestWait_count2rNrr rrr r rrr ceZdZdZdZdZy)TestEventBasicsctt}tj|}|j||~~yr)rweakrefrefre)rrUrs r test_weakrefzTestEventBasics.test_weakrefs, G KKN a rctgfd}tj|dtj|dtj|j dj tj jj}|jjdj|d|j gd|j|jy)NcHjj|yr)rrR)argr)rs rwait_then_appendzCTestEventBasics.test_wait_while_notifying..wait_then_appends JJL NN3 rrrr)rrr)rr$r,idlerW linkcountrloopcheckrrRr(stopclose)rrrr)rs @@rtest_wait_while_notifyingz)TestEventBasics.test_wait_while_notifyings    %q) %q)  EOO-. %%++- GNNA&  ),  rct}|jtj|g}|j ||gtj|g}|j ||gyr)rr(r$rrW)rr)rqs r'test_gevent_wait_twice_when_already_setz7TestEventBasics.test_gevent_wait_twice_when_already_setsX eW% %)eW% %)rN)rrrrrrr rrr r s4 *rr __main__)* __future__rrrr r$ gevent.eventrrgevent.testingtestingrgevent.testing.sixrgevent.testing.timingr r r r r`rr"r9r=r@ ExceptionrDTestCaserFrxrrrrrrrrr r rmainr rrr)sb&% +"%<=,4''/$$7$$N,5, 656 +3+  ) 49i((49lN/!3!3N/`  5  ?)"4"4?< Y//  6  !7  \y!! \Fhh-*i((-*` zINNr